| 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 RingNodepublic java.lang.Object receiveToken(int timeout)
throws TokenLostException
receiveToken in interface RingNodeTokenLostExceptionpublic java.lang.Object receiveToken()
throws TokenLostException
receiveToken in interface RingNodeTokenLostExceptionpublic void passToken(java.lang.Object token)
throws TokenLostException
passToken in interface RingNodeTokenLostExceptionpublic void tokenArrived(java.lang.Object token)
tokenArrived in interface RingNodepublic void reconfigureAll(java.util.Vector newMembers)
public void reconfigure(java.util.Vector newMembers)
reconfigure in interface RingNodeCopyright ? 1998-2006 Bela Ban. All Rights Reserved.