From 03ccb8265d5edbaf096828700d6bcb183caa7402 Mon Sep 17 00:00:00 2001 From: fhanik Date: Thu, 28 Jun 2007 21:21:37 +0000 Subject: [PATCH] try setting equalness to false, see if we can do better git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@551702 13f79535-47bb-0310-9956-ffa450edef68 --- .../catalina/tribes/group/interceptors/OrderInterceptor.java | 4 ++-- .../catalina/tribes/test/io/TestSenderConnections.java | 12 ++++++++++++ 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java b/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java index f92398b9e..16432d11e 100644 --- a/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java +++ b/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java @@ -61,8 +61,8 @@ public class OrderInterceptor extends ChannelInterceptorBase { private boolean forwardExpired = true; private int maxQueue = Integer.MAX_VALUE; - ReentrantReadWriteLock inLock = new ReentrantReadWriteLock(true); - ReentrantReadWriteLock outLock= new ReentrantReadWriteLock(true); + ReentrantReadWriteLock inLock = new ReentrantReadWriteLock(false); + ReentrantReadWriteLock outLock= new ReentrantReadWriteLock(false); public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException { if ( !okToProcess(msg.getOptions()) ) { diff --git a/test/org/apache/catalina/tribes/test/io/TestSenderConnections.java b/test/org/apache/catalina/tribes/test/io/TestSenderConnections.java index 553e1cfe1..6b52f9b90 100644 --- a/test/org/apache/catalina/tribes/test/io/TestSenderConnections.java +++ b/test/org/apache/catalina/tribes/test/io/TestSenderConnections.java @@ -29,6 +29,9 @@ import java.io.Serializable; import java.util.Random; import java.util.HashMap; import org.apache.catalina.tribes.transport.ReplicationTransmitter; +import org.apache.catalina.tribes.membership.MemberImpl; +import org.apache.catalina.tribes.transport.DataSender; +import org.apache.catalina.tribes.transport.AbstractSender; public class TestSenderConnections extends TestCase { private static int count = 2; @@ -68,6 +71,15 @@ public class TestSenderConnections extends TestCase { sendMessages(0,15000); } + public void testSendToNonExistent() throws Exception { + ReplicationTransmitter transmitter = (ReplicationTransmitter) channels[0].getChannelSender(); + AbstractSender sender = (AbstractSender)transmitter.getTransport(); + sender.setMaxRetryAttempts(0); + sender.setTimeout(60000); + MemberImpl impl = new MemberImpl("127.0.0.1",9443,1000,new byte[]{1,2,3,4,5,6,7,8,1,2,3,4,5,6,7,8}); + channels[0].send(new Member[]{impl},new TestMsg(),0); + } + public void testKeepAliveCount() throws Exception { System.out.println("Setting keep alive count to 0"); for (int i = 0; i < channels.length; i++) { -- 2.11.0