diff --git a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py index cd3e487182f0535431bac465f7cd7b5bc50f71ac..53288d86141abf5c1768b28a7a14729f31ee77e4 100755 --- a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py +++ b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py @@ -47,24 +47,14 @@ class GridftpFileTransferPlugin(FileTransferPlugin): # Original data directory may contain host/port (scheme, host, port, replacementDirPath) = FtpUtility.parseFtpUrl(dataDirectory) ftpUtility = SftpUtility(storageHost) - self.logger.debug("SVDBG STORAGE DIR: %s", storageDirectory) - self.logger.debug("SVDBG STORAGE HOST: %s", storageHost) storageFilePathsDict = ftpUtility.getFiles(storageDirectory, {}, replacementDirPath) - self.logger.debug("SVDBG STORAGE PATHS: %s", storageFilePathsDict) - self.logger.debug("SVDB ORIG PATHS: %s", filePathsDict) pluginFilePathsDict = {} filePaths = filePathsDict.keys() for filePath in filePaths: filePathDict = filePathsDict.get(filePath) - #experimentFilePath = os.path.relpath(filePath, dataDirectory) - #storageFilePath = os.path.join(storageDirectory, experimentFilePath) - #storageFilePathDict = storageFilePathsDict.get(storageFilePath) storageFilePathDict = storageFilePathsDict.get(filePath) - self.logger.debug("SVDBG SRC: %s", filePathDict) - self.logger.debug("SVDBG DEST: %s", storageFilePathDict) if not storageFilePathDict: - self.logger.debug("SVDBG STORAGE HAS NO SUCH FILE: %s", filePathDict) # remote directory does not have the file pluginFilePathsDict[filePath] = filePathDict else: @@ -72,14 +62,12 @@ class GridftpFileTransferPlugin(FileTransferPlugin): sfSize = storageFilePathDict.get('fileSize') # check size if not fSize or not sfSize or fSize != sfSize: - self.logger.debug("SVDBG SIZES DO NOT MATCH: %s", filePathDict) pluginFilePathsDict[filePath] = filePathDict else: # sizes are the same, check modify time mTime = filePathDict.get('fileModificationTime') smTime = storageFilePathDict.get('fileModificationTime') if not mTime or not smTime or mTime > smTime: - self.logger.debug("SVDBG TIMES DO NOT MATCH: %s", filePathDict) pluginFilePathsDict[filePath] = filePathDict self.logger.debug('Number of original files: %s, number of plugin files: %s', len(filePathsDict), len(pluginFilePathsDict))