[jboss-cvs] JBossRemoting/src/main/org/jboss/remoting/transport/multiplex ...
Ron Sigal
ron_sigal at yahoo.com
Tue Mar 27 04:09:31 EDT 2007
User: rsigal
Date: 07/03/27 04:09:31
Modified: src/main/org/jboss/remoting/transport/multiplex
MultiplexingManager.java
Log:
JBREM-729: Reduced log.info() messages to log.debug().
Revision Changes Path
1.58 +20 -20 JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/MultiplexingManager.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: MultiplexingManager.java
===================================================================
RCS file: /cvsroot/jboss/JBossRemoting/src/main/org/jboss/remoting/transport/multiplex/MultiplexingManager.java,v
retrieving revision 1.57
retrieving revision 1.58
diff -u -b -r1.57 -r1.58
--- MultiplexingManager.java 23 Aug 2006 07:28:53 -0000 1.57
+++ MultiplexingManager.java 27 Mar 2007 08:09:31 -0000 1.58
@@ -276,7 +276,7 @@
if (staticThreadsRunning)
return;
- log.info("starting static threads");
+ log.debug("starting static threads");
// Start output thread.
outputMultiplexor = new OutputMultiplexor(configuration);
@@ -1052,7 +1052,7 @@
*/
protected synchronized static void shutdownThreads()
{
- log.info("entering shutdownThreads");
+ log.debug("entering shutdownThreads");
if (outputThread != null)
outputThread.shutdown();
@@ -1065,7 +1065,7 @@
if (pendingActionThread != null)
pendingActionThread.shutdown();
- log.info("cancelling timer");
+ log.debug("cancelling timer");
if (timer != null)
timer.cancel();
@@ -1091,7 +1091,7 @@
}
staticThreadsRunning = false;
- log.info("static threads shut down");
+ log.debug("static threads shut down");
}
@@ -1232,7 +1232,7 @@
{
try
{
- if (info) log.info(this + ": entering unRegisterSocket()");
+ if (debug) log.debug(this + ": entering unRegisterSocket()");
shutdownManager.decrementReferences();
SocketId localSocketId = socket.getLocalSocketId();
@@ -1250,7 +1250,7 @@
if (debug) log.debug("unregistering virtual socket on port: " + localSocketId.getPort());
registeredSockets.remove(localSocketId);
removeAnInputStream(localSocketId);
- if (info) log.info(this + ": leaving unRegisterSocket()");
+ if (debug) log.debug(this + ": leaving unRegisterSocket()");
}
finally
{
@@ -2300,7 +2300,7 @@
// time spent in decrementReferences() or by ShutdownMonitorTimerTask waiting
// for a response.
shutdown = protocol.requestManagerShutdown(shutdownRequestTimeout * 2);
- if (info) log.info("shutdown: " + shutdown);
+ if (debug) log.debug("shutdown: " + shutdown);
}
catch (SocketTimeoutException e)
{
@@ -2313,7 +2313,7 @@
log.debug("i/o exception in manager shutdown request", e);
}
- if (info) log.info("ShutdownRequestThread.run() done: " + shutdown);
+ if (debug) log.debug("ShutdownRequestThread.run() done: " + shutdown);
shutdownRequestInProgress = false;
synchronized(ShutdownManager.this)
@@ -2400,14 +2400,14 @@
// Another ShutdownMonitorTimerTask got here first.
if (shutdownHandled)
{
- if (info) log.info(description + ": shutdownHandled == true");
+ if (debug) log.debug(description + ": shutdownHandled == true");
cancel();
}
// ShutdownRequestThread got a positive response.
else if (shutdown)
{
- if (info) log.info(description + ": shutdown is true");
+ if (debug) log.debug(description + ": shutdown is true");
shutdownHandled = true;
shutdown();
cancel();
@@ -2416,7 +2416,7 @@
// Peer MultiplexingManager requested shutdown consent.
else if (readyToShutdown && remoteShutdown)
{
- if (info) log.info(description + ": ShutdownMonitorTimerTask: found remoteShutdown == true");
+ if (debug) log.debug(description + ": ShutdownMonitorTimerTask: found remoteShutdown == true");
shutdown = true;
shutdownHandled = true;
shutdown();
@@ -2427,7 +2427,7 @@
// Timeout (or other error) in ShutdownRequestThread
else if (requestShutdownFailed)
{
- if (info) log.info(description + ": ShutdownMonitorTimerTask: found requestShutdownFailed == true");
+ if (debug) log.debug(description + ": ShutdownMonitorTimerTask: found requestShutdownFailed == true");
shutdown = true;
shutdownHandled = true;
shutdown();
@@ -2439,8 +2439,8 @@
// Assume peer is hung up somehow and shut down.
else if (count > shutdownRefusalsMaximum)
{
- if (info)
- log.info(description + ": ShutdownMonitorTimerTask: " +
+ if (debug)
+ log.debug(description + ": ShutdownMonitorTimerTask: " +
"shutdown refusal count exceeded maximut: " + shutdownRefusalsMaximum);
shutdown = true;
@@ -2453,7 +2453,7 @@
// ShutdownRequestThread is still running.
else if (shutdownRequestInProgress)
{
- if (info) log.info(description + ": shutdownRequestInProgress == true");
+ if (debug) log.debug(description + ": shutdownRequestInProgress == true");
return;
}
@@ -2466,7 +2466,7 @@
ShutdownRequestThread shutdownRequestThread = new ShutdownRequestThread();
shutdownRequestThread.setName(shutdownRequestThread.getName() + ":shutdownRequest:" + time);
shutdownRequestThread.setDaemon(true);
- if (info) log.info(description + ": starting ShutdownRequestThread: " + shutdownRequestThread.toString());
+ if (debug) log.debug(description + ": starting ShutdownRequestThread: " + shutdownRequestThread.toString());
shutdownRequestThread.start();
}
}
@@ -2624,7 +2624,7 @@
ShutdownRequestThread shutdownRequestThread = new ShutdownRequestThread();
shutdownRequestThread.setName(shutdownRequestThread.getName() + ":shutdownRequest:" + time);
shutdownRequestThread.setDaemon(true);
- if (info) log.info(description + "starting ShutdownRequestThread: " + shutdownRequestThread.toString());
+ if (debug) log.debug(description + "starting ShutdownRequestThread: " + shutdownRequestThread.toString());
shutdownRequestThread.start();
try
@@ -2674,7 +2674,7 @@
// shutdownMonitorThread.start();
shutdownMonitorTimerTask = new ShutdownMonitorTimerTask();
- if (info) log.info(description + ": scheduling ShutdownMonitorTask: " + shutdownMonitorTimerTask);
+ if (debug) log.debug(description + ": scheduling ShutdownMonitorTask: " + shutdownMonitorTimerTask);
timer.schedule(shutdownMonitorTimerTask, shutdownMonitorPeriod, shutdownMonitorPeriod);
}
}
@@ -2806,10 +2806,10 @@
shutdown = true;
// Remove this MultiplexManager from set of all managers
- if (info) log.info("removing from allManagers: " + description + "(" + id + ")");
+ if (debug) log.debug("removing from allManagers: " + description + "(" + id + ")");
allManagers.remove(MultiplexingManager.this);
- if (info) log.info("manager shut down (: " + id + "): " + message);
+ if (debug) log.debug("manager shut down (: " + id + "): " + message);
if (debug) log.debug("managers left: " + allManagers.size());
}
More information about the jboss-cvs-commits
mailing list