diff options
| author | chrislusf <chris.lu@gmail.com> | 2015-12-30 22:48:19 -0800 |
|---|---|---|
| committer | chrislusf <chris.lu@gmail.com> | 2015-12-30 22:48:19 -0800 |
| commit | 6c88abf62f9e2a03f782753fc236b790681714e6 (patch) | |
| tree | 9d261ddf0b660fce2480e8c51f74bf1a627deffb /go | |
| parent | 963c36338ab733210cc39ef1af553ccdee175ea6 (diff) | |
| download | seaweedfs-6c88abf62f9e2a03f782753fc236b790681714e6.tar.xz seaweedfs-6c88abf62f9e2a03f782753fc236b790681714e6.zip | |
adjust print out when error
Diffstat (limited to 'go')
| -rw-r--r-- | go/topology/store_replicate.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/go/topology/store_replicate.go b/go/topology/store_replicate.go index 4adb4431e..a4be4726f 100644 --- a/go/topology/store_replicate.go +++ b/go/topology/store_replicate.go @@ -96,12 +96,11 @@ func distributedOperation(masterNode string, store *storage.Store, volumeId stor ret = ret && <-results } if volume := store.GetVolume(volumeId); volume != nil { - copyCount := volume.ReplicaPlacement.GetCopyCount() - 1 - if length < copyCount { - glog.V(0).Infoln("replicating opetations [%d] is less than volume's replication copy count [%d]", length, copyCount) + 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()) |