From a96372b61eac196bec88f3bb2ed9f7c068d8aebb Mon Sep 17 00:00:00 2001 From: Simon Rettberg Date: Wed, 17 Sep 2014 16:30:58 +0200 Subject: Adapt to changed method names from master-sync-shared --- .../imagemaster/serverconnection/ConnectionHandler.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java b/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java index 7fa9c4e..2faa9b9 100644 --- a/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java +++ b/src/main/java/org/openslx/imagemaster/serverconnection/ConnectionHandler.java @@ -124,14 +124,14 @@ public class ConnectionHandler implements IncomingEvent // check token to identify the client if ( !connections.containsKey( token ) ) { uploader.sendErrorCode( "Token not accepted." ); - uploader.close(); + uploader.close(null); return; } // check if he was a downloading client if ( connections.get( token ).type == Connection.UPLOADING ) { uploader.sendErrorCode( "You can not download, if you are uploading." ); - uploader.close(); + uploader.close(null); return; } @@ -141,10 +141,10 @@ public class ConnectionHandler implements IncomingEvent long actual; for ( Integer block : blocks ) { actual = block * Globals.blockSize; - uploader.sendRange( actual, ( ( fileSize - actual ) < Globals.blockSize ) ? fileSize : ( block + 1 ) * Globals.blockSize ); + uploader.prepareSendRange( actual, ( ( fileSize - actual ) < Globals.blockSize ) ? fileSize : ( block + 1 ) * Globals.blockSize ); uploader.sendFile( fileName ); } - uploader.close(); + uploader.close(null); } @@ -163,7 +163,7 @@ public class ConnectionHandler implements IncomingEvent token = downloader.getToken(); if ( !connections.containsKey( token ) ) { downloader.sendErrorCode( "Token not accepted." ); - downloader.close(); + downloader.close(null); return; } @@ -176,7 +176,7 @@ public class ConnectionHandler implements IncomingEvent // check if he was a uploading client if ( connections.get( token ).type == Connection.DOWNLOADING ) { downloader.sendErrorCode( "You can not upload, if you are downloading." ); - downloader.close(); + downloader.close(null); return; } @@ -187,8 +187,8 @@ public class ConnectionHandler implements IncomingEvent log.debug( "Block " + blockNumber + " was transmitted " + image.getTimesTransmitted( blockNumber ) + " time(s)." ); downloader.setOutputFilename( connections.get( token ).filepath ); - downloader.readBinary(); + downloader.receiveBinary(); } - downloader.close(); + downloader.close(null); } } -- cgit v1.2.3-55-g7522