From 47112917ff2d2460a04582033435b9af048bebc0 Mon Sep 17 00:00:00 2001 From: jsh Date: Thu, 9 Nov 2023 17:04:18 +0800 Subject: [PATCH] ec.decode: mount the collected ec shards --- weed/shell/command_ec_decode.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/weed/shell/command_ec_decode.go b/weed/shell/command_ec_decode.go index aecc21065..aa0ca5045 100644 --- a/weed/shell/command_ec_decode.go +++ b/weed/shell/command_ec_decode.go @@ -197,6 +197,16 @@ func collectEcShards(commandEnv *CommandEnv, nodeToEcIndexBits map[pb.ServerAddr return fmt.Errorf("copy %d.%v %s => %s : %v\n", vid, needToCopyEcIndexBits.ShardIds(), loc, targetNodeLocation, copyErr) } + fmt.Printf("mount %d.%v on %s\n", vid, needToCopyEcIndexBits.ShardIds(), targetNodeLocation) + _, mountErr := volumeServerClient.VolumeEcShardsMount(context.Background(), &volume_server_pb.VolumeEcShardsMountRequest{ + VolumeId: uint32(vid), + Collection: collection, + ShardIds: needToCopyEcIndexBits.ToUint32Slice(), + }) + if mountErr != nil { + return fmt.Errorf("mount %d.%v on %s : %v\n", vid, needToCopyEcIndexBits.ShardIds(), targetNodeLocation, mountErr) + } + return nil })