Author: kfujino
Date: Mon Apr 18 07:54:32 2016
New Revision: 1739701
URL: http://svn.apache.org/viewvc?rev=1739701&view=rev
Log:
Add get/set method for the channel that is related to each Channel services.
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastService.java
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java
tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java?rev=1739701&r1=1739700&r2=1739701&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java
Mon Apr 18 07:54:32 2016
@@ -27,6 +27,7 @@ import org.apache.catalina.tribes.Messag
import org.apache.catalina.tribes.UniqueId;
import org.apache.catalina.tribes.membership.McastService;
import org.apache.catalina.tribes.membership.StaticMember;
+import org.apache.catalina.tribes.transport.ReceiverBase;
import org.apache.catalina.tribes.transport.ReplicationTransmitter;
import org.apache.catalina.tribes.transport.SenderState;
import org.apache.catalina.tribes.transport.nio.NioReceiver;
@@ -168,10 +169,16 @@ public class ChannelCoordinator extends
getClusterReceiver().getSecurePort(),
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;
}
@@ -181,10 +188,16 @@ public class ChannelCoordinator extends
((McastService)membershipService).setMessageListener(this);
}
membershipService.start(MembershipService.MBR_RX);
+ if (membershipService instanceof McastService) {
+ ((McastService)membershipService).setChannel(getChannel());
+ }
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());
+ }
valid = true;
}
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastService.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastService.java?rev=1739701&r1=1739700&r2=1739701&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastService.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastService.java
Mon Apr 18 07:54:32 2016
@@ -77,6 +77,8 @@ public class McastService implements Mem
protected byte[] domain;
+ private Channel channel;
+
/**
* Create a membership service.
*/
@@ -357,7 +359,7 @@ public class McastService implements Mem
impl.setRecoveryCounter(recCnt);
long recSlpTime =
Long.parseLong(properties.getProperty("recoverySleepTime","5000"));
impl.setRecoverySleepTime(recSlpTime);
-
+ impl.setChannel(channel);
impl.start(level);
@@ -564,6 +566,14 @@ public class McastService implements Mem
else setDomain(Arrays.convert(domain));
}
+ public Channel getChannel() {
+ return channel;
+ }
+
+ public void setChannel(Channel channel) {
+ this.channel = channel;
+ }
+
/**
* Simple test program
* @param args Command-line arguments
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java?rev=1739701&r1=1739700&r2=1739701&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/membership/McastServiceImpl.java
Mon Apr 18 07:54:32 2016
@@ -156,6 +156,8 @@ public class McastServiceImpl
*/
protected final boolean localLoopbackDisabled;
+ private Channel channel;
+
/**
* Create a new mcast service impl
* @param member - the local member
@@ -526,6 +528,14 @@ public class McastServiceImpl
return recoverySleepTime;
}
+ public Channel getChannel() {
+ return channel;
+ }
+
+ public void setChannel(Channel channel) {
+ this.channel = channel;
+ }
+
public class ReceiverThread extends Thread {
int errorCounter = 0;
public ReceiverThread() {
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java?rev=1739701&r1=1739700&r2=1739701&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReceiverBase.java
Mon Apr 18 07:54:32 2016
@@ -26,6 +26,7 @@ import java.util.concurrent.ThreadFactor
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
+import org.apache.catalina.tribes.Channel;
import org.apache.catalina.tribes.ChannelMessage;
import org.apache.catalina.tribes.ChannelReceiver;
import org.apache.catalina.tribes.MessageListener;
@@ -79,7 +80,7 @@ public abstract class ReceiverBase imple
private long maxIdleTime = 60000;
private ExecutorService executor;
-
+ private Channel channel;
public ReceiverBase() {
}
@@ -488,6 +489,14 @@ public abstract class ReceiverBase imple
this.udpTxBufSize = udpTxBufSize;
}
+ public Channel getChannel() {
+ return channel;
+ }
+
+ public void setChannel(Channel channel) {
+ this.channel = channel;
+ }
+
// ---------------------------------------------- ThreadFactory Inner Class
class TaskThreadFactory implements ThreadFactory {
final ThreadGroup group;
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java?rev=1739701&r1=1739700&r2=1739701&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java
Mon Apr 18 07:54:32 2016
@@ -16,6 +16,7 @@
*/
package org.apache.catalina.tribes.transport;
+import org.apache.catalina.tribes.Channel;
import org.apache.catalina.tribes.ChannelException;
import org.apache.catalina.tribes.ChannelMessage;
import org.apache.catalina.tribes.ChannelSender;
@@ -29,6 +30,8 @@ import org.apache.catalina.tribes.transp
*/
public class ReplicationTransmitter implements ChannelSender {
+ private Channel channel;
+
public ReplicationTransmitter() {
}
@@ -105,4 +108,13 @@ public class ReplicationTransmitter impl
public synchronized void remove(Member member) {
getTransport().remove(member);
}
+
+ public Channel getChannel() {
+ return channel;
+ }
+
+ public void setChannel(Channel channel) {
+ this.channel = channel;
+ }
+
}
Modified: tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml?rev=1739701&r1=1739700&r2=1739701&view=diff
==============================================================================
--- tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml (original)
+++ tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml Mon Apr 18 07:54:32 2016
@@ -201,6 +201,10 @@
environment, the local member inherits properties from the cluster
receiver. (kfujino)
</fix>
+ <add>
+ Add get/set method for the channel that is related to each Channel
+ services. (kfujino)
+ </add>
</changelog>
</subsection>
<subsection name="Other">
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
