bugfix: unregister ec shards when volume server disconnected (seaweed…

…fs#5697) bugfix unregister ec shards when volume server disconnected Co-authored-by: liguowei <[email protected]>
Numblgw · Jun 20, 2024 · 73baf82 · 73baf82
1 parent 3416501
commit 73baf82
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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())