diff options
author | Simon Rettberg | 2018-05-16 13:08:44 +0200 |
---|---|---|
committer | Simon Rettberg | 2018-05-16 13:08:44 +0200 |
commit | e519e8edee76b0861f0684823f8f2a0cb9938ff3 (patch) | |
tree | 0380ebc565c0c17af8671b8f965c5015f8c16cf3 /src/main/java/org/openslx/filetransfer/util/IncomingTransferBase.java | |
parent | Add PrioThreadFactory (diff) | |
download | master-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.java | 7 |
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(); |