From 0e44e8db125141a124954821611483422f2c292a Mon Sep 17 00:00:00 2001 From: tnextday Date: Sun, 10 Jan 2016 23:08:01 +0800 Subject: [PATCH] update --- go/topology/store_replicate.go | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/go/topology/store_replicate.go b/go/topology/store_replicate.go index b105aac3d..772bf8516 100644 --- a/go/topology/store_replicate.go +++ b/go/topology/store_replicate.go @@ -83,12 +83,14 @@ func distributedOperation(masterNode string, store *storage.Store, volumeId stor for i := 0; i < length; i++ { ret = ret && <-results } - // if volume := store.GetVolume(volumeId); volume != nil { - // if length+1 < volume.ReplicaPlacement.GetCopyCount() { - // glog.V(0).Infof("replicating opetations [%d] is less than volume's replication copy count [%d]", length+1, volume.ReplicaPlacement.GetCopyCount()) - // ret = false - // } - // } + // we shouldn't check ReplicaPlacement because the needle have been written in head volume + + // if volume := store.GetVolume(volumeId); volume != nil { + // if length+1 < volume.ReplicaPlacement.GetCopyCount() { + // glog.V(0).Infof("replicating opetations [%d] is less than volume's replication copy count [%d]", length+1, volume.ReplicaPlacement.GetCopyCount()) + // ret = false + // } + // } return ret } else { glog.V(0).Infoln("Failed to lookup for", volumeId, lookupErr.Error())