diff options
Diffstat (limited to 'src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java')
| -rw-r--r-- | src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java b/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java index d7a3c12..d18e8a8 100644 --- a/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java +++ b/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java @@ -18,14 +18,16 @@ import org.apache.thrift.transport.TSSLTransportFactory; import org.apache.thrift.transport.TSSLTransportFactory.TSSLTransportParameters; import org.apache.thrift.transport.TServerTransport; import org.apache.thrift.transport.TTransportException; +import org.openslx.bwlp.thrift.iface.MasterServer; import org.openslx.imagemaster.Globals; -import org.openslx.imagemaster.thrift.iface.ImageServer; +import org.openslx.thrifthelper.TBinaryProtocolSafe; public class BinaryListener implements Runnable { private static final int MAX_MSG_LEN = 30 * 1000 * 1000; - private final ImageServer.Processor<ImageServerHandler> processor = new ImageServer.Processor<ImageServerHandler>( new ImageServerHandler() ); + private final MasterServer.Processor<MasterServerHandler> processor = new MasterServer.Processor<MasterServerHandler>( + new MasterServerHandler() ); final TProtocolFactory protFactory = new TBinaryProtocolSafe.Factory( true, true ); private static Logger log = Logger.getLogger( BinaryListener.class ); @@ -49,7 +51,7 @@ public class BinaryListener implements Runnable } /** - * Listen with TLS wrapping - has to use the threadpool server, since encrypted + * Listen with TLS wrapping - has to use the thread pool server, since encrypted * servers cannot use nonblocking sockets :( * * @param port listen port @@ -76,7 +78,7 @@ public class BinaryListener implements Runnable args.protocolFactory( protFactory ); args.processor( processor ); args.minWorkerThreads( 4 ).maxWorkerThreads( 256 ); - args.requestTimeout( 30 ).requestTimeoutUnit( TimeUnit.SECONDS ); + args.requestTimeout( 2 ).requestTimeoutUnit( TimeUnit.MINUTES ); args.transportFactory( new TFramedTransport.Factory( MAX_MSG_LEN ) ); return new TThreadPoolServer( args ); } |