diff options
Diffstat (limited to 'src/main/java/org/openslx/filetransfer')
| -rw-r--r-- | src/main/java/org/openslx/filetransfer/Downloader.java | 4 | ||||
| -rw-r--r-- | src/main/java/org/openslx/filetransfer/Transfer.java | 1 |
2 files changed, 5 insertions, 0 deletions
diff --git a/src/main/java/org/openslx/filetransfer/Downloader.java b/src/main/java/org/openslx/filetransfer/Downloader.java index 5f026c2..cb933af 100644 --- a/src/main/java/org/openslx/filetransfer/Downloader.java +++ b/src/main/java/org/openslx/filetransfer/Downloader.java @@ -151,6 +151,10 @@ public class Downloader extends Transfer } sendDone(); sendEndOfMeta(); + try { + transferSocket.shutdownOutput(); + } catch ( IOException e ) { + } } finally { this.close( null ); } diff --git a/src/main/java/org/openslx/filetransfer/Transfer.java b/src/main/java/org/openslx/filetransfer/Transfer.java index 79a0242..4502622 100644 --- a/src/main/java/org/openslx/filetransfer/Transfer.java +++ b/src/main/java/org/openslx/filetransfer/Transfer.java @@ -127,6 +127,7 @@ public abstract class Transfer { try { outStream.writeShort( 0 ); + outStream.flush(); } catch ( SocketTimeoutException e ) { log.error( "Error sending end of meta - socket timeout" ); return false; |
