[jetrix-cvs] SF.net SVN: jetrix:[867] jetrix/trunk/src/java/net/jetrix/listeners/ ClientListener.java

[<sm...@us...>]

Revision: 867
          http://jetrix.svn.sourceforge.net/jetrix/?rev=867&view=rev
Author:   smanux
Date:     2010-08-26 12:32:10 +0000 (Thu, 26 Aug 2010)

Log Message:
-----------
Enabled TCP_NODELAY on the sockets

Modified Paths:
--------------
    jetrix/trunk/src/java/net/jetrix/listeners/ClientListener.java

Modified: jetrix/trunk/src/java/net/jetrix/listeners/ClientListener.java
===================================================================
--- jetrix/trunk/src/java/net/jetrix/listeners/ClientListener.java	2010-08-23 15:02:51 UTC (rev 866)
+++ jetrix/trunk/src/java/net/jetrix/listeners/ClientListener.java	2010-08-26 12:32:10 UTC (rev 867)
@@ -24,7 +24,6 @@
 import java.util.*;
 import java.util.logging.*;
 
-
 import net.jetrix.*;
 import net.jetrix.clients.*;
 import net.jetrix.config.*;
@@ -33,7 +32,7 @@
 import net.jetrix.services.*;
 
 /**
- * Abstract Listener waiting for incomming clients.
+ * Abstract Listener waiting for incoming clients.
  *
  * @author Emmanuel Bourg
  * @version $Revision$, $Date$
@@ -60,24 +59,22 @@
     {
         log = Logger.getLogger("net.jetrix");
         ServerConfig serverConfig = Server.getInstance().getConfig();
-        running = true;
-
+        
         try
         {
             // bind the listener to the host & port
             serverSocket = new ServerSocket(getPort(), 50, serverConfig.getHost());
+            running = true;
             log.info("Listening at " + getName() + " port " + getPort()
                     + ((serverConfig.getHost() != null) ? ", bound to " + serverConfig.getHost() : ""));
         }
         catch (BindException e)
         {
             log.severe("Unable to bind " + getName() + " listener at port " + getPort());
-            running = false;
         }
         catch (IOException e)
         {
-            log.severe("Cannot open ServerSocket");
-            e.printStackTrace();
+            log.log(Level.SEVERE, "Cannot open ServerSocket on port " + getPort(), e);
         }
 
         while (serverConfig.isRunning() && running)
@@ -87,7 +84,9 @@
                 // waiting for connexions
                 socket = serverSocket.accept();
                 socket.setSoTimeout(10000);
-
+                socket.setTcpNoDelay(true);
+                socket.setTrafficClass(0x10); // low delay
+                
                 InetAddress address = socket.getInetAddress();
 
                 // log the connection


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.