gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix ec volume lookup data sync (#5900)

Browse Source
This commit is contained in:
augustazz
2024-08-16 21:08:33 +08:00
committed by GitHub
parent 0b00706454
commit db833abfa2
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
weed/server/master_grpc_server.go
View File

@@ -80,7 +80,7 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
message.DeletedVids = append(message.DeletedVids, uint32(v.Id)) message.DeletedVids = append(message.DeletedVids, uint32(v.Id))
} }
for _, s := range dn.GetEcShards() { for _, s := range dn.GetEcShards() {
message.DeletedVids = append(message.DeletedVids, uint32(s.VolumeId)) message.DeletedEcVids = append(message.DeletedEcVids, uint32(s.VolumeId))
} }
// if the volume server disconnects and reconnects quickly // if the volume server disconnects and reconnects quickly
@@ -89,7 +89,7 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
glog.V(0).Infof("unregister disconnected volume server %s:%d", dn.Ip, dn.Port) glog.V(0).Infof("unregister disconnected volume server %s:%d", dn.Ip, dn.Port)
ms.UnRegisterUuids(dn.Ip, dn.Port) ms.UnRegisterUuids(dn.Ip, dn.Port)
if len(message.DeletedVids) > 0 { if len(message.DeletedVids) > 0 || len(message.DeletedEcVids) > 0 {
ms.broadcastToClients(&master_pb.KeepConnectedResponse{VolumeLocation: message}) ms.broadcastToClients(&master_pb.KeepConnectedResponse{VolumeLocation: message})
} }
} }