org.mpisws.p2p.transport.liveness
Class LivenessTransportLayerImpl.EntityManager

java.lang.Object
  org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl.EntityManager

Enclosing class:

LivenessTransportLayerImpl<Identifier>

public class LivenessTransportLayerImpl.EntityManager
extends java.lang.Object

Internal class which is charges with managing the remote connection via a specific route

Field Summary

protected java.lang.ref.WeakReference<Identifier>	identifier
protected int	liveness
protected java.util.Set<org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl.LSocket>	sockets
protected long	updated

Constructor Summary

LivenessTransportLayerImpl.EntityManager(Identifier identifier)
Constructor - builds a route manager given the route

Method Summary

protected boolean	checkLiveness(java.util.Map<java.lang.String,java.lang.Object> options) Method which checks to see this route is dead.
void	destroy()
LivenessTransportLayerImpl.DeadChecker	getPending()
protected void	markAlive(java.util.Map<java.lang.String,java.lang.Object> options) This method should be called when this route is declared alive.
protected void	markDead(java.util.Map<java.lang.String,java.lang.Object> options) This method should be called when this route is declared dead.
protected void	markDeadForever(java.util.Map<java.lang.String,java.lang.Object> options)
protected void	markDeadHelper(int liveness, java.util.Map<java.lang.String,java.lang.Object> options, boolean notify)
protected void	markSuspected(java.util.Map<java.lang.String,java.lang.Object> options) This method should be called when this route is declared suspected.
void	removeSocket(org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl.LSocket socket)
int	rto()
void	setPending(LivenessTransportLayerImpl.DeadChecker d)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

identifier

protected java.lang.ref.WeakReference<Identifier> identifier

liveness

protected int liveness

updated

protected long updated

sockets

protected java.util.Set<org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl.LSocket> sockets

Constructor Detail

LivenessTransportLayerImpl.EntityManager

public LivenessTransportLayerImpl.EntityManager(Identifier identifier)

Constructor - builds a route manager given the route

Parameters:

route - The route

Method Detail

getPending

public LivenessTransportLayerImpl.DeadChecker getPending()

setPending

public void setPending(LivenessTransportLayerImpl.DeadChecker d)

removeSocket

public void removeSocket(org.mpisws.p2p.transport.liveness.LivenessTransportLayerImpl.LSocket socket)

rto

public int rto()

markAlive

protected void markAlive(java.util.Map<java.lang.String,java.lang.Object> options)

This method should be called when this route is declared alive.

markSuspected

protected void markSuspected(java.util.Map<java.lang.String,java.lang.Object> options)

This method should be called when this route is declared suspected.

markDead

protected void markDead(java.util.Map<java.lang.String,java.lang.Object> options)

This method should be called when this route is declared dead.

markDeadForever

protected void markDeadForever(java.util.Map<java.lang.String,java.lang.Object> options)

markDeadHelper

protected void markDeadHelper(int liveness,
                              java.util.Map<java.lang.String,java.lang.Object> options,
                              boolean notify)

checkLiveness

protected boolean checkLiveness(java.util.Map<java.lang.String,java.lang.Object> options)

Method which checks to see this route is dead. If this address has been checked within the past CHECK_DEAD_THROTTLE millis, then this method does not actually do a check.

Returns:

true if there will be an update (either a ping, or a change in liveness)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

destroy

public void destroy()