JBoss Remoting SVN: r5370 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/sslbisocket.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-08-18 22:02:56 -0400 (Tue, 18 Aug 2009)
New Revision: 5370
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/sslbisocket/SSLBisocketServerInvoker.java
Log:
JBREM-1120: Moved SocketFactory creation from SSLBisocketServerInvoker to BisocketServerInvoker.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/sslbisocket/SSLBisocketServerInvoker.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/sslbisocket/SSLBisocketServerInvoker.java 2009-08-19 02:02:25 UTC (rev 5369)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/sslbisocket/SSLBisocketServerInvoker.java 2009-08-19 02:02:56 UTC (rev 5370)
@@ -74,10 +74,6 @@
protected void setup() throws Exception
{
super.setup();
- if (isCallbackServer)
- {
- socketFactory = createSocketFactory(configuration);
- }
}
protected SocketFactory createSocketFactory(Map configuration)
14 years, 8 months
JBoss Remoting SVN: r5369 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-08-18 22:02:25 -0400 (Tue, 18 Aug 2009)
New Revision: 5369
Added:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/TimedOutputStream.java
Log:
JBREM-1120: New OutputStream for output timeout facility.
Added: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/TimedOutputStream.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/TimedOutputStream.java (rev 0)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/TimedOutputStream.java 2009-08-19 02:02:25 UTC (rev 5369)
@@ -0,0 +1,160 @@
+/*
+* JBoss, Home of Professional Open Source
+* Copyright 2009, JBoss Inc., and individual contributors as indicated
+* by the @authors tag. See the copyright.txt in the distribution for a
+* full listing of individual contributors.
+*
+* This is free software; you can redistribute it and/or modify it
+* under the terms of the GNU Lesser General Public License as
+* published by the Free Software Foundation; either version 2.1 of
+* the License, or (at your option) any later version.
+*
+* This software is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+* Lesser General Public License for more details.
+*
+* You should have received a copy of the GNU Lesser General Public
+* License along with this software; if not, write to the Free
+* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+*/
+
+package org.jboss.remoting.transport.socket;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.util.Timer;
+import java.util.TimerTask;
+
+import org.jboss.logging.Logger;
+
+/**
+ * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
+ * @version $Rev$
+ * <p>
+ * Copyright April 22, 2009
+ * </p>
+ */
+public class TimedOutputStream extends OutputStream
+{
+ static private Timer timer = new Timer(true);
+ static private Logger log = Logger.getLogger(TimedOutputStream.class);
+
+ private OutputStream os;
+ private int outputTimeout;
+ private OutputTimerTask timerTask;
+ private Object lock = new Object();
+
+ public TimedOutputStream(OutputStream os, int outputTimeout)
+ {
+ this.os = os;
+ this.outputTimeout = outputTimeout;
+ }
+
+ public void close() throws IOException
+ {
+ os.close();
+ }
+
+ public void write(int b) throws IOException
+ {
+ synchronized (lock)
+ {
+ if (timerTask == null)
+ {
+ try
+ {
+ timerTask = new OutputTimerTask(this);
+ timer.schedule(timerTask, outputTimeout);
+ if (log.isTraceEnabled()) log.trace("scheduled OutputTimerTask: " + outputTimeout);
+ }
+ catch (IllegalStateException e)
+ {
+ timer = new Timer(true);
+ timer.schedule(new OutputTimerTask(this), outputTimeout);
+ if (log.isTraceEnabled()) log.trace("scheduled OutputTimerTask: " + outputTimeout);
+ }
+ }
+ }
+
+ try
+ {
+ os.write(b);
+ }
+ finally
+ {
+ synchronized (lock)
+ {
+ timerTask.cancel();
+ timerTask = null;
+ }
+ }
+ }
+
+ public void write(byte b[], int off, int len) throws IOException
+ {
+ synchronized (lock)
+ {
+ if (timerTask == null)
+ {
+ try
+ {
+ timerTask = new OutputTimerTask(this);
+ timer.schedule(timerTask, outputTimeout);
+ if (log.isTraceEnabled()) log.trace(this + " scheduled " + timerTask + ": " + outputTimeout);
+ }
+ catch (IllegalStateException e)
+ {
+// timer = new Timer("TimedOutputStreamTimer", true);
+ timer = new Timer(true);
+ timer.schedule(new OutputTimerTask(this), outputTimeout);
+ if (log.isTraceEnabled()) log.trace(this + " scheduled " + timerTask + ": " + outputTimeout);
+ }
+ }
+ }
+
+ try
+ {
+ os.write(b, off, len);
+ }
+ finally
+ {
+ synchronized (lock)
+ {
+ timerTask.cancel();
+ timerTask = null;
+ }
+ }
+ }
+
+ static class OutputTimerTask extends TimerTask
+ {
+ private TimedOutputStream tos;
+
+ public OutputTimerTask(TimedOutputStream tos)
+ {
+ this.tos = tos;
+ }
+
+ public void run()
+ {
+ try
+ {
+ log.debug(this + " closing: " + tos);
+ tos.close();
+ tos = null;
+ }
+ catch (IOException e)
+ {
+ log.debug("unable to close " + tos);
+ }
+ }
+
+ public boolean cancel()
+ {
+ tos = null;
+ return super.cancel();
+ }
+ }
+}
14 years, 8 months
JBoss Remoting SVN: r5368 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-08-18 22:01:56 -0400 (Tue, 18 Aug 2009)
New Revision: 5368
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketWrapper.java
Log:
JBREM-1120: Added WRITE_TIMEOUT constant; also, removed some old commented code.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketWrapper.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketWrapper.java 2009-08-19 02:01:05 UTC (rev 5367)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketWrapper.java 2009-08-19 02:01:56 UTC (rev 5368)
@@ -42,6 +42,7 @@
public static final String MARSHALLER = "marshaller";
public static final String UNMARSHALLER = "unmarshaller";
public static final String TEMP_TIMEOUT = "temptimeout";
+ public static final String WRITE_TIMEOUT = "writeTimeout";
protected static final int CLOSING = 254;
@@ -51,7 +52,7 @@
// Attributes -----------------------------------------------------------------------------------
- private Socket socket;
+ protected Socket socket;
private int timeout;
// Constructors ---------------------------------------------------------------------------------
14 years, 8 months
JBoss Remoting SVN: r5367 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-08-18 22:01:05 -0400 (Tue, 18 Aug 2009)
New Revision: 5367
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java
Log:
JBREM-1120: Added writeTimeout facility; also, corrected some javadoc.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java 2009-08-19 02:00:04 UTC (rev 5366)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/SocketServerInvoker.java 2009-08-19 02:01:05 UTC (rev 5367)
@@ -95,6 +95,8 @@
// defaults to -1 as to not have idle timeouts
protected int idleTimeout = -1;
protected IdleTimerTask idleTimerTask = null;
+
+ protected int writeTimeout = -1;
public SocketServerInvoker(InvokerLocator locator)
{
@@ -376,7 +378,7 @@
}
/**
- * @return Value of property serverBindPort.
+ * @return Number of idle ServerThreads
* @jmx:managed-attribute
*/
public int getCurrentThreadPoolSize()
@@ -385,7 +387,7 @@
}
/**
- * @return Value of property serverBindPort.
+ * @return Number of ServerThreads current executing or waiting on an invocation
* @jmx:managed-attribute
*/
public int getCurrentClientPoolSize()
@@ -498,7 +500,17 @@
}
}
}
+
+ public int getWriteTimeout()
+ {
+ return writeTimeout;
+ }
+ public void setWriteTimeout(int writeTimeout)
+ {
+ this.writeTimeout = writeTimeout;
+ }
+
public void run()
{
if(trace) { log.trace(this + " started execution of method run()"); }
@@ -594,7 +606,7 @@
if(trace) { log.trace(this + " creating new worker thread"); }
worker = new ServerThread(socket, this, clientpool, threadpool,
- getTimeout(), serverSocketClass);
+ getTimeout(), writeTimeout, serverSocketClass);
if(trace) { log.trace(this + " created " + worker); }
14 years, 8 months
JBoss Remoting SVN: r5366 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-08-18 22:00:04 -0400 (Tue, 18 Aug 2009)
New Revision: 5366
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/ServerThread.java
Log:
JBREM-1120: Added writeTimeout facility.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/ServerThread.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/ServerThread.java 2009-08-19 01:59:20 UTC (rev 5365)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/ServerThread.java 2009-08-19 02:00:04 UTC (rev 5366)
@@ -106,6 +106,7 @@
private Socket socket;
private int timeout;
+ private int writeTimeout;
protected SocketServerInvoker invoker;
private Constructor serverSocketConstructor;
protected SocketWrapper socketWrapper;
@@ -130,7 +131,7 @@
// Constructors ---------------------------------------------------------------------------------
public ServerThread(Socket socket, SocketServerInvoker invoker, LRUPool clientpool,
- LinkedList threadpool, int timeout, String serverSocketClassName)
+ LinkedList threadpool, int timeout, int writeTimeout, String serverSocketClassName)
throws Exception
{
super();
@@ -142,6 +143,7 @@
this.socket = socket;
this.timeout = timeout;
+ this.writeTimeout = writeTimeout;
this.serverSocketClassName = serverSocketClassName;
this.invoker = invoker;
this.clientpool = clientpool;
@@ -752,7 +754,11 @@
}
localMetadata.put(SocketWrapper.MARSHALLER, marshaller);
localMetadata.put(SocketWrapper.UNMARSHALLER, unmarshaller);
-
+ if (writeTimeout > 0)
+ {
+ localMetadata.put(SocketWrapper.WRITE_TIMEOUT, new Integer(writeTimeout));
+ }
+
serverSocketWrapper = (SocketWrapper)serverSocketConstructor.
newInstance(new Object[]{socket, localMetadata, new Integer(timeout)});
}
14 years, 8 months
JBoss Remoting SVN: r5365 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-08-18 21:59:20 -0400 (Tue, 18 Aug 2009)
New Revision: 5365
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java
Log:
JBREM-1120: Added writeTimeout facility; JBREM-1146: added generalized retriable IOException facility.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java 2009-08-19 01:53:51 UTC (rev 5364)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java 2009-08-19 01:59:20 UTC (rev 5365)
@@ -76,7 +76,10 @@
* or wrapped in a RuntimeException.
*/
public static final String WRAP_INTERRUPTED_EXCEPTION = "wrapInterruptedException";
-
+
+ /** Key for setting socket write timeout */
+ public static final String WRITE_TIMEOUT = "writeTimeout";
+
/**
* Default value for enable TCP nodelay. Value is false.
*/
@@ -215,6 +218,14 @@
public Object usedPoolLock;
protected boolean wrapInterruptedException = false;
+
+ /**
+ * If true, an IOException with message "Connection reset by peer: socket write error" will
+ * be treated like a SocketException.
+ */
+ protected boolean generalizeSocketException;
+
+ protected int writeTimeout = -1;
// Constructors ---------------------------------------------------------------------------------
@@ -280,6 +291,38 @@
reuseAddress = reuse;
}
+ public int getWriteTimeout()
+ {
+ return writeTimeout;
+ }
+
+ public void setWriteTimeout(int writeTimeout)
+ {
+ this.writeTimeout = writeTimeout;
+ }
+
+ /**
+ * Get the generalizeSocketException.
+ *
+ * @return the generalizeSocketException.
+ */
+
+ public synchronized boolean isGeneralizeSocketException()
+ {
+ return generalizeSocketException;
+ }
+
+ /**
+ * Set the generalizeSocketException.
+ *
+ * @param generalizeSocketException The generalizeSocketException to set.
+ */
+
+ public synchronized void setGeneralizeSocketException(boolean generalizeSocketException)
+ {
+ this.generalizeSocketException = generalizeSocketException;
+ }
+
public synchronized void disconnect()
{
log.debug(this + " disconnecting ...");
@@ -443,6 +486,22 @@
shouldCheckConnection = true;
log.debug(this + " setting shouldCheckConnection to " + shouldCheckConnection);
}
+
+ // look for writeTimeout param
+ val = params.get(WRITE_TIMEOUT);
+ if (val != null)
+ {
+ try
+ {
+ writeTimeout = Integer.valueOf((String)val).intValue();
+ log.debug(this + " setting writeTimeout to " + writeTimeout);
+ }
+ catch (Exception e)
+ {
+ log.warn(this + " could not convert " + WRITE_TIMEOUT + " value of " +
+ val + " to an int value");
+ }
+ }
}
protected ServerAddress createServerAddress()
@@ -616,47 +675,27 @@
}
catch (SocketException sex)
{
- log.debug(this + " got SocketException " + sex);
-
- try
- {
- semaphore.release();
- if (trace) log.trace(this + " released semaphore: " + semaphore.permits());
- socketWrapper.close();
- }
- catch (Exception ex)
- {
- if (trace) { log.trace(this + " couldn't successfully close its socketWrapper", ex); }
- }
-
- /**
- * About to run out of retries and
- * pool may be full of timed out sockets,
- * so want to flush the pool and try with
- * fresh socket as a last effort.
- */
- if (retryCount == (numberOfCallRetries - 2))
- {
- flushConnectionPool();
- }
+ handleSocketException(sex, socketWrapper, semaphore, retryCount);
sockEx = sex;
continue;
}
- catch (Exception ex)
+ catch (IOException e)
{
- log.debug(this + " got exception " + ex);
-
- try
+ if (isGeneralizeSocketException() && e.getMessage().startsWith("Connection reset"))
{
- semaphore.release();
- if (trace) log.trace(this + " released semaphore: " + semaphore.permits());
- socketWrapper.close();
+ handleSocketException(e, socketWrapper, semaphore, retryCount);
+ sockEx = new SocketException(e.getMessage());
+ continue;
}
- catch (Exception ignored)
+ else
{
+ return handleOtherException(e, semaphore, socketWrapper);
}
- return handleException(ex, socketWrapper);
}
+ catch (Exception ex)
+ {
+ return handleOtherException(ex, semaphore, socketWrapper);
+ }
// call worked, so no need to retry
break;
@@ -695,6 +734,51 @@
return response;
}
+
+ protected void handleSocketException(Exception sex, SocketWrapper socketWrapper, Semaphore semaphore, int retryCount)
+ {
+ log.debug(this + " got SocketException " + sex);
+
+ try
+ {
+ semaphore.release();
+ if (trace) log.trace(this + " released semaphore: " + semaphore.permits());
+ socketWrapper.close();
+ }
+ catch (Exception ex)
+ {
+ if (trace) { log.trace(this + " couldn't successfully close its socketWrapper", ex); }
+ }
+
+ /**
+ * About to run out of retries and
+ * pool may be full of timed out sockets,
+ * so want to flush the pool and try with
+ * fresh socket as a last effort.
+ */
+ if (retryCount == (numberOfCallRetries - 2))
+ {
+ flushConnectionPool();
+ }
+ }
+
+ protected Object handleOtherException(Exception ex, Semaphore semaphore, SocketWrapper socketWrapper)
+ throws ClassNotFoundException, MarshalException
+ {
+ log.debug(this + " got exception " + ex);
+
+ try
+ {
+ semaphore.release();
+ if (trace) log.trace(this + " released semaphore: " + semaphore.permits());
+ socketWrapper.close();
+ }
+ catch (Exception ignored)
+ {
+ }
+ return handleException(ex, socketWrapper);
+ }
+
protected Object handleException(Exception ex, SocketWrapper socketWrapper)
throws ClassNotFoundException, MarshalException
{
@@ -809,7 +893,10 @@
}
metadata.put(SocketWrapper.MARSHALLER, marshaller);
metadata.put(SocketWrapper.UNMARSHALLER, unmarshaller);
-
+ if (writeTimeout > 0)
+ {
+ metadata.put(SocketWrapper.WRITE_TIMEOUT, new Integer(writeTimeout));
+ }
if (timeAllowed > 0)
{
timeRemaining = (int) (timeAllowed - (System.currentTimeMillis() - start));
14 years, 8 months
JBoss Remoting SVN: r5364 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-08-18 21:53:51 -0400 (Tue, 18 Aug 2009)
New Revision: 5364
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/ClientSocketWrapper.java
Log:
JBREM-1120: Added writeTimeout variable.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/ClientSocketWrapper.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/ClientSocketWrapper.java 2009-08-19 01:52:55 UTC (rev 5363)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/ClientSocketWrapper.java 2009-08-19 01:53:51 UTC (rev 5364)
@@ -51,6 +51,7 @@
private InputStream in;
private OutputStream out;
+ private int writeTimeout = -1;
// Constructors ---------------------------------------------------------------------------------
@@ -78,6 +79,16 @@
return in;
}
+ public int getWriteTimeout()
+ {
+ return writeTimeout;
+ }
+
+ public void setWriteTimeout(int writeTimeout)
+ {
+ this.writeTimeout = writeTimeout;
+ }
+
public void checkConnection() throws IOException
{
// Test to see if socket is alive by send ACK message
@@ -98,7 +109,7 @@
public void checkOpenConnection() throws IOException
{
- log.trace("checking open connection");
+ if (trace) log.trace("checking open connection");
if (in.available() > 1)
{
log.trace("remote endpoint has closed");
@@ -156,6 +167,15 @@
log.trace("set temp timeout to: " + tempTimeout);
}
}
+ o = metadata.get(WRITE_TIMEOUT);
+ if (o instanceof Integer)
+ {
+ writeTimeout = ((Integer) o).intValue();
+ if (writeTimeout != -1)
+ {
+ log.trace("set writeTimeout to: " + writeTimeout);
+ }
+ }
}
out = createOutputStream(serializationType, socket, marshaller);
@@ -192,6 +212,11 @@
log.warn("got null marshaller");
OutputStream os = socket.getOutputStream();
+ if (writeTimeout > 0)
+ {
+ os = new TimedOutputStream(os, writeTimeout);
+ }
+
if (marshaller instanceof PreferredStreamMarshaller)
{
PreferredStreamMarshaller psm = (PreferredStreamMarshaller) marshaller;
14 years, 8 months
JBoss Remoting SVN: r5363 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-08-18 21:52:55 -0400 (Tue, 18 Aug 2009)
New Revision: 5363
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java
Log:
JBREM-1120: Moved SocketFactory creation from SSLBisocketServerInvoker to BisocketServerInvoker; JBREM-1140: Backed out the ping reply mechanism.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java 2009-08-18 15:29:15 UTC (rev 5362)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/bisocket/BisocketServerInvoker.java 2009-08-19 01:52:55 UTC (rev 5363)
@@ -82,7 +82,6 @@
private int socketCreationRetries = Bisocket.MAX_RETRIES_DEFAULT;
private int controlConnectionRestarts = Bisocket.MAX_CONTROL_CONNECTION_RESTARTS_DEFAULT;
private ControlMonitorTimerTask controlMonitorTimerTask;
- private boolean enablePingReplies = false;
protected boolean isCallbackServer = false;
protected int secondaryBindPort = -1;
protected int secondaryConnectPort = -1;
@@ -203,13 +202,6 @@
secondaryServerSocketThread.start();
log.debug("started secondary port: " + host + ":" + secondaryBindPort);
}
- Object val = configuration.get(Bisocket.ENABLE_PING_REPLIES);
- if (val != null)
- {
- // Boolean.valueOf doesn't throw exceptions :-)
- boolean bVal = Boolean.valueOf((String) val).booleanValue();
- enablePingReplies = bVal;
- }
}
@@ -517,6 +509,11 @@
log.warn("\"" + Bisocket.SECONDARY_CONNECT_PORT + "\" must be specified as a String");
}
+ if (isCallbackServer)
+ {
+ socketFactory = createSocketFactory(configuration);
+ }
+
super.setup();
}
@@ -807,10 +804,6 @@
break;
case Bisocket.PING:
- if (enablePingReplies)
- {
- socket.getOutputStream().write(Bisocket.PING);
- }
continue;
case -1:
14 years, 8 months
JBoss Remoting SVN: r5362 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-08-18 11:29:15 -0400 (Tue, 18 Aug 2009)
New Revision: 5362
Modified:
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/WriteTimeoutTestParent.java
Log:
JBREM-1120: Reduced log level to INFO.
Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/WriteTimeoutTestParent.java
===================================================================
--- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/WriteTimeoutTestParent.java 2009-08-18 03:33:36 UTC (rev 5361)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/WriteTimeoutTestParent.java 2009-08-18 15:29:15 UTC (rev 5362)
@@ -93,7 +93,7 @@
if (firstTime)
{
firstTime = false;
- Logger.getLogger("org.jboss.remoting").setLevel(XLevel.TRACE);
+ Logger.getLogger("org.jboss.remoting").setLevel(Level.INFO);
Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO);
String pattern = "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n";
PatternLayout layout = new PatternLayout(pattern);
14 years, 8 months