diff options
| author | Lisandro Pin <lisandro.pin@proton.ch> | 2024-11-19 15:33:18 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-11-19 06:33:18 -0800 |
| commit | 0d5393641eab18ec356c7e0ebaf51b1164094d8c (patch) | |
| tree | 38bf4a3ed3b277c9e1210bb025f4b2e34a6f09a4 /weed/shell/command_ec_decode.go | |
| parent | 2caa0e37414be6feeb5a8ef0b57bdfc78c64728e (diff) | |
| download | seaweedfs-0d5393641eab18ec356c7e0ebaf51b1164094d8c.tar.xz seaweedfs-0d5393641eab18ec356c7e0ebaf51b1164094d8c.zip | |
Unify usage of shell.EcNode.dc as DataCenterId. (#6258)
Diffstat (limited to 'weed/shell/command_ec_decode.go')
| -rw-r--r-- | weed/shell/command_ec_decode.go | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/weed/shell/command_ec_decode.go b/weed/shell/command_ec_decode.go index 02d0f316d..d3e985a2f 100644 --- a/weed/shell/command_ec_decode.go +++ b/weed/shell/command_ec_decode.go @@ -4,11 +4,12 @@ import ( "context" "flag" "fmt" - "github.com/seaweedfs/seaweedfs/weed/pb" - "github.com/seaweedfs/seaweedfs/weed/storage/types" "io" "time" + "github.com/seaweedfs/seaweedfs/weed/pb" + "github.com/seaweedfs/seaweedfs/weed/storage/types" + "google.golang.org/grpc" "github.com/seaweedfs/seaweedfs/weed/operation" @@ -262,7 +263,7 @@ func collectTopologyInfo(commandEnv *CommandEnv, delayBeforeCollecting time.Dura func collectEcShardIds(topoInfo *master_pb.TopologyInfo, selectedCollection string) (vids []needle.VolumeId) { vidMap := make(map[uint32]bool) - eachDataNode(topoInfo, func(dc string, rack RackId, dn *master_pb.DataNodeInfo) { + eachDataNode(topoInfo, func(dc DataCenterId, rack RackId, dn *master_pb.DataNodeInfo) { if diskInfo, found := dn.DiskInfos[string(types.HardDriveType)]; found { for _, v := range diskInfo.EcShardInfos { if v.Collection == selectedCollection { @@ -282,7 +283,7 @@ func collectEcShardIds(topoInfo *master_pb.TopologyInfo, selectedCollection stri func collectEcNodeShardBits(topoInfo *master_pb.TopologyInfo, vid needle.VolumeId) map[pb.ServerAddress]erasure_coding.ShardBits { nodeToEcIndexBits := make(map[pb.ServerAddress]erasure_coding.ShardBits) - eachDataNode(topoInfo, func(dc string, rack RackId, dn *master_pb.DataNodeInfo) { + eachDataNode(topoInfo, func(dc DataCenterId, rack RackId, dn *master_pb.DataNodeInfo) { if diskInfo, found := dn.DiskInfos[string(types.HardDriveType)]; found { for _, v := range diskInfo.EcShardInfos { if v.Id == uint32(vid) { |