Author: kfujino
Date: Thu Apr 21 07:11:23 2016
New Revision: 1740245
URL: http://svn.apache.org/viewvc?rev=1740245&view=rev
Log:
Revert r1740046.
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelCoordinator.java
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelInterceptorBase.java
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.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/java/org/apache/catalina/tribes/transport/bio/BioReceiver.java
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReceiver.java
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=1740245&r1=1740244&r2=1740245&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
Thu Apr 21 07:11:23 2016
@@ -154,11 +154,11 @@ public class ChannelCoordinator extends
if ( Channel.SND_RX_SEQ==(svc & Channel.SND_RX_SEQ) ) {
clusterReceiver.setMessageListener(this);
if (clusterReceiver instanceof ReceiverBase) {
- ((ReceiverBase)clusterReceiver).setChannel(channel);
+ ((ReceiverBase)clusterReceiver).setChannel(getChannel());
}
clusterReceiver.start();
//synchronize, big time FIXME
- Member localMember = channel.getLocalMember(false);
+ Member localMember = getChannel().getLocalMember(false);
if (localMember instanceof StaticMember) {
// static member
StaticMember staticMember = (StaticMember)localMember;
@@ -176,7 +176,7 @@ public class ChannelCoordinator extends
}
if ( Channel.SND_TX_SEQ==(svc & Channel.SND_TX_SEQ) ) {
if (clusterSender instanceof ReplicationTransmitter) {
-
((ReplicationTransmitter)clusterSender).setChannel(channel);
+
((ReplicationTransmitter)clusterSender).setChannel(getChannel());
}
clusterSender.start();
valid = true;
@@ -186,14 +186,14 @@ public class ChannelCoordinator extends
membershipService.setMembershipListener(this);
if (membershipService instanceof McastService) {
((McastService)membershipService).setMessageListener(this);
- ((McastService)membershipService).setChannel(channel);
+ ((McastService)membershipService).setChannel(getChannel());
}
membershipService.start(MembershipService.MBR_RX);
valid = true;
}
if ( Channel.MBR_TX_SEQ==(svc & Channel.MBR_TX_SEQ) ) {
if (membershipService instanceof McastService) {
- ((McastService)membershipService).setChannel(channel);
+ ((McastService)membershipService).setChannel(getChannel());
}
membershipService.start(MembershipService.MBR_TX);
valid = true;
@@ -255,7 +255,7 @@ public class ChannelCoordinator extends
}
startLevel = (startLevel & (~svc));
- channel = null;
+ setChannel(null);
} catch (Exception x) {
throw new ChannelException(x);
}
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelInterceptorBase.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelInterceptorBase.java?rev=1740245&r1=1740244&r2=1740245&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelInterceptorBase.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/ChannelInterceptorBase.java
Thu Apr 21 07:11:23 2016
@@ -29,7 +29,7 @@ public abstract class ChannelInterceptor
private ChannelInterceptor next;
private ChannelInterceptor previous;
- protected Channel channel;
+ private Channel channel;
//default value, always process
protected int optionFlag = 0;
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java?rev=1740245&r1=1740244&r2=1740245&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
Thu Apr 21 07:11:23 2016
@@ -136,8 +136,9 @@ public class MessageDispatchInterceptor
return;
}
String channelName = "";
- if (channel instanceof GroupChannel &&
((GroupChannel)channel).getName() != null) {
- channelName = "[" + ((GroupChannel)channel).getName() + "]";
+ if (getChannel() instanceof GroupChannel
+ && ((GroupChannel)getChannel()).getName() != null) {
+ channelName = "[" + ((GroupChannel)getChannel()).getName() + "]";
}
executor = ExecutorFactory.newThreadPool(maxSpareThreads, maxThreads,
keepAliveTime,
TimeUnit.MILLISECONDS,
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.java?rev=1740245&r1=1740244&r2=1740245&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.java
Thu Apr 21 07:11:23 2016
@@ -72,8 +72,9 @@ public class TcpPingInterceptor extends
thread = new PingThread();
thread.setDaemon(true);
String channelName = "";
- if (channel instanceof GroupChannel &&
((GroupChannel)channel).getName() != null) {
- channelName = "[" + ((GroupChannel)channel).getName() + "]";
+ if (getChannel() instanceof GroupChannel
+ && ((GroupChannel)getChannel()).getName() != null) {
+ channelName = "[" + ((GroupChannel)getChannel()).getName() +
"]";
}
thread.setName("TcpPingInterceptor.PingThread" + channelName
+"-"+cnt.addAndGet(1));
thread.start();
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=1740245&r1=1740244&r2=1740245&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
Thu Apr 21 07:11:23 2016
@@ -77,7 +77,7 @@ public class McastService implements Mem
protected byte[] domain;
- protected Channel channel;
+ private Channel channel;
/**
* Create a membership service.
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=1740245&r1=1740244&r2=1740245&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
Thu Apr 21 07:11:23 2016
@@ -157,7 +157,7 @@ public class McastServiceImpl
*/
protected final boolean localLoopbackDisabled;
- protected Channel channel;
+ private Channel channel;
/**
* Create a new mcast service impl
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=1740245&r1=1740244&r2=1740245&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
Thu Apr 21 07:11:23 2016
@@ -81,7 +81,7 @@ public abstract class ReceiverBase imple
private long maxIdleTime = 60000;
private ExecutorService executor;
- protected Channel channel;
+ private Channel channel;
public ReceiverBase() {
}
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=1740245&r1=1740244&r2=1740245&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
Thu Apr 21 07:11:23 2016
@@ -30,7 +30,7 @@ import org.apache.catalina.tribes.transp
*/
public class ReplicationTransmitter implements ChannelSender {
- protected Channel channel;
+ private Channel channel;
public ReplicationTransmitter() {
}
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/bio/BioReceiver.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/bio/BioReceiver.java?rev=1740245&r1=1740244&r2=1740245&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/bio/BioReceiver.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/bio/BioReceiver.java
Thu Apr 21 07:11:23 2016
@@ -56,8 +56,9 @@ public class BioReceiver extends Receive
getBind();
bind();
String channelName = "";
- if (channel instanceof GroupChannel &&
((GroupChannel)channel).getName() != null) {
- channelName = "[" + ((GroupChannel)channel).getName() + "]";
+ if (getChannel() instanceof GroupChannel
+ && ((GroupChannel)getChannel()).getName() != null) {
+ channelName = "[" + ((GroupChannel)getChannel()).getName() +
"]";
}
Thread t = new Thread(this, "BioReceiver" + channelName);
t.setDaemon(true);
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReceiver.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReceiver.java?rev=1740245&r1=1740244&r2=1740245&view=diff
==============================================================================
---
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReceiver.java
(original)
+++
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/transport/nio/NioReceiver.java
Thu Apr 21 07:11:23 2016
@@ -91,8 +91,9 @@ public class NioReceiver extends Receive
getBind();
bind();
String channelName = "";
- if (channel instanceof GroupChannel &&
((GroupChannel)channel).getName() != null) {
- channelName = "[" + ((GroupChannel)channel).getName() + "]";
+ if (getChannel() instanceof GroupChannel
+ && ((GroupChannel)getChannel()).getName() != null) {
+ channelName = "[" + ((GroupChannel)getChannel()).getName() +
"]";
}
Thread t = new Thread(this, "NioReceiver" + channelName);
t.setDaemon(true);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
