aboutsummaryrefslogtreecommitdiff
path: root/weed/topology
diff options
context:
space:
mode:
author霍晓栋 <huoxd@jiedaibao.com>2016-07-25 14:54:40 +0800
committer霍晓栋 <huoxd@jiedaibao.com>2016-07-25 14:54:40 +0800
commit09bd3d015d02fb9a8c237d64586a0fbc8a6bde8f (patch)
tree372a74f8977845aa567d100be00143ae590feb57 /weed/topology
parent78678f4bcb7aa6b18cd364f86135b54e2d633f24 (diff)
downloadseaweedfs-09bd3d015d02fb9a8c237d64586a0fbc8a6bde8f.tar.xz
seaweedfs-09bd3d015d02fb9a8c237d64586a0fbc8a6bde8f.zip
deleted index entry could not point to deleted needle
Diffstat (limited to 'weed/topology')
-rw-r--r--weed/topology/volume_layout.go1
1 files changed, 0 insertions, 1 deletions
diff --git a/weed/topology/volume_layout.go b/weed/topology/volume_layout.go
index 066f5f69a..afb14b6e4 100644
--- a/weed/topology/volume_layout.go
+++ b/weed/topology/volume_layout.go
@@ -43,7 +43,6 @@ func (vl *VolumeLayout) RegisterVolume(v *storage.VolumeInfo, dn *DataNode) {
if _, ok := vl.vid2location[v.Id]; !ok {
vl.vid2location[v.Id] = NewVolumeLocationList()
}
- vl.vid2location[v.Id].Set(dn)
glog.V(4).Infoln("volume", v.Id, "added to dn", dn.Id(), "len", vl.vid2location[v.Id].Length(), "copy", v.ReplicaPlacement.GetCopyCount())
if vl.vid2location[v.Id].Length() == vl.rp.GetCopyCount() && vl.isWritable(v) {
if _, ok := vl.oversizedVolumes[v.Id]; !ok {