Browse Source

todo

add-ec-vacuum
chrislu 5 months ago
parent
commit
e9033136aa
  1. 1
      weed/shell/command_ec_common.go
  2. 1
      weed/shell/command_ec_decode.go
  3. 1
      weed/shell/command_ec_rebuild.go

1
weed/shell/command_ec_common.go

@ -288,6 +288,7 @@ func oneServerCopyAndMountEcShardsFromSource(grpcDialOption grpc.DialOption,
CopyEcjFile: true, CopyEcjFile: true,
CopyVifFile: true, CopyVifFile: true,
SourceDataNode: string(existingLocation), SourceDataNode: string(existingLocation),
Generation: 0, // shell commands operate on existing (generation 0) volumes
}) })
if copyErr != nil { if copyErr != nil {
return fmt.Errorf("copy %d.%v %s => %s : %v\n", volumeId, shardIdsToCopy, existingLocation, targetServer.info.Id, copyErr) return fmt.Errorf("copy %d.%v %s => %s : %v\n", volumeId, shardIdsToCopy, existingLocation, targetServer.info.Id, copyErr)

1
weed/shell/command_ec_decode.go

@ -196,6 +196,7 @@ func collectEcShards(commandEnv *CommandEnv, nodeToEcIndexBits map[pb.ServerAddr
CopyEcjFile: true, CopyEcjFile: true,
CopyVifFile: true, CopyVifFile: true,
SourceDataNode: string(loc), SourceDataNode: string(loc),
Generation: 0, // shell commands operate on existing (generation 0) volumes
}) })
if copyErr != nil { if copyErr != nil {
return fmt.Errorf("copy %d.%v %s => %s : %v\n", vid, needToCopyEcIndexBits.ShardIds(), loc, targetNodeLocation, copyErr) return fmt.Errorf("copy %d.%v %s => %s : %v\n", vid, needToCopyEcIndexBits.ShardIds(), loc, targetNodeLocation, copyErr)

1
weed/shell/command_ec_rebuild.go

@ -231,6 +231,7 @@ func prepareDataToRecover(commandEnv *CommandEnv, rebuilder *EcNode, collection
CopyEcjFile: true, CopyEcjFile: true,
CopyVifFile: needEcxFile, CopyVifFile: needEcxFile,
SourceDataNode: ecNodes[0].info.Id, SourceDataNode: ecNodes[0].info.Id,
Generation: 0, // shell commands operate on existing (generation 0) volumes
}) })
return copyErr return copyErr
}) })

Loading…
Cancel
Save