diff --git a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py index 2e9b372620fb8bacf000ba17c605c2873efc162c..abf5f2cd4184c8f6e92f797ec0bc5434f84174df 100755 --- a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py +++ b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py @@ -3,13 +3,16 @@ from fileTransferPlugin import FileTransferPlugin class GridftpFileTransferPlugin(FileTransferPlugin): - COMMAND = 'globus-url-copy -v' + COMMAND = 'globus-url-copy -c -cd -r -vb -tcp-bs 512K -p 1 -sync -sync-level 2' - def __init__(self, src=None, dest=None): - FileTransferPlugin.__init__(self, self.COMMAND, src, dest) + def __init__(self, src=None, dest=None, command=GridftpFileTransferPlugin.COMMAND): + FileTransferPlugin.__init__(self, command, src, dest) def getSrcUrl(self, filePath, dataDirectory): - srcUrl = 'file://%s' % filePath + if self.src is None: + srcUrl = 'file://%s' % filePath + else: + srcUrl = '%s/%s' % filePath return srcUrl def getDestUrl(self, storageHost, storageDirectory):