diff options
Diffstat (limited to 'go/topology/topology_event_handling.go')
| -rw-r--r-- | go/topology/topology_event_handling.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/go/topology/topology_event_handling.go b/go/topology/topology_event_handling.go index 3879fbaba..8a3cc5a89 100644 --- a/go/topology/topology_event_handling.go +++ b/go/topology/topology_event_handling.go @@ -54,7 +54,7 @@ func (t *Topology) SetVolumeCapacityFull(volumeInfo storage.VolumeInfo) bool { return true } func (t *Topology) UnRegisterDataNode(dn *DataNode) { - for _, v := range dn.volumes { + for _, v := range dn.GetVolumes() { glog.V(0).Infoln("Removing Volume", v.Id, "from the dead volume server", dn) vl := t.GetVolumeLayout(v.Collection, v.ReplicaPlacement, v.Ttl) vl.SetVolumeUnavailable(dn, v.Id) @@ -65,7 +65,7 @@ func (t *Topology) UnRegisterDataNode(dn *DataNode) { dn.Parent().UnlinkChildNode(dn.Id()) } func (t *Topology) RegisterRecoveredDataNode(dn *DataNode) { - for _, v := range dn.volumes { + for _, v := range dn.GetVolumes() { vl := t.GetVolumeLayout(v.Collection, v.ReplicaPlacement, v.Ttl) if vl.isWritable(&v) { vl.SetVolumeAvailable(dn, v.Id) |