diff options
| author | Simon Rettberg | 2014-09-30 18:29:45 +0200 |
|---|---|---|
| committer | Simon Rettberg | 2014-09-30 18:29:45 +0200 |
| commit | f2797278048f8fc6766097c7d58b93d1dd9a141a (patch) | |
| tree | 71e3f3442baa573b950d5470c1a3ddbd7f71db5d | |
| parent | Use KeyPair classes for satellite authentication (diff) | |
| download | masterserver-f2797278048f8fc6766097c7d58b93d1dd9a141a.tar.gz masterserver-f2797278048f8fc6766097c7d58b93d1dd9a141a.tar.xz masterserver-f2797278048f8fc6766097c7d58b93d1dd9a141a.zip | |
Set max read len for thrift
| -rw-r--r-- | src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java | 4 |
1 files changed, 3 insertions, 1 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 7d9c7f0..19a8a24 100644 --- a/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java +++ b/src/main/java/org/openslx/imagemaster/thrift/server/BinaryListener.java @@ -26,7 +26,9 @@ public class BinaryListener implements Runnable log.fatal( "Could not listen on port 9090" ); return; } - TServer server = new THsHaServer( new THsHaServer.Args( transport ).protocolFactory( protFactory ).processor( processor ).workerThreads( 8 ) ); + THsHaServer.Args args = new THsHaServer.Args( transport ).protocolFactory( protFactory ).processor( processor ).workerThreads( 8 ); + args.maxReadBufferBytes = 30l * 1000l * 1000l; + TServer server = new THsHaServer( args ); log.info( "Starting Binary Thrift" ); server.serve(); } |