Skip to content

Commit

Permalink
Fix upload
Browse files Browse the repository at this point in the history
  • Loading branch information
iychoi committed Jun 27, 2022
1 parent 73fc57b commit b5abb82
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions commons/parallel.go
Original file line number Diff line number Diff line change
Expand Up @@ -290,7 +290,7 @@ func (manager *ParallelTransferManager) ScheduleUploadIfDifferent(filesystem *ir

// up
logger.Debugf("uploading a local file %s to %s", source, target)
err = filesystem.UploadFileParallel(source, "", target, 0, true)
err = filesystem.UploadFileParallel(source, target, "", 0, true)
if err != nil {
manager.mutex.Lock()
defer manager.mutex.Unlock()
Expand Down Expand Up @@ -334,7 +334,7 @@ func (manager *ParallelTransferManager) ScheduleUpload(filesystem *irodsclient_f

task := func() {
logger.Debugf("uploading a local file %s to %s", source, target)
err := filesystem.UploadFileParallel(source, "", target, 0, true)
err := filesystem.UploadFileParallel(source, target, "", 0, true)
if err != nil {
manager.mutex.Lock()
defer manager.mutex.Unlock()
Expand Down

0 comments on commit b5abb82

Please sign in to comment.