Author: kfujino
Date: Mon Apr 18 09:23:13 2016
New Revision: 1739716
URL: http://svn.apache.org/viewvc?rev=1739716&view=rev
Log:
Set the channel instance before starting channel services.
Modified:
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java
Modified:
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java
URL:
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java?rev=1739716&r1=1739715&r2=1739716&view=diff
==============================================================================
---
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java
(original)
+++
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java
Mon Apr 18 09:23:13 2016
@@ -143,6 +143,9 @@ public class ChannelCoordinator extends
//listens to with the local membership settings
if ( Channel.SND_RX_SEQ==(svc & Channel.SND_RX_SEQ) ) {
clusterReceiver.setMessageListener(this);
+ if (clusterReceiver instanceof ReceiverBase) {
+ ((ReceiverBase)clusterReceiver).setChannel(getChannel());
+ }
clusterReceiver.start();
//synchronize, big time FIXME
Member localMember = getChannel().getLocalMember(false);
@@ -160,35 +163,30 @@ public class ChannelCoordinator extends
getClusterReceiver().getUdpPort());
}
- if (clusterReceiver instanceof ReceiverBase) {
- ((ReceiverBase)clusterReceiver).setChannel(getChannel());
- }
valid = true;
}
if ( Channel.SND_TX_SEQ==(svc & Channel.SND_TX_SEQ) ) {
- clusterSender.start();
if (clusterSender instanceof ReplicationTransmitter) {
((ReplicationTransmitter)clusterSender).setChannel(getChannel());
}
valid = true;
+ clusterSender.start();
}
if ( Channel.MBR_RX_SEQ==(svc & Channel.MBR_RX_SEQ) ) {
membershipService.setMembershipListener(this);
if (membershipService instanceof McastService) {
((McastService)membershipService).setMessageListener(this);
- }
- membershipService.start(MembershipService.MBR_RX);
- if (membershipService instanceof McastService) {
((McastService)membershipService).setChannel(getChannel());
}
+ membershipService.start(MembershipService.MBR_RX);
valid = true;
}
if ( Channel.MBR_TX_SEQ==(svc & Channel.MBR_TX_SEQ) ) {
- membershipService.start(MembershipService.MBR_TX);
if (membershipService instanceof McastService) {
((McastService)membershipService).setChannel(getChannel());
}
+ membershipService.start(MembershipService.MBR_TX);
valid = true;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
