From a629d464f51cc218193e53beae27103e68a9621d Mon Sep 17 00:00:00 2001
From: Sinisa Veseli <sveseli@aps.anl.gov>
Date: Fri, 6 Nov 2015 23:30:11 +0000
Subject: [PATCH] updated gridftp file transfer plugin for 8idi beamline
---
.../processing/plugins/gridftpFileTransferPlugin.py | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
diff --git a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py
index 2e9b3726..abf5f2cd 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):
--
GitLab