diff options
| author | Chris Lu <chris.lu@gmail.com> | 2013-07-29 10:09:36 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2013-07-29 10:09:36 -0700 |
| commit | e94d52c1af1a97dfe849a70cf7fe6bec2fb5c97f (patch) | |
| tree | 5a3f6e7aee0f707929f4ab4bc01accc9c02eb3e2 /go/replication | |
| parent | fb53ec30f7c6dc6b2bce8640eeaf7b2fb09678ea (diff) | |
| download | seaweedfs-e94d52c1af1a97dfe849a70cf7fe6bec2fb5c97f.tar.xz seaweedfs-e94d52c1af1a97dfe849a70cf7fe6bec2fb5c97f.zip | |
replicate mime type
Diffstat (limited to 'go/replication')
| -rw-r--r-- | go/replication/store_replicate.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/go/replication/store_replicate.go b/go/replication/store_replicate.go index 358f7dade..bdc13ee3b 100644 --- a/go/replication/store_replicate.go +++ b/go/replication/store_replicate.go @@ -25,7 +25,7 @@ func ReplicatedWrite(masterNode string, s *storage.Store, volumeId storage.Volum if needToReplicate { //send to other replica locations if r.FormValue("type") != "replicate" { if !distributedOperation(masterNode, s, volumeId, func(location operation.Location) bool { - _, err := operation.Upload("http://"+location.Url+r.URL.Path+"?type=replicate&ts="+strconv.FormatUint(needle.LastModified,10), string(needle.Name), bytes.NewReader(needle.Data), needle.IsGzipped()) + _, err := operation.Upload("http://"+location.Url+r.URL.Path+"?type=replicate&ts="+strconv.FormatUint(needle.LastModified,10), string(needle.Name), bytes.NewReader(needle.Data), needle.IsGzipped(), string(needle.Mime)) return err == nil }) { ret = 0 |