diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2021-10-01 12:05:51 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-10-01 12:05:51 -0700 |
| commit | 88e006bc6d7a3019067ea94e47196a0b0bf0b3c7 (patch) | |
| tree | a62042d28b5ff687d4dd4cfa8e4e7ea7a3e517df /weed/shell/command_ec_decode.go | |
| parent | f58ea6a2ee0430828474ef4a36beaffbf9edfbd8 (diff) | |
| parent | 5e64b22b45dc272254cd9d5eeb1e51814035d7fd (diff) | |
| download | seaweedfs-88e006bc6d7a3019067ea94e47196a0b0bf0b3c7.tar.xz seaweedfs-88e006bc6d7a3019067ea94e47196a0b0bf0b3c7.zip | |
Merge pull request #2349 from kmlebedev/fix_repl_volumes_per_step
Topology update for every Nth id volume
Diffstat (limited to 'weed/shell/command_ec_decode.go')
| -rw-r--r-- | weed/shell/command_ec_decode.go | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/weed/shell/command_ec_decode.go b/weed/shell/command_ec_decode.go index 18cea0504..3483156cb 100644 --- a/weed/shell/command_ec_decode.go +++ b/weed/shell/command_ec_decode.go @@ -208,6 +208,18 @@ func collectEcShards(commandEnv *CommandEnv, nodeToEcIndexBits map[pb.ServerAddr } +func LookupVolumeIds(commandEnv *CommandEnv, volumeIds []string) (err error, volumeIdLocations []*master_pb.LookupVolumeResponse_VolumeIdLocation) { + var resp *master_pb.LookupVolumeResponse + err = commandEnv.MasterClient.WithClient(func(client master_pb.SeaweedClient) error { + resp, err = client.LookupVolume(context.Background(), &master_pb.LookupVolumeRequest{VolumeOrFileIds: volumeIds}) + return err + }) + if err != nil { + return err, nil + } + return nil, resp.VolumeIdLocations +} + func collectTopologyInfo(commandEnv *CommandEnv) (topoInfo *master_pb.TopologyInfo, volumeSizeLimitMb uint64, err error) { var resp *master_pb.VolumeListResponse |