mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-09-30 19:55:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(master): route ec shard vids to NewEcVids on initial subscribe (#9435)

Browse Source 
* fix(master): route ec shard vids to NewEcVids on initial subscribe

ToVolumeLocations appended EC shard volume IDs to NewVids, so a freshly
subscribing master client registered them in the regular-volume map via
addLocation instead of addEcLocation until the next heartbeat-driven
delta arrived. Append to NewEcVids to match the incremental path.

Fixes #9429

* fix(master): dedupe ec vids in initial subscribe snapshot

dn.GetEcShards returns per-(vid, diskId) entries, so a single EC volume
spread across multiple physical disks on one DataNode emitted the same
vid multiple times in NewEcVids. Dedupe so the snapshot carries each
vid once.
This commit is contained in:
Chris Lu
2026-05-11 10:56:26 -07:00
committed by GitHub
parent defe047e1a
commit 514ba7a233
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
weed/topology/topology_info.go
+10 -1
View File
@@ -102,8 +102,17 @@ func (t *Topology) ToVolumeLocations() (volumeLocations []*master_pb.VolumeLocat
for _, v := range dn.GetVolumes() {
volumeLocation.NewVids = append(volumeLocation.NewVids, uint32(v.Id))
}
// A single EC volume's shards can live on multiple disks of
// one DataNode, so GetEcShards returns per-(vid,disk) entries.
// Dedupe so the snapshot carries each vid once.
seenEcVids := make(map[uint32]struct{})
for _, s := range dn.GetEcShards() {
volumeLocation.NewVids = append(volumeLocation.NewVids, uint32(s.VolumeId))
vid := uint32(s.VolumeId)
if _, ok := seenEcVids[vid]; ok {
continue
}
seenEcVids[vid] = struct{}{}
volumeLocation.NewEcVids = append(volumeLocation.NewEcVids, vid)
}
volumeLocations = append(volumeLocations, volumeLocation)
}