|
@ -191,6 +191,7 @@ func spreadEcShards(commandEnv *CommandEnv, volumeId needle.VolumeId, collection |
|
|
|
|
|
|
|
|
// ask the source volume server to delete the original volume
|
|
|
// ask the source volume server to delete the original volume
|
|
|
for _, location := range existingLocations { |
|
|
for _, location := range existingLocations { |
|
|
|
|
|
fmt.Printf("delete volume %d from %s\n", volumeId, location.Url) |
|
|
err = deleteVolume(commandEnv.option.GrpcDialOption, volumeId, location.Url) |
|
|
err = deleteVolume(commandEnv.option.GrpcDialOption, volumeId, location.Url) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return fmt.Errorf("deleteVolume %s volume %d: %v", location.Url, volumeId, err) |
|
|
return fmt.Errorf("deleteVolume %s volume %d: %v", location.Url, volumeId, err) |
|
|