git.useribm.hu - mediacube.git/blob

   1 package user.jobengine.server.steps;\r
   2 \r
   3 import org.apache.commons.io.FileUtils;\r
   4 import org.apache.logging.log4j.LogManager;\r
   5 import org.apache.logging.log4j.Logger;\r
   6 \r
   7 import user.commons.RemoteFile;\r
   8 import user.commons.StoreUri;\r
   9 \r
  10 public class FILEZILLA_PASARESTORETransferToStep extends TransferStep {\r
  11         private static final Logger logger = LogManager.getLogger();\r
  12 \r
  13         @Override\r
  14         @StepEntry\r
  15         public Object[] execute(StoreUri sourceStoreUri, String sourceFileName, StoreUri targetStoreUri, String targetFileName) throws Exception {\r
  16                 long start = System.currentTimeMillis();\r
  17                 Object[] result = super.execute(sourceStoreUri, sourceFileName, targetStoreUri, targetFileName);\r
  18                 RemoteFile remoteFile = sourceStoreUri.getRemoteFile(targetFileName);\r
  19                 if (remoteFile != null) {\r
  20                         if (remoteFile.getSize() > 0) {\r
  21                                 long diff = (System.currentTimeMillis() - start) / 1000;\r
  22                                 long bytesSpeed = remoteFile.getSize() / diff;\r
  23                                 String speed = FileUtils.byteCountToDisplaySize(bytesSpeed);\r
  24                                 logger.info(getMarker(), "{} size is {}, upload speed was {}/sec", targetFileName, FileUtils.byteCountToDisplaySize(remoteFile.getSize()),\r
  25                                                 speed);\r
  26                         } else\r
  27                                 logger.info(getMarker(), "RemoteFile {} size is 0!", targetFileName);\r
  28                 }\r
  29                 return result;\r
  30         }\r
  31 }\r