Author: fhanik
Date: Thu Jun 28 14:21:37 2007
New Revision: 551702
URL: http://svn.apache.org/viewvc?view=rev&rev=551702
Log:
try setting equalness to false, see if we can do better
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
tomcat/trunk/test/org/apache/catalina/tribes/test/io/TestSenderConnections.java
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java?view=diff&rev=551702&r1=551701&r2=551702
==============================================================================
---
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
(original)
+++
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/OrderInterceptor.java
Thu Jun 28 14:21:37 2007
@@ -61,8 +61,8 @@
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()) ) {
Modified:
tomcat/trunk/test/org/apache/catalina/tribes/test/io/TestSenderConnections.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/test/org/apache/catalina/tribes/test/io/TestSenderConnections.java?view=diff&rev=551702&r1=551701&r2=551702
==============================================================================
---
tomcat/trunk/test/org/apache/catalina/tribes/test/io/TestSenderConnections.java
(original)
+++
tomcat/trunk/test/org/apache/catalina/tribes/test/io/TestSenderConnections.java
Thu Jun 28 14:21:37 2007
@@ -29,6 +29,9 @@
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;
@@ -66,6 +69,15 @@
public void testConnectionLinger() throws Exception {
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 {
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
