summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java
diff options
context:
space:
mode:
authorSimon Rettberg2018-05-16 13:08:44 +0200
committerSimon Rettberg2018-05-16 13:08:44 +0200
commite519e8edee76b0861f0684823f8f2a0cb9938ff3 (patch)
tree0380ebc565c0c17af8671b8f965c5015f8c16cf3 /src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java
parentAdd PrioThreadFactory (diff)
downloadmaster-sync-shared-e519e8edee76b0861f0684823f8f2a0cb9938ff3.tar.gz
master-sync-shared-e519e8edee76b0861f0684823f8f2a0cb9938ff3.tar.xz
master-sync-shared-e519e8edee76b0861f0684823f8f2a0cb9938ff3.zip
More speedup: LZ4 and empty chunk detection
Diffstat (limited to 'src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java')
-rw-r--r--src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java b/src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java
index 0355182..eaef63b 100644
--- a/src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java
+++ b/src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java
@@ -643,6 +643,13 @@ public abstract class IncomingTransferBase extends AbstractTransfer implements H
if ( state == TransferState.FINISHED ) {
return;
}
+ try {
+ if ( tmpFileHandle.length() < fileSize && chunks.lastChunkIsZero() ) {
+ tmpFileHandle.setLength( fileSize );
+ }
+ } catch ( IOException e) {
+ LOGGER.warn( "Cannot extend file size to " + fileSize );
+ }
safeClose( tmpFileHandle );
if ( localCopyManager != null ) {
localCopyManager.interrupt();