Truncate files if they are resumed and bigger than expected

2 files changed, 8 insertions, 0 deletions

diff --git a/src/main/java/org/openslx/filetransfer/Transfer.java b/src/main/java/org/openslx/filetransfer/Transfer.java
index cf9b475..01c7227 100644
--- a/src/main/java/org/openslx/filetransfer/Transfer.java
+++ b/src/main/java/org/openslx/filetransfer/Transfer.java
@@ -90,6 +90,7 @@ public abstract class Transfer
 	{
 		try {
 			sendKeyValuePair( "ERROR", errString );
+			sendEndOfMeta();
 		} catch ( IOException e ) {
 			e.printStackTrace();
 			this.close( e.toString() );
diff --git a/src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java b/src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java
index c2d8ee9..518a29f 100644
--- a/src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java
+++ b/src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java
@@ -88,6 +88,13 @@ public abstract class IncomingTransferBase extends AbstractTransfer implements H
 		tmpFileName = absFilePath;
 		tmpFileName.getParentFile().mkdirs();
 		tmpFileHandle = new RandomAccessFile( absFilePath, "rw" );
+		try {
+			if ( tmpFileHandle.length() > fileSize ) {
+				tmpFileHandle.setLength( fileSize );
+			}
+		} catch ( IOException e ) {
+			LOGGER.debug( "File " + tmpFileName + " is too long and could not be truncated" );
+		}
 		chunks = new ChunkList( fileSize, blockHashes );
 	}