diff options
| author | 霍晓栋 <huoxd@jiedaibao.com> | 2016-07-25 15:07:11 +0800 |
|---|---|---|
| committer | 霍晓栋 <huoxd@jiedaibao.com> | 2016-07-25 15:07:11 +0800 |
| commit | 52e55508da33db3632b9c2976aaec04b4b9fb4bb (patch) | |
| tree | 801566226da8e0e5880b43644aae0f3124b3c8ac | |
| parent | b9b3651a98d3ba19565ded8ccaa8d4beb5c79f17 (diff) | |
| download | seaweedfs-52e55508da33db3632b9c2976aaec04b4b9fb4bb.tar.xz seaweedfs-52e55508da33db3632b9c2976aaec04b4b9fb4bb.zip | |
deleted index entry could not point to deleted needle
| -rw-r--r-- | weed/topology/volume_layout.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/weed/topology/volume_layout.go b/weed/topology/volume_layout.go index afb14b6e4..066f5f69a 100644 --- a/weed/topology/volume_layout.go +++ b/weed/topology/volume_layout.go @@ -43,6 +43,7 @@ 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 { |