in = new BufferedReader(new InputStreamReader(socket.getInputStream()));\r
\r
// Start the thread to listen for incoming messages\r
- logger.info("CLIENT: connection successful to port "\r
- + socket.getPort() + " via port " + socket.getLocalPort());\r
+// logger.info("CLIENT: connection successful to port "\r
+// + socket.getPort() + " via port " + socket.getLocalPort());\r
start();\r
\r
return true;\r
}\r
catch (Exception e)\r
{\r
- logger.info("CLIENT: connection failed: " + e);\r
+ //logger.info("CLIENT: connection failed: " + e);\r
return false;\r
}\r
}\r
{\r
String str = message.getRawMessage();\r
\r
- logger.info("CLIENT: send " + str + " to " + rPort);\r
+ //logger.info("CLIENT: send " + str + " to " + rPort);\r
os.write(str);\r
\r
// We use a newline to terminate the message\r
}\r
catch (Exception e)\r
{\r
- logger.info("CLIENT: failed to send");\r
+ //logger.info("CLIENT: failed to send");\r
\r
// TODO: terminate the connection on a failed send or retry?\r
terminate();\r
while (true)\r
{\r
String str = in.readLine(); \r
- logger.info("CLIENT: recv " + str + " from " + rPort);\r
+ //logger.info("CLIENT: recv " + str + " from " + rPort);\r
\r
// TODO: Spawn this off into the GUI Event-Dispatch thread...\r
\r
{\r
// Means the other end of the connection has (probably died) so we need\r
// terminate this endpoint (if this is server side)\r
- logger.info("CLIENT: read failed: " + e);\r
+ //logger.info("CLIENT: read failed: " + e);\r
\r
terminate();\r
}\r
try { socket.close(); }\r
catch (IOException e) {}\r
\r
- logger.info("CLIENT: closing connection to port " + socket.getPort());\r
+ //logger.info("CLIENT: closing connection to port " + socket.getPort());\r
manager.removeEndPoint(this);\r
}\r
\r
}\r
catch (Exception e)\r
{\r
- logger.info("Unable to reconstruct message: " + e);\r
+ //logger.info("Unable to reconstruct message: " + e);\r
}\r
\r
return null;\r
}\r
catch (IOException e)\r
{\r
- logger.info("SERVER: " + e);\r
+ //logger.info("SERVER: " + e);\r
return false;\r
}\r
}\r
*/\r
public void run()\r
{\r
- logger.info("SERVER: listening on " + PORT + " - SERVER");\r
+ //logger.info("SERVER: listening on " + PORT + " - SERVER");\r
\r
// Loop forever, accepting connectons from other clients\r
// TODO: add in the ability to terminate the server if a VAMSAS session\r
try\r
{\r
Socket socket = serverSocket.accept(); \r
- logger.info("SERVER: connection detected");\r
+ //logger.info("SERVER: connection detected");\r
\r
manager.addEndPoint(socket);\r
}\r
if (client.openConnection())\r
{\r
clients.add(client);\r
- logger.info("List now contains " + clients.size() + " client(s)");\r
+ //logger.info("List now contains " + clients.size() + " client(s)");\r
return true;\r
}\r
\r
\r
if (msgHandler != null)\r
msgHandler.handleMessage(message);\r
- else\r
- logger.info("No handler available to deal with incoming message");\r
+// else\r
+// logger.info("No handler available to deal with incoming message");\r
}\r
\r
/**\r
synchronized void removeEndPoint(PickEndPoint client)\r
{\r
clients.remove(client);\r
- logger.info("List now contains " + clients.size() + " client(s)");\r
+ //logger.info("List now contains " + clients.size() + " client(s)");\r
\r
// If there's no endpoints left, then we've lost all connections and\r
// need to reinitialize\r
{\r
public void run()\r
{\r
- logger.info("Initializing connection...");\r
+ //logger.info("Initializing connection...");\r
boolean connected = false;\r
\r
// Loop until we can get a connection (one way or the other)\r