summaryrefslogtreecommitdiffstats
path: root/dozentenmodul/src/main/java
diff options
context:
space:
mode:
authorSimon Rettberg2015-10-27 11:43:39 +0100
committerSimon Rettberg2015-10-27 11:43:39 +0100
commit35605203f7c1b8a20cae7f7f1b2a45302cafd425 (patch)
tree25c1baa9ec269335b7fa328060ed5feb30fe21c3 /dozentenmodul/src/main/java
parent[client] Clean up config window, add config button to login dialog (diff)
downloadtutor-module-35605203f7c1b8a20cae7f7f1b2a45302cafd425.tar.gz
tutor-module-35605203f7c1b8a20cae7f7f1b2a45302cafd425.tar.xz
tutor-module-35605203f7c1b8a20cae7f7f1b2a45302cafd425.zip
[*] Implement max connection information in satellite config
Diffstat (limited to 'dozentenmodul/src/main/java')
-rw-r--r--dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/TransferTask.java7
1 files changed, 7 insertions, 0 deletions
diff --git a/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/TransferTask.java b/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/TransferTask.java
index dbc42b16..53d8f436 100644
--- a/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/TransferTask.java
+++ b/dozentenmodul/src/main/java/org/openslx/dozmod/filetransfer/TransferTask.java
@@ -8,6 +8,7 @@ import java.util.concurrent.atomic.AtomicInteger;
import org.apache.log4j.Logger;
import org.openslx.bwlp.thrift.iface.TransferState;
+import org.openslx.dozmod.thrift.Session;
import org.openslx.filetransfer.Transfer;
import org.openslx.util.Util;
@@ -112,6 +113,12 @@ public abstract class TransferTask implements Runnable {
protected abstract TransferEvent getTransferEvent();
public final void setMinConnections(int count) {
+ if (Session.getSatelliteConfig() != null
+ && Session.getSatelliteConfig().isSetMaxConnectionsPerTransfer()
+ && Session.getSatelliteConfig().getMaxConnectionsPerTransfer() > 0
+ && Session.getSatelliteConfig().getMaxConnectionsPerTransfer() < count) {
+ count = Session.getSatelliteConfig().getMaxConnectionsPerTransfer();
+ }
synchronized (transfers) {
this.minConnectionCount = count;
}