add gridftp plugin class

src/python/dm/common/processing/plugins/fileTransferPlugin.py

@@ -26,12 +26,20 @@ class FileTransferPlugin(FileProcessor):
 
         storageHost = experiment.get('storageHost')
         storageDirectory = experiment.get('storageDirectory')
-        dest = '%s:%s' % (storageHost, storageDirectory)
+        destUrl = self.getDestUrl(storageHost, storageDirectory)
         # Use relative path with respect to data directory as a source
         os.chdir(dataDirectory)
-        src = os.path.relpath(filePath, dataDirectory)
-        self.start(src, dest)
-
+        srcUrl = self.getSrcUrl(filePath, dataDirectory)
+        self.start(srcUrl, destUrl)
+
+    def getSrcUrl(self, filePath, dataDirectory):
+        srcUrl = os.path.relpath(filePath, dataDirectory)
+        return srcUrl
+    
+    def getDestUrl(self, storageHost, storageDirectory):
+        destUrl = '%s:%s' % (storageHost, storageDirectory)
+        return destUrl
+    
     def getFullCommand(self, src, dest):
         return '%s %s %s' % (self.command, src, dest)
 

src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py

+#!/usr/bin/env python
+
+from fileTransferPlugin import FileTransferPlugin
+class GridftpFileTransferPlugin(FileTransferPlugin):
+
+    COMMAND = 'globus-url-copy -v'
+
+    def __init__(self, src=None, dest=None):
+        FileTransferPlugin.__init__(self, self.COMMAND, src, dest)
+
+    def getSrcUrl(self, filePath, dataDirectory):
+        srcUrl = 'file://%s' % filePath
+        return srcUrl
+    
+    def getDestUrl(self, storageHost, storageDirectory):
+        destUrl = 'sshftp://%s:%s' % (storageHost, storageDirectory)
+        return destUrl
+
+#######################################################################
+# Testing.
+if __name__ == '__main__':
+    ft = GridftpFileTransferPlugin('/tmp/xyz', '/tmp/xyz2')
+    ft.start()
+    print 'StdOut: ', ft.getStdOut()
+    print 'StdErr: ', ft.getStdErr()
+    print 'Exit Status: ', ft.getExitStatus()