| java.lang.Object
 org.apache.catalina.cluster.mcast.McastMembership
| McastMembership | | public class McastMembership (Code) | | A membership implementation using simple multicast.
This is the representation of a multicast membership.
This class is responsible for maintaining a list of active cluster nodes in the cluster.
If a node fails to send out a heartbeat, the node will be dismissed.
author:
Filip Hanik
version:
$Revision: 1.5 $, $Date: 2004/05/26 16:35:59 $ |
| Inner Class :protected static class MbrEntry | |
| Constructor Summary | |
| public | McastMembership(String myName)
Constructs a new membership
Parameters:
myName - - has to be the name of the local member. |
| Method Summary | |
| public synchronized McastMember[] | expire(long maxtime)
Runs a refresh cycle and returns a list of members that has expired.
This also removes the members from the membership, in such a way that
getMembers() = getMembers() - expire()
Parameters:
maxtime - - the max time a member can remain unannounced before it is considered dead. | | protected synchronized MbrEntry[] | getMemberEntries()
| | public synchronized McastMember[] | getMembers()
| | public synchronized boolean | memberAlive(McastMember m)
Notify the membership that this member has announced itself.
Parameters:
m - - the member that just pinged us - true if this member is new to the cluster, false otherwise. | | public synchronized void | reset()
Reset the membership and start over fresh. |
| map | | protected HashMap map(Code) | | A map of all the members in the cluster.
|
| name | | protected String name(Code) | | The name of this membership, has to be the same as the name for the local
member
|
| McastMembership | | public McastMembership(String myName)(Code) | | Constructs a new membership
Parameters:
myName - - has to be the name of the local member. Used to filter the local member from the cluster membership |
| expire | | public synchronized McastMember[] expire(long maxtime)(Code) | | Runs a refresh cycle and returns a list of members that has expired.
This also removes the members from the membership, in such a way that
getMembers() = getMembers() - expire()
Parameters:
maxtime - - the max time a member can remain unannounced before it is considered dead. the list of expired members |
| getMemberEntries | | protected synchronized MbrEntry[] getMemberEntries()(Code) | | |
| getMembers | | public synchronized McastMember[] getMembers()(Code) | | Returning a list of all the members in the membership
|
| memberAlive | | public synchronized boolean memberAlive(McastMember m)(Code) | | Notify the membership that this member has announced itself.
Parameters:
m - - the member that just pinged us - true if this member is new to the cluster, false otherwise. - false if this member is the local member. |
| reset | | public synchronized void reset()(Code) | | Reset the membership and start over fresh.
Ie, delete all the members and wait for them to ping again and join this membership
|
|
|