net.i2p.router.tunnel
Constructor and Description |
---|
TunnelDispatcher(RouterContext ctx)
Creates a new instance of TunnelDispatcher
|
Modifier and Type | Method and Description |
---|---|
void |
dispatch(TunnelDataMessage msg,
Hash recvFrom)
We are participating in a tunnel (perhaps we're even the endpoint), so
take the message and do what it says.
|
void |
dispatch(TunnelGatewayMessage msg)
We are the inbound tunnel gateway, so encrypt it as necessary and forward
it on.
|
void |
dispatchOutbound(I2NPMessage msg,
TunnelId outboundTunnel,
Hash targetPeer)
We are the outbound tunnel gateway (we created it), so wrap up this message
with instructions to be forwarded to the targetPeer when it reaches the
endpoint.
|
void |
dispatchOutbound(I2NPMessage msg,
TunnelId outboundTunnel,
TunnelId targetTunnel,
Hash targetPeer)
We are the outbound tunnel gateway (we created it), so wrap up this message
with instructions to be forwarded to the targetTunnel on the targetPeer when
it reaches the endpoint.
|
long |
getLastParticipatingExpiration()
what is the date/time on which the last non-locally-created tunnel expires?
|
int |
getParticipatingCount() |
static int |
getShareBandwidth(RouterContext ctx) |
void |
joinInbound(TunnelCreatorConfig cfg)
We are the inbound endpoint - we created this tunnel
|
void |
joinInboundGateway(HopConfig cfg)
We are the inbound gateway in this tunnel, and did not create it
|
void |
joinOutbound(TunnelCreatorConfig cfg)
We are the outbound gateway - we created this tunnel
|
void |
joinOutboundEndpoint(HopConfig cfg)
We are the outbound endpoint in this tunnel, and did not create it
|
void |
joinParticipant(HopConfig cfg)
We are a participant in this tunnel, but not as the endpoint or gateway
|
List<HopConfig> |
listParticipatingTunnels() |
void |
remove(HopConfig cfg)
No longer participate in the tunnel that someone asked us to be a member of
|
void |
remove(TunnelCreatorConfig cfg)
We no longer want to participate in this tunnel that we created
|
void |
renderStatusHTML(Writer out)
Deprecated.
moved to router console
|
void |
restart()
Perform a soft restart.
|
boolean |
shouldDropParticipatingMessage(String type,
int length)
Implement random early discard (RED) to enforce the share bandwidth limit.
|
void |
shutdown()
Instruct the service that the router is shutting down and that it should do
whatever is necessary to go down gracefully.
|
void |
startup()
public void dropBiggestParticipating() {
List
|
void |
updateParticipatingStats(int ms)
Generate a current estimate of usage per-participating-tunnel lifetime.
|
public TunnelDispatcher(RouterContext ctx)
public void joinOutbound(TunnelCreatorConfig cfg)
public void joinInbound(TunnelCreatorConfig cfg)
public void joinParticipant(HopConfig cfg)
public void joinOutboundEndpoint(HopConfig cfg)
public void joinInboundGateway(HopConfig cfg)
public int getParticipatingCount()
public long getLastParticipatingExpiration()
public void remove(TunnelCreatorConfig cfg)
public void remove(HopConfig cfg)
public void dispatch(TunnelDataMessage msg, Hash recvFrom)
public void dispatch(TunnelGatewayMessage msg)
public void dispatchOutbound(I2NPMessage msg, TunnelId outboundTunnel, Hash targetPeer)
msg
- raw message to deliver to the target peeroutboundTunnel
- tunnel to send the message outtargetPeer
- peer to receive the messagepublic void dispatchOutbound(I2NPMessage msg, TunnelId outboundTunnel, TunnelId targetTunnel, Hash targetPeer)
msg
- raw message to deliver to the targetTunnel on the targetPeeroutboundTunnel
- tunnel to send the message outtargetTunnel
- tunnel on the targetPeer to deliver the message totargetPeer
- gateway to the tunnel to receive the messagepublic void updateParticipatingStats(int ms)
public boolean shouldDropParticipatingMessage(String type, int length)
type
- message hop location and typelength
- the length of the messagepublic void startup()
public static int getShareBandwidth(RouterContext ctx)
public void shutdown()
Service
public void restart()
Service
public void renderStatusHTML(Writer out) throws IOException
renderStatusHTML
in interface Service
IOException