diff options
| author | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-10-01 18:51:22 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-10-01 18:51:22 +0500 |
| commit | 5e64b22b45dc272254cd9d5eeb1e51814035d7fd (patch) | |
| tree | 6ffa9f79aed027b67b264352987d56bddc93f606 /weed/shell/command_ec_decode.go | |
| parent | 2cecde89c31db80fc72713aa2cef1e0d4a26fa70 (diff) | |
| download | seaweedfs-5e64b22b45dc272254cd9d5eeb1e51814035d7fd.tar.xz seaweedfs-5e64b22b45dc272254cd9d5eeb1e51814035d7fd.zip | |
check that the topology has been updated
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 |