[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/serverlockup ...
Ovidiu Feodorov
ovidiu.feodorov at jboss.com
Mon Jan 15 19:29:29 EST 2007
User: ovidiu
Date: 07/01/15 19:29:29
Modified: src/tests/org/jboss/test/remoting/transport/socket/serverlockup
Tag: remoting_2_x ServerLockupClientTest.java
ServerLockupServerTest.java
Added: src/tests/org/jboss/test/remoting/transport/socket/serverlockup
Tag: remoting_2_x RogueClientInvoker.java
Log:
more TRACE logging and tests
Revision Changes Path
No revision
No revision
1.1.2.2 +20 -5 JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/serverlockup/Attic/ServerLockupClientTest.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: ServerLockupClientTest.java
===================================================================
RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/serverlockup/Attic/ServerLockupClientTest.java,v
retrieving revision 1.1.2.1
retrieving revision 1.1.2.2
diff -u -b -r1.1.2.1 -r1.1.2.2
--- ServerLockupClientTest.java 13 Jan 2007 12:42:36 -0000 1.1.2.1
+++ ServerLockupClientTest.java 16 Jan 2007 00:29:29 -0000 1.1.2.2
@@ -37,6 +37,7 @@
{
client.setUp();
client.testSimplePing();
+ client.testRogueClient();
client.tearDown();
}
catch (Throwable throwable)
@@ -63,6 +64,20 @@
new Object[] {"hello"},
new String[] {"java.lang.String"}));
assertEquals("pong.hello", ret);
+ }
+
+ /**
+ * Invoking the server with a specially crafted client that is trying to lock up the server.
+ */
+ public void testRogueClient() throws Throwable
+ {
+ log.debug("testRogueClient()");
+
+ RogueClientInvoker rogueInvoker =
+ new RogueClientInvoker(new InvokerLocator(getTransport() + "://localhost:" + port));
+
+ rogueInvoker.connect();
+ rogueInvoker.openConnectionButDontSendAnything();
}
@@ -87,9 +102,6 @@
protected void setUp() throws Exception
{
-// BasicConfigurator.configure();
-// Category.getRoot().setLevel(Level.INFO);
-
// This is a retry hack because in some cases, can get duplicate callback server ports when
// trying to find a free one.
@@ -134,7 +146,10 @@
Connector connector = new Connector();
- InvokerLocator locator = new InvokerLocator(getTransport() + "://localhost:" + port);
+ String locatorString =
+ getTransport() + "://localhost:" + port + "/?serializationType=jboss";
+
+ InvokerLocator locator = new InvokerLocator(locatorString);
connector.setInvokerLocator(locator.getLocatorURI());
connector.create();
@@ -148,7 +163,7 @@
{
try
{
- String locatorURI = getTransport() + "://localhost:" + port;
+ String locatorURI = getTransport() + "://localhost:" + port + "/?serializationType=jboss";
InvokerLocator locator = new InvokerLocator(locatorURI);
client = new Client(locator, "mock");
1.1.2.2 +5 -1 JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/serverlockup/Attic/ServerLockupServerTest.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: ServerLockupServerTest.java
===================================================================
RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/serverlockup/Attic/ServerLockupServerTest.java,v
retrieving revision 1.1.2.1
retrieving revision 1.1.2.2
diff -u -b -r1.1.2.1 -r1.1.2.2
--- ServerLockupServerTest.java 13 Jan 2007 12:42:36 -0000 1.1.2.1
+++ ServerLockupServerTest.java 16 Jan 2007 00:29:29 -0000 1.1.2.2
@@ -90,7 +90,11 @@
log.debug("port = " + serverPort);
connector = new Connector();
- InvokerLocator locator = new InvokerLocator(getTransport() + "://localhost:" + serverPort);
+
+ String locatorString =
+ getTransport() + "://localhost:" + serverPort + "/?serializationType=jboss";
+
+ InvokerLocator locator = new InvokerLocator(locatorString);
connector.setInvokerLocator(locator.getLocatorURI());
connector.create();
connector.addInvocationHandler(getSubsystem(), getServerInvocationHandler());
No revision
No revision
1.1.2.1 +83 -0 JBossRemoting/src/tests/org/jboss/test/remoting/transport/socket/serverlockup/Attic/RogueClientInvoker.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: RogueClientInvoker.java
===================================================================
RCS file: RogueClientInvoker.java
diff -N RogueClientInvoker.java
--- /dev/null 1 Jan 1970 00:00:00 -0000
+++ RogueClientInvoker.java 16 Jan 2007 00:29:29 -0000 1.1.2.1
@@ -0,0 +1,83 @@
+/**
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.test.remoting.transport.socket.serverlockup;
+
+import org.jboss.remoting.transport.socket.MicroSocketClientInvoker;
+import org.jboss.remoting.transport.socket.SocketWrapper;
+import org.jboss.remoting.InvokerLocator;
+import org.jboss.logging.Logger;
+
+import java.net.SocketException;
+import java.net.Socket;
+import java.io.OutputStream;
+import java.io.InputStream;
+
+/**
+ * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
+ * @version <tt>$Revision: 1.1.2.1 $</tt>
+ * <p/>
+ * $Id: RogueClientInvoker.java,v 1.1.2.1 2007/01/16 00:29:29 ovidiu Exp $
+ */
+public class RogueClientInvoker extends MicroSocketClientInvoker
+{
+ // Constants ------------------------------------------------------------------------------------
+
+ private static final Logger log = Logger.getLogger(RogueClientInvoker.class);
+
+ // Static ---------------------------------------------------------------------------------------
+
+ // Attributes -----------------------------------------------------------------------------------
+
+ // Constructors ---------------------------------------------------------------------------------
+
+ public RogueClientInvoker(InvokerLocator locator)
+ {
+ super(locator);
+ }
+
+ // Public ---------------------------------------------------------------------------------------
+
+ public String toString()
+ {
+ return "RogueClientInvoker[" + Integer.toHexString(hashCode()) + "]";
+ }
+
+ // Package protected ----------------------------------------------------------------------------
+
+ void openConnectionButDontSendAnything() throws Exception
+ {
+ log.debug(this + " creating simple socket");
+
+ Socket socket = new Socket(locator.getHost(), locator.getPort());
+
+ log.debug(this + " created socket " + socket + ", sleeping ...");
+
+ Thread.sleep(30000);
+
+ log.debug(this + " done sleeping");
+
+
+
+// OutputStream outputStream = socketWrapper.getOutputStream();
+//
+// writeVersion(outputStream, version);
+//
+// versionedWrite(outputStream, marshaller, invocation, version);
+//
+// InputStream inputStream = socketWrapper.getInputStream();
+//
+// version = readVersion(inputStream);
+//
+// response = versionedRead(inputStream, unmarshaller, version);
+ }
+
+ // Protected ------------------------------------------------------------------------------------
+
+ // Private --------------------------------------------------------------------------------------
+
+ // Inner classes --------------------------------------------------------------------------------
+}
More information about the jboss-cvs-commits
mailing list