jboss-remoting-commits
October 2010
jboss-remoting-commits@lists.jboss.org
- 1 participants
- 14 discussions
JBoss Remoting SVN: r6119 - in remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test: spi and 1 other directory.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2010-10-05 12:24:55 -0400 (Tue, 05 Oct 2010)
New Revision: 6119
Added:
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/spi/
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/spi/SpiUtilsTestCase.java
Log:
JBREM-1228: New unit test.
Added: remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/spi/SpiUtilsTestCase.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/spi/SpiUtilsTestCase.java (rev 0)
+++ remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/spi/SpiUtilsTestCase.java 2010-10-05 16:24:55 UTC (rev 6119)
@@ -0,0 +1,233 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2010, 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.remoting3.test.spi;
+
+import static org.testng.Assert.assertTrue;
+
+import java.io.IOException;
+import java.util.concurrent.RejectedExecutionException;
+
+import org.jboss.remoting3.ClientContext;
+import org.jboss.remoting3.CloseHandler;
+import org.jboss.remoting3.RequestCancelHandler;
+import org.jboss.remoting3.RequestContext;
+import org.jboss.remoting3.spi.LocalReplyHandler;
+import org.jboss.remoting3.spi.RemoteReplyHandler;
+import org.jboss.remoting3.spi.SpiUtils;
+import org.jboss.remoting3.test.RemotingTestBase;
+import org.testng.annotations.AfterMethod;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.Test;
+
+/**
+ * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
+ * @version $Revision: 1.1 $
+ * <p>
+ * Copyright Jun 7, 2010
+ */
+@Test(suiteName = "SpiUtils")
+public class SpiUtilsTestCase extends RemotingTestBase {
+
+ @BeforeMethod
+ public void setUp() {
+ }
+
+ @AfterMethod
+ public void tearDown() throws IOException {
+ }
+
+ @Test
+ public void testSafeHandleExceptionRemote() throws Exception {
+ enter();
+ try {
+ TestRemoteReplyHandler replyHandler = new TestRemoteReplyHandler();
+ SpiUtils.safeHandleException(replyHandler, new IOException());
+ assertTrue(replyHandler.handledException);
+ } finally {
+ exit();
+ }
+ }
+
+ @Test
+ public void testSafeHandleExceptionLocal() throws Exception {
+ enter();
+ try {
+ TestLocalReplyHandler replyHandler = new TestLocalReplyHandler();
+ SpiUtils.safeHandleException(replyHandler, null);
+ assertTrue(replyHandler.handledException);
+ } finally {
+ exit();
+ }
+ }
+
+ @Test
+ public void testSafeHandleReplyRemote() throws Exception {
+ enter();
+ try {
+ TestRemoteReplyHandler replyHandler = new TestRemoteReplyHandler();
+ SpiUtils.safeHandleReply(replyHandler, new IOException());
+ assertTrue(replyHandler.handledReply);
+ } finally {
+ exit();
+ }
+ }
+
+ @Test
+ public void testSafeHandleReplyLocal() throws Exception {
+ enter();
+ try {
+ TestLocalReplyHandler replyHandler = new TestLocalReplyHandler();
+ SpiUtils.safeHandleReply(replyHandler, null);
+ assertTrue(replyHandler.handledReply);
+ } finally {
+ exit();
+ }
+ }
+
+ @Test
+ public void testSafeHandleCancellationRemote() throws Exception {
+ enter();
+ try {
+ TestRemoteReplyHandler replyHandler = new TestRemoteReplyHandler();
+ SpiUtils.safeHandleCancellation(replyHandler);
+ assertTrue(replyHandler.handledCancellation);
+ } finally {
+ exit();
+ }
+ }
+
+ @Test
+ public void testSafeHandleCancellationLocal() throws Exception {
+ enter();
+ try {
+ TestLocalReplyHandler replyHandler = new TestLocalReplyHandler();
+ SpiUtils.safeHandleCancellation(replyHandler);
+ assertTrue(replyHandler.handledCancellation);
+ } finally {
+ exit();
+ }
+ }
+
+
+ @Test
+ public void testSafeNotifyCancellation() throws Exception {
+ enter();
+ try {
+ TestRequestCancelHandler cancelHandler = new TestRequestCancelHandler();
+ SpiUtils.safeNotifyCancellation(cancelHandler, new TestRequestContext());
+ assertTrue(cancelHandler.handledNotifyCancel);
+ } finally {
+ exit();
+ }
+ }
+
+ @Test
+ public void testSafeHandleClose() throws Exception {
+ enter();
+ try {
+ TestCloseHandler closeHandler = new TestCloseHandler();
+ SpiUtils.safeHandleClose(closeHandler, new Object());
+ assertTrue(closeHandler.handledClose);
+ } finally {
+ exit();
+ }
+ }
+
+ static class TestRemoteReplyHandler implements RemoteReplyHandler {
+ public boolean handledException;
+ public boolean handledReply;
+ public boolean handledCancellation;
+
+ public void handleCancellation() throws IOException {
+ handledCancellation = true;
+ throw new IOException("handleCancellation");
+ }
+ public void handleException(IOException exception) throws IOException {
+ handledException = true;
+ throw new IOException("handleException()");
+ }
+ public void handleReply(Object reply) throws IOException {
+ handledReply = true;
+ throw new IOException("handleReply()");
+ }
+ }
+
+ static class TestLocalReplyHandler implements LocalReplyHandler {
+ public boolean handledException;
+ public boolean handledReply;
+ public boolean handledCancellation;
+
+ public ClassLoader getClassLoader() {
+ return null;
+ }
+ public void handleCancellation() {
+ handledCancellation = true;
+ throw new RuntimeException("handleCancellation");
+ }
+ public void handleException(IOException exception) {
+ handledException = true;
+ throw new RuntimeException("handleException()");
+ }
+ public void handleReply(Object reply) {
+ handledReply = true;
+ throw new RuntimeException("handleReply()");
+ }
+ }
+
+ static class TestRequestCancelHandler implements RequestCancelHandler<Object> {
+ public boolean handledNotifyCancel;
+
+ public void notifyCancel(RequestContext<Object> requestContext) {
+ handledNotifyCancel = true;
+ throw new RuntimeException("notifyCancel");
+ }
+ }
+
+ static class TestRequestContext implements RequestContext<Object> {
+ public void addCancelHandler(RequestCancelHandler<Object> handler) {
+ }
+ public void execute(Runnable command) throws RejectedExecutionException {
+ }
+ public ClientContext getContext() {
+ return null;
+ }
+ public boolean isCancelled() {
+ return false;
+ }
+ public void sendCancelled() throws IOException, IllegalStateException {
+ }
+ public void sendFailure(String msg, Throwable cause) throws IOException, IllegalStateException {
+ }
+ public void sendReply(Object reply) throws IOException, IllegalStateException {
+ }
+ }
+
+ static class TestCloseHandler implements CloseHandler<Object> {
+ public boolean handledClose;
+
+ public void handleClose(Object closed) {
+ handledClose = true;
+ throw new RuntimeException("handledClose");
+ }
+ }
+}
13 years, 7 months
- 1
- 0
JBoss Remoting SVN: r6118 - remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/stream.
by jboss-remoting-commits＠lists.jboss.org
Author: ron.sigal(a)jboss.com
Date: 2010-10-04 23:01:44 -0400 (Mon, 04 Oct 2010)
New Revision: 6118
Added:
remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/stream/PrimaryExternalizerFactoryTestCase.java
Log:
JBREM-1228: New unit test.
Added: remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/stream/PrimaryExternalizerFactoryTestCase.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/stream/PrimaryExternalizerFactoryTestCase.java (rev 0)
+++ remoting3/trunk/jboss-remoting/src/test/java/org/jboss/remoting3/test/stream/PrimaryExternalizerFactoryTestCase.java 2010-10-05 03:01:44 UTC (rev 6118)
@@ -0,0 +1,537 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2010, 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.remoting3.test.stream;
+
+import static org.testng.Assert.assertEquals;
+import static org.testng.Assert.assertTrue;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.io.PipedInputStream;
+import java.io.PipedOutputStream;
+import java.io.Reader;
+import java.io.Serializable;
+import java.io.StringReader;
+import java.io.StringWriter;
+import java.io.Writer;
+import java.net.URISyntaxException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+import java.util.Random;
+
+import org.jboss.remoting3.Client;
+import org.jboss.remoting3.Connection;
+import org.jboss.remoting3.RemoteExecutionException;
+import org.jboss.remoting3.RequestContext;
+import org.jboss.remoting3.RequestListener;
+import org.jboss.remoting3.stream.ObjectSink;
+import org.jboss.remoting3.stream.ObjectSource;
+import org.jboss.remoting3.stream.Streams;
+import org.jboss.remoting3.test.RemotingTestBase;
+import org.jboss.xnio.OptionMap;
+import org.jboss.xnio.log.Logger;
+import org.testng.annotations.AfterMethod;
+import org.testng.annotations.BeforeMethod;
+import org.testng.annotations.Test;
+
+/**
+ * @author <a href="ron.sigal(a)jboss.com">Ron Sigal</a>
+ * @version $Revision: 1.1 $
+ * <p>
+ * Copyright September 25, 2010
+ */
+@Test(suiteName = "PrimaryExternalizerFactory")
+public class PrimaryExternalizerFactoryTestCase extends RemotingTestBase {
+
+ private static final Logger log = Logger.getLogger(PrimaryExternalizerFactoryTestCase.class);
+ private static final String SERVICE_TYPE = "streamservicetype";
+ private static final String INSTANCE_NAME = "test";
+ private static final String READER_TEST_STRING = "reader test string";
+ private static final String WRITER_TEST_STRING = "writer test string";
+
+ private static int counter = new Random(new Date().getTime()).nextInt();
+
+ @BeforeMethod
+ public void setUp() {
+ }
+
+ @AfterMethod
+ public void tearDown() throws IOException {
+ }
+
+ @Test
+ public void testInputStream() throws Exception {
+ enter();
+
+ ServerPackage sp0 = null;
+ ServerPackage sp1 = null;
+ Connection connection = null;
+ Client<Object, Object> client = null;
+
+ try {
+ int id0 = counter++;
+ int id1 = counter++;
+
+ // Set up services.
+ sp0 = setupServer(null, id0, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+ sp1 = setupServer(null, id1, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+
+ // Set up connection and client.
+ connection = setupConnection(sp0, sp1);
+ client = setupClient(connection, SERVICE_TYPE, INSTANCE_NAME);
+
+ // Write to streams.
+ final PipedInputStream pis = new PipedInputStream();
+ final PipedOutputStream pos = new PipedOutputStream(pis);
+ pos.write("before invocation".getBytes());
+ pos.flush();
+
+ class Holder {
+ public Object result;
+ };
+
+ final Holder holder = new Holder();
+ final Client<Object, Object> finalClient = client;
+ new Thread() {
+ public void run() {
+ try {
+ log.info(this + " calling invoke()");
+ Object o = finalClient.invoke(pis);
+ synchronized(holder) {
+ holder.result = o;
+ log.info("set result to: " + holder.result);
+ holder.notifyAll();
+ }
+ } catch (IOException e) {
+ log.error("unable to call Client.invoke()");
+ }
+ }
+ }.start();
+
+ Thread.sleep(1000);
+ pos.write(" | after invocation".getBytes());
+ pos.flush();
+
+ synchronized (holder) {
+ if (holder.result == null) {
+ holder.wait(3000);
+ }
+ }
+
+ pos.close();
+ pis.close();
+
+ Thread.sleep(1000);
+
+ log.info(this + " holder.result: " + holder.result);
+ assertEquals("before invocation | after invocation", holder.result);
+
+ log.info(getName() + " PASSES");
+ } finally {
+ if (client != null) {
+ client.close();
+ }
+ if (connection != null) {
+ connection.close();
+ }
+ if (sp0 != null) {
+ sp0.close();
+ }
+ if (sp1 != null) {
+ sp1.close();
+ }
+ exit();
+ }
+ }
+
+ @Test
+ public void testOutputStream() throws Exception {
+ enter();
+
+ ServerPackage sp0 = null;
+ ServerPackage sp1 = null;
+ Connection connection = null;
+ Client<Object, Object> client = null;
+
+ try {
+ int id0 = counter++;
+ int id1 = counter++;
+
+ // Set up services.
+ sp0 = setupServer(null, id0, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+ sp1 = setupServer(null, id1, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+
+ // Set up connection and client.
+ connection = setupConnection(sp0, sp1);
+ client = setupClient(connection, SERVICE_TYPE, INSTANCE_NAME);
+
+ // Test OutputStream.
+ ByteArrayOutputStream baos = new ByteArrayOutputStream();
+ client.invoke(baos);
+ String result = new String(baos.toByteArray());
+ assertEquals(WRITER_TEST_STRING, result);
+ log.info("result: " + result);
+
+ log.info(getName() + " PASSES");
+ } finally {
+ if (client != null) {
+ client.close();
+ }
+ if (connection != null) {
+ connection.close();
+ }
+ if (sp0 != null) {
+ sp0.close();
+ }
+ if (sp1 != null) {
+ sp1.close();
+ }
+ exit();
+ }
+ }
+
+ @Test
+ public void testReader() throws Exception {
+ enter();
+
+ ServerPackage sp0 = null;
+ ServerPackage sp1 = null;
+ Connection connection = null;
+ Client<Object, Object> client = null;
+
+ try {
+ int id0 = counter++;
+ int id1 = counter++;
+
+ // Set up services.
+ sp0 = setupServer(null, id0, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+ sp1 = setupServer(null, id1, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+
+ // Set up connection and client.
+ connection = setupConnection(sp0, sp1);
+ client = setupClient(connection, SERVICE_TYPE, INSTANCE_NAME);
+
+ // Test Reader.
+ Reader reader = new StringReader(READER_TEST_STRING);
+ Object o = client.invoke(reader);
+ log.info(this + " response: " + o);
+ assertEquals(READER_TEST_STRING, o);
+
+ log.info(getName() + " PASSES");
+ } finally {
+ if (client != null) {
+ client.close();
+ }
+ if (connection != null) {
+ connection.close();
+ }
+ if (sp0 != null) {
+ sp0.close();
+ }
+ if (sp1 != null) {
+ sp1.close();
+ }
+ exit();
+ }
+ }
+
+ @Test
+ public void testWriter() throws Exception {
+ enter();
+
+ ServerPackage sp0 = null;
+ ServerPackage sp1 = null;
+ Connection connection = null;
+ Client<Object, Object> client = null;
+
+ try {
+ int id0 = counter++;
+ int id1 = counter++;
+
+ // Set up services.
+ sp0 = setupServer(null, id0, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+ sp1 = setupServer(null, id1, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+
+ // Set up connection and client.
+ connection = setupConnection(sp0, sp1);
+ client = setupClient(connection, SERVICE_TYPE, INSTANCE_NAME);
+
+ // Test Writer.
+ StringWriter writer = new StringWriter();
+ Object o = client.invoke(writer);
+ log.info(this + " response: " + o);
+ assertEquals(WRITER_TEST_STRING, o);
+ StringBuffer buffer = writer.getBuffer();
+ char[] chars = new char[buffer.length()];
+ buffer.getChars(0, buffer.length(), chars, 0);
+ String writerContents = new String(chars);
+ log.info(this + " returned in writer: " + writerContents);
+ assertEquals(WRITER_TEST_STRING, writerContents);
+
+ log.info(getName() + " PASSES");
+ } finally {
+ if (client != null) {
+ client.close();
+ }
+ if (connection != null) {
+ connection.close();
+ }
+ if (sp0 != null) {
+ sp0.close();
+ }
+ if (sp1 != null) {
+ sp1.close();
+ }
+ exit();
+ }
+ }
+
+ @Test
+ public void testObjectSource() throws Exception {
+ enter();
+
+ ServerPackage sp0 = null;
+ ServerPackage sp1 = null;
+ Connection connection = null;
+ Client<Object, Object> client = null;
+
+ try {
+ int id0 = counter++;
+ int id1 = counter++;
+
+ // Set up services.
+ sp0 = setupServer(null, id0, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+ sp1 = setupServer(null, id1, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+
+ // Set up connection and client.
+ connection = setupConnection(sp0, sp1);
+ client = setupClient(connection, SERVICE_TYPE, INSTANCE_NAME);
+
+ // Test ObjectSource.
+ ArrayList<Object> list = new ArrayList<Object>();
+ TestObject o1 = new TestObject(1);
+ TestObject o2 = new TestObject(2);
+ TestObject o3 = new TestObject(3);
+ list.add(o1);
+ list.add(o2);
+ list.add(o3);
+ ObjectSource<Object> source = Streams.getIteratorObjectSource(list.iterator());
+ Object o = client.invoke(source);
+ log.info(this + " response: " + o);
+ assertTrue(o instanceof List<?>);
+ @SuppressWarnings("unchecked")
+ List<Object> result = (List<Object>) o;
+ assertEquals(3, result.size());
+ assertTrue(result.contains(o1));
+ assertTrue(result.contains(o2));
+ assertTrue(result.contains(o3));
+
+ log.info(getName() + " PASSES");
+ } finally {
+ if (client != null) {
+ client.close();
+ }
+ if (connection != null) {
+ connection.close();
+ }
+ if (sp0 != null) {
+ sp0.close();
+ }
+ if (sp1 != null) {
+ sp1.close();
+ }
+ exit();
+ }
+ }
+
+ @Test
+ public void testObjectSink() throws Exception {
+ enter();
+
+ ServerPackage sp0 = null;
+ ServerPackage sp1 = null;
+ Connection connection = null;
+ Client<Object, Object> client = null;
+
+ try {
+ int id0 = counter++;
+ int id1 = counter++;
+
+ // Set up services.
+ sp0 = setupServer(null, id0, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+ sp1 = setupServer(null, id1, new TestRequestListener(), SERVICE_TYPE, INSTANCE_NAME);
+
+ // Set up connection and client.
+ connection = setupConnection(sp0, sp1);
+ client = setupClient(connection, SERVICE_TYPE, INSTANCE_NAME);
+
+ // Test ObjectSink.
+ List<String> set = new ArrayList<String>();
+ ObjectSink<String> objectSink = Streams.getCollectionObjectSink(set);
+ client.invoke(objectSink);
+ assertEquals(3, set.size());
+ assertTrue(set.contains("sink 1"));
+ assertTrue(set.contains("sink 2"));
+ assertTrue(set.contains("sink 3"));
+
+ log.info(getName() + " PASSES");
+ } finally {
+ if (client != null) {
+ client.close();
+ }
+ if (connection != null) {
+ connection.close();
+ }
+ if (sp0 != null) {
+ sp0.close();
+ }
+ if (sp1 != null) {
+ sp1.close();
+ }
+ exit();
+ }
+ }
+
+ protected OptionMap getClientOptionMap() {
+ return OptionMap.EMPTY;
+ }
+
+ public Client<Object, Object> setupClient(Connection connection, String serviceType, String instanceName) throws IOException, URISyntaxException {
+ Client<Object, Object> client = getFutureResult(connection.openClient(serviceType, instanceName, Object.class, Object.class, getClientOptionMap()), 1000000, "unable to open client to " + serviceType + ":" + instanceName);
+ return client;
+ }
+
+ static class TestRequestListener implements RequestListener<Object, Object> {
+ public void handleRequest(RequestContext<Object> context, Object request) throws RemoteExecutionException {
+ try {
+ if (request instanceof InputStream) {
+ log.info(this + " got InputStream: " + request);
+ InputStream is = (InputStream) request;
+ byte[] bytes = new byte[1024];
+ int n = 0;
+ int pos = 0;
+ do {
+ n = is.read(bytes, pos, 1024 - pos);
+ log.info(this + " read " + n + " bytes");
+ if (n <= 0) {
+ break;
+ }
+ pos += n;
+ log.info(this + " read from InputStream: " + new String(bytes));
+ } while (true);
+ byte[] trimmedBytes = Arrays.copyOfRange(bytes, 0, pos);
+ log.info(this + " sending reply: " + new String(trimmedBytes));
+ context.sendReply(new String(trimmedBytes));
+ }
+
+ else if (request instanceof OutputStream) {
+ log.info(this + " got OutputStream: " + request);
+ OutputStream outputStream = (OutputStream) request;
+ outputStream.write(WRITER_TEST_STRING.getBytes());
+ outputStream.flush();
+ outputStream.close();
+ context.sendReply(null);
+ }
+
+ else if (request instanceof Reader) {
+ log.info(this + " got Reader: " + request);
+ Reader reader = (Reader) request;
+ char[] chars = new char[1024];
+ int n = 0;
+ int pos = 0;
+ do {
+ n = reader.read(chars, pos, 1024 - pos);
+ log.info(this + " read " + n + " chars");
+ if (n <= 0) {
+ break;
+ }
+ pos += n;
+ log.info(this + " read from InputStream: " + new String(chars));
+ } while (true);
+ char[] trimmedChars = Arrays.copyOfRange(chars, 0, pos);
+ log.info(this + " sending reply: " + new String(trimmedChars));
+ context.sendReply(new String(trimmedChars));
+ }
+
+ else if (request instanceof Writer) {
+ log.info(this + " got Writer: " + request);
+ Writer writer = (Writer) request;
+ writer.write(WRITER_TEST_STRING);
+ writer.close();
+ log.info(this + " sending reply: " + WRITER_TEST_STRING);
+ context.sendReply(WRITER_TEST_STRING);
+ }
+
+ else if (request instanceof ObjectSource<?>) {
+ log.info(this + " got ObjectSource: " + request);
+ @SuppressWarnings("unchecked")
+ ObjectSource<Object> source = (ObjectSource<Object>) request;
+ ArrayList<Object> list = new ArrayList<Object>();
+ while (source.hasNext()) {
+ Object o = source.next();
+ log.info(this + " adding " + o + " to list");
+ list.add(o);
+ }
+ context.sendReply(list);
+ }
+
+ else if (request instanceof ObjectSink<?>) {
+ log.info(this + " got ObjectSink: " + request);
+ @SuppressWarnings("unchecked")
+ ObjectSink<String> sink = (ObjectSink<String>) request;
+ sink.accept("sink 1");
+ sink.accept("sink 2");
+ sink.accept("sink 3");
+ sink.flush();
+ sink.close();
+ context.sendReply(null);
+ }
+ } catch (IOException e) {
+ log.error(this + " unable to send reply", e);
+ e.printStackTrace();
+ }
+ }
+ }
+
+ static class TestObject implements Serializable {
+ public int seed;
+ private static final long serialVersionUID = -6320960380815363629L;
+
+ public TestObject(int seed) {
+ this.seed = seed;
+ }
+ public int hashCode() {
+ return seed;
+ }
+ public boolean equals(Object o) {
+ if (! (o instanceof TestObject)) {
+ return false;
+ }
+ return seed == ((TestObject) o).seed;
+ }
+ }
+}
13 years, 7 months
- 1
- 0
13 years, 7 months
- 1
- 0
JBoss Remoting SVN: r6117 - in remoting2/branches/2.5.2.SP2_JBREM-1245/src: tests/org/jboss/test/remoting/transport/socket and 1 other directories.
by jboss-remoting-commits＠lists.jboss.org
Author: jbertram(a)redhat.com
Date: 2010-10-01 13:09:37 -0400 (Fri, 01 Oct 2010)
New Revision: 6117
Added:
remoting2/branches/2.5.2.SP2_JBREM-1245/src/tests/org/jboss/test/remoting/transport/socket/retriable/
remoting2/branches/2.5.2.SP2_JBREM-1245/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java
Removed:
remoting2/branches/2.5.2.SP2_JBREM-1245/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java
Modified:
remoting2/branches/2.5.2.SP2_JBREM-1245/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java
Log:
JBPAPP-5137
Modified: remoting2/branches/2.5.2.SP2_JBREM-1245/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java
===================================================================
--- remoting2/branches/2.5.2.SP2_JBREM-1245/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java 2010-09-25 01:41:02 UTC (rev 6116)
+++ remoting2/branches/2.5.2.SP2_JBREM-1245/src/main/org/jboss/remoting/transport/socket/MicroSocketClientInvoker.java 2010-10-01 17:09:37 UTC (rev 6117)
@@ -139,7 +139,7 @@
public static long serializeTime = 0;
public static long deserializeTime = 0;
- private static final String patternString = "^.*(?:connection.*reset|connection.*closed|broken.*pipe).*$";
+ private static final String patternString = "^.*(?:connection.*reset|connection.*closed|broken.*pipe|connection.*shutdown).*$";
private static final Pattern RETRIABLE_ERROR_MESSAGE = Pattern.compile(patternString, Pattern.CASE_INSENSITIVE);
/**
Copied: remoting2/branches/2.5.2.SP2_JBREM-1245/src/tests/org/jboss/test/remoting/transport/socket/retriable (from rev 6108, remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/retriable)
Deleted: remoting2/branches/2.5.2.SP2_JBREM-1245/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java
===================================================================
--- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java 2010-09-23 04:08:58 UTC (rev 6108)
+++ remoting2/branches/2.5.2.SP2_JBREM-1245/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java 2010-10-01 17:09:37 UTC (rev 6117)
@@ -1,340 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2010, 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.retriable;
-
-import java.io.IOException;
-import java.io.OutputStream;
-import java.net.InetAddress;
-import java.net.Socket;
-import java.net.UnknownHostException;
-import java.util.HashMap;
-import java.util.Map;
-
-import javax.management.MBeanServer;
-import javax.net.SocketFactory;
-import javax.net.ssl.SSLException;
-
-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.Remoting;
-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;
-
-
-/**
- * Unit test for JBREM-1245.
- *
- * @author <a href="mailto:ron.sigal@jboss.com">Ron Sigal</a>
- * @version $Rev$
- * <p>
- * Copyright Sep 22, 2010
- * </p>
- */
-public class SocketGeneralizedExceptionTestCase extends TestCase
-{
- private static Logger log = Logger.getLogger(SocketGeneralizedExceptionTestCase.class);
-
- private static boolean firstTime = true;
- protected static IOException exceptionToThrow;
-
- 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.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;
- TestOutputStream.threwException = false;
- }
-
-
- public void tearDown()
- {
- }
-
-
- public void testSSLException() throws Throwable
- {
- log.info("entering " + getName());
- exceptionToThrow = new SSLException("Connection has been shutdown");
- doTest();
- log.info(getName() + " PASSES");
- }
-
-
- public void testConnectionResetException() throws Throwable
- {
- log.info("entering " + getName());
- exceptionToThrow = new IOException("Connection reset by peer");
- doTest();
- log.info(getName() + " PASSES");
- }
-
-
- public void testConnectionClosedException() throws Throwable
- {
- log.info("entering " + getName());
- exceptionToThrow = new IOException("Connection is closed");
- doTest();
- log.info(getName() + " PASSES");
- }
-
-
- public void testBrokenPipeException() throws Throwable
- {
- log.info("entering " + getName());
- exceptionToThrow = new IOException("Broken pipe");
- doTest();
- log.info(getName() + " PASSES");
- }
-
-
- protected void doTest() throws Throwable
- {
- // Start server.
- setupServer();
-
- // Create client.
- InvokerLocator clientLocator = new InvokerLocator(locatorURI);
- HashMap clientConfig = new HashMap();
- clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
- clientConfig.put(Remoting.CUSTOM_SOCKET_FACTORY, new TestSocketFactory(2));
- addExtraClientConfig(clientConfig);
- Client client = new Client(clientLocator, clientConfig);
- client.connect();
- log.info("client is connected");
-
- // Verify invocation works in spite of exception.
- assertEquals("xyz", client.invoke("xyz"));
- assertTrue(TestOutputStream.threwException);
-
- client.disconnect();
- shutdownServer();
- }
-
-
- protected String getTransport()
- {
- return "socket";
- }
-
- protected void addExtraServerConfig(Map config) {}
- protected void addExtraClientConfig(Map config) {}
-
-
- protected void setupServer() throws Exception
- {
- host = InetAddress.getLocalHost().getHostAddress();
- port = PortUtil.findFreePort(host);
- locatorURI = getTransport() + "://" + host + ":" + port + "/?generalizeSocketException=true";
- String metadata = System.getProperty("remoting.metadata");
- if (metadata != null)
- {
- locatorURI += "&" + metadata;
- }
- 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) {}
- }
-
-
- public static class TestSocketFactory extends SocketFactory
- {
- int initialSuccesses = 1;
-
- public TestSocketFactory()
- {
- }
- public TestSocketFactory(int initialSuccesses)
- {
- this.initialSuccesses = initialSuccesses;
- }
- public Socket createSocket()
- {
- Socket s = new TestSocket(initialSuccesses);
- log.info("returning " + s);
- return s;
- }
- public Socket createSocket(String arg0, int arg1) throws IOException, UnknownHostException
- {
- Socket s = new TestSocket(arg0, arg1, initialSuccesses);
- log.info("returning " + s);
- return s;
- }
-
- public Socket createSocket(InetAddress arg0, int arg1) throws IOException
- {
- Socket s = new TestSocket(arg0, arg1, initialSuccesses);
- log.info("returning " + s);
- return s;
- }
-
- public Socket createSocket(String arg0, int arg1, InetAddress arg2, int arg3) throws IOException, UnknownHostException
- {
- Socket s = new TestSocket(arg0, arg1, arg2, arg3, initialSuccesses);
- log.info("returning " + s);
- return s;
- }
-
- public Socket createSocket(InetAddress arg0, int arg1, InetAddress arg2, int arg3) throws IOException
- {
- Socket s = new TestSocket(arg0, arg1, arg2, arg3, initialSuccesses);
- log.info("returning " + s);
- return s;
- }
- }
-
-
- static class TestSocket extends Socket
- {
- int initialSuccesses;
-
- public TestSocket(int initialWrites)
- {
- this.initialSuccesses = initialWrites;
- }
- public TestSocket(String host, int port, int initialWrites) throws UnknownHostException, IOException
- {
- super(host, port);
- this.initialSuccesses = initialWrites;
- }
- public TestSocket(InetAddress address, int port, int initialWrites) throws IOException
- {
- super(address, port);
- this.initialSuccesses = initialWrites;
- }
- public TestSocket(String host, int port, InetAddress localAddr, int localPort, int initialWrites) throws IOException
- {
- super(host, port, localAddr, localPort);
- this.initialSuccesses = initialWrites;
- }
- public TestSocket(InetAddress address, int port, InetAddress localAddr, int localPort, int initialWrites) throws IOException
- {
- super(address, port, localAddr, localPort);
- this.initialSuccesses = initialWrites;
- }
- public OutputStream getOutputStream() throws IOException
- {
- return new TestOutputStream(super.getOutputStream(), initialSuccesses);
- }
- public String toString()
- {
- return "TestSocket[" + getLocalPort() + "->" + getPort() + "]";
- }
- }
-
-
- static class TestOutputStream extends OutputStream
- {
- public static int counter;
- public static boolean threwException;
-
- OutputStream os;
- boolean closed;
- int initialWrites;
- boolean doThrow = true;
-
- public TestOutputStream(OutputStream os, int initialWrites)
- {
- this.os = os;
- this.initialWrites = initialWrites;
- }
- public void write(int b) throws IOException
- {
- if (doThrow && ++counter == initialWrites)
- {
- log.info("throwing " + exceptionToThrow);
- threwException = true;
- throw exceptionToThrow;
- }
- os.write(b);
- }
- public void write(byte b[], int off, int len) throws IOException
- {
- log.info("TestOutputStream: counter = " + (counter + 1) + ", initialWrites = " + initialWrites);
- if (++counter == initialWrites)
- {
- log.info("throwing " + exceptionToThrow);
- threwException = true;
- throw exceptionToThrow;
- }
- log.info(this + " calling write()");
- doThrow = false;
- os.write(b, off, len);
- os.flush();
- doThrow = true;
- log.info(this + " back from write()");
- }
- }
-}
\ No newline at end of file
Copied: remoting2/branches/2.5.2.SP2_JBREM-1245/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java (from rev 6108, remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java)
===================================================================
--- remoting2/branches/2.5.2.SP2_JBREM-1245/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java (rev 0)
+++ remoting2/branches/2.5.2.SP2_JBREM-1245/src/tests/org/jboss/test/remoting/transport/socket/retriable/SocketGeneralizedExceptionTestCase.java 2010-10-01 17:09:37 UTC (rev 6117)
@@ -0,0 +1,341 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2010, 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.retriable;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.net.InetAddress;
+import java.net.Socket;
+import java.net.UnknownHostException;
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.management.MBeanServer;
+import javax.net.SocketFactory;
+import javax.net.ssl.SSLException;
+
+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.logging.XLevel;
+import org.jboss.remoting.Client;
+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.InvokerCallbackHandler;
+import org.jboss.remoting.transport.Connector;
+import org.jboss.remoting.transport.PortUtil;
+
+
+/**
+ * Unit test for JBREM-1245.
+ *
+ * @author <a href="mailto:ron.sigal@jboss.com">Ron Sigal</a>
+ * @version $Rev$
+ * <p>
+ * Copyright Sep 22, 2010
+ * </p>
+ */
+public class SocketGeneralizedExceptionTestCase extends TestCase
+{
+ private static Logger log = Logger.getLogger(SocketGeneralizedExceptionTestCase.class);
+
+ private static boolean firstTime = true;
+ protected static IOException exceptionToThrow;
+
+ 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(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);
+ }
+
+ TestOutputStream.counter = 0;
+ TestOutputStream.threwException = false;
+ }
+
+
+ public void tearDown()
+ {
+ }
+
+
+ public void testSSLException() throws Throwable
+ {
+ log.info("entering " + getName());
+ exceptionToThrow = new SSLException("Connection has been shutdown");
+ doTest();
+ log.info(getName() + " PASSES");
+ }
+
+
+ public void testConnectionResetException() throws Throwable
+ {
+ log.info("entering " + getName());
+ exceptionToThrow = new IOException("Connection reset by peer");
+ doTest();
+ log.info(getName() + " PASSES");
+ }
+
+
+ public void testConnectionClosedException() throws Throwable
+ {
+ log.info("entering " + getName());
+ exceptionToThrow = new IOException("Connection is closed");
+ doTest();
+ log.info(getName() + " PASSES");
+ }
+
+
+ public void testBrokenPipeException() throws Throwable
+ {
+ log.info("entering " + getName());
+ exceptionToThrow = new IOException("Broken pipe");
+ doTest();
+ log.info(getName() + " PASSES");
+ }
+
+
+ protected void doTest() throws Throwable
+ {
+ // Start server.
+ setupServer();
+
+ // Create client.
+ InvokerLocator clientLocator = new InvokerLocator(locatorURI);
+ HashMap clientConfig = new HashMap();
+ clientConfig.put(InvokerLocator.FORCE_REMOTE, "true");
+ clientConfig.put(Remoting.CUSTOM_SOCKET_FACTORY, new TestSocketFactory(2));
+ addExtraClientConfig(clientConfig);
+ Client client = new Client(clientLocator, clientConfig);
+ client.connect();
+ log.info("client is connected");
+
+ // Verify invocation works in spite of exception.
+ assertEquals("xyz", client.invoke("xyz"));
+ assertTrue(TestOutputStream.threwException);
+
+ client.disconnect();
+ shutdownServer();
+ }
+
+
+ protected String getTransport()
+ {
+ return "socket";
+ }
+
+ protected void addExtraServerConfig(Map config) {}
+ protected void addExtraClientConfig(Map config) {}
+
+
+ protected void setupServer() throws Exception
+ {
+ host = InetAddress.getLocalHost().getHostAddress();
+ port = PortUtil.findFreePort(host);
+ locatorURI = getTransport() + "://" + host + ":" + port + "/?generalizeSocketException=true";
+ String metadata = System.getProperty("remoting.metadata");
+ if (metadata != null)
+ {
+ locatorURI += "&" + metadata;
+ }
+ 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) {}
+ }
+
+
+ public static class TestSocketFactory extends SocketFactory
+ {
+ int initialSuccesses = 1;
+
+ public TestSocketFactory()
+ {
+ }
+ public TestSocketFactory(int initialSuccesses)
+ {
+ this.initialSuccesses = initialSuccesses;
+ }
+ public Socket createSocket()
+ {
+ Socket s = new TestSocket(initialSuccesses);
+ log.info("returning " + s);
+ return s;
+ }
+ public Socket createSocket(String arg0, int arg1) throws IOException, UnknownHostException
+ {
+ Socket s = new TestSocket(arg0, arg1, initialSuccesses);
+ log.info("returning " + s);
+ return s;
+ }
+
+ public Socket createSocket(InetAddress arg0, int arg1) throws IOException
+ {
+ Socket s = new TestSocket(arg0, arg1, initialSuccesses);
+ log.info("returning " + s);
+ return s;
+ }
+
+ public Socket createSocket(String arg0, int arg1, InetAddress arg2, int arg3) throws IOException, UnknownHostException
+ {
+ Socket s = new TestSocket(arg0, arg1, arg2, arg3, initialSuccesses);
+ log.info("returning " + s);
+ return s;
+ }
+
+ public Socket createSocket(InetAddress arg0, int arg1, InetAddress arg2, int arg3) throws IOException
+ {
+ Socket s = new TestSocket(arg0, arg1, arg2, arg3, initialSuccesses);
+ log.info("returning " + s);
+ return s;
+ }
+ }
+
+
+ static class TestSocket extends Socket
+ {
+ int initialSuccesses;
+
+ public TestSocket(int initialWrites)
+ {
+ this.initialSuccesses = initialWrites;
+ }
+ public TestSocket(String host, int port, int initialWrites) throws UnknownHostException, IOException
+ {
+ super(host, port);
+ this.initialSuccesses = initialWrites;
+ }
+ public TestSocket(InetAddress address, int port, int initialWrites) throws IOException
+ {
+ super(address, port);
+ this.initialSuccesses = initialWrites;
+ }
+ public TestSocket(String host, int port, InetAddress localAddr, int localPort, int initialWrites) throws IOException
+ {
+ super(host, port, localAddr, localPort);
+ this.initialSuccesses = initialWrites;
+ }
+ public TestSocket(InetAddress address, int port, InetAddress localAddr, int localPort, int initialWrites) throws IOException
+ {
+ super(address, port, localAddr, localPort);
+ this.initialSuccesses = initialWrites;
+ }
+ public OutputStream getOutputStream() throws IOException
+ {
+ return new TestOutputStream(super.getOutputStream(), initialSuccesses);
+ }
+ public String toString()
+ {
+ return "TestSocket[" + getLocalPort() + "->" + getPort() + "]";
+ }
+ }
+
+
+ static class TestOutputStream extends OutputStream
+ {
+ public static int counter;
+ public static boolean threwException;
+
+ OutputStream os;
+ boolean closed;
+ int initialWrites;
+ boolean doThrow = true;
+
+ public TestOutputStream(OutputStream os, int initialWrites)
+ {
+ this.os = os;
+ this.initialWrites = initialWrites;
+ }
+ public void write(int b) throws IOException
+ {
+ if (doThrow && ++counter == initialWrites)
+ {
+ log.info("throwing " + exceptionToThrow);
+ threwException = true;
+ throw exceptionToThrow;
+ }
+ os.write(b);
+ }
+ public void write(byte b[], int off, int len) throws IOException
+ {
+ log.info("TestOutputStream: counter = " + (counter + 1) + ", initialWrites = " + initialWrites);
+ if (++counter == initialWrites)
+ {
+ log.info("throwing " + exceptionToThrow);
+ threwException = true;
+ throw exceptionToThrow;
+ }
+ log.info(this + " calling write()");
+ doThrow = false;
+ os.write(b, off, len);
+ os.flush();
+ doThrow = true;
+ log.info(this + " back from write()");
+ }
+ }
+}
\ No newline at end of file
13 years, 7 months
- 1
- 0