You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by fh...@apache.org on 2006/03/03 13:51:43 UTC
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
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