[haver-commits] r719 - in trunk/clients/Javer2/src/org/haverdev: haver/server javer2

[haver]

Author: bdonlan
Date: 2005-05-23 20:18:01 -0400 (Mon, 23 May 2005)
New Revision: 719

Modified:
   trunk/clients/Javer2/src/org/haverdev/haver/server/AcceptLoop.java
   trunk/clients/Javer2/src/org/haverdev/haver/server/UserConnection.java
   trunk/clients/Javer2/src/org/haverdev/javer2/CMod.java
Log:
* Give threads names for debugging purposes
* NonblockingOutputStream is now in autoflush mode
* CMod uses the same port as AcceptLoop


Modified: trunk/clients/Javer2/src/org/haverdev/haver/server/AcceptLoop.java
===================================================================
--- trunk/clients/Javer2/src/org/haverdev/haver/server/AcceptLoop.java  
2005-05-24 00:05:37 UTC (rev 718)
+++ trunk/clients/Javer2/src/org/haverdev/haver/server/AcceptLoop.java  
2005-05-24 00:18:01 UTC (rev 719)
@@ -20,6 +20,7 @@
     /** Creates a new instance of AcceptLoop */
     public AcceptLoop(int port) throws IOException {
         socket = new ServerSocket(port);
+        setName("Listening socket on port " + port);
     }
     
     public void run() {

Modified: trunk/clients/Javer2/src/org/haverdev/haver/server/UserConnection.java
===================================================================
--- trunk/clients/Javer2/src/org/haverdev/haver/server/UserConnection.java      
2005-05-24 00:05:37 UTC (rev 718)
+++ trunk/clients/Javer2/src/org/haverdev/haver/server/UserConnection.java      
2005-05-24 00:18:01 UTC (rev 719)
@@ -119,6 +119,7 @@
     public UserConnection(Socket s) throws IOException {
         sock = s;
         nws = new NonblockingOutputStream(new 
BufferedOutputStream(s.getOutputStream()));
+        nws.setAutoFlush(true);
         writer = new PrintWriter(new OutputStreamWriter(nws));
         reader = new BufferedReader(new 
InputStreamReader(sock.getInputStream()));
         
@@ -127,6 +128,7 @@
                 inputLoop();
             }
         });
+        readThread.setName("New incoming connection...");
         readThread.start();
     }
     
@@ -333,6 +335,7 @@
             sendLine(msg);
             e = new UserEntity(args[1]);
             context = new NormalContext();
+            readThread.setName("Reader thread for user '" + args[1] + "'");
         }
     }
     

Modified: trunk/clients/Javer2/src/org/haverdev/javer2/CMod.java
===================================================================
--- trunk/clients/Javer2/src/org/haverdev/javer2/CMod.java      2005-05-24 
00:05:37 UTC (rev 718)
+++ trunk/clients/Javer2/src/org/haverdev/javer2/CMod.java      2005-05-24 
00:18:01 UTC (rev 719)
@@ -46,7 +46,7 @@
     }
     
     public static void main(String[] args) throws Throwable {
-        new CMod("localhost", 13456, "cmod", "lobby");
+        new CMod("localhost", 15678, "cmod", "test");
     }
     
     static final int STATE_IDLE = 0;