This commit is contained in:
Chris Lu 2020-10-31 16:45:38 -07:00
parent 306062b4e7
commit de86945aeb
4 changed files with 4 additions and 4 deletions

View file

@ -405,7 +405,7 @@ func (worker *FileCopyWorker) uploadFileInChunks(task FileCopyTask, f *os.File,
Replication: *worker.options.replication, Replication: *worker.options.replication,
Collection: *worker.options.collection, Collection: *worker.options.collection,
TtlSec: worker.options.ttlSec, TtlSec: worker.options.ttlSec,
Path: task.destinationUrlPath+fileName, Path: task.destinationUrlPath + fileName,
} }
assignResult, assignError = client.AssignVolume(context.Background(), request) assignResult, assignError = client.AssignVolume(context.Background(), request)

View file

@ -76,7 +76,7 @@ func (vs *VolumeServer) VolumeCopy(ctx context.Context, req *volume_server_pb.Vo
return err return err
} }
os.Remove(volumeFileName+".note") os.Remove(volumeFileName + ".note")
return nil return nil
}) })

View file

@ -61,7 +61,7 @@ func (v *Volume) Destroy() (err error) {
} }
func removeVolumeFiles(filename string) { func removeVolumeFiles(filename string) {
os.Remove(filename+ ".dat") os.Remove(filename + ".dat")
os.Remove(filename + ".idx") os.Remove(filename + ".idx")
os.Remove(filename + ".vif") os.Remove(filename + ".vif")
os.Remove(filename + ".sdx") os.Remove(filename + ".sdx")