diff options
Diffstat (limited to 'src/main/java/org/openslx/satellitedaemon/ftp/FtpUploadWorker.java')
-rw-r--r-- | src/main/java/org/openslx/satellitedaemon/ftp/FtpUploadWorker.java | 87 |
1 files changed, 0 insertions, 87 deletions
diff --git a/src/main/java/org/openslx/satellitedaemon/ftp/FtpUploadWorker.java b/src/main/java/org/openslx/satellitedaemon/ftp/FtpUploadWorker.java deleted file mode 100644 index 4445a2e..0000000 --- a/src/main/java/org/openslx/satellitedaemon/ftp/FtpUploadWorker.java +++ /dev/null @@ -1,87 +0,0 @@ -package org.openslx.satellitedaemon.ftp; - -import java.util.List; -import java.util.UUID; - -import org.apache.log4j.Logger; -import org.openslx.filetransfer.Uploader; -import org.openslx.imagemaster.thrift.iface.ImageData; -import org.openslx.imagemaster.thrift.iface.UploadInfos; -import org.openslx.satellitedaemon.Globals; -import org.openslx.satellitedaemon.Globals.PropInt; -import org.openslx.satellitedaemon.Globals.PropString; -import org.openslx.satellitedaemon.db.DbImage; - -// TODO: Rename all this FTP* Stuff (also the constants in Globals) now that we're not using ftp anymore - -public class FtpUploadWorker implements Runnable -{ - private static Logger log = Logger.getLogger( FtpUploadWorker.class ); - - @Override - public void run() - { - while ( true ) { - // This List contains all Images in the Database that should be uploaded. - List<DbImage> imageList = DbImage.getAllMarkedForUpload(); - log.info( "FtpUploadWorker: imageList Contains " + imageList.size() + " items." ); - - // Upload one Image after the other. - for ( DbImage image : imageList ) { - // TODO: still some fields for ImageData, which i can't fill with info from DbImage. -// ImageData imDat = new ImageData( image.guid, image.rid, -// image.name, System.currentTimeMillis(), System.currentTimeMillis(), image.creator, "anyThing", -// true, false, "best", "theVeryBest", image.fileSize ); - - ImageData imDat = new ImageData( UUID.randomUUID().toString(), image.rid, - image.name, System.currentTimeMillis(), System.currentTimeMillis(), image.creator, "anyThing", - true, false, "best", "theVeryBest", image.fileSize ); - - // uploadInfo and ThriftAuthentication - String crcPath = image.path.concat( ".crc" ); - UploadInfos upInfos = ThriftConnection.getUploadInfos( imDat, crcPath ); - if ( upInfos == null ) { - log.error( "The UploadInfos returned by ThriftConnection Class are null" ); - - return; - - // FIXME: And then..? If you just continue, you'll run into a null pointer exception - - } - log.info( "Got upInfos. Trying to create Uploader with token: " + upInfos.token ); - - // creating the uploader with the "context"-item. - Uploader u = new Uploader( Globals.getPropertyString( PropString.FTPSERVERIP ), upInfos.port, Globals.getMasterServerSslContext() ); - u.sendToken( upInfos.token ); - - // continue sending Blocks until getMissingBlocks is empty. - while ( !upInfos.getMissingBlocks().isEmpty() ) { - // Send all Blocks from upInfos.getMissingBlocks() in ranges. - List<Integer> blocks = upInfos.getMissingBlocks(); - int start = 0; - for ( int i = 0; i < blocks.size() - 1; i++ ) { - if ( blocks.get( i ) != ( blocks.get( i + 1 ) - 1 ) ) { - u.sendRange( start * Globals.getPropertyInt( PropInt.BLOCKSIZE ), i * Globals.getPropertyInt( PropInt.BLOCKSIZE )); - u.sendFile( image.path ); - start = i + 1; - } - if ( i == blocks.size() - 2 ) { // TODO: != - u.sendRange( start * Globals.getPropertyInt( PropInt.BLOCKSIZE ), (blocks.size() - 1) * Globals.getPropertyInt( PropInt.BLOCKSIZE ) ); - u.sendFile( image.path ); - } - } - upInfos = ThriftConnection.getUploadInfos( imDat ); - } - u.close(); - } - try { - Thread.sleep( 5 * 60 * 1000 ); - // Thread.sleep( 1000 ); - } catch ( InterruptedException e ) { - Thread.currentThread().interrupt(); - return; - } - } - - } -} |