Browse Source

adjust ec shard status on disconnect

pull/991/head
Chris Lu 6 years ago
parent
commit
92f9c7b1aa
  1. 3
      weed/server/master_grpc_server.go

3
weed/server/master_grpc_server.go

@ -31,6 +31,9 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
for _, v := range dn.GetVolumes() { for _, v := range dn.GetVolumes() {
message.DeletedVids = append(message.DeletedVids, uint32(v.Id)) message.DeletedVids = append(message.DeletedVids, uint32(v.Id))
} }
for _, s := range dn.GetEcShards() {
message.DeletedVids = append(message.DeletedVids, uint32(s.VolumeId))
}
if len(message.DeletedVids) > 0 { if len(message.DeletedVids) > 0 {
ms.clientChansLock.RLock() ms.clientChansLock.RLock()

Loading…
Cancel
Save