diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2019-01-15 00:02:46 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-01-15 00:02:46 -0800 |
| commit | 7081261fca0bc795c868e2390deeb8894c0dd9a0 (patch) | |
| tree | ab7006b9eac3f3232b912812332d8d88d3f6e28a | |
| parent | 2ff95ead5737421323eea624ac98a8510fd2efaa (diff) | |
| parent | 219838db87a612045d42e9fe7ab90149b996cebd (diff) | |
| download | seaweedfs-7081261fca0bc795c868e2390deeb8894c0dd9a0.tar.xz seaweedfs-7081261fca0bc795c868e2390deeb8894c0dd9a0.zip | |
Merge pull request #834 from bingoohuang/patch-1
fail fast when failed to write local volume
| -rw-r--r-- | weed/topology/store_replicate.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/weed/topology/store_replicate.go b/weed/topology/store_replicate.go index 42ad5bf10..f2e4f481d 100644 --- a/weed/topology/store_replicate.go +++ b/weed/topology/store_replicate.go @@ -28,9 +28,11 @@ func ReplicatedWrite(masterNode string, s *storage.Store, needToReplicate := !s.HasVolume(volumeId) if err != nil { errorStatus = "Failed to write to local disk (" + err.Error() + ")" - } else { - needToReplicate = needToReplicate || s.GetVolume(volumeId).NeedToReplicate() + size = ret + return } + + needToReplicate = needToReplicate || s.GetVolume(volumeId).NeedToReplicate() if !needToReplicate { needToReplicate = s.GetVolume(volumeId).NeedToReplicate() } |