diff options
Diffstat (limited to 'weed/topology/store_replicate.go')
| -rw-r--r-- | weed/topology/store_replicate.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/topology/store_replicate.go b/weed/topology/store_replicate.go index a2be991fa..10fe35f0a 100644 --- a/weed/topology/store_replicate.go +++ b/weed/topology/store_replicate.go @@ -1,6 +1,7 @@ package topology import ( + "context" "encoding/json" "errors" "fmt" @@ -23,7 +24,7 @@ import ( util_http "github.com/seaweedfs/seaweedfs/weed/util/http" ) -func ReplicatedWrite(masterFn operation.GetMasterFn, grpcDialOption grpc.DialOption, s *storage.Store, volumeId needle.VolumeId, n *needle.Needle, r *http.Request, contentMd5 string) (isUnchanged bool, err error) { +func ReplicatedWrite(ctx context.Context, masterFn operation.GetMasterFn, grpcDialOption grpc.DialOption, s *storage.Store, volumeId needle.VolumeId, n *needle.Needle, r *http.Request, contentMd5 string) (isUnchanged bool, err error) { //check JWT jwt := security.GetJwt(r) @@ -121,7 +122,7 @@ func ReplicatedWrite(masterFn operation.GetMasterFn, grpcDialOption grpc.DialOpt glog.Errorf("replication-UploadData, err:%v, url:%s", err, u.String()) return err } - _, err = uploader.UploadData(n.Data, uploadOption) + _, err = uploader.UploadData(ctx, n.Data, uploadOption) if err != nil { glog.Errorf("replication-UploadData, err:%v, url:%s", err, u.String()) } |