From 73baf82f056a2ace5a52a7a76113656213c1e2cf Mon Sep 17 00:00:00 2001 From: Numblgw <44025291+Numblgw@users.noreply.github.com> Date: Fri, 21 Jun 2024 06:29:36 +0800 Subject: [PATCH] bugfix: unregister ec shards when volume server disconnected (#5697) bugfix unregister ec shards when volume server disconnected Co-authored-by: liguowei --- weed/topology/topology_event_handling.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/weed/topology/topology_event_handling.go b/weed/topology/topology_event_handling.go index 761649ff4..d0ecd089a 100644 --- a/weed/topology/topology_event_handling.go +++ b/weed/topology/topology_event_handling.go @@ -90,6 +90,11 @@ func (t *Topology) UnRegisterDataNode(dn *DataNode) { vl.SetVolumeUnavailable(dn, v.Id) } + // unregister ec shards when volume server disconnected + for _, s := range dn.GetEcShards() { + t.UnRegisterEcShards(s, dn) + } + negativeUsages := dn.GetDiskUsages().negative() dn.UpAdjustDiskUsageDelta(negativeUsages) dn.DeltaUpdateVolumes([]storage.VolumeInfo{}, dn.GetVolumes())