Commit 2c859f35 authored by Gaston Dombiak's avatar Gaston Dombiak Committed by gato

Assigned higher priority to threads that accept connections. JM-502

git-svn-id: http://svn.igniterealtime.org/svn/repos/wildfire/trunk@3244 b35dd754-fafc-0310-a699-88a17e54d16e
parent 05305945
...@@ -90,6 +90,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana ...@@ -90,6 +90,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
serverSocketThread = new SocketAcceptThread(this, serverPort); serverSocketThread = new SocketAcceptThread(this, serverPort);
ports.add(serverPort); ports.add(serverPort);
serverSocketThread.setDaemon(true); serverSocketThread.setDaemon(true);
serverSocketThread.setPriority(Thread.MAX_PRIORITY);
serverSocketThread.start(); serverSocketThread.start();
List<String> params = new ArrayList<String>(); List<String> params = new ArrayList<String>();
...@@ -123,6 +124,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana ...@@ -123,6 +124,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
componentSocketThread = new SocketAcceptThread(this, serverPort); componentSocketThread = new SocketAcceptThread(this, serverPort);
ports.add(serverPort); ports.add(serverPort);
componentSocketThread.setDaemon(true); componentSocketThread.setDaemon(true);
componentSocketThread.setPriority(Thread.MAX_PRIORITY);
componentSocketThread.start(); componentSocketThread.start();
List<String> params = new ArrayList<String>(); List<String> params = new ArrayList<String>();
...@@ -156,6 +158,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana ...@@ -156,6 +158,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
socketThread = new SocketAcceptThread(this, serverPort); socketThread = new SocketAcceptThread(this, serverPort);
ports.add(serverPort); ports.add(serverPort);
socketThread.setDaemon(true); socketThread.setDaemon(true);
socketThread.setPriority(Thread.MAX_PRIORITY);
socketThread.start(); socketThread.start();
List<String> params = new ArrayList<String>(); List<String> params = new ArrayList<String>();
...@@ -193,6 +196,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana ...@@ -193,6 +196,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
sslSocketThread = new SSLSocketAcceptThread(this, serverPort); sslSocketThread = new SSLSocketAcceptThread(this, serverPort);
ports.add(serverPort); ports.add(serverPort);
sslSocketThread.setDaemon(true); sslSocketThread.setDaemon(true);
sslSocketThread.setPriority(Thread.MAX_PRIORITY);
sslSocketThread.start(); sslSocketThread.start();
List<String> params = new ArrayList<String>(); List<String> params = new ArrayList<String>();
...@@ -239,6 +243,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana ...@@ -239,6 +243,7 @@ public class ConnectionManagerImpl extends BasicModule implements ConnectionMana
} }
Thread thread = new Thread(reader, threadName); Thread thread = new Thread(reader, threadName);
thread.setDaemon(true); thread.setDaemon(true);
thread.setPriority(Thread.NORM_PRIORITY);
thread.start(); thread.start();
} }
catch (IOException e) { catch (IOException e) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment