jboss-remoting-commits
July 2009
jboss-remoting-commits@lists.jboss.org
- 1 participants
- 19 discussions
JBoss Remoting SVN: r5319 - 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-07-30 22:14:33 -0400 (Thu, 30 Jul 2009)
New Revision: 5319
Modified:
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/SSLWriteTimeoutTestParent.java
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/WriteTimeoutTestParent.java
Log:
JBREM-1120: Various fixes.
Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/SSLWriteTimeoutTestParent.java
====…
[View More]===============================================================
--- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/SSLWriteTimeoutTestParent.java 2009-07-31 02:14:01 UTC (rev 5318)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/SSLWriteTimeoutTestParent.java 2009-07-31 02:14:33 UTC (rev 5319)
@@ -21,19 +21,18 @@
*/
package org.jboss.test.remoting.transport.socket.timeout;
-import java.io.EOFException;
import java.io.IOException;
+import java.io.InputStream;
import java.io.OutputStream;
import java.lang.reflect.Constructor;
import java.net.InetAddress;
+import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
+import java.net.SocketAddress;
import java.net.UnknownHostException;
-import java.util.HashMap;
import java.util.Map;
-import java.util.Set;
-import javax.management.MBeanServer;
import javax.net.ServerSocketFactory;
import javax.net.SocketFactory;
import javax.net.ssl.HandshakeCompletedListener;
@@ -42,30 +41,10 @@
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocket;
-import junit.framework.TestCase;
-
-import org.apache.log4j.ConsoleAppender;
-import org.apache.log4j.Level;
import org.apache.log4j.Logger;
-import org.apache.log4j.PatternLayout;
-import org.jboss.remoting.Client;
-import org.jboss.remoting.InvocationFailureException;
-import org.jboss.remoting.InvocationRequest;
import org.jboss.remoting.InvokerLocator;
-import org.jboss.remoting.Remoting;
-import org.jboss.remoting.ServerInvocationHandler;
-import org.jboss.remoting.ServerInvoker;
-import org.jboss.remoting.callback.Callback;
-import org.jboss.remoting.callback.HandleCallbackException;
-import org.jboss.remoting.callback.InvokerCallbackHandler;
import org.jboss.remoting.security.SSLSocketBuilder;
import org.jboss.remoting.transport.Connector;
-import org.jboss.remoting.transport.PortUtil;
-import org.jboss.remoting.transport.bisocket.Bisocket;
-import org.jboss.remoting.transport.socket.SocketServerInvoker;
-import org.jboss.remoting.transport.socket.SocketWrapper;
-import org.jboss.test.remoting.transport.socket.timeout.WriteTimeoutTestParent.TestServerSocketFactory;
-import org.jboss.test.remoting.transport.socket.timeout.WriteTimeoutTestParent.TestSocketFactory;
/**
@@ -85,7 +64,6 @@
protected static int SECONDARY_SERVER_SOCKET_PORT = 8765;
protected static String SECONDARY_SERVER_SOCKET_PORT_STRING = "8765";
- protected static boolean callbackTest;
protected String host;
protected int port;
@@ -120,7 +98,7 @@
protected Constructor getServerSocketFactoryConstructor() throws NoSuchMethodException
{
- return SSLTestServerSocketFactory.class.getConstructor(new Class[]{int.class});
+ return SSLTestServerSocketFactory.class.getConstructor(new Class[]{int.class, int.class});
}
protected String getSocketFactoryClassName()
@@ -130,22 +108,25 @@
protected Constructor getSocketFactoryConstructor() throws NoSuchMethodException
{
- return SSLTestSocketFactory.class.getConstructor(new Class[]{int.class});
+ return SSLTestSocketFactory.class.getConstructor(new Class[]{int.class, int.class});
}
static public class SSLTestServerSocketFactory extends ServerSocketFactory
{
int timeout;
ServerSocketFactory factory;
+ int initialWrites;
public SSLTestServerSocketFactory() throws IOException
{
this.timeout = 5000;
+ this.initialWrites = -1;
setupFactory();
}
- public SSLTestServerSocketFactory(int timeout) throws IOException
+ public SSLTestServerSocketFactory(int timeout, int initialWrites) throws IOException
{
this.timeout = timeout;
+ this.initialWrites = initialWrites;
setupFactory();
}
public ServerSocket createServerSocket() throws IOException
@@ -157,7 +138,7 @@
}
else
{
- ss = new SSLTestServerSocket(timeout, ((SSLServerSocket) factory.createServerSocket()));
+ ss = new SSLTestServerSocket(timeout, initialWrites, ((SSLServerSocket) factory.createServerSocket()));
}
log.info("returning: " + ss);
return ss;
@@ -165,13 +146,13 @@
public ServerSocket createServerSocket(int port) throws IOException
{
ServerSocket ss = null;
- if (callbackTest && port != SECONDARY_SERVER_SOCKET_PORT)
+ if (callbackTest && port != secondaryServerSocketPort)
{
ss = SSLServerSocketFactory.getDefault().createServerSocket(port);
}
else
{
- ss = new SSLTestServerSocket(port, timeout, ((SSLServerSocket) factory.createServerSocket()));
+ ss = new SSLTestServerSocket(port, timeout, initialWrites, ((SSLServerSocket) factory.createServerSocket()));
}
log.info("returning: " + ss);
return ss;
@@ -180,13 +161,13 @@
public ServerSocket createServerSocket(int port, int backlog) throws IOException
{
ServerSocket ss = null;
- if (callbackTest && port != SECONDARY_SERVER_SOCKET_PORT)
+ if (callbackTest && port != secondaryServerSocketPort)
{
ss = SSLServerSocketFactory.getDefault().createServerSocket(port, backlog);
}
else
{
- ss = new SSLTestServerSocket(port, backlog, timeout, ((SSLServerSocket) factory.createServerSocket()));
+ ss = new SSLTestServerSocket(port, backlog, timeout, initialWrites, ((SSLServerSocket) factory.createServerSocket()));
}
log.info("returning: " + ss);
return ss;
@@ -195,13 +176,13 @@
public ServerSocket createServerSocket(int port, int backlog, InetAddress ifAddress) throws IOException
{
ServerSocket ss = null;
- if (callbackTest && port != SECONDARY_SERVER_SOCKET_PORT)
+ if (callbackTest && port != secondaryServerSocketPort)
{
ss = SSLServerSocketFactory.getDefault().createServerSocket(port, backlog, ifAddress);
}
else
{
- ss = new SSLTestServerSocket(port, backlog, ifAddress, timeout, ((SSLServerSocket) factory.createServerSocket()));
+ ss = new SSLTestServerSocket(port, backlog, ifAddress, timeout, initialWrites, ((SSLServerSocket) factory.createServerSocket()));
}
log.info("returning: " + ss);
return ss;
@@ -219,39 +200,56 @@
static class SSLTestServerSocket extends SSLServerSocket
{
int timeout;
+ int initialWrites;
SSLServerSocket serverSocket;
- public SSLTestServerSocket(int timeout, SSLServerSocket serverSocket) throws IOException
+ public SSLTestServerSocket(int timeout, int initialWrites, SSLServerSocket serverSocket) throws IOException
{
super();
this.timeout = timeout;
+ this.initialWrites = initialWrites;
this.serverSocket = serverSocket;
}
- public SSLTestServerSocket(int port, int timeout, SSLServerSocket serverSocket) throws IOException
+ public SSLTestServerSocket(int port, int timeout, int initialWrites, SSLServerSocket serverSocket) throws IOException
{
super(port);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
this.serverSocket = serverSocket;
+ bind(new InetSocketAddress(port), 50);
}
- public SSLTestServerSocket(int port, int backlog, int timeout, SSLServerSocket serverSocket) throws IOException
+ public SSLTestServerSocket(int port, int backlog, int timeout, int initialWrites, SSLServerSocket serverSocket) throws IOException
{
super(port, backlog);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
this.serverSocket = serverSocket;
+ bind(new InetSocketAddress(port), backlog);
}
- public SSLTestServerSocket(int port, int backlog, InetAddress bindAddr, int timeout, SSLServerSocket serverSocket) throws IOException
+ public SSLTestServerSocket(int port, int backlog, InetAddress bindAddr, int timeout, int initialWrites, SSLServerSocket serverSocket) throws IOException
{
super(port, backlog, bindAddr);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
this.serverSocket = serverSocket;
+ bind(new InetSocketAddress(bindAddr, port), 50);
}
public Socket accept() throws IOException
{
SSLSocket s1 = (SSLSocket) serverSocket.accept();
- Socket s2 = new SSLTestSocket(timeout, s1);
- implAccept(s2);
+ Socket s2 = new SSLTestSocket(timeout, initialWrites, s1);
return s2;
}
+ public void bind(SocketAddress endpoint, int backlog) throws IOException
+ {
+ log.info("serverSocket: " + serverSocket);
+ if (serverSocket != null) log.info("bound: " + serverSocket.isBound());
+ if (serverSocket != null && !serverSocket.isBound())
+ {
+ log.info("binding " + serverSocket);
+ serverSocket.bind(endpoint, backlog);
+ }
+ }
public String toString()
{
return "SSLTestServerSocket[" + serverSocket.toString() + "]";
@@ -318,40 +316,43 @@
public static class SSLTestSocketFactory extends SocketFactory
{
int timeout;
+ int initialWrites;
SocketFactory factory;
public SSLTestSocketFactory() throws IOException
{
timeout = 5000;
+ initialWrites = -1;
setupFactory();
}
- public SSLTestSocketFactory(int timeout) throws IOException
+ public SSLTestSocketFactory(int timeout, int initialWrites) throws IOException
{
this.timeout = timeout;
+ this.initialWrites = initialWrites;
setupFactory();
}
public Socket createSocket() throws IOException
{
- return new SSLTestSocket(timeout, ((SSLSocket) factory.createSocket()));
+ return new SSLTestSocket(timeout, initialWrites, ((SSLSocket) factory.createSocket()));
}
public Socket createSocket(String arg0, int arg1) throws IOException, UnknownHostException
{
- return new SSLTestSocket(arg0, arg1, timeout, ((SSLSocket) factory.createSocket()));
+ return new SSLTestSocket(arg0, arg1, timeout, initialWrites, ((SSLSocket) factory.createSocket()));
}
public Socket createSocket(InetAddress arg0, int arg1) throws IOException
{
- return new SSLTestSocket(arg0, arg1, timeout, ((SSLSocket) factory.createSocket()));
+ return new SSLTestSocket(arg0, arg1, timeout, initialWrites, ((SSLSocket) factory.createSocket()));
}
public Socket createSocket(String arg0, int arg1, InetAddress arg2, int arg3) throws IOException, UnknownHostException
{
- return new SSLTestSocket(arg0, arg1, arg2, arg3, timeout, ((SSLSocket) factory.createSocket()));
+ return new SSLTestSocket(arg0, arg1, arg2, arg3, timeout, initialWrites, ((SSLSocket) factory.createSocket()));
}
public Socket createSocket(InetAddress arg0, int arg1, InetAddress arg2, int arg3) throws IOException
{
- return new SSLTestSocket(arg0, arg1, arg2, arg3, timeout, ((SSLSocket) factory.createSocket()));
+ return new SSLTestSocket(arg0, arg1, arg2, arg3, timeout, initialWrites, ((SSLSocket) factory.createSocket()));
}
protected void setupFactory() throws IOException
@@ -365,49 +366,80 @@
static class SSLTestSocket extends SSLSocket
{
int timeout;
+ int initialWrites;
SSLSocket socket;
+ SocketAddress endpoint;
- public SSLTestSocket(int timeout, SSLSocket socket)
+ public SSLTestSocket(int timeout, int initialWrites, SSLSocket socket)
{
this.timeout = timeout;
+ this.initialWrites = initialWrites;
this.socket = socket;
}
- public SSLTestSocket(String host, int port, int timeout, SSLSocket socket) throws UnknownHostException, IOException
+ public SSLTestSocket(String host, int port, int timeout, int initialWrites, SSLSocket socket) throws UnknownHostException, IOException
{
super(host, port);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
this.socket = socket;
+ connect(new InetSocketAddress(host, port), timeout);
}
- public SSLTestSocket(InetAddress address, int port, int timeout, SSLSocket socket) throws IOException
+ public SSLTestSocket(InetAddress address, int port, int timeout, int initialWrites, SSLSocket socket) throws IOException
{
super(address, port);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
this.socket = socket;
+ connect(new InetSocketAddress(address, port), timeout);
}
- public SSLTestSocket(String host, int port, InetAddress localAddr, int localPort, int timeout, SSLSocket socket) throws IOException
+ public SSLTestSocket(String host, int port, InetAddress localAddr, int localPort, int timeout, int initialWrites, SSLSocket socket) throws IOException
{
super(host, port, localAddr, localPort);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
this.socket = socket;
+ bind(new InetSocketAddress(localAddr, localPort));
+ connect(new InetSocketAddress(host, port), timeout);
}
- public SSLTestSocket(InetAddress address, int port, InetAddress localAddr, int localPort, int timeout, SSLSocket socket) throws IOException
+ public SSLTestSocket(InetAddress address, int port, InetAddress localAddr, int localPort, int timeout, int initialWrites, SSLSocket socket) throws IOException
{
super(address, port, localAddr, localPort);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
this.socket = socket;
+ bind(new InetSocketAddress(localAddr, localPort));
+ connect(new InetSocketAddress(address, port), timeout);
}
public String toString()
{
return "SSLTestSocket[" + socket.toString() + "]";
}
+ public InputStream getInputStream() throws IOException
+ {
+ return socket.getInputStream();
+ }
public OutputStream getOutputStream() throws IOException
{
- return new TestOutputStream(socket.getOutputStream(), timeout);
+ return new TestOutputStream(socket.getOutputStream(), timeout, initialWrites);
}
public void addHandshakeCompletedListener(HandshakeCompletedListener listener)
{
socket.addHandshakeCompletedListener(listener);
}
+ public void bind(SocketAddress bindpoint) throws IOException
+ {
+ if (socket != null)
+ socket.bind(bindpoint);
+ }
+ public void connect(SocketAddress endpoint) throws IOException
+ {
+ if (socket != null)
+ socket.connect(endpoint);
+ }
+ public void connect(SocketAddress endpoint, int timeout) throws IOException
+ {
+ socket.connect(endpoint, timeout);
+ }
public boolean getEnableSessionCreation()
{
return socket.getEnableSessionCreation();
@@ -420,6 +452,10 @@
{
return socket.getEnabledProtocols();
}
+ public InetAddress getInetAddress()
+ {
+ return socket.getInetAddress();
+ }
public boolean getNeedClientAuth()
{
return socket.getNeedClientAuth();
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-07-31 02:14:01 UTC (rev 5318)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/timeout/WriteTimeoutTestParent.java 2009-07-31 02:14:33 UTC (rev 5319)
@@ -21,9 +21,10 @@
*/
package org.jboss.test.remoting.transport.socket.timeout;
-import java.io.EOFException;
import java.io.IOException;
import java.io.OutputStream;
+import java.lang.reflect.Constructor;
+import java.lang.reflect.InvocationTargetException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
@@ -35,6 +36,7 @@
import javax.management.MBeanServer;
import javax.net.ServerSocketFactory;
import javax.net.SocketFactory;
+import javax.net.ssl.SSLProtocolException;
import junit.framework.TestCase;
@@ -42,6 +44,7 @@
import org.apache.log4j.Level;
import org.apache.log4j.Logger;
import org.apache.log4j.PatternLayout;
+import org.jboss.remoting.CannotConnectException;
import org.jboss.remoting.Client;
import org.jboss.remoting.InvocationFailureException;
import org.jboss.remoting.InvocationRequest;
@@ -73,9 +76,7 @@
private static Logger log = Logger.getLogger(WriteTimeoutTestParent.class);
private static boolean firstTime = true;
-
- protected static int SECONDARY_SERVER_SOCKET_PORT = 8765;
- protected static String SECONDARY_SERVER_SOCKET_PORT_STRING = "8765";
+ protected static int secondaryServerSocketPort;
protected static boolean callbackTest;
protected String host;
@@ -91,13 +92,15 @@
if (firstTime)
{
firstTime = false;
- Logger.getLogger("org.jboss.remoting").setLevel(Level.INFO);
+ Logger.getLogger("org.jboss.remoting").setLevel(Level.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);
}
+
+ TestOutputStream.counter = 0;
}
@@ -111,14 +114,15 @@
log.info("entering " + getName());
// Start server.
- setupServer(false, false, "", -1);
+ setupServer(false, false, "", -1, -1);
// Create client.
InvokerLocator clientLocator = new InvokerLocator(locatorURI);
HashMap clientConfig = new HashMap();
clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
clientConfig.put(SocketWrapper.WRITE_TIMEOUT, "1000");
- clientConfig.put(Remoting.CUSTOM_SOCKET_FACTORY, new TestSocketFactory(5000));
+ SocketFactory sf = (SocketFactory) getSocketFactoryConstructor().newInstance(new Object[]{new Integer(5000), new Integer(-1)});
+ clientConfig.put(Remoting.CUSTOM_SOCKET_FACTORY, sf);
addExtraClientConfig(clientConfig);
Client client = new Client(clientLocator, clientConfig);
client.connect();
@@ -160,13 +164,14 @@
log.info("entering " + getName());
// Start server.
- setupServer(true, false, "1000", 5000);
+ setupServer(true, false, "1000", 5000, -1);
// Create client.
InvokerLocator clientLocator = new InvokerLocator(locatorURI);
HashMap clientConfig = new HashMap();
clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
clientConfig.put("numberOfCallRetries", "1");
+ clientConfig.put("timeout", "10000");
addExtraClientConfig(clientConfig);
Client client = new Client(clientLocator, clientConfig);
client.connect();
@@ -184,9 +189,9 @@
catch (InvocationFailureException e)
{
log.info(e.getMessage());
- assertNotNull(e.getMessage());
- assertTrue(e.getMessage().startsWith("Unable to perform invocation"));
- assertTrue(e.getCause() instanceof EOFException);
+// assertNotNull(e.getMessage());
+// assertTrue(e.getMessage().startsWith("Unable to perform invocation"));
+// assertTrue(e.getCause() instanceof EOFException);
log.info("got expected Exception");
}
catch (Throwable t)
@@ -213,7 +218,7 @@
log.info("entering " + getName());
// Start server.
- setupServer(false, false, "", -1);
+ setupServer(false, false, "", -1, -1);
// Create client.
InvokerLocator clientLocator = new InvokerLocator(locatorURI);
@@ -238,7 +243,7 @@
if (isBisocket(getTransport()))
{
metadata.put(SocketWrapper.WRITE_TIMEOUT, "1000");
- metadata.put(Remoting.SOCKET_FACTORY_NAME, TestSocketFactory.class.getName());
+ metadata.put(Remoting.SOCKET_FACTORY_NAME, getSocketFactoryClassName());
metadata.put("numberOfCallRetries", "1");
metadata.put(Bisocket.IS_CALLBACK_SERVER, "true");
metadata.put(Bisocket.PING_FREQUENCY, "11111111");
@@ -246,13 +251,18 @@
else
{
metadata.put(SocketWrapper.WRITE_TIMEOUT, "1000");
- metadata.put(ServerInvoker.SERVER_SOCKET_FACTORY, TestServerSocketFactory.class.getName());
+ metadata.put(ServerInvoker.SERVER_SOCKET_FACTORY, getServerSocketFactoryClassName());
metadata.put("numberOfCallRetries", "1");
}
client.addListener(callbackHandler, metadata, null, true);
+ log.info("called Client.addListener()");
// Test server invoker state.
- Thread.sleep(4000);
+ // Wait for local ServerThread to time out. Might take a while in bisocket transports, since
+ // the request to get a socket for the callback client invoker needs its own write on the
+ // control socket.
+ Thread.sleep(20000);
+ log.info("back from sleep");
Set callbackConnectors = client.getCallbackConnectors(callbackHandler);
assertEquals(1, callbackConnectors.size());
Connector callbackConnector = (Connector) callbackConnectors.iterator().next();
@@ -275,11 +285,11 @@
if (isBisocket(getTransport()))
{
callbackTest = true;
- setupServer(true, false, "1000", 5000);
+ setupServer(true, false, "1000", 5000, 1);
}
else
{
- setupServer(false, true, "1000", 5000);
+ setupServer(false, true, "1000", 5000, -1);
}
// Create client.
@@ -307,19 +317,31 @@
metadata.put(Bisocket.IS_CALLBACK_SERVER, "true");
}
TestCallbackHandler callbackHandler = new TestCallbackHandler();
- client.addListener(callbackHandler, null, null, true);
+ client.addListener(callbackHandler, metadata, null, true);
+ log.info("added listener");
// Test server invoker state.
- Thread.sleep(4000);
+ Thread.sleep(20000);
+ log.info("waking up");
Throwable t = invocationHandler.t;
assertTrue(t instanceof HandleCallbackException);
- assertTrue(t.getCause() instanceof InvocationFailureException);
- InvocationFailureException e = (InvocationFailureException) t.getCause();
- assertNotNull(e.getMessage());
- assertTrue(e.getMessage().startsWith("Unable to perform invocation"));
- assertTrue(e.getCause() instanceof IOException);
- IOException ioe = (IOException) e.getCause();
- assertEquals("closed", ioe.getMessage());
+ log.info("t.getCause:", t.getCause());
+ if (t.getCause() instanceof InvocationFailureException)
+ {
+ InvocationFailureException e = (InvocationFailureException) t.getCause();
+ assertNotNull(e.getMessage());
+ assertTrue(e.getMessage().startsWith("Unable to perform invocation"));
+ assertTrue(e.getCause() instanceof IOException);
+ IOException ioe = (IOException) e.getCause();
+ assertEquals("closed", ioe.getMessage());
+ }
+ else
+ {
+ assertTrue(t.getCause() instanceof CannotConnectException);
+ log.info("t.getCause().getCause(): ", t.getCause().getCause());
+ assertTrue(t.getCause().getCause() instanceof InvocationTargetException);
+ assertTrue(t.getCause().getCause().getCause() instanceof SSLProtocolException);
+ }
log.info("got expected Exception");
client.disconnect();
@@ -335,12 +357,32 @@
return transport.indexOf("bisocket") >= 0;
}
+ protected String getServerSocketFactoryClassName()
+ {
+ return TestServerSocketFactory.class.getName();
+ }
+
+ protected Constructor getServerSocketFactoryConstructor() throws NoSuchMethodException
+ {
+ return TestServerSocketFactory.class.getConstructor(new Class[]{int.class, int.class});
+ }
+
+ protected String getSocketFactoryClassName()
+ {
+ return TestSocketFactory.class.getName();
+ }
+
+ protected Constructor getSocketFactoryConstructor() throws NoSuchMethodException
+ {
+ return TestSocketFactory.class.getConstructor(new Class[]{int.class, int.class});
+ }
+
protected void addExtraClientConfig(Map config) {}
protected void addExtraServerConfig(Map config) {}
protected void setupServer(boolean setWriteTimeout, boolean setCallbackWriteTimeout,
- String writeTimeout, int blockingTime) throws Exception
+ String writeTimeout, int blockingTime, int initialWrites) throws Exception
{
host = InetAddress.getLocalHost().getHostAddress();
port = PortUtil.findFreePort(host);
@@ -356,18 +398,21 @@
config.put(InvokerLocator.FORCE_REMOTE, "true");
if (isBisocket(getTransport()))
{
- config.put(Bisocket.SECONDARY_BIND_PORT, SECONDARY_SERVER_SOCKET_PORT_STRING);
+ secondaryServerSocketPort = PortUtil.findFreePort(host);
+ config.put(Bisocket.SECONDARY_BIND_PORT, Integer.toString(secondaryServerSocketPort));
config.put(Bisocket.PING_FREQUENCY, "11111111");
}
if (setWriteTimeout)
{
config.put(SocketWrapper.WRITE_TIMEOUT, writeTimeout);
- config.put(Remoting.CUSTOM_SERVER_SOCKET_FACTORY, new TestServerSocketFactory(blockingTime));
+ ServerSocketFactory ssf = (ServerSocketFactory) getServerSocketFactoryConstructor().newInstance(new Object[]{new Integer(blockingTime), new Integer(initialWrites)});
+ config.put(Remoting.CUSTOM_SERVER_SOCKET_FACTORY, ssf);
}
if (setCallbackWriteTimeout)
{
config.put(SocketWrapper.WRITE_TIMEOUT, writeTimeout);
- config.put(Remoting.CUSTOM_SOCKET_FACTORY, new TestSocketFactory(blockingTime));
+ SocketFactory sf = (SocketFactory) getSocketFactoryConstructor().newInstance(new Object[]{new Integer(blockingTime), new Integer(initialWrites)});
+ config.put(Remoting.CUSTOM_SOCKET_FACTORY, sf);
}
if (callbackTest)
{
@@ -392,17 +437,25 @@
static class TestInvocationHandler implements ServerInvocationHandler
{
Throwable t;
-
- public void addListener(InvokerCallbackHandler callbackHandler)
+
+ public void addListener(final InvokerCallbackHandler callbackHandler)
{
- try
+ new Thread()
{
- callbackHandler.handleCallback(new Callback("callback"));
- }
- catch (Throwable t)
- {
- this.t = t;
- }
+ public void run()
+ {
+ try
+ {
+ log.info("sending callback");
+ callbackHandler.handleCallback(new Callback("callback"));
+ }
+ catch (Throwable t)
+ {
+ log.info("throwable: ", t);
+ TestInvocationHandler.this.t = t;
+ }
+ }
+ }.start();
}
public Object invoke(final InvocationRequest invocation) throws Throwable
{
@@ -426,13 +479,17 @@
static public class TestServerSocketFactory extends ServerSocketFactory
{
int timeout;
+ int initialWrites;
+
public TestServerSocketFactory()
{
this.timeout = 5000;
+ this.initialWrites = -1;
}
- public TestServerSocketFactory(int timeout)
+ public TestServerSocketFactory(int timeout, int initialWrites)
{
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
public ServerSocket createServerSocket() throws IOException
{
@@ -443,7 +500,7 @@
}
else
{
- ss = new TestServerSocket(timeout);
+ ss = new TestServerSocket(timeout, initialWrites);
}
log.info("returning: " + ss);
return ss;
@@ -451,13 +508,13 @@
public ServerSocket createServerSocket(int port) throws IOException
{
ServerSocket ss = null;
- if (callbackTest && port != SECONDARY_SERVER_SOCKET_PORT)
+ if (callbackTest && port != secondaryServerSocketPort)
{
ss = ServerSocketFactory.getDefault().createServerSocket(port);
}
else
{
- ss = new TestServerSocket(port, timeout);
+ ss = new TestServerSocket(port, timeout, initialWrites);
}
log.info("returning: " + ss);
return ss;
@@ -466,13 +523,13 @@
public ServerSocket createServerSocket(int port, int backlog) throws IOException
{
ServerSocket ss = null;
- if (callbackTest && port != SECONDARY_SERVER_SOCKET_PORT)
+ if (callbackTest && port != secondaryServerSocketPort)
{
ss = ServerSocketFactory.getDefault().createServerSocket(port, backlog);
}
else
{
- ss = new TestServerSocket(port, backlog, timeout);
+ ss = new TestServerSocket(port, backlog, timeout, initialWrites);
}
log.info("returning: " + ss);
return ss;
@@ -481,13 +538,13 @@
public ServerSocket createServerSocket(int port, int backlog, InetAddress ifAddress) throws IOException
{
ServerSocket ss = null;
- if (callbackTest && port != SECONDARY_SERVER_SOCKET_PORT)
+ if (callbackTest && port != secondaryServerSocketPort)
{
ss = ServerSocketFactory.getDefault().createServerSocket(port, backlog, ifAddress);
}
else
{
- ss = new TestServerSocket(port, backlog, ifAddress, timeout);
+ ss = new TestServerSocket(port, backlog, ifAddress, timeout, initialWrites);
}
log.info("returning: " + ss);
return ss;
@@ -498,30 +555,35 @@
static class TestServerSocket extends ServerSocket
{
int timeout;
+ int initialWrites;
- public TestServerSocket(int timeout) throws IOException
+ public TestServerSocket(int timeout, int initialWrites) throws IOException
{
super();
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
- public TestServerSocket(int port, int timeout) throws IOException
+ public TestServerSocket(int port, int timeout, int initialWrites) throws IOException
{
super(port);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
- public TestServerSocket(int port, int backlog, int timeout) throws IOException
+ public TestServerSocket(int port, int backlog, int timeout, int initialWrites) throws IOException
{
super(port, backlog);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
- public TestServerSocket(int port, int backlog, InetAddress bindAddr, int timeout) throws IOException
+ public TestServerSocket(int port, int backlog, InetAddress bindAddr, int timeout, int initialWrites) throws IOException
{
super(port, backlog, bindAddr);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
public Socket accept() throws IOException
{
- Socket s = new TestSocket(timeout);
+ Socket s = new TestSocket(timeout, initialWrites);
implAccept(s);
return s;
}
@@ -535,72 +597,84 @@
public static class TestSocketFactory extends SocketFactory
{
int timeout;
+ int initialWrites = -1;
public TestSocketFactory()
{
timeout = 5000;
}
- public TestSocketFactory(int timeout)
+ public TestSocketFactory(int timeout, int initialWrites)
{
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
public Socket createSocket()
{
- return new TestSocket(timeout);
+ return new TestSocket(timeout, initialWrites);
}
public Socket createSocket(String arg0, int arg1) throws IOException, UnknownHostException
{
- return new TestSocket(arg0, arg1, timeout);
+ return new TestSocket(arg0, arg1, timeout, initialWrites);
}
public Socket createSocket(InetAddress arg0, int arg1) throws IOException
{
- return new TestSocket(arg0, arg1, timeout);
+ return new TestSocket(arg0, arg1, timeout, initialWrites);
}
public Socket createSocket(String arg0, int arg1, InetAddress arg2, int arg3) throws IOException, UnknownHostException
{
- return new TestSocket(arg0, arg1, arg2, arg3, timeout);
+ return new TestSocket(arg0, arg1, arg2, arg3, timeout, initialWrites);
}
public Socket createSocket(InetAddress arg0, int arg1, InetAddress arg2, int arg3) throws IOException
{
- return new TestSocket(arg0, arg1, arg2, arg3, timeout);
+ return new TestSocket(arg0, arg1, arg2, arg3, timeout, initialWrites);
}
}
static class TestSocket extends Socket
{
int timeout;
+ int initialWrites;
- public TestSocket(int timeout)
+ public TestSocket(int timeout, int initialWrites)
{
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
- public TestSocket(String host, int port, int timeout) throws UnknownHostException, IOException
+ public TestSocket(String host, int port, int timeout, int initialWrites) throws UnknownHostException, IOException
{
super(host, port);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
- public TestSocket(InetAddress address, int port, int timeout) throws IOException
+ public TestSocket(InetAddress address, int port, int timeout, int initialWrites) throws IOException
{
super(address, port);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
- public TestSocket(String host, int port, InetAddress localAddr, int localPort, int timeout) throws IOException
+ public TestSocket(String host, int port, InetAddress localAddr, int localPort, int timeout, int initialWrites) throws IOException
{
super(host, port, localAddr, localPort);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
- public TestSocket(InetAddress address, int port, InetAddress localAddr, int localPort, int timeout) throws IOException
+ public TestSocket(InetAddress address, int port, InetAddress localAddr, int localPort, int timeout, int initialWrites) throws IOException
{
super(address, port, localAddr, localPort);
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
public OutputStream getOutputStream() throws IOException
{
- return new TestOutputStream(super.getOutputStream(), timeout);
+ return new TestOutputStream(super.getOutputStream(), timeout, initialWrites);
}
+ public String toString()
+ {
+ return "TestSocket[" + getLocalPort() + "->" + getPort() + "]";
+ }
}
static class TestOutputStream extends OutputStream
@@ -608,11 +682,15 @@
OutputStream os;
int timeout;
boolean closed;
+ int initialWrites;
+ boolean doWait = true;
+ public static int counter;
- public TestOutputStream(OutputStream os, int timeout)
+ public TestOutputStream(OutputStream os, int timeout, int initialWrites)
{
this.os = os;
this.timeout = timeout;
+ this.initialWrites = initialWrites;
}
public void close()throws IOException
{
@@ -627,6 +705,18 @@
log.info("TestOutputStream closed, cannot write");
throw new IOException("closed");
}
+ if (doWait && ++counter > initialWrites)
+ {
+ try
+ {
+ log.info("TestOutputStream.write() sleeping: " + timeout);
+ Thread.sleep(timeout);
+ }
+ catch (InterruptedException e)
+ {
+ e.printStackTrace();
+ }
+ }
os.write(b);
}
public void write(byte b[], int off, int len) throws IOException
@@ -636,17 +726,23 @@
log.info("TestOutputStream closed, cannot write");
throw new IOException("closed");
}
- try
+ log.info("TestOutputStream: counter = " + counter + ", initialWrites = " + initialWrites);
+ if (++counter > initialWrites)
{
- log.info("TestOutputStream.write() sleeping: " + timeout);
- Thread.sleep(timeout);
+ try
+ {
+ log.info("TestOutputStream.write() sleeping: " + timeout);
+ Thread.sleep(timeout);
+ }
+ catch (InterruptedException e)
+ {
+ e.printStackTrace();
+ }
}
- catch (InterruptedException e)
- {
- e.printStackTrace();
- }
log.info("TestOutputStream writing");
+ doWait = false;
os.write(b, off, len);
+ doWait = true;
}
}
}
\ No newline at end of file
[View Less]
15 years, 8 months
- 1
- 0
JBoss Remoting SVN: r5318 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/ssl/timeout.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-07-30 22:14:01 -0400 (Thu, 30 Jul 2009)
New Revision: 5318
Added:
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/ssl/timeout/SSLSocketWriteTimeoutTestCase.java
Removed:
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/ssl/timeout/SSLSocketWriteTimeoutTest.java
Log:
JBREM-1120: Renamed SSLSocketWriteTimeoutTest to SSLSocketWriteTimeoutTestCase.
Deleted: remoting2/branches/2.x/src/tests/org/jboss/…
[View More]test/remoting/transport/socket/ssl/timeout/SSLSocketWriteTimeoutTest.java
===================================================================
--- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/ssl/timeout/SSLSocketWriteTimeoutTest.java 2009-07-31 02:13:03 UTC (rev 5317)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/ssl/timeout/SSLSocketWriteTimeoutTest.java 2009-07-31 02:14:01 UTC (rev 5318)
@@ -1,41 +0,0 @@
-/*
-* 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.test.remoting.transport.socket.ssl.timeout;
-
-import org.jboss.test.remoting.transport.socket.timeout.SSLWriteTimeoutTestParent;
-
-/**
- * Unit tests for JBREM-1120.
- *
- * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
- * @version $Rev$
- * <p>
- * Copyright Apr 22, 2009
- * </p>
- */
-public class SSLSocketWriteTimeoutTest extends SSLWriteTimeoutTestParent
-{
- protected String getTransport()
- {
- return "sslsocket";
- }
-}
Copied: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/ssl/timeout/SSLSocketWriteTimeoutTestCase.java (from rev 5274, remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/ssl/timeout/SSLSocketWriteTimeoutTest.java)
===================================================================
--- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/ssl/timeout/SSLSocketWriteTimeoutTestCase.java (rev 0)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/ssl/timeout/SSLSocketWriteTimeoutTestCase.java 2009-07-31 02:14:01 UTC (rev 5318)
@@ -0,0 +1,41 @@
+/*
+* 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.test.remoting.transport.socket.ssl.timeout;
+
+import org.jboss.test.remoting.transport.socket.timeout.SSLWriteTimeoutTestParent;
+
+/**
+ * Unit tests for JBREM-1120.
+ *
+ * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
+ * @version $Rev$
+ * <p>
+ * Copyright Apr 22, 2009
+ * </p>
+ */
+public class SSLSocketWriteTimeoutTestCase extends SSLWriteTimeoutTestParent
+{
+ protected String getTransport()
+ {
+ return "sslsocket";
+ }
+}
[View Less]
15 years, 8 months
- 1
- 0
JBoss Remoting SVN: r5317 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/ssl/timeout.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-07-30 22:13:03 -0400 (Thu, 30 Jul 2009)
New Revision: 5317
Added:
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/ssl/timeout/SSLBisocketWriteTimeoutTestCase.java
Log:
JBREM-1120: New unit tests for sslbisocket.
Added: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/ssl/timeout/SSLBisocketWriteTimeoutTestCase.java
===================================================================
--- remoting2/…
[View More]branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/ssl/timeout/SSLBisocketWriteTimeoutTestCase.java (rev 0)
+++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/bisocket/ssl/timeout/SSLBisocketWriteTimeoutTestCase.java 2009-07-31 02:13:03 UTC (rev 5317)
@@ -0,0 +1,41 @@
+/*
+* 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.test.remoting.transport.bisocket.ssl.timeout;
+
+import org.jboss.test.remoting.transport.socket.timeout.SSLWriteTimeoutTestParent;
+
+/**
+ * Unit tests for JBREM-1120.
+ *
+ * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
+ * @version $Rev$
+ * <p>
+ * Copyright Apr 22, 2009
+ * </p>
+ */
+public class SSLBisocketWriteTimeoutTestCase extends SSLWriteTimeoutTestParent
+{
+ protected String getTransport()
+ {
+ return "sslbisocket";
+ }
+}
[View Less]
15 years, 8 months
- 1
- 0
JBoss Remoting SVN: r5316 - remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-07-30 22:10:05 -0400 (Thu, 30 Jul 2009)
New Revision: 5316
Modified:
remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/TimedOutputStream.java
Log:
JBREM-1120: Elaborated logging.
Modified: remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/TimedOutputStream.java
===================================================================
--- remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/…
[View More]TimedOutputStream.java 2009-07-28 20:50:59 UTC (rev 5315)
+++ remoting2/branches/2.x/src/main/org/jboss/remoting/transport/socket/TimedOutputStream.java 2009-07-31 02:10:05 UTC (rev 5316)
@@ -73,14 +73,14 @@
{
timerTask = new OutputTimerTask(this);
timer.schedule(timerTask, outputTimeout);
- if (log.isTraceEnabled()) log.trace("scheduled OutputTimerTask: " + 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("scheduled OutputTimerTask: " + outputTimeout);
+ if (log.isTraceEnabled()) log.trace(this + " scheduled " + timerTask + ": " + outputTimeout);
}
}
}
[View Less]
15 years, 8 months
- 1
- 0
JBoss Remoting SVN: r5315 - remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-07-28 16:50:59 -0400 (Tue, 28 Jul 2009)
New Revision: 5315
Added:
remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnClientTestCase.java
remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnServerTestCase.java
remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnServerWithXMLTestCase.java
Log:
JBREM-1139: new unit tests.
Added: remoting2/branches/2.2/src/tests/org/jboss/…
[View More]test/remoting/util/PortUtilRangeOnClientTestCase.java
===================================================================
--- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnClientTestCase.java (rev 0)
+++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnClientTestCase.java 2009-07-28 20:50:59 UTC (rev 5315)
@@ -0,0 +1,148 @@
+/*
+* 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.test.remoting.util;
+
+
+import java.net.InetAddress;
+import java.util.HashMap;
+import java.util.Map;
+
+import junit.framework.TestCase;
+
+import org.apache.log4j.Logger;
+import org.jboss.remoting.Client;
+import org.jboss.remoting.InvokerLocator;
+import org.jboss.remoting.transport.PortUtil;
+
+/**
+ * Unit test for JBREM-1139.
+ *
+ * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
+ * @version $Revision: 2320 $
+ * <p>
+ * Copyright July 13, 2009.
+ * </p>
+ */
+public class PortUtilRangeOnClientTestCase extends TestCase
+{
+ private static Logger log = Logger.getLogger(PortUtilRangeOnClientTestCase.class);
+
+
+ public void testUpdateRangeOnClient() throws Exception
+ {
+ log.info("entering " + getName());
+
+ // Test initial values.
+ assertEquals(1024, PortUtil.getMinPort());
+ assertEquals(65535, PortUtil.getMaxPort());
+
+ // Set new values using configuration map.
+ Map clientConfig = new HashMap();
+ clientConfig.put(PortUtil.MIN_PORT, "2000");
+ clientConfig.put(PortUtil.MAX_PORT, "60000");
+ String host = InetAddress.getLocalHost().getHostAddress();
+ InvokerLocator locator = new InvokerLocator("socket://" + host);
+ Client client = new Client(locator, clientConfig);
+ assertEquals(2000, PortUtil.getMinPort());
+ assertEquals(60000, PortUtil.getMaxPort());
+
+ // Set more restrictive values using configuration map.
+ clientConfig.put(PortUtil.MIN_PORT, "3000");
+ clientConfig.put(PortUtil.MAX_PORT, "50000");
+ client = new Client(locator, clientConfig);
+ assertEquals(3000, PortUtil.getMinPort());
+ assertEquals(50000, PortUtil.getMaxPort());
+
+ // Set more restrictive values with InvokerLocator overriding configuration map.
+ clientConfig.put(PortUtil.MIN_PORT, "3500");
+ clientConfig.put(PortUtil.MAX_PORT, "45000");
+ locator = new InvokerLocator("socket://" + host + "/?" + PortUtil.MIN_PORT + "=4000&" + PortUtil.MAX_PORT + "=40000");
+ client = new Client(locator, clientConfig);
+ assertEquals(4000, PortUtil.getMinPort());
+ assertEquals(40000, PortUtil.getMaxPort());
+
+ // Try to set less restrictive values - should have no effect.
+ clientConfig.put(PortUtil.MIN_PORT, "2000");
+ clientConfig.put(PortUtil.MAX_PORT, "60000");
+ locator = new InvokerLocator("socket://" + host);
+ client = new Client(locator, clientConfig);
+ assertEquals(4000, PortUtil.getMinPort());
+ assertEquals(40000, PortUtil.getMaxPort());
+
+ // Try to set invalid minPort - should have no effect.
+ clientConfig.put(PortUtil.MIN_PORT, "60000");
+ clientConfig.remove(PortUtil.MAX_PORT);
+ try
+ {
+ log.info("=====================================");
+ log.info("EXPECT ILLEGAL_STATE_EXCEPTION");
+ client = new Client(locator, clientConfig);
+ }
+ catch (Exception e)
+ {
+ log.info(e.getMessage());
+ if (e instanceof IllegalStateException
+ && e.getMessage() != null
+ && e.getMessage().startsWith("trying to set minPort"))
+ {
+ log.info("GOT EXPECTED ILLEGAL_STATE_EXCEPTION");
+ log.info("=====================================");
+ }
+ else
+ {
+ fail("expected IllegalStateException");
+ }
+ }
+ assertEquals(4000, PortUtil.getMinPort());
+ assertEquals(40000, PortUtil.getMaxPort());
+
+ // Try to set invalid maxPort - should have no effect.
+ clientConfig.remove(PortUtil.MIN_PORT);
+ clientConfig.put(PortUtil.MAX_PORT, "2000");
+ try
+ {
+ log.info("=====================================");
+ log.info("EXPECT ILLEGAL_STATE_EXCEPTION");
+ client = new Client(locator, clientConfig);
+ }
+ catch (Exception e)
+ {
+ log.info(e.getMessage());
+ if (e instanceof IllegalStateException
+ && e.getMessage() != null
+ && e.getMessage().startsWith("trying to set maxPort"))
+ {
+ log.info("GOT EXPECTED ILLEGAL_STATE_EXCEPTION");
+ log.info("=====================================");
+ }
+ else
+ {
+ fail("expected IllegalStateException");
+ }
+ }
+ assertEquals(4000, PortUtil.getMinPort());
+ assertEquals(40000, PortUtil.getMaxPort());
+
+ log.info(getName()+ " PASSES");
+ }
+
+}
\ No newline at end of file
Added: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnServerTestCase.java
===================================================================
--- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnServerTestCase.java (rev 0)
+++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnServerTestCase.java 2009-07-28 20:50:59 UTC (rev 5315)
@@ -0,0 +1,166 @@
+/*
+* 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.test.remoting.util;
+
+
+import java.net.InetAddress;
+import java.util.HashMap;
+import java.util.Map;
+
+import junit.framework.TestCase;
+
+import org.apache.log4j.Logger;
+import org.jboss.remoting.InvokerLocator;
+import org.jboss.remoting.transport.Connector;
+import org.jboss.remoting.transport.PortUtil;
+
+/**
+ * Unit test for JBREM-1139.
+ *
+ * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
+ * @version $Revision: 2320 $
+ * <p>
+ * Copyright July 13, 2009.
+ * </p>
+ */
+public class PortUtilRangeOnServerTestCase extends TestCase
+{
+ private static Logger log = Logger.getLogger(PortUtilRangeOnServerTestCase.class);
+
+
+
+ public void testUpdateRangeOnServer() throws Exception
+ {
+ log.info("entering " + getName());
+
+ // Test initial values.
+ assertEquals(1024, PortUtil.getMinPort());
+ assertEquals(65535, PortUtil.getMaxPort());
+
+ // Set new values using configuration mapr.
+ Map serverConfig = new HashMap();
+ serverConfig.put(PortUtil.MIN_PORT, "2000");
+ serverConfig.put(PortUtil.MAX_PORT, "60000");
+ String host = InetAddress.getLocalHost().getHostAddress();
+ InvokerLocator locator = new InvokerLocator("socket://" + host);
+ Connector connector = new Connector(locator, serverConfig);
+ connector.start();
+ log.info("InvokerLocator: " + connector.getInvokerLocator());
+ assertEquals(2000, PortUtil.getMinPort());
+ assertEquals(60000, PortUtil.getMaxPort());
+ connector.stop();
+
+ // Set more restrictive values using configuration map.
+ serverConfig.put(PortUtil.MIN_PORT, "3000");
+ serverConfig.put(PortUtil.MAX_PORT, "50000");
+ connector = new Connector(locator, serverConfig);
+ connector.start();
+ log.info("InvokerLocator: " + connector.getInvokerLocator());
+ assertEquals(3000, PortUtil.getMinPort());
+ assertEquals(50000, PortUtil.getMaxPort());
+ connector.stop();
+
+ // Set more restrictive values with InvokerLocator overriding configuration map.
+ serverConfig.put(PortUtil.MIN_PORT, "3500");
+ serverConfig.put(PortUtil.MAX_PORT, "45000");
+ locator = new InvokerLocator("socket://" + host + "/?" + PortUtil.MIN_PORT + "=4000&" + PortUtil.MAX_PORT + "=40000");
+ connector = new Connector(locator, serverConfig);
+ connector.start();
+ log.info("InvokerLocator: " + connector.getInvokerLocator());
+ assertEquals(4000, PortUtil.getMinPort());
+ assertEquals(40000, PortUtil.getMaxPort());
+ connector.stop();
+
+ // Try to set less restrictive values - should have no effect.
+ serverConfig.put(PortUtil.MIN_PORT, "2000");
+ serverConfig.put(PortUtil.MAX_PORT, "60000");
+ locator = new InvokerLocator("socket://" + host);
+ connector = new Connector(locator, serverConfig);
+ connector.start();
+ log.info("InvokerLocator: " + connector.getInvokerLocator());
+ assertEquals(4000, PortUtil.getMinPort());
+ assertEquals(40000, PortUtil.getMaxPort());
+ connector.stop();
+
+ // Try to set invalid minPort - should have no effect.
+ serverConfig.put(PortUtil.MIN_PORT, "60000");
+ serverConfig.remove(PortUtil.MAX_PORT);
+ connector = new Connector(locator, serverConfig);
+ try
+ {
+ log.info("=====================================");
+ log.info("EXPECT ILLEGAL_STATE_EXCEPTION");
+ connector.start();
+ }
+ catch (Exception e)
+ {
+ log.info(e.getCause());
+ if (e.getCause() instanceof IllegalStateException
+ && e.getCause().getMessage() != null
+ && e.getCause().getMessage().startsWith("trying to set minPort"))
+ {
+ log.info("GOT EXPECTED ILLEGAL_STATE_EXCEPTION");
+ log.info("=====================================");
+ }
+ else
+ {
+ fail("expected IllegalStateException");
+ }
+ }
+ log.info("InvokerLocator: " + connector.getInvokerLocator());
+ assertEquals(4000, PortUtil.getMinPort());
+ assertEquals(40000, PortUtil.getMaxPort());
+ connector.stop();
+
+ // Try to set invalid maxPort - should have no effect.
+ serverConfig.remove(PortUtil.MIN_PORT);
+ serverConfig.put(PortUtil.MAX_PORT, "2000");
+ connector = new Connector(locator, serverConfig);
+ try
+ {
+ log.info("=====================================");
+ log.info("EXPECT ILLEGAL_STATE_EXCEPTION");
+ connector.start();
+ }
+ catch (Exception e)
+ {
+ log.info(e.getCause());
+ if (e.getCause() instanceof IllegalStateException
+ && e.getCause().getMessage() != null
+ && e.getCause().getMessage().startsWith("trying to set maxPort"))
+ {
+ log.info("GOT EXPECTED ILLEGAL_STATE_EXCEPTION");
+ log.info("=====================================");
+ }
+ else
+ {
+ fail("expected IllegalStateException");
+ }
+ }
+ log.info("InvokerLocator: " + connector.getInvokerLocator());
+ assertEquals(4000, PortUtil.getMinPort());
+ assertEquals(40000, PortUtil.getMaxPort());
+ connector.stop();
+
+ log.info(getName()+ " PASSES");
+ }
+}
\ No newline at end of file
Added: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnServerWithXMLTestCase.java
===================================================================
--- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnServerWithXMLTestCase.java (rev 0)
+++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/util/PortUtilRangeOnServerWithXMLTestCase.java 2009-07-28 20:50:59 UTC (rev 5315)
@@ -0,0 +1,192 @@
+/*
+* 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.test.remoting.util;
+
+
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.net.InetAddress;
+
+import javax.management.MBeanServer;
+import javax.xml.parsers.DocumentBuilderFactory;
+import javax.xml.parsers.ParserConfigurationException;
+
+import junit.framework.TestCase;
+
+import org.apache.log4j.Logger;
+import org.jboss.remoting.InvocationRequest;
+import org.jboss.remoting.ServerInvocationHandler;
+import org.jboss.remoting.ServerInvoker;
+import org.jboss.remoting.callback.InvokerCallbackHandler;
+import org.jboss.remoting.transport.Connector;
+import org.jboss.remoting.transport.PortUtil;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.xml.sax.SAXException;
+
+/**
+ * Unit test for JBREM-1139.
+ *
+ * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
+ * @version $Revision: 2320 $
+ * <p>
+ * Copyright July 13, 2009.
+ * </p>
+ */
+public class PortUtilRangeOnServerWithXMLTestCase extends TestCase
+{
+ private static Logger log = Logger.getLogger(PortUtilRangeOnServerWithXMLTestCase.class);
+
+
+
+ public void testUpdateRangeOnServer() throws Exception
+ {
+ log.info("entering " + getName());
+
+ // Test initial values.
+ assertEquals(1024, PortUtil.getMinPort());
+ assertEquals(65535, PortUtil.getMaxPort());
+
+ // Set new values.
+ Connector connector = new Connector();
+ connector.setConfiguration(getXML(2000, 60000));
+ connector.start();
+ assertEquals(2000, PortUtil.getMinPort());
+ assertEquals(60000, PortUtil.getMaxPort());
+ connector.stop();
+
+ // Set more restrictive values.
+ connector = new Connector();
+ connector.setConfiguration(getXML(3000, 50000));
+ connector.start();
+ assertEquals(3000, PortUtil.getMinPort());
+ assertEquals(50000, PortUtil.getMaxPort());
+ connector.stop();
+
+ // Try to set less restrictive values - should have no effect.
+ connector = new Connector();
+ connector.setConfiguration(getXML(2000, 60000));
+ connector.start();
+ assertEquals(3000, PortUtil.getMinPort());
+ assertEquals(50000, PortUtil.getMaxPort());
+ connector.stop();
+
+ // Try to set invalid minPort - should have no effect.
+ connector = new Connector();
+ connector.setConfiguration(getXML(60000, -1));
+ try
+ {
+ log.info("=====================================");
+ log.info("EXPECT ILLEGAL_STATE_EXCEPTION");
+ connector.start();
+ }
+ catch (Exception e)
+ {
+ log.info(e.getMessage());
+ if (e instanceof IllegalStateException
+ && e.getMessage() != null
+ && e.getMessage().startsWith("Error configuring invoker for connector."))
+ {
+ log.info("GOT EXPECTED ILLEGAL_STATE_EXCEPTION");
+ log.info("=====================================");
+ }
+ else
+ {
+ fail("expected IllegalStateException");
+ }
+ }
+ assertEquals(3000, PortUtil.getMinPort());
+ assertEquals(50000, PortUtil.getMaxPort());
+ connector.stop();
+
+ // Try to set invalid maxPort - should have no effect.
+ connector = new Connector();
+ connector.setConfiguration(getXML(-1, 2000));
+ try
+ {
+ log.info("=====================================");
+ log.info("EXPECT ILLEGAL_STATE_EXCEPTION");
+ connector.start();
+ }
+ catch (Exception e)
+ {
+ log.info(e.getMessage());
+ if (e instanceof IllegalStateException
+ && e.getMessage() != null
+ && e.getMessage().startsWith("Error configuring invoker for connector."))
+ {
+ log.info("GOT EXPECTED ILLEGAL_STATE_EXCEPTION");
+ log.info("=====================================");
+ }
+ else
+ {
+ fail("expected IllegalStateException");
+ }
+ }
+ assertEquals(3000, PortUtil.getMinPort());
+ assertEquals(50000, PortUtil.getMaxPort());
+ connector.stop();
+
+ log.info(getName()+ " PASSES");
+ }
+
+
+ Element getXML(int minPort, int maxPort) throws SAXException, IOException, ParserConfigurationException
+ {
+ String host = InetAddress.getLocalHost().getHostAddress();
+ StringBuffer buf = new StringBuffer();
+ buf.append("<?xml version=\"1.0\"?>\n");
+ buf.append("<config>\n");
+ buf.append(" <invoker transport=\"socket\">\n");
+ buf.append(" <attribute name=\"serverBindAddress\">" + host + "</attribute>\n");
+ if (minPort > -1)
+ {
+ buf.append(" <attribute name=\"" + PortUtil.MIN_PORT + "\">" + minPort + "</attribute>\n");
+ }
+ if (maxPort > -1)
+ {
+ buf.append(" <attribute name=\"" + PortUtil.MAX_PORT + "\">" + maxPort + "</attribute>\n");
+ }
+ buf.append(" </invoker>\n");
+ buf.append(" <handlers>\n");
+ buf.append(" <handler subsystem=\"test\">" + TestInvocationHandler.class.getName() + "</handler>\n");
+ buf.append(" </handlers>\n");
+ buf.append("</config>\n");
+ log.info("\n\n" + buf.toString());
+ ByteArrayInputStream bais = new ByteArrayInputStream(buf.toString().getBytes());
+ Document xml = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(bais);
+ return xml.getDocumentElement();
+ }
+
+
+ public static class TestInvocationHandler implements ServerInvocationHandler
+ {
+ public void addListener(InvokerCallbackHandler callbackHandler) {}
+ public Object invoke(final InvocationRequest invocation) throws Throwable
+ {
+ return invocation.getParameter();
+ }
+ public void removeListener(InvokerCallbackHandler callbackHandler) {}
+ public void setMBeanServer(MBeanServer server) {}
+ public void setInvoker(ServerInvoker invoker) {}
+ }
+}
\ No newline at end of file
[View Less]
15 years, 8 months
- 1
- 0
JBoss Remoting SVN: r5314 - remoting2/branches/2.2/src/tests/org/jboss/test/remoting/invoker.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-07-28 16:48:58 -0400 (Tue, 28 Jul 2009)
New Revision: 5314
Added:
remoting2/branches/2.2/src/tests/org/jboss/test/remoting/invoker/ClientInvokerDelayedDestructionTestCase.java
Log:
JBREM-1143: new unit test.
Added: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/invoker/ClientInvokerDelayedDestructionTestCase.java
===================================================================
--- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/…
[View More]invoker/ClientInvokerDelayedDestructionTestCase.java (rev 0)
+++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/invoker/ClientInvokerDelayedDestructionTestCase.java 2009-07-28 20:48:58 UTC (rev 5314)
@@ -0,0 +1,364 @@
+/*
+* JBoss, Home of Professional Open Source
+* Copyright 2005, 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.test.remoting.invoker;
+
+import java.lang.reflect.Field;
+import java.net.InetAddress;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Timer;
+
+import javax.management.MBeanServer;
+
+import junit.framework.TestCase;
+
+import org.apache.log4j.ConsoleAppender;
+import org.apache.log4j.Level;
+import org.apache.log4j.Logger;
+import org.apache.log4j.PatternLayout;
+import org.jboss.remoting.Client;
+import org.jboss.remoting.InvocationRequest;
+import org.jboss.remoting.InvokerLocator;
+import org.jboss.remoting.InvokerRegistry;
+import org.jboss.remoting.ServerInvocationHandler;
+import org.jboss.remoting.ServerInvoker;
+import org.jboss.remoting.callback.Callback;
+import org.jboss.remoting.callback.HandleCallbackException;
+import org.jboss.remoting.callback.InvokerCallbackHandler;
+import org.jboss.remoting.transport.ClientInvoker;
+import org.jboss.remoting.transport.Connector;
+import org.jboss.remoting.transport.PortUtil;
+
+
+/**
+ * Unit tests from JBREM-877.
+ *
+ * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
+ * @version $Revision: 1.1 $
+ * <p>
+ * Copyright Feb 22, 2008
+ * </p>
+ */
+public class ClientInvokerDelayedDestructionTestCase extends TestCase
+{
+ private static Logger log = Logger.getLogger(ClientInvokerDelayedDestructionTestCase.class);
+
+ private static boolean firstTime = true;
+
+ protected String host;
+ protected int port;
+ protected String locatorURI;
+ protected InvokerLocator serverLocator;
+ protected Connector connector;
+ protected TestInvocationHandler invocationHandler;
+
+
+ public void setUp() throws Exception
+ {
+ if (firstTime)
+ {
+ firstTime = false;
+ 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);
+ ConsoleAppender consoleAppender = new ConsoleAppender(layout);
+ Logger.getRootLogger().addAppender(consoleAppender);
+ }
+ }
+
+
+ public void tearDown()
+ {
+ }
+
+
+ public void testNoDelayedDestruction() throws Throwable
+ {
+ log.info("entering " + getName());
+
+ // Start server.
+ setupServer();
+
+ // Create client.
+ InvokerLocator clientLocator = new InvokerLocator(locatorURI);
+ HashMap clientConfig = new HashMap();
+ clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+ addExtraClientConfig(clientConfig);
+ Client client = new Client(clientLocator, clientConfig);
+ client.connect();
+ ClientInvoker invoker1 = client.getInvoker();
+
+ // Test connections.
+ assertEquals("abc", client.invoke("abc"));
+ log.info("connection is good for first client");
+ client.disconnect();
+
+ client = new Client(clientLocator, clientConfig);
+ client.connect();
+ ClientInvoker invoker2 = client.getInvoker();
+ assertEquals("abc", client.invoke("abc"));
+ log.info("connection is good for second client");
+ assertNotSame(invoker2, invoker1);
+
+ client.disconnect();
+ shutdownServer();
+ log.info(getName() + " PASSES");
+ }
+
+
+ public void testZeroDelay() throws Throwable
+ {
+ log.info("entering " + getName());
+
+ // Start server.
+ setupServer();
+
+ // Create client.
+ InvokerLocator clientLocator = new InvokerLocator(locatorURI);
+ HashMap clientConfig = new HashMap();
+ clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+ clientConfig.put(Client.INVOKER_DESTRUCTION_DELAY, "0");
+ addExtraClientConfig(clientConfig);
+ Client client = new Client(clientLocator, clientConfig);
+ client.connect();
+ ClientInvoker invoker1 = client.getInvoker();
+
+ // Test connections.
+ assertEquals("abc", client.invoke("abc"));
+ log.info("connection is good for first client");
+ client.disconnect();
+
+ client = new Client(clientLocator, clientConfig);
+ client.connect();
+ ClientInvoker invoker2 = client.getInvoker();
+ assertEquals("abc", client.invoke("abc"));
+ log.info("connection is good for second client");
+ assertNotSame(invoker2, invoker1);
+
+ client.disconnect();
+ shutdownServer();
+ log.info(getName() + " PASSES");
+ }
+
+
+ public void testDelayThenGetNewInvoker() throws Throwable
+ {
+ log.info("entering " + getName());
+
+ // Start server.
+ setupServer();
+
+ // Create client.
+ InvokerLocator clientLocator = new InvokerLocator(locatorURI);
+ HashMap clientConfig = new HashMap();
+ clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+ clientConfig.put(Client.INVOKER_DESTRUCTION_DELAY, "5000");
+ addExtraClientConfig(clientConfig);
+ Client client = new Client(clientLocator, clientConfig);
+ client.connect();
+ ClientInvoker invoker1 = client.getInvoker();
+
+ // Test connections.
+ assertEquals("abc", client.invoke("abc"));
+ log.info("connection is good for first client");
+ client.disconnect();
+
+ Thread.sleep(10000);
+ client = new Client(clientLocator, clientConfig);
+ client.connect();
+ ClientInvoker invoker2 = client.getInvoker();
+ assertEquals("abc", client.invoke("abc"));
+ log.info("connection is good for second client");
+ assertNotSame(invoker2, invoker1);
+
+ client.disconnect();
+ shutdownServer();
+ log.info(getName() + " PASSES");
+ }
+
+
+ public void testDelayThenReuseInvoker() throws Throwable
+ {
+ log.info("entering " + getName());
+
+ // Start server.
+ setupServer();
+
+ // Create client.
+ InvokerLocator clientLocator = new InvokerLocator(locatorURI);
+ HashMap clientConfig = new HashMap();
+ clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+ clientConfig.put(Client.INVOKER_DESTRUCTION_DELAY, "10000");
+ addExtraClientConfig(clientConfig);
+ Client client = new Client(clientLocator, clientConfig);
+ client.connect();
+ ClientInvoker invoker1 = client.getInvoker();
+
+ // Test connections.
+ assertEquals("abc", client.invoke("abc"));
+ log.info("connection is good for first client");
+ client.disconnect();
+
+ Thread.sleep(5000);
+ client = new Client(clientLocator, clientConfig);
+ client.connect();
+ ClientInvoker invoker2 = client.getInvoker();
+ assertEquals("abc", client.invoke("abc"));
+ log.info("connection is good for second client");
+ assertSame(invoker2, invoker1);
+
+ client.disconnect();
+ shutdownServer();
+ log.info(getName() + " PASSES");
+ }
+
+
+ public void testEventualDestruction() throws Throwable
+ {
+ log.info("entering " + getName());
+
+ // Start server.
+ setupServer();
+
+ // Create client.
+ InvokerLocator clientLocator = new InvokerLocator(locatorURI);
+ HashMap clientConfig = new HashMap();
+ clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+ clientConfig.put(Client.INVOKER_DESTRUCTION_DELAY, "5000");
+ addExtraClientConfig(clientConfig);
+
+ for (int i = 0; i < 50; i++)
+ {
+ Client client = new Client(clientLocator, clientConfig);
+ client.connect();
+ assertEquals("abc", client.invoke("abc"));
+ client.disconnect();
+ }
+
+ Thread.sleep(10000);
+ assertEquals(0, InvokerRegistry.getClientInvokers().length);
+
+ shutdownServer();
+ log.info(getName() + " PASSES");
+ }
+
+
+ public void testStaticTimer() throws Throwable
+ {
+ log.info("entering " + getName());
+
+ // Start server.
+ setupServer();
+
+
+ // Get static Timer.
+ Field field = Client.class.getDeclaredField("invokerDestructionTimer");
+ field.setAccessible(true);
+ Timer invokerDestructionTimer = (Timer) field.get(null);
+
+ // Create client.
+ InvokerLocator clientLocator = new InvokerLocator(locatorURI);
+ HashMap clientConfig = new HashMap();
+ clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+ clientConfig.put(Client.INVOKER_DESTRUCTION_DELAY, "5000");
+ addExtraClientConfig(clientConfig);
+ Client[] clients = new Client[50];
+
+ for (int i = 0; i < 50; i++)
+ {
+ clients[i] = new Client(clientLocator, clientConfig);
+ clients[i].connect();
+ assertEquals("abc", clients[i].invoke("abc"));
+ clients[i].disconnect();
+ }
+
+ // Verify all Clients are using the same Timer.
+ for (int i = 0; i < 50; i++)
+ {
+ assertEquals("Should be the same Timer", invokerDestructionTimer, field.get(clients[i]));
+ }
+
+ Thread.sleep(10000);
+ assertEquals(0, InvokerRegistry.getClientInvokers().length);
+
+ shutdownServer();
+ log.info(getName() + " PASSES");
+ }
+
+
+ protected String getTransport()
+ {
+ return "socket";
+ }
+
+
+ protected void addExtraClientConfig(Map config) {}
+ protected void addExtraServerConfig(Map config) {}
+
+
+ protected void setupServer() throws Exception
+ {
+ host = InetAddress.getLocalHost().getHostAddress();
+ port = PortUtil.findFreePort(host);
+ locatorURI = getTransport() + "://" + host + ":" + port;
+ serverLocator = new InvokerLocator(locatorURI);
+ log.info("Starting remoting server with locator uri of: " + locatorURI);
+ HashMap config = new HashMap();
+ config.put(InvokerLocator.FORCE_REMOTE, "true");
+ addExtraServerConfig(config);
+ connector = new Connector(serverLocator, config);
+ connector.create();
+ invocationHandler = new TestInvocationHandler();
+ connector.addInvocationHandler("test", invocationHandler);
+ connector.start();
+ }
+
+
+ protected void shutdownServer() throws Exception
+ {
+ if (connector != null)
+ connector.stop();
+ }
+
+
+ static class TestInvocationHandler implements ServerInvocationHandler
+ {
+ public void addListener(InvokerCallbackHandler callbackHandler) {}
+ public Object invoke(final InvocationRequest invocation) throws Throwable
+ {
+ return invocation.getParameter();
+ }
+ public void removeListener(InvokerCallbackHandler callbackHandler) {}
+ public void setMBeanServer(MBeanServer server) {}
+ public void setInvoker(ServerInvoker invoker) {}
+ }
+
+
+ static class TestCallbackHandler implements InvokerCallbackHandler
+ {
+ public void handleCallback(Callback callback) throws HandleCallbackException
+ {
+ log.info("received callback");
+ }
+ }
+}
\ No newline at end of file
[View Less]
15 years, 8 months
- 1
- 0
JBoss Remoting SVN: r5313 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-07-28 16:39:04 -0400 (Tue, 28 Jul 2009)
New Revision: 5313
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/Connector.java
Log:
JBREM-1139: Adjusts PortUtil range in getInvokerConfig().
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/Connector.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/Connector.java 2009-07-28 …
[View More]20:38:11 UTC (rev 5312)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/Connector.java 2009-07-28 20:39:04 UTC (rev 5313)
@@ -524,6 +524,7 @@
String serverBindPort = (String) invokerConfig.get("serverBindPort");
String path = (String) invokerConfig.get("path");
+ PortUtil.updateRange(invokerConfig);
String host = clientConnectAddress != null ? clientConnectAddress : serverBindAddress != null ? serverBindAddress : InetAddress.getLocalHost().getHostAddress();
int port = clientConnectPort != null ? Integer.parseInt(clientConnectPort) : serverBindPort != null ? Integer.parseInt(serverBindPort) : PortUtil.findFreePort(serverBindAddress != null ? serverBindAddress : InetAddress.getLocalHost().getHostAddress());
[View Less]
15 years, 8 months
- 1
- 0
JBoss Remoting SVN: r5312 - remoting2/branches/2.2/src/main/org/jboss/remoting.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-07-28 16:38:11 -0400 (Tue, 28 Jul 2009)
New Revision: 5312
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java
Log:
JBREM-1139: Adjusts PortUtil range in setup().
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java 2009-07-28 20:36:37 UTC (rev 5311)
+++ …
[View More]remoting2/branches/2.2/src/main/org/jboss/remoting/ServerInvoker.java 2009-07-28 20:38:11 UTC (rev 5312)
@@ -1034,6 +1034,7 @@
protected void setup() throws Exception
{
Map config = getConfiguration();
+ PortUtil.updateRange(config);
String maxNumOfThreads = (String)config.get(MAX_NUM_ONEWAY_THREADS_KEY);
if(maxNumOfThreads != null && maxNumOfThreads.length() > 0)
[View Less]
15 years, 8 months
- 1
- 0
JBoss Remoting SVN: r5311 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-07-28 16:36:37 -0400 (Tue, 28 Jul 2009)
New Revision: 5311
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/transport/PortUtil.java
Log:
JBREM-1139: Supports configuration of range from which ports may be chosen.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/PortUtil.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/PortUtil.…
[View More]java 2009-07-28 20:35:27 UTC (rev 5310)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/PortUtil.java 2009-07-28 20:36:37 UTC (rev 5311)
@@ -25,7 +25,7 @@
import java.net.ServerSocket;
import java.net.InetAddress;
import java.io.IOException;
-import java.security.SecureRandom;
+import java.util.Map;
import java.util.Random;
import org.jboss.logging.Logger;
@@ -39,12 +39,18 @@
*/
public class PortUtil
{
+ public static final String MIN_PORT = "minPort";
+ public static final String MAX_PORT = "maxPort";
+
private static final Logger log = Logger.getLogger(PortUtil.class);
private static final int MIN_UNPRIVILEGED_PORT = 1024;
private static final int MAX_LEGAL_PORT = 65535;
private static int portCounter = 0;
private static int retryMax = 50;
+
+ private static int minPort = MIN_UNPRIVILEGED_PORT;
+ private static int maxPort = MAX_LEGAL_PORT;
static
{
@@ -134,20 +140,111 @@
private static synchronized int getNextPort()
{
- if (portCounter < MAX_LEGAL_PORT)
+ if (portCounter < maxPort)
return portCounter++;
- portCounter = MIN_UNPRIVILEGED_PORT;
- return MAX_LEGAL_PORT;
+ portCounter = minPort;
+ return maxPort;
}
public static int getRandomStartingPort()
{
- int range = MAX_LEGAL_PORT - MIN_UNPRIVILEGED_PORT + 1;
- int port = new Random(System.currentTimeMillis()).nextInt(range) + MIN_UNPRIVILEGED_PORT;
+ int range = maxPort - minPort + 1;
+ int port = new Random(System.currentTimeMillis()).nextInt(range) + minPort;
return port;
}
+
+ public static synchronized int getMinPort()
+ {
+ return minPort;
+ }
+ public static synchronized void setMinPort(int minPort) throws IllegalStateException
+ {
+ if (minPort > PortUtil.maxPort)
+ {
+ String msg = "trying to set minPort to value greater than maxPort: " + minPort + " > " + PortUtil.maxPort;
+ log.debug(msg);
+ throw new IllegalStateException(msg);
+ }
+ if (minPort < PortUtil.minPort)
+ {
+ log.debug("will not set minPort to " + minPort + ": minPort is already " + PortUtil.minPort);
+ return;
+ }
+ log.debug("setting minPort to " + minPort);
+ PortUtil.minPort = minPort;
+ }
+
+ public static synchronized int getMaxPort()
+ {
+ return maxPort;
+ }
+
+ public static synchronized void setMaxPort(int maxPort)
+ {
+ if (maxPort < PortUtil.minPort)
+ {
+ String msg = "trying to set maxPort to value less than minPort: " + maxPort + " < " + PortUtil.minPort;
+ log.debug(msg);
+ throw new IllegalStateException(msg);
+ }
+ if (maxPort > PortUtil.maxPort)
+ {
+ log.debug("will not set maxPort to " + maxPort + ": maxPort is already " + PortUtil.maxPort);
+ return;
+ }
+ log.debug("setting maxPort to " + maxPort);
+ PortUtil.maxPort = maxPort;
+ }
+
+ public static synchronized void updateRange(Map config)
+ {
+ if (config != null)
+ {
+ int savedMinPort = getMinPort();
+ Object o = config.get(MIN_PORT);
+ if (o instanceof String)
+ {
+ try
+ {
+ setMinPort(Integer.parseInt((String) o));
+ }
+ catch (NumberFormatException e)
+ {
+ log.error("minPort parameter has invalid format: " + o);
+ }
+ }
+ else if (o != null)
+ {
+ log.error("minPort parameter must be a string in integer format: " + o);
+ }
+
+ int savedMaxPort = getMaxPort();
+ o = config.get(MAX_PORT);
+ if (o instanceof String)
+ {
+ try
+ {
+ setMaxPort(Integer.parseInt((String) o));
+ }
+ catch (NumberFormatException e)
+ {
+ log.error("maxPort parameter has invalid format: " + o);
+ }
+ }
+ else if (o != null)
+ {
+ log.error("maxPort parameter must be a string in integer format: " + o);
+ }
+
+ if (savedMinPort != getMinPort() || savedMaxPort != getMaxPort())
+ {
+ portCounter = getRandomStartingPort();
+ }
+ }
+ }
+
public static void main(String args[])
{
try
[View Less]
15 years, 8 months
- 1
- 0
JBoss Remoting SVN: r5310 - remoting2/branches/2.2/src/main/org/jboss/remoting.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2009-07-28 16:35:27 -0400 (Tue, 28 Jul 2009)
New Revision: 5310
Modified:
remoting2/branches/2.2/src/main/org/jboss/remoting/Client.java
Log:
JBREM-1139: Adjusts PortUtil range in constructor; JBREM-1143: implements "invoker destruction delay" feature.
Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/Client.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/Client.…
[View More]java 2009-07-28 02:19:48 UTC (rev 5309)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/Client.java 2009-07-28 20:35:27 UTC (rev 5310)
@@ -60,6 +60,8 @@
import java.util.List;
import java.util.Map;
import java.util.Set;
+import java.util.Timer;
+import java.util.TimerTask;
/**
* Client is a convience class for invoking remote methods for a given subsystem. It is intended to
@@ -152,6 +154,11 @@
*/
public static final int DEFAULT_DISCONNECT_TIMEOUT = -1;
+ /**
+ * Key for setting delay before client invoker is destroyed by disconnect().
+ */
+ public static final String INVOKER_DESTRUCTION_DELAY = "invokerDestructionDelay";
+
public static final String THROW_CALLBACK_EXCEPTION = "throwCallbackException";
/** The key to use to specify that parameters for objects created by Client should be taken,
@@ -169,6 +176,9 @@
private static boolean trace = log.isTraceEnabled();
private static final long serialVersionUID = 5679279425009837934L;
+
+ private static Timer invokerDestructionTimer;
+ private static Object invokerDestructionTimerLock = new Object();
// Static ---------------------------------------------------------------------------------------
@@ -202,6 +212,8 @@
private boolean connected = false;
+ private int invokerDestructionDelay = 0;
+
private Set connectionListeners = new HashSet();
private boolean useClientConnectionIdentity;
@@ -282,9 +294,27 @@
if (configuration != null)
{
this.configuration = new HashMap(configuration);
- Object o = configuration.get(Remoting.USE_CLIENT_CONNECTION_IDENTITY);
+ Object o = configuration.get(INVOKER_DESTRUCTION_DELAY);
if (o instanceof String)
{
+ try
+ {
+ invokerDestructionDelay = Integer.parseInt((String) o);
+ log.debug(this + " setting invokerDestructionDelay to " + invokerDestructionDelay);
+ }
+ catch (NumberFormatException e)
+ {
+ log.error("invokerDestructionDelay parameter has invalid format: " + o);
+ }
+ }
+ else if (o != null)
+ {
+ log.error("invokerDestructionDelay parameter must be a string in integer format: " + o);
+ }
+
+ o = configuration.get(Remoting.USE_CLIENT_CONNECTION_IDENTITY);
+ if (o instanceof String)
+ {
useClientConnectionIdentity = Boolean.valueOf((String) o).booleanValue();
}
else if (o != null)
@@ -304,6 +334,15 @@
}
}
}
+
+ Map tempMap = new HashMap();
+ if (this.configuration != null)
+ {
+ tempMap.putAll(this.configuration);
+ }
+ tempMap.putAll(locator.getParameters());
+ PortUtil.updateRange(tempMap);
+
this.sessionId = new GUID().toString();
}
@@ -634,7 +673,36 @@
// Need to remove myself from registry so will not keep reference to me since I am of no
// use now. Will have to create a new one.
- InvokerRegistry.destroyClientInvoker(invoker.getLocator(), configuration);
+
+ if (invokerDestructionDelay > 0)
+ {
+ synchronized (invokerDestructionTimerLock)
+ {
+ InvokerDestructionTimerTask task = new InvokerDestructionTimerTask(invoker);
+ if (invokerDestructionTimer == null)
+ {
+ invokerDestructionTimer = new Timer(true);
+ }
+
+ try
+ {
+ invokerDestructionTimer.schedule(task, invokerDestructionDelay);
+ }
+ catch (IllegalStateException e)
+ {
+ log.debug("Unable to schedule InvokerDestructionTimerTask on existing Timer", e);
+ invokerDestructionTimer = new Timer(true);
+ invokerDestructionTimer.schedule(task, invokerDestructionDelay);
+ }
+
+ if (trace) log.trace(this + " scheduled destruction of " + invoker);
+ }
+ }
+ else
+ {
+ InvokerRegistry.destroyClientInvoker(invoker.getLocator(), configuration);
+ }
+
invoker = null;
}
@@ -1944,6 +2012,25 @@
// Inner classes --------------------------------------------------------------------------------
+
+ class InvokerDestructionTimerTask extends TimerTask
+ {
+ private WeakReference ref;
+
+ public InvokerDestructionTimerTask(ClientInvoker invoker)
+ {
+ ref = new WeakReference(invoker);
+ }
+
+ public void run()
+ {
+ ClientInvoker invoker = (ClientInvoker) ref.get();
+ log.trace(this + " calling InvokerRegistry.destroyClientInvoker() for " + invoker);
+ InvokerRegistry.destroyClientInvoker(invoker.getLocator(), configuration);
+ ref.clear();
+ ref = null;
+ }
+ }
static class ConnectionValidatorKey
{
[View Less]
15 years, 8 months
- 1
- 0