diff options
| author | Simon Rettberg | 2023-05-24 16:25:37 +0200 |
|---|---|---|
| committer | Simon Rettberg | 2023-05-24 16:25:37 +0200 |
| commit | 870ed89ca71e65f0d365d929bd2d447f3b3342c0 (patch) | |
| tree | beebfdc3353f6eafc2ca41b3290269d9581bd5b6 /src/main/java/org/openslx/filetransfer/util | |
| parent | ThiriftHelper: Discard connections from pool after idling for too long (diff) | |
| download | master-sync-shared-870ed89ca71e65f0d365d929bd2d447f3b3342c0.tar.gz master-sync-shared-870ed89ca71e65f0d365d929bd2d447f3b3342c0.tar.xz master-sync-shared-870ed89ca71e65f0d365d929bd2d447f3b3342c0.zip | |
BFTP: Minor cleanup, comments, refactor
Diffstat (limited to 'src/main/java/org/openslx/filetransfer/util')
| -rw-r--r-- | src/main/java/org/openslx/filetransfer/util/OutgoingTransferBase.java | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/main/java/org/openslx/filetransfer/util/OutgoingTransferBase.java b/src/main/java/org/openslx/filetransfer/util/OutgoingTransferBase.java index 15c86fb..ad2e96c 100644 --- a/src/main/java/org/openslx/filetransfer/util/OutgoingTransferBase.java +++ b/src/main/java/org/openslx/filetransfer/util/OutgoingTransferBase.java @@ -75,9 +75,13 @@ public abstract class OutgoingTransferBase extends AbstractTransfer @Override public void run() { - boolean ret = connection.upload( sourceFile.getAbsolutePath() ); - synchronized ( uploads ) { - uploads.remove( connection ); + boolean ret = false; + try { + ret = connection.upload( sourceFile.getAbsolutePath() ); + } finally { + synchronized ( uploads ) { + uploads.remove( connection ); + } } if ( ret ) { connectFails.set( 0 ); |