import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * memberAdded gets invoked by the interceptor below the channel
 * and the channel will broadcast it to the membership listeners
 * @param member Member - the new member
 */
@Override
public void memberAdded(Member member) {
    //notify upwards
    for (int i=0; i<membershipListeners.size(); i++ ) {
        MembershipListener membershipListener = (MembershipListener)membershipListeners.get(i);
        if (membershipListener != null) membershipListener.memberAdded(member);
    }
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * memberDisappeared gets invoked by the interceptor below the channel
 * and the channel will broadcast it to the membership listeners
 * @param member Member - the member that left or crashed
 */
@Override
public void memberDisappeared(Member member) {
    //notify upwards
    for (int i=0; i<membershipListeners.size(); i++ ) {
        MembershipListener membershipListener = (MembershipListener)membershipListeners.get(i);
        if (membershipListener != null) membershipListener.memberDisappeared(member);
    }
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * Create a new mcast service impl
 * @param member - the local member
 * @param sendFrequency - the time (ms) in between pings sent out
 * @param expireTime - the time (ms) for a member to expire
 * @param port - the mcast port
 * @param bind - the bind address (not sure this is used yet)
 * @param mcastAddress - the mcast address
 * @param service - the callback service
 * @param localLoopbackDisabled - disable loopbackMode
 * @throws IOException
 */
public McastServiceImpl(
    MemberImpl member,
    long sendFrequency,
    long expireTime,
    int port,
    InetAddress bind,
    InetAddress mcastAddress,
    int ttl,
    int soTimeout,
    MembershipListener service,
    MessageListener msgservice,
    boolean localLoopbackDisabled)
throws IOException {
    this.member = member;
    this.address = mcastAddress;
    this.port = port;
    this.mcastSoTimeout = soTimeout;
    this.mcastTTL = ttl;
    this.mcastBindAddress = bind;
    this.timeToExpiration = expireTime;
    this.service = service;
    this.msgservice = msgservice;
    this.sendFrequency = sendFrequency;
    this.localLoopbackDisabled = localLoopbackDisabled;
    init();
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * memberAdded gets invoked by the interceptor below the channel and the
 * channel will broadcast it to the membership listeners
 * 
 * @param member
 *            Member - the new member
 */
@Override
public void memberAdded(Member member) {
	// notify upwards
	for (int i = 0; i < membershipListeners.size(); i++) {
		MembershipListener membershipListener = (MembershipListener) membershipListeners.get(i);
		if (membershipListener != null)
			membershipListener.memberAdded(member);
	}
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * memberDisappeared gets invoked by the interceptor below the channel and
 * the channel will broadcast it to the membership listeners
 * 
 * @param member
 *            Member - the member that left or crashed
 */
@Override
public void memberDisappeared(Member member) {
	// notify upwards
	for (int i = 0; i < membershipListeners.size(); i++) {
		MembershipListener membershipListener = (MembershipListener) membershipListeners.get(i);
		if (membershipListener != null)
			membershipListener.memberDisappeared(member);
	}
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * Adds a membership listener to the channel.<br>
 * Membership listeners are uniquely identified using the equals(Object) method
 * @param membershipListener MembershipListener
 */
@Override
public void addMembershipListener(MembershipListener membershipListener) {
    if (!this.membershipListeners.contains(membershipListener) )
        this.membershipListeners.add(membershipListener);
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * Removes a membership listener from the channel.<br>
 * Membership listeners are uniquely identified using the equals(Object) method
 * @param membershipListener MembershipListener
 */

@Override
public void removeMembershipListener(MembershipListener membershipListener) {
    membershipListeners.remove(membershipListener);
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * Create a new mcast service impl
 * 
 * @param member
 *            - the local member
 * @param sendFrequency
 *            - the time (ms) in between pings sent out
 * @param expireTime
 *            - the time (ms) for a member to expire
 * @param port
 *            - the mcast port
 * @param bind
 *            - the bind address (not sure this is used yet)
 * @param mcastAddress
 *            - the mcast address
 * @param service
 *            - the callback service
 * @param localLoopbackDisabled
 *            - disable loopbackMode
 * @throws IOException
 */
public McastServiceImpl(MemberImpl member, long sendFrequency, long expireTime, int port, InetAddress bind,
		InetAddress mcastAddress, int ttl, int soTimeout, MembershipListener service, MessageListener msgservice,
		boolean localLoopbackDisabled) throws IOException {
	this.member = member;
	this.address = mcastAddress;
	this.port = port;
	this.mcastSoTimeout = soTimeout;
	this.mcastTTL = ttl;
	this.mcastBindAddress = bind;
	this.timeToExpiration = expireTime;
	this.service = service;
	this.msgservice = msgservice;
	this.sendFrequency = sendFrequency;
	this.localLoopbackDisabled = localLoopbackDisabled;
	init();
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
public void setMembershipListener(MembershipListener membershipListener) {
    // Nothing to do
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * Add a membership listener, this version only supports one listener per service,
 * so calling this method twice will result in only the second listener being active.
 * @param listener The listener
 */
@Override
public void setMembershipListener(MembershipListener listener) {
    this.listener = listener;
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * Adds a membership listener to the channel.<br>
 * Membership listeners are uniquely identified using the equals(Object)
 * method
 * 
 * @param membershipListener
 *            MembershipListener
 */
@Override
public void addMembershipListener(MembershipListener membershipListener) {
	if (!this.membershipListeners.contains(membershipListener))
		this.membershipListeners.add(membershipListener);
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * Removes a membership listener from the channel.<br>
 * Membership listeners are uniquely identified using the equals(Object)
 * method
 * 
 * @param membershipListener
 *            MembershipListener
 */

@Override
public void removeMembershipListener(MembershipListener membershipListener) {
	membershipListeners.remove(membershipListener);
}
 

import org.apache.catalina.tribes.MembershipListener; //导入依赖的package包/类
/**
 * Add a membership listener, this version only supports one listener per
 * service, so calling this method twice will result in only the second
 * listener being active.
 * 
 * @param listener
 *            The listener
 */
@Override
public void setMembershipListener(MembershipListener listener) {
	this.listener = listener;
}