Package net.i2p.router

Class RouterThrottleImpl

java.lang.Object

net.i2p.router.RouterThrottleImpl

All Implemented Interfaces:

RouterThrottle

Direct Known Subclasses:

RouterDoSThrottle

public class RouterThrottleImpl
extends Object
implements RouterThrottle

Simple throttle that basically stops accepting messages or nontrivial requests if the jobQueue lag is too large.

Field Summary

Fields

Modifier and Type	Field	Description
protected final RouterContext	_context
static final int	DEFAULT_MAX_TUNNELS
static final long	DEFAULT_REJECT_STARTUP_TIME
static final String	PROP_MAX_TUNNELS
static final String	PROP_REJECT_STARTUP_TIME
static final int	TUNNEL_ACCEPT	tunnel acceptance

Constructor Summary

Constructors

Constructor	Description
RouterThrottleImpl(RouterContext context)

Method Summary

Modifier and Type	Method	Description
boolean	acceptNetDbLookupRequest(Hash key)	Deprecated. unused, function moved to netdb
boolean	acceptNetworkMessage()	Should we accept any more data from the network for any sort of message, taking into account our current load, or should we simply slow down? FIXME only called by SSU Receiver, not NTCP! FIXME should put warning on the console FIXME or should we do this at all? We have Codel queues all over now...
int	acceptTunnelRequest()	If we should send a reject, return a nonzero reject code.
void	cancelShutdownStatus()
double	getInboundRateDelta()	How much faster (or if negative, slower) we are receiving data as opposed to our longer term averages?
String	getLocalizedTunnelStatus()	getTunnelStatus(), translated if available.
long	getMessageDelay()	How backed up we are at the moment processing messages (in milliseconds)
long	getTunnelLag()	How backed up our tunnels are at the moment (in milliseconds)
String	getTunnelStatus()	Message on the state of participating tunnel acceptance
void	setShutdownStatus()
void	setTunnelStatus(String msg)

Methods inherited from class java.lang.Object

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

Field Details

_context

protected final RouterContext _context

PROP_MAX_TUNNELS

public static final String PROP_MAX_TUNNELS

See Also:

• Constant Field Values

DEFAULT_MAX_TUNNELS

public static final int DEFAULT_MAX_TUNNELS

See Also:

• Constant Field Values

DEFAULT_REJECT_STARTUP_TIME

public static final long DEFAULT_REJECT_STARTUP_TIME

See Also:

• Constant Field Values

PROP_REJECT_STARTUP_TIME

public static final String PROP_REJECT_STARTUP_TIME

See Also:

• Constant Field Values

TUNNEL_ACCEPT

public static final int TUNNEL_ACCEPT

tunnel acceptance

See Also:

• Constant Field Values

Constructor Details

RouterThrottleImpl

public RouterThrottleImpl(RouterContext context)

Method Details

acceptNetworkMessage

public boolean acceptNetworkMessage()

Should we accept any more data from the network for any sort of message, taking into account our current load, or should we simply slow down? FIXME only called by SSU Receiver, not NTCP! FIXME should put warning on the console FIXME or should we do this at all? We have Codel queues all over now...

Specified by:

acceptNetworkMessage in interface RouterThrottle

acceptNetDbLookupRequest

@Deprecated
public boolean acceptNetDbLookupRequest(Hash key)

Deprecated.

unused, function moved to netdb

Description copied from interface: RouterThrottle

Should we accept the netDb lookup message, replying either with the value or some closer peers, or should we simply drop it due to overload?

Specified by:

acceptNetDbLookupRequest in interface RouterThrottle

acceptTunnelRequest

public int acceptTunnelRequest()

If we should send a reject, return a nonzero reject code. Anything that causes us to drop a request instead of rejecting it must go in BuildHandler.handleInboundRequest(), not here.

Specified by:

acceptTunnelRequest in interface RouterThrottle

Returns:

0 for accept or nonzero reject code

getMessageDelay

public long getMessageDelay()

Description copied from interface: RouterThrottle

How backed up we are at the moment processing messages (in milliseconds)

Specified by:

getMessageDelay in interface RouterThrottle

getTunnelLag

public long getTunnelLag()

Description copied from interface: RouterThrottle

How backed up our tunnels are at the moment (in milliseconds)

Specified by:

getTunnelLag in interface RouterThrottle

getInboundRateDelta

public double getInboundRateDelta()

Description copied from interface: RouterThrottle

How much faster (or if negative, slower) we are receiving data as opposed to our longer term averages?

Specified by:

getInboundRateDelta in interface RouterThrottle

getTunnelStatus

public String getTunnelStatus()

Description copied from interface: RouterThrottle

Message on the state of participating tunnel acceptance

Specified by:

getTunnelStatus in interface RouterThrottle

getLocalizedTunnelStatus

public String getLocalizedTunnelStatus()

getTunnelStatus(), translated if available.

Specified by:

getLocalizedTunnelStatus in interface RouterThrottle

Since:

0.9.45

setShutdownStatus

public void setShutdownStatus()

Specified by:

setShutdownStatus in interface RouterThrottle

Since:

0.8.12

cancelShutdownStatus

public void cancelShutdownStatus()

Specified by:

cancelShutdownStatus in interface RouterThrottle

Since:

0.8.12

setTunnelStatus

public void setTunnelStatus(String msg)

Specified by:

setTunnelStatus in interface RouterThrottle