diff options
| author | augustazz <102299780+augustazz@users.noreply.github.com> | 2024-08-16 21:08:33 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-16 06:08:33 -0700 |
| commit | db833abfa22b77ac51177564808bc146a08e4770 (patch) | |
| tree | 40104c6ea26bebae9d23dd4988e7dec551a4d163 | |
| parent | 0b00706454478abbb246af2f0d30d34c79b09b40 (diff) | |
| download | seaweedfs-db833abfa22b77ac51177564808bc146a08e4770.tar.xz seaweedfs-db833abfa22b77ac51177564808bc146a08e4770.zip | |
fix ec volume lookup data sync (#5900)
| -rw-r--r-- | weed/server/master_grpc_server.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go index 088e91be8..4b5800fbe 100644 --- a/weed/server/master_grpc_server.go +++ b/weed/server/master_grpc_server.go @@ -80,7 +80,7 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ message.DeletedVids = append(message.DeletedVids, uint32(v.Id)) } 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 @@ -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) 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}) } } |