diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-05-26 01:05:08 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-05-26 01:05:08 -0700 |
| commit | 92f9c7b1aaf4b12a94a10a59d470dbd0e524df0b (patch) | |
| tree | a9120bc78255176910801b75ac78d578e6fbea6e | |
| parent | ac14cd5ad0615271c514966fa69618e78797d753 (diff) | |
| download | seaweedfs-92f9c7b1aaf4b12a94a10a59d470dbd0e524df0b.tar.xz seaweedfs-92f9c7b1aaf4b12a94a10a59d470dbd0e524df0b.zip | |
adjust ec shard status on disconnect
| -rw-r--r-- | weed/server/master_grpc_server.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go index 1bc28fdf6..1e8e14046 100644 --- a/weed/server/master_grpc_server.go +++ b/weed/server/master_grpc_server.go @@ -31,6 +31,9 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ for _, v := range dn.GetVolumes() { 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 { ms.clientChansLock.RLock() |