diff options
| author | chrislu <chris.lu@gmail.com> | 2024-08-12 11:54:23 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-08-12 11:54:25 -0700 |
| commit | e14b6e02df21d22de4bce64b22a4aa611115e256 (patch) | |
| tree | ea167f23f9b8365ea442fe9ee78269e0d9b22547 | |
| parent | 352db40f61934af2a102907b03bb5812a6ca7b34 (diff) | |
| download | seaweedfs-e14b6e02df21d22de4bce64b22a4aa611115e256.tar.xz seaweedfs-e14b6e02df21d22de4bce64b22a4aa611115e256.zip | |
load ec volume id locations
fix https://github.com/seaweedfs/seaweedfs/issues/5713
| -rw-r--r-- | weed/shell/command_fs_verify.go | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/weed/shell/command_fs_verify.go b/weed/shell/command_fs_verify.go index 47052cca0..9fe5bc0cb 100644 --- a/weed/shell/command_fs_verify.go +++ b/weed/shell/command_fs_verify.go @@ -119,6 +119,13 @@ func (c *commandFsVerify) collectVolumeIds() error { c.volumeServers = append(c.volumeServers, volumeServer) } } + for _, vi := range diskInfo.EcShardInfos { + volumeServer := pb.NewServerAddressFromDataNode(nodeInfo) + c.volumeIds[vi.Id] = append(c.volumeIds[vi.Id], volumeServer) + if !slices.Contains(c.volumeServers, volumeServer) { + c.volumeServers = append(c.volumeServers, volumeServer) + } + } } }) return nil |