From e8f38625650f0ead3ebe9be54e37b869e63b5c76 Mon Sep 17 00:00:00 2001 From: fhanik Date: Thu, 26 Apr 2007 16:52:29 +0000 Subject: [PATCH] Change the name to a more appropriate name git-svn-id: https://svn.apache.org/repos/asf/tomcat/tc6.0.x/trunk@532800 13f79535-47bb-0310-9956-ffa450edef68 --- java/org/apache/catalina/tribes/transport/MultiPointSender.java | 4 ++-- java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java | 4 ++-- .../org/apache/catalina/tribes/transport/bio/MultipointBioSender.java | 4 ++-- java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java | 4 ++-- java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java | 4 ++-- .../apache/catalina/tribes/transport/nio/PooledParallelSender.java | 4 ++-- 6 files changed, 12 insertions(+), 12 deletions(-) diff --git a/java/org/apache/catalina/tribes/transport/MultiPointSender.java b/java/org/apache/catalina/tribes/transport/MultiPointSender.java index 1a5f1e7a9..e1b1c4a17 100644 --- a/java/org/apache/catalina/tribes/transport/MultiPointSender.java +++ b/java/org/apache/catalina/tribes/transport/MultiPointSender.java @@ -33,6 +33,6 @@ public interface MultiPointSender extends DataSender public void setTxBufSize(int size); public void setMaxRetryAttempts(int attempts); public void setDirectBuffer(boolean directBuf); - public void memberAdded(Member member); - public void memberDisappeared(Member member); + public void add(Member member); + public void remove(Member member); } diff --git a/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java b/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java index 04065c7e3..cb3e8543a 100644 --- a/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java +++ b/java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java @@ -116,7 +116,7 @@ public class ReplicationTransmitter implements ChannelSender { * @see org.apache.catalina.tribes.ClusterSender#add(org.apache.catalina.tribes.Member) */ public synchronized void add(Member member) { - getTransport().memberAdded(member); + getTransport().add(member); } /** @@ -125,7 +125,7 @@ public class ReplicationTransmitter implements ChannelSender { * @see org.apache.catalina.tribes.ClusterSender#remove(org.apache.catalina.tribes.Member) */ public synchronized void remove(Member member) { - getTransport().memberDisappeared(member); + getTransport().remove(member); } // ------------------------------------------------------------- protected diff --git a/java/org/apache/catalina/tribes/transport/bio/MultipointBioSender.java b/java/org/apache/catalina/tribes/transport/bio/MultipointBioSender.java index 34924aeb9..3672a3c86 100644 --- a/java/org/apache/catalina/tribes/transport/bio/MultipointBioSender.java +++ b/java/org/apache/catalina/tribes/transport/bio/MultipointBioSender.java @@ -107,11 +107,11 @@ public class MultipointBioSender extends AbstractSender implements MultiPointSen if ( x != null ) throw x; } - public void memberAdded(Member member) { + public void add(Member member) { } - public void memberDisappeared(Member member) { + public void remove(Member member) { //disconnect senders BioSender sender = (BioSender)bioSenders.remove(member); if ( sender != null ) sender.disconnect(); diff --git a/java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java b/java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java index 6491073fa..a9f864dda 100644 --- a/java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java +++ b/java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java @@ -70,11 +70,11 @@ public class PooledMultiSender extends PooledSender { } - public void memberAdded(Member member) { + public void add(Member member) { } - public void memberDisappeared(Member member) { + public void remove(Member member) { //disconnect senders } diff --git a/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java b/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java index c606e44cf..2b41edf59 100644 --- a/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java +++ b/java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java @@ -256,11 +256,11 @@ public class ParallelNioSender extends AbstractSender implements MultiPointSende if ( x != null ) throw x; } - public void memberAdded(Member member) { + public void add(Member member) { } - public void memberDisappeared(Member member) { + public void remove(Member member) { //disconnect senders NioSender sender = (NioSender)nioSenders.remove(member); if ( sender != null ) sender.disconnect(); diff --git a/java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java b/java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java index 2403fb0a2..534aeb293 100644 --- a/java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java +++ b/java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java @@ -73,11 +73,11 @@ public class PooledParallelSender extends PooledSender implements MultiPointSend super.connect(); } - public void memberAdded(Member member) { + public void add(Member member) { } - public void memberDisappeared(Member member) { + public void remove(Member member) { //disconnect senders } } \ No newline at end of file -- 2.11.0