December 2010 - jboss-remoting-commits

JBoss Remoting SVN: r6190 - remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2010-12-23 19:02:43 -0500 (Thu, 23 Dec 2010) New Revision: 6190 Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java Log: JBREM-1144: Added "numberOfCallRetries" to Client's config map for ConnectionValidator. Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java =================================================================== --- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-23 19:35:34 UTC (rev 6189) +++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-24 00:02:43 UTC (rev 6190) @@ -122,6 +122,7 @@ InvokerLocator clientLocator = new InvokerLocator(locatorURI + "&dummy=dummy"); HashMap clientConfig = new HashMap(); clientConfig.put(InvokerLocator.FORCE_REMOTE, "true"); + clientConfig.put("numberOfCallRetries", "3"); // for ConnectionValidator addExtraClientConfig(clientConfig); Client client = new Client(clientLocator, clientConfig); client.connect(); @@ -177,6 +178,7 @@ InvokerLocator clientLocator = new InvokerLocator(locatorURI + "&dummy=dummy"); HashMap clientConfig = new HashMap(); clientConfig.put(InvokerLocator.FORCE_REMOTE, "true"); + clientConfig.put("numberOfCallRetries", "3"); // for ConnectionValidator addExtraClientConfig(clientConfig); Client client = new Client(clientLocator, clientConfig); client.connect();

13 years, 7 months

1
0
0 / 0

JBoss Remoting SVN: r6189 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2010-12-23 14:35:34 -0500 (Thu, 23 Dec 2010) New Revision: 6189 Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration/BisocketCallbackSocketConfigurationTestCase.java Log: JBREM-1226: Changed traffic class to 8 (a power of 2). Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration/BisocketCallbackSocketConfigurationTestCase.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration/BisocketCallbackSocketConfigurationTestCase.java 2010-12-19 01:13:49 UTC (rev 6188) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration/BisocketCallbackSocketConfigurationTestCase.java 2010-12-23 19:35:34 UTC (rev 6189) @@ -74,7 +74,7 @@ protected static final int SEND_BUFFER_SIZE = 10333; protected static final boolean SO_LINGER = true; protected static final int SO_LINGER_DURATION = 444; - protected static final int TRAFFIC_CLASS = 5; + protected static final int TRAFFIC_CLASS = 8; private static boolean firstTime = true;

13 years, 7 months

1
0
0 / 0

JBoss Remoting SVN: r6188 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2010-12-18 20:13:49 -0500 (Sat, 18 Dec 2010) New Revision: 6188 Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityVersionTestServer.java remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityWithLeasingVersionTestClient.java remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityWithoutLeasingVersionTestClient.java Log: JBREM-1144: Changed Level.TRACE to XLevel.TRACE for jdk 1.4 runs. Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityVersionTestServer.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityVersionTestServer.java 2010-12-18 22:03:56 UTC (rev 6187) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityVersionTestServer.java 2010-12-19 01:13:49 UTC (rev 6188) @@ -35,6 +35,7 @@ import org.apache.log4j.Logger; import org.apache.log4j.PatternLayout; import org.jboss.jrunit.extensions.ServerTestCase; +import org.jboss.logging.XLevel; import org.jboss.remoting.Client; import org.jboss.remoting.ConnectionListener; import org.jboss.remoting.InvocationRequest; @@ -94,7 +95,7 @@ { try { - Logger.getLogger("org.jboss.remoting").setLevel(Level.TRACE); + Logger.getLogger("org.jboss.remoting").setLevel(XLevel.TRACE); Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO); String pattern = "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n"; PatternLayout layout = new PatternLayout(pattern); Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityWithLeasingVersionTestClient.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityWithLeasingVersionTestClient.java 2010-12-18 22:03:56 UTC (rev 6187) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityWithLeasingVersionTestClient.java 2010-12-19 01:13:49 UTC (rev 6188) @@ -32,6 +32,7 @@ import org.apache.log4j.Level; import org.apache.log4j.Logger; import org.apache.log4j.PatternLayout; +import org.jboss.logging.XLevel; import org.jboss.remoting.Client; import org.jboss.remoting.ConnectionListener; import org.jboss.remoting.ConnectionValidator; @@ -78,7 +79,7 @@ setErr(ps); } - Logger.getLogger("org.jboss.remoting").setLevel(Level.TRACE); + Logger.getLogger("org.jboss.remoting").setLevel(XLevel.TRACE); Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO); String pattern = "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n"; PatternLayout layout = new PatternLayout(pattern); Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityWithoutLeasingVersionTestClient.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityWithoutLeasingVersionTestClient.java 2010-12-18 22:03:56 UTC (rev 6187) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityWithoutLeasingVersionTestClient.java 2010-12-19 01:13:49 UTC (rev 6188) @@ -32,6 +32,7 @@ import org.apache.log4j.Level; import org.apache.log4j.Logger; import org.apache.log4j.PatternLayout; +import org.jboss.logging.XLevel; import org.jboss.remoting.Client; import org.jboss.remoting.ConnectionListener; import org.jboss.remoting.ConnectionValidator; @@ -79,7 +80,7 @@ setErr(ps); } - Logger.getLogger("org.jboss.remoting").setLevel(Level.TRACE); + Logger.getLogger("org.jboss.remoting").setLevel(XLevel.TRACE); Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO); String pattern = "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n"; PatternLayout layout = new PatternLayout(pattern);

13 years, 7 months

1
0
0 / 0

JBoss Remoting SVN: r6187 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2010-12-18 17:03:56 -0500 (Sat, 18 Dec 2010) New Revision: 6187 Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java Log: JBREM-1144: (1) Shut down ServerThreads in shutdownServer(); (2) sped up LeasePinger. Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-18 22:02:27 UTC (rev 6186) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-18 22:03:56 UTC (rev 6187) @@ -23,12 +23,16 @@ import java.io.ByteArrayOutputStream; import java.io.PrintStream; +import java.lang.reflect.Field; import java.net.InetAddress; import java.security.AccessController; import java.security.PrivilegedActionException; import java.security.PrivilegedExceptionAction; +import java.util.ConcurrentModificationException; import java.util.HashMap; +import java.util.Iterator; import java.util.Map; +import java.util.Set; import javax.management.MBeanServer; @@ -50,6 +54,10 @@ import org.jboss.remoting.callback.InvokerCallbackHandler; import org.jboss.remoting.transport.Connector; import org.jboss.remoting.transport.PortUtil; +import org.jboss.remoting.transport.socket.LRUPool; +import org.jboss.remoting.transport.socket.ServerSocketWrapper; +import org.jboss.remoting.transport.socket.ServerThread; +import org.jboss.remoting.transport.socket.SocketServerInvoker; import org.jboss.remoting.util.SecurityUtility; @@ -198,7 +206,7 @@ log.info("SHUT DOWN SERVER"); setupServer(true); log.info("SET UP NEW SERVER"); - Thread.sleep(10000); + Thread.sleep(15000); log.info(this + " listener.connectionFailed: " + listener.connectionFailed); assertTrue(listener.connectionFailed); @@ -285,7 +293,7 @@ if (useLeasing) { locatorURI += "&" + InvokerLocator.CLIENT_LEASE + "=true"; - locatorURI += "&" + InvokerLocator.CLIENT_LEASE_PERIOD + "=20000"; + locatorURI += "&" + InvokerLocator.CLIENT_LEASE_PERIOD + "=2000"; } String metadata = System.getProperty("remoting.metadata"); if (metadata != null) @@ -312,7 +320,33 @@ protected void shutdownServer() throws Exception { if (connector != null) + { + // Remoting versions 1.x and 2.2.x don't necessarily shut down all of their + // ServerThreads, so an exiting connection could connect to a ServerThread + // associated with the old ServerInvoker. + SocketServerInvoker invoker = (SocketServerInvoker) connector.getServerInvoker(); + Field clientpoolField = SocketServerInvoker.class.getDeclaredField("clientpool"); + clientpoolField.setAccessible(true); + Field socketWrapperField = ServerThread.class.getDeclaredField("socketWrapper"); + socketWrapperField.setAccessible(true); + LRUPool clientpool = (LRUPool) clientpoolField.get(invoker); + Set threads = clientpool.getContents(); + Iterator it = threads.iterator(); + while (it.hasNext()) + { + try + { + ServerThread t = (ServerThread) it.next(); + ServerSocketWrapper socketWrapper = (ServerSocketWrapper) socketWrapperField.get(t); + socketWrapper.close(); + } + catch (ConcurrentModificationException e) + { + log.info(this + " caught " + e.getMessage()); + } + } connector.stop(); + } }

13 years, 7 months

1
0
0 / 0

JBoss Remoting SVN: r6186 - remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2010-12-18 17:02:27 -0500 (Sat, 18 Dec 2010) New Revision: 6186 Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java Log: JBREM-1144: (1) Added log search for "detected new serverId"; (2) sped up LeasePinger. Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java =================================================================== --- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-18 18:36:02 UTC (rev 6185) +++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-18 22:02:27 UTC (rev 6186) @@ -21,6 +21,8 @@ */ package org.jboss.test.remoting.connection.identity; +import java.io.ByteArrayOutputStream; +import java.io.PrintStream; import java.lang.reflect.Field; import java.net.InetAddress; import java.util.ConcurrentModificationException; @@ -50,11 +52,9 @@ import org.jboss.remoting.transport.Connector; import org.jboss.remoting.transport.PortUtil; import org.jboss.remoting.transport.socket.LRUPool; -import org.jboss.remoting.transport.socket.MicroSocketClientInvoker; import org.jboss.remoting.transport.socket.ServerSocketWrapper; import org.jboss.remoting.transport.socket.ServerThread; import org.jboss.remoting.transport.socket.SocketServerInvoker; -import org.jboss.remoting.transport.socket.SocketWrapper; /** @@ -70,29 +70,36 @@ { private static Logger log = Logger.getLogger(ServerIdentityTestCase.class); - private static boolean firstTime = true; - protected String host; protected int port; protected String locatorURI; protected InvokerLocator serverLocator; protected Connector connector; protected TestInvocationHandler invocationHandler; - + protected ByteArrayOutputStream baosOut; + protected PrintStream originalOutPrintStream; + protected ByteArrayOutputStream baosErr; + protected PrintStream originalErrPrintStream; public void setUp() throws Exception { - if (firstTime) - { - firstTime = false; - Logger.getLogger("org.jboss.remoting").setLevel(XLevel.TRACE); - Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO); - String pattern = "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n"; - PatternLayout layout = new PatternLayout(pattern); - ConsoleAppender consoleAppender = new ConsoleAppender(layout); - Logger.getRootLogger().addAppender(consoleAppender); - } + originalOutPrintStream = System.out; + baosOut = new ByteArrayOutputStream(); + PrintStream ps = new PrintStream(baosOut); + setOut(ps); + originalErrPrintStream = System.err; + baosErr = new ByteArrayOutputStream(); + ps = new PrintStream(baosErr); + setErr(ps); + + Logger.getLogger("org.jboss.remoting").setLevel(XLevel.TRACE); + Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO); + String pattern = "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n"; + PatternLayout layout = new PatternLayout(pattern); + ConsoleAppender consoleAppender = new ConsoleAppender(layout); + Logger.getRootLogger().addAppender(consoleAppender); + host = InetAddress.getLocalHost().getHostAddress(); port = PortUtil.findFreePort(host); } @@ -143,6 +150,14 @@ Thread.sleep(10000); log.info(this + " listener.connectionFailed: " + listener.connectionFailed); assertTrue(listener.connectionFailed); + + setOut(originalOutPrintStream); + String sOut = new String(baosOut.toByteArray()); + System.out.println(sOut); + setErr(originalErrPrintStream); + String sErr = new String(baosErr.toByteArray()); + System.out.println(sErr); + assertTrue(sOut.indexOf("detected new serverId:") > -1 || sErr.indexOf("detected new serverId:") > -1); client.disconnect(); shutdownServer(); @@ -187,9 +202,17 @@ log.info("SHUT DOWN SERVER"); setupServer(true); log.info("SET UP NEW SERVER"); - Thread.sleep(10000); + Thread.sleep(15000); log.info(this + " listener.connectionFailed: " + listener.connectionFailed); assertTrue(listener.connectionFailed); + + setOut(originalOutPrintStream); + String sOut = new String(baosOut.toByteArray()); +// System.out.println(sOut); + setErr(originalErrPrintStream); + String sErr = new String(baosErr.toByteArray()); +// System.out.println(sErr); + assertTrue(sOut.indexOf("detected new serverId:") > -1 || sErr.indexOf("detected new serverId:") > -1); client.disconnect(); shutdownServer(); @@ -208,13 +231,25 @@ protected void addExtraServerConfig(Map config) {} + private void setOut(final PrintStream ps) + { + System.setOut(ps); + } + + + private void setErr(final PrintStream ps) + { + System.setErr(ps); + } + + protected void setupServer(boolean useLeasing) throws Exception { locatorURI = getTransport() + "://" + host + ":" + port + "?" + Remoting.USE_SERVER_CONNECTION_IDENTITY + "=true"; if (useLeasing) { locatorURI += "&" + InvokerLocator.CLIENT_LEASE + "=true"; - locatorURI += "&" + InvokerLocator.CLIENT_LEASE_PERIOD + "=20000"; + locatorURI += "&" + InvokerLocator.CLIENT_LEASE_PERIOD + "=2000"; } String metadata = System.getProperty("remoting.metadata"); if (metadata != null)

13 years, 7 months

1
0
0 / 0

JBoss Remoting SVN: r6185 - remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2010-12-18 13:36:02 -0500 (Sat, 18 Dec 2010) New Revision: 6185 Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java Log: JBREM-1144: Ignore ConcurrentModificationException when shutting down ServerThreads. Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java =================================================================== --- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-18 18:26:53 UTC (rev 6184) +++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-18 18:36:02 UTC (rev 6185) @@ -23,6 +23,7 @@ import java.lang.reflect.Field; import java.net.InetAddress; +import java.util.ConcurrentModificationException; import java.util.HashMap; import java.util.Iterator; import java.util.Map; @@ -254,9 +255,16 @@ Iterator it = threads.iterator(); while (it.hasNext()) { - ServerThread t = (ServerThread) it.next(); - ServerSocketWrapper socketWrapper = (ServerSocketWrapper) socketWrapperField.get(t); - socketWrapper.close(); + try + { + ServerThread t = (ServerThread) it.next(); + ServerSocketWrapper socketWrapper = (ServerSocketWrapper) socketWrapperField.get(t); + socketWrapper.close(); + } + catch (ConcurrentModificationException e) + { + log.info(this + " caught " + e.getMessage()); + } } connector.stop(); }

13 years, 7 months

1
0
0 / 0

JBoss Remoting SVN: r6184 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2010-12-18 13:26:53 -0500 (Sat, 18 Dec 2010) New Revision: 6184 Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration/BisocketCallbackSocketConfigurationTestCase.java Log: JBREM-1226: Added logging. Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration/BisocketCallbackSocketConfigurationTestCase.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration/BisocketCallbackSocketConfigurationTestCase.java 2010-12-18 04:59:49 UTC (rev 6183) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/configuration/BisocketCallbackSocketConfigurationTestCase.java 2010-12-18 18:26:53 UTC (rev 6184) @@ -137,6 +137,14 @@ for (Iterator it = TestServerSocket.sockets.iterator(); it.hasNext(); ) { Socket s = (Socket) it.next(); + log.info("testing socket: " + s); + log.info("reuseAddress: " + s.getReuseAddress()); + log.info("keepAlive: " + s.getKeepAlive()); + log.info("OOBInline: " + s.getOOBInline()); + log.info("receiveBufferSize: " + s.getReceiveBufferSize()); + log.info("sendBufferSize: " + s.getSendBufferSize()); + log.info("SoLinger: " + s.getSoLinger()); + log.info("trafficClass: " + s.getTrafficClass()); assertEquals(REUSE_ADDRESS, s.getReuseAddress()); assertEquals(KEEP_ALIVE, s.getKeepAlive()); assertEquals(OOBINLINE, s.getOOBInline());

13 years, 7 months

1
0
0 / 0

JBoss Remoting SVN: r6183 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2010-12-17 23:59:49 -0500 (Fri, 17 Dec 2010) New Revision: 6183 Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java Log: JBREM-1144: Changed Level.TRACE to XLevel.TRACE for jdk 1.4 runs. Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-18 04:08:47 UTC (rev 6182) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/connection/identity/ServerIdentityTestCase.java 2010-12-18 04:59:49 UTC (rev 6183) @@ -38,6 +38,7 @@ import org.apache.log4j.Level; import org.apache.log4j.Logger; import org.apache.log4j.PatternLayout; +import org.jboss.logging.XLevel; import org.jboss.remoting.Client; import org.jboss.remoting.ConnectionListener; import org.jboss.remoting.ConnectionValidator; @@ -88,7 +89,7 @@ ps = new PrintStream(baosErr); setErr(ps); - Logger.getLogger("org.jboss.remoting").setLevel(Level.TRACE); + Logger.getLogger("org.jboss.remoting").setLevel(XLevel.TRACE); Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO); String pattern = "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n"; PatternLayout layout = new PatternLayout(pattern);

13 years, 7 months

1
0
0 / 0

JBoss Remoting SVN: r6182 - remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/socket/retriable.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2010-12-17 23:08:47 -0500 (Fri, 17 Dec 2010) New Revision: 6182 Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java Log: JBREM-1262: Added testConnectionAbortException(). Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java =================================================================== --- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java 2010-12-18 04:08:10 UTC (rev 6181) +++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java 2010-12-18 04:08:47 UTC (rev 6182) @@ -133,7 +133,16 @@ log.info(getName() + " PASSES"); } + + public void testConnectionAbortException() throws Throwable + { + log.info("entering " + getName()); + exceptionToThrow = new IOException("Software caused connection abort: socket write error"); + doTest(); + log.info(getName() + " PASSES"); + } + protected void doTest() throws Throwable { // Start server.

13 years, 7 months

1
0
0 / 0

JBoss Remoting SVN: r6181 - 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: 2010-12-17 23:08:10 -0500 (Fri, 17 Dec 2010) New Revision: 6181 Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java Log: JBREM-1262: Added IOException("*connection abort*") to set of retriable exceptions. 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 2010-12-18 04:05:12 UTC (rev 6180) +++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java 2010-12-18 04:08:10 UTC (rev 6181) @@ -118,7 +118,7 @@ public static long serializeTime = 0; public static long deserializeTime = 0; - private static final String patternString = "^.*(?:connection.*reset|connection.*closed|broken.*pipe|connection.*shutdown).*$"; + private static final String patternString = "^.*(?:connection.*reset|connection.*closed|connection.*abort|broken.*pipe|connection.*shutdown).*$"; private static final Pattern RETRIABLE_ERROR_MESSAGE = Pattern.compile(patternString, Pattern.CASE_INSENSITIVE); /**

13 years, 7 months

1
0
0 / 0

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

jboss-remoting-commits December 2010