diff options
Diffstat (limited to 'dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java')
| -rw-r--r-- | dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java index d730eace..abf5721c 100644 --- a/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java +++ b/dozentenmodulserver/src/main/java/org/openslx/bwlp/sat/thrift/BinaryListener.java @@ -30,8 +30,6 @@ public class BinaryListener implements Runnable { private static final Logger log = LogManager.getLogger(BinaryListener.class); private static final int MAX_MSG_LEN = 30 * 1000 * 1000; - private static final int MINWORKERTHREADS = 2; - private static final int MAXWORKERTHREADS = 96; private final SatelliteServer.Processor<ServerHandler> processor = new SatelliteServer.Processor<ServerHandler>( new ServerHandler()); @@ -41,10 +39,11 @@ public class BinaryListener implements Runnable { public BinaryListener(int port, boolean secure, ExecutorService es) throws TTransportException, NoSuchAlgorithmException, IOException { - if (secure) + if (secure) { server = initSecure(port, es); - else - server = initNormal(port); + } else { + server = initNormal(port, es); + } } @Override @@ -75,13 +74,12 @@ public class BinaryListener implements Runnable { args.protocolFactory(protFactory); args.processor(processor); args.executorService(es); - args.minWorkerThreads(MINWORKERTHREADS).maxWorkerThreads(MAXWORKERTHREADS); args.stopTimeoutVal(2).stopTimeoutUnit(TimeUnit.MINUTES); args.transportFactory(new TFastFramedTransport.Factory(MAX_MSG_LEN)); return new TThreadPoolServer(args); } - private TServer initNormal(int port) throws TTransportException { + private TServer initNormal(int port, ExecutorService es) throws TTransportException { final TNonblockingServerTransport serverTransport; try { serverTransport = new TNonblockingServerSocket(port); @@ -93,7 +91,7 @@ public class BinaryListener implements Runnable { THsHaServer.Args args = new THsHaServer.Args(serverTransport); args.protocolFactory(protFactory); args.processor(processor); - args.maxWorkerThreads(8); + args.executorService(es); args.maxReadBufferBytes = MAX_MSG_LEN; return new THsHaServer(args); } |