tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fha...@apache.org
Subject svn commit: r382792 - in /tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes: Channel.java group/GroupChannel.java tcp/ReplicationTransmitter.java
Date Fri, 03 Mar 2006 12:51:43 GMT
Author: fhanik
Date: Fri Mar  3 04:51:42 2006
New Revision: 382792

URL: http://svn.apache.org/viewcvs?rev=382792&view=rev
Log:
Added in the ability to send a message to a member that has not yet made itself visible but
that has sent messages out.

Modified:
    tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java
    tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java
    tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java

Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java
URL: http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java?rev=382792&r1=382791&r2=382792&view=diff
==============================================================================
--- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java
(original)
+++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java
Fri Mar  3 04:51:42 2006
@@ -102,6 +102,13 @@
      * @return Member
      */
     public Member getLocalMember() ;
+    
+    /**
+     * 
+     * @param mbr Member
+     * @return Member
+     */
+    public Member getMember(Member mbr);
 
     
 }

Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java
URL: http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java?rev=382792&r1=382791&r2=382792&view=diff
==============================================================================
--- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java
(original)
+++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java
Fri Mar  3 04:51:42 2006
@@ -238,6 +238,16 @@
     public Member[] getMembers() {
         return coordinator.getMembershipService().getMembers();
     }
+    
+    /**
+     * 
+     * @param mbr Member
+     * @return Member
+     */
+    public Member getMember(Member mbr){
+        return coordinator.getMembershipService().getMember(mbr);
+    }
+
 
     /**
      * Return the member that represents this node.

Modified: tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java
URL: http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java?rev=382792&r1=382791&r2=382792&view=diff
==============================================================================
--- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java
(original)
+++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java
Fri Mar  3 04:51:42 2006
@@ -285,11 +285,12 @@
         }
     }
     
+    /**
+     * @todo FIX THIS TO BE IN THE FACTORY
+     */
     PooledParallelSender parallelsender = null;
     public MultiPointSender getParallelSender() {
         if ( parallelsender == null ) {
-
-
             PooledParallelSender sender = new PooledParallelSender();
             sender.setMaxRetryAttempts(2);
             sender.setRxBufSize(getRxBufSize());
@@ -305,6 +306,10 @@
     public void sendMessage(ChannelMessage message, Member destination) throws ChannelException
{       
         Object key = getKey(destination);
         SinglePointSender sender = (SinglePointSender) map.get(key);
+        if ( sender == null ) {
+            add(destination);
+            sender = (SinglePointSender) map.get(key);
+        }
         sendMessageData(message, sender);
     }
     



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org


Mime
View raw message