[jboss-remoting-commits] JBoss Remoting SVN: r6285 - remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket.
Author: ron.sigal(a)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());