|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.InNetMessagePool
public class InNetMessagePool
Manage a pool of inbound InNetMessages. This pool is filled by the Network communication system when it receives messages, and various jobs periodically retrieve them for processing.
Field Summary | |
---|---|
static boolean |
DEFAULT_DISPATCH_THREADED
|
static java.lang.String |
PROP_DISPATCH_THREADED
If set to true, we will have two additional threads - one for dispatching tunnel data messages, and another for dispatching tunnel gateway messages. |
Constructor Summary | |
---|---|
InNetMessagePool(RouterContext context)
|
Method Summary | |
---|---|
int |
add(I2NPMessage messageBody,
RouterIdentity fromRouter,
Hash fromRouterHash)
Add a new message to the pool, returning the number of messages in the pool so that the comm system can throttle inbound messages. |
int |
handleReplies(I2NPMessage messageBody)
|
HandlerJobBuilder |
registerHandlerJobBuilder(int i2npMessageType,
HandlerJobBuilder builder)
|
void |
renderStatusHTML(java.io.Writer out)
|
void |
restart()
Perform a soft restart. |
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()
Instruct the service that it should start normal operation. |
HandlerJobBuilder |
unregisterHandlerJobBuilder(int i2npMessageType)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String PROP_DISPATCH_THREADED
public static final boolean DEFAULT_DISPATCH_THREADED
Constructor Detail |
---|
public InNetMessagePool(RouterContext context)
Method Detail |
---|
public HandlerJobBuilder registerHandlerJobBuilder(int i2npMessageType, HandlerJobBuilder builder)
public HandlerJobBuilder unregisterHandlerJobBuilder(int i2npMessageType)
public int add(I2NPMessage messageBody, RouterIdentity fromRouter, Hash fromRouterHash)
public int handleReplies(I2NPMessage messageBody)
public void renderStatusHTML(java.io.Writer out)
renderStatusHTML
in interface Service
public void restart()
Service
restart
in interface Service
public void shutdown()
Service
shutdown
in interface Service
public void startup()
Service
startup
in interface Service
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |