Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.logging.Log |
log |
Constructor and Description |
---|
TcpRingNode(RpcProtocol owner,
Address memberAddress) |
Modifier and Type | Method and Description |
---|---|
IpAddress |
getTokenReceiverAddress() |
void |
passToken(java.lang.Object token) |
java.lang.Object |
receiveToken() |
java.lang.Object |
receiveToken(int timeout) |
void |
reconfigure(java.util.Vector newMembers) |
void |
reconfigureAll(java.util.Vector newMembers) |
void |
tokenArrived(java.lang.Object token) |
public TcpRingNode(RpcProtocol owner, Address memberAddress)
public IpAddress getTokenReceiverAddress()
getTokenReceiverAddress
in interface RingNode
public java.lang.Object receiveToken(int timeout) throws TokenLostException
receiveToken
in interface RingNode
TokenLostException
public java.lang.Object receiveToken() throws TokenLostException
receiveToken
in interface RingNode
TokenLostException
public void passToken(java.lang.Object token) throws TokenLostException
passToken
in interface RingNode
TokenLostException
public void tokenArrived(java.lang.Object token)
tokenArrived
in interface RingNode
public void reconfigureAll(java.util.Vector newMembers)
public void reconfigure(java.util.Vector newMembers)
reconfigure
in interface RingNode
Copyright ? 1998-2006 Bela Ban. All Rights Reserved.