From 219838db87a612045d42e9fe7ab90149b996cebd Mon Sep 17 00:00:00 2001 From: bingoohuang Date: Tue, 15 Jan 2019 15:47:43 +0800 Subject: [PATCH] fail fast when failed to write local volume --- weed/topology/store_replicate.go | 6 ++++-- 1 file 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() }