|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.catalina.cluster.mcast.McastServiceImpl
A membership implementation using simple multicast. This is the representation of a multicast membership service. 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. This is the low level implementation that handles the multicasting sockets. Need to fix this, could use java.nio and only need one thread to send and receive, or just use a timeout on the receive
Nested Class Summary | |
class |
McastServiceImpl.ReceiverThread
|
protected static class |
McastServiceImpl.RecoveryThread
|
class |
McastServiceImpl.SenderThread
|
Field Summary | |
protected java.net.InetAddress |
address
The multicast address |
protected boolean |
doRun
Internal flag used for the listen thread that listens to the multicasting socket. |
protected java.net.InetAddress |
mcastBindAddress
|
protected int |
mcastSoTimeout
|
protected int |
mcastTTL
|
protected McastMember |
member
The local member that we intend to broad cast over and over again |
protected McastMembership |
membership
The membership, used so that we calculate memberships when they arrive or don't arrive |
protected java.lang.Object |
membershipMutex
|
protected int |
port
The multicast port |
protected java.net.DatagramPacket |
receivePacket
Reuse the receivePacket, no need to create a new one everytime |
protected McastServiceImpl.ReceiverThread |
receiver
Thread to listen for pings |
protected int |
recoveryCounter
nr of times the system has to fail before a recovery is initiated |
protected boolean |
recoveryEnabled
Add the ability to turn on/off recovery |
protected long |
recoverySleepTime
The time the recovery thread sleeps between recovery attempts |
protected McastServiceImpl.SenderThread |
sender
Thread to send pings |
protected long |
sendFrequency
How often to we send out a broadcast saying we are alive, must be smaller than timeToExpiration |
protected java.net.DatagramPacket |
sendPacket
Reuse the sendPacket, no need to create a new one everytime |
protected MembershipListener |
service
The actual listener, for callback when shits goes down |
protected long |
serviceStartTime
When was the service started |
protected java.net.MulticastSocket |
socket
Socket that we intend to listen to |
protected long |
timeToExpiration
The time it takes for a member to expire. |
Constructor Summary | |
McastServiceImpl(McastMember member,
long sendFrequency,
long expireTime,
int port,
java.net.InetAddress bind,
java.net.InetAddress mcastAddress,
int ttl,
int soTimeout,
MembershipListener service)
Create a new mcast service impl |
Method Summary | |
protected void |
checkExpire()
check member expire or alive |
int |
getRecoveryCounter()
|
long |
getRecoverySleepTime()
|
long |
getServiceStartTime()
|
protected void |
init()
|
boolean |
isRecoveryEnabled()
|
void |
receive()
Receive a datagram packet, locking wait |
void |
send()
Send a ping |
void |
setRecoveryCounter(int recoveryCounter)
|
void |
setRecoveryEnabled(boolean recoveryEnabled)
|
void |
setRecoverySleepTime(long recoverySleepTime)
|
protected void |
setupSocket()
|
void |
start(int level)
Start the service |
void |
stop()
Stops the service |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected boolean doRun
protected java.net.MulticastSocket socket
protected McastMember member
protected java.net.InetAddress address
protected int port
protected long timeToExpiration
protected long sendFrequency
protected java.net.DatagramPacket sendPacket
protected java.net.DatagramPacket receivePacket
protected McastMembership membership
protected MembershipListener service
protected McastServiceImpl.ReceiverThread receiver
protected McastServiceImpl.SenderThread sender
protected long serviceStartTime
protected int mcastTTL
protected int mcastSoTimeout
protected java.net.InetAddress mcastBindAddress
protected int recoveryCounter
protected long recoverySleepTime
protected boolean recoveryEnabled
protected final java.lang.Object membershipMutex
Constructor Detail |
public McastServiceImpl(McastMember member, long sendFrequency, long expireTime, int port, java.net.InetAddress bind, java.net.InetAddress mcastAddress, int ttl, int soTimeout, MembershipListener service) throws java.io.IOException
member
- - the local membersendFrequency
- - the time (ms) in between pings sent outexpireTime
- - the time (ms) for a member to expireport
- - the mcast portbind
- - the bind address (not sure this is used yet)mcastAddress
- - the mcast addressservice
- - the callback service
java.io.IOException
Method Detail |
protected void init() throws java.io.IOException
java.io.IOException
protected void setupSocket() throws java.io.IOException
java.io.IOException
public void start(int level) throws java.io.IOException
level
- 1 starts the receiver, level 2 starts the sender
java.io.IOException
- if the service fails to start
java.lang.IllegalStateException
- if the service is already startedpublic void stop() throws java.io.IOException
java.io.IOException
- if the service fails to disconnect from the socketspublic void receive() throws java.io.IOException
java.io.IOException
protected void checkExpire()
public void send() throws java.lang.Exception
java.lang.Exception
public long getServiceStartTime()
public int getRecoveryCounter()
public boolean isRecoveryEnabled()
public long getRecoverySleepTime()
public void setRecoveryCounter(int recoveryCounter)
public void setRecoveryEnabled(boolean recoveryEnabled)
public void setRecoverySleepTime(long recoverySleepTime)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |