diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2022-02-14 01:48:21 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-02-14 01:48:21 -0800 |
| commit | 305418fac5b83ea629e63ac98a017fe8a9c49ad5 (patch) | |
| tree | d4266833f447f3f3dc20b24d81921a21cc3104fc /weed | |
| parent | aa13168b4d792e1353802047adc2e50e2d0ae410 (diff) | |
| parent | 0ed76a05567f5d047f70b1bc987be5f3425f67fb (diff) | |
| download | seaweedfs-305418fac5b83ea629e63ac98a017fe8a9c49ad5.tar.xz seaweedfs-305418fac5b83ea629e63ac98a017fe8a9c49ad5.zip | |
Merge pull request #2667 from kmlebedev/syncReplicatedWrite
atomically write to replicas
Diffstat (limited to 'weed')
| -rw-r--r-- | weed/topology/store_replicate.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/topology/store_replicate.go b/weed/topology/store_replicate.go index b0d063ac9..65625b3b7 100644 --- a/weed/topology/store_replicate.go +++ b/weed/topology/store_replicate.go @@ -101,6 +101,7 @@ func ReplicatedWrite(masterFn operation.GetMasterFn, grpcDialOption grpc.DialOpt stats.VolumeServerRequestCounter.WithLabelValues(stats.ErrorWriteToReplicas).Inc() err = fmt.Errorf("failed to write to replicas for volume %d: %v", volumeId, err) glog.V(0).Infoln(err) + return false, err } } return |