Multi-Client implementiert (zickt aber noch..)

3 files changed, 25 insertions, 21 deletions

diff --git a/Dozentenmodulserver/bin/server/BinaryListener.class b/Dozentenmodulserver/bin/server/BinaryListener.class
index 81db32c2..3518f758 100644
--- a/Dozentenmodulserver/bin/server/BinaryListener.class
+++ b/Dozentenmodulserver/bin/server/BinaryListener.class
diff --git a/Dozentenmodulserver/bin/util/XMLCreator.class b/Dozentenmodulserver/bin/util/XMLCreator.class
index cfdf6004..0c9c6d45 100644
--- a/Dozentenmodulserver/bin/util/XMLCreator.class
+++ b/Dozentenmodulserver/bin/util/XMLCreator.class
diff --git a/Dozentenmodulserver/src/server/BinaryListener.java b/Dozentenmodulserver/src/server/BinaryListener.java
index acf92a89..172b910b 100644
--- a/Dozentenmodulserver/src/server/BinaryListener.java
+++ b/Dozentenmodulserver/src/server/BinaryListener.java
@@ -11,34 +11,38 @@ import org.apache.thrift.transport.TServerSocket;
 import org.apache.thrift.transport.TServerTransport;
 import org.apache.thrift.transport.TTransportException;
 
-public class BinaryListener implements Runnable
-{
-	private static Logger log = Logger.getLogger( BinaryListener.class );
+public class BinaryListener implements Runnable {
+	private static Logger log = Logger.getLogger(BinaryListener.class);
+
+	private final int MINWORKERTHREADS = 20; // keine ahnung ob das passt...
+	private final int MAXWORKERTHREADS = 80; // ebenso
 
 	@Override
-	public void run()
-	{
+	public void run() {
 		final ServerHandler handler = new ServerHandler();
-		final Server.Processor<ServerHandler> processor = new Server.Processor<ServerHandler>( handler );
+		final Server.Processor<ServerHandler> processor = new Server.Processor<ServerHandler>(
+				handler);
 		final TServerTransport transport;
-		final TProtocolFactory protFactory = new TBinaryProtocolSafe.Factory( true, true );
+		final TProtocolFactory protFactory = new TBinaryProtocolSafe.Factory(
+				true, true);
 		try {
-			transport = new TServerSocket( 9090 );
-			log.info(new Date()+" - Connected to Port 9090");
-		} catch ( TTransportException e ) {
-			log.fatal( new Date() +" - Could not listen on port 9090" );
+			transport = new TServerSocket(9090);
+			log.info(new Date() + " - Connected to Port 9090");
+
+		} catch (TTransportException e) {
+			log.fatal(new Date() + " - Could not listen on port 9090");
 			return;
 		}
-		//TServer server = new TSimpleServer( new Args( transport ).processor( processor ) );
-		//TServer server = new TThreadPoolServer( new Args( transport ).protocolFactory( protFactory ).processor( processor ).minWorkerThreads( 4 ).maxWorkerThreads( 8 ) );
-		//TServer server = new TThreadPoolServer( new Args( transport ).protocolFactory( protFactory ).processor( processor ) );
-		//TThreadPoolServer server = new TThreadPoolServer( new Args( transport ).protocolFactory( protFactory ).processor( processor ).minWorkerThreads( 4 ).maxWorkerThreads( 8 ) );
-		
-		TServer server = new TThreadPoolServer( new Args( transport ).protocolFactory( protFactory ).processor( processor ).minWorkerThreads( 4 ).maxWorkerThreads( 8 ) );
-		
-		log.info(new Date() +" - Started running BinaryListener");
+		TServer server = new TThreadPoolServer(new Args(transport)
+				.protocolFactory(protFactory).processor(processor)
+				.minWorkerThreads(MINWORKERTHREADS)
+				.maxWorkerThreads(MAXWORKERTHREADS));
+
+		log.info(new Date() + " - Started running BinaryListener");
+		log.info(new Date() + " - MINWORKERTHREADS=" + MINWORKERTHREADS
+				+ " and MAXWORKERTHREADS=" + MAXWORKERTHREADS+"\n");
 		server.serve();
-		
+
 	}
-	
+
 }