[jboss-remoting-commits] JBoss Remoting SVN: r6285 - remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2011-03-19 17:04:11 -0400 (Sat, 19 Mar 2011)
New Revision: 6285

Modified:
   remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java
Log:
JBREM-1277: Add accept thread priority configuration option.

Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java
===================================================================
--- remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java	2011-03-19 20:51:35 UTC (rev 6284)
+++ remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java	2011-03-19 21:04:11 UTC (rev 6285)
@@ -101,6 +101,7 @@
    protected LRUPool clientpool;
    protected LinkedList threadpool;
    protected boolean immediateShutdown;
+   protected int acceptThreadPriorityIncrement = 0;
 
    protected ServerSocketRefresh refreshThread;
    protected boolean newServerSocketFactory = false;
@@ -261,7 +262,11 @@
             ServerSocket ss = (ServerSocket) it.next();
             for(int j = 0; j < numAcceptThreads; j++)
             {
-               acceptThreads[i++] = new AcceptThread(ss, refreshThread);
+               acceptThreads[i] = new AcceptThread(ss, refreshThread);
+               acceptThreads[i].setPriority(Thread.NORM_PRIORITY + acceptThreadPriorityIncrement);
+               if(trace) { log.trace(this + " created and registered " + acceptThreads[i] 
+                                          + " with priority " + acceptThreads[i].getPriority()); }
+               i++;
             }
          }
       }
@@ -735,7 +740,25 @@
    {
       this.writeTimeout = writeTimeout;
    }
+   
+   public int getAcceptThreadPriorityIncrement()
+   {
+      return acceptThreadPriorityIncrement;
+   }
 
+   public void setAcceptThreadPriorityIncrement(int acceptThreadPriorityIncrement)
+   {
+      int resultingPriority = Thread.NORM_PRIORITY + acceptThreadPriorityIncrement;
+      if (resultingPriority < Thread.MIN_PRIORITY || resultingPriority > Thread.MAX_PRIORITY)
+      {
+         log.warn(this + " resulting priority out of range: " + resultingPriority);
+      }
+      else
+      {
+         this.acceptThreadPriorityIncrement = acceptThreadPriorityIncrement;
+      }
+   }
+
    protected void configureSocket(Socket s) throws SocketException
    {
       s.setReuseAddress(getReuseAddress());