[prev in list] [next in list] [prev in thread] [next in thread] 

List:       tomcat-dev
Subject:    svn commit: r551702 - in /tomcat/trunk:
From:       fhanik () apache ! org
Date:       2007-06-28 21:21:38
Message-ID: 20070628212138.BBAE11A981A () eris ! apache ! org
[Download RAW message or body]

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: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org


[prev in list] [next in list] [prev in thread] [next in thread]