Constructors in net.i2p.router.client with parameters of type RouterContext |
RequestLeaseSetJob(RouterContext ctx,
ClientConnectionRunner runner,
LeaseSet set,
long expiration,
Job onCreate,
Job onFail)
|
ReportAbuseJob(RouterContext context,
ClientConnectionRunner runner,
java.lang.String reason,
int severity)
|
MessageReceivedJob(RouterContext ctx,
ClientConnectionRunner runner,
Destination toDest,
Destination fromDest,
Payload payload)
|
CreateSessionJob(RouterContext context,
ClientConnectionRunner runner)
|
ClientWriterRunner(RouterContext context,
ClientConnectionRunner runner)
|
ClientMessageEventListener(RouterContext context,
ClientConnectionRunner runner)
|
ClientManagerFacadeImpl(RouterContext context)
|
ClientManager(RouterContext context,
int port)
|
ClientListenerRunner(RouterContext context,
ClientManager manager,
int port)
|
ClientConnectionRunner(RouterContext context,
ClientManager manager,
java.net.Socket socket)
Create a new runner against the given socket |
Methods in net.i2p.router.message with parameters of type RouterContext |
(package private) static GarlicMessage |
OutboundClientMessageJobHelper.createGarlicMessage(RouterContext ctx,
long replyToken,
long expiration,
PublicKey recipientPK,
Payload data,
Hash from,
Destination dest,
TunnelInfo replyTunnel,
SessionKey wrappedKey,
java.util.Set wrappedTags,
boolean requireAck,
LeaseSet bundledReplyLeaseSet)
Build a garlic message that will be delivered to the router on which the target is located. |
(package private) static GarlicMessage |
OutboundClientMessageJobHelper.createGarlicMessage(RouterContext ctx,
long replyToken,
long expiration,
PublicKey recipientPK,
PayloadGarlicConfig dataClove,
Hash from,
Destination dest,
TunnelInfo replyTunnel,
SessionKey wrappedKey,
java.util.Set wrappedTags,
boolean requireAck,
LeaseSet bundledReplyLeaseSet)
Allow the app to specify the data clove directly, which enables OutboundClientMessage to resend the
same payload (including expiration and unique id) in different garlics (down different tunnels) |
(package private) static PayloadGarlicConfig |
OutboundClientMessageJobHelper.buildDataClove(RouterContext ctx,
Payload data,
Destination dest,
long expiration)
Build a clove that sends the payload to the destination |
(package private) static PayloadGarlicConfig |
OutboundClientMessageJobHelper.buildLeaseSetClove(RouterContext ctx,
long expiration,
LeaseSet replyLeaseSet)
Build a clove that stores the leaseSet locally |
static GarlicMessage |
GarlicMessageBuilder.buildMessage(RouterContext ctx,
GarlicConfig config)
|
static GarlicMessage |
GarlicMessageBuilder.buildMessage(RouterContext ctx,
GarlicConfig config,
SessionKey wrappedKey,
java.util.Set wrappedTags)
|
static GarlicMessage |
GarlicMessageBuilder.buildMessage(RouterContext ctx,
GarlicConfig config,
SessionKey wrappedKey,
java.util.Set wrappedTags,
int numTagsToDeliver)
|
static GarlicMessage |
GarlicMessageBuilder.buildMessage(RouterContext ctx,
GarlicConfig config,
SessionKey wrappedKey,
java.util.Set wrappedTags,
PublicKey target,
SessionKey encryptKey,
SessionTag encryptTag)
|
Constructors in net.i2p.router.message with parameters of type RouterContext |
SendMessageDirectJob(RouterContext ctx,
I2NPMessage message,
Hash toPeer,
int timeoutMs,
int priority)
|
SendMessageDirectJob(RouterContext ctx,
I2NPMessage message,
Hash toPeer,
ReplyJob onSuccess,
Job onFail,
MessageSelector selector,
int timeoutMs,
int priority)
|
SendMessageDirectJob(RouterContext ctx,
I2NPMessage message,
Hash toPeer,
Job onSend,
ReplyJob onSuccess,
Job onFail,
MessageSelector selector,
int timeoutMs,
int priority)
|
SendGarlicJob(RouterContext ctx,
GarlicConfig config,
Job onSend,
Job onSendFailed,
ReplyJob onReply,
Job onReplyFailed,
long timeoutMs,
int priority,
MessageSelector replySelector)
|
SendGarlicJob(RouterContext ctx,
GarlicConfig config,
Job onSend,
Job onSendFailed,
ReplyJob onReply,
Job onReplyFailed,
long timeoutMs,
int priority,
MessageSelector replySelector,
SessionKey wrappedKey,
java.util.Set wrappedTags)
|
OutboundClientMessageStatus(RouterContext ctx,
ClientMessage msg)
|
OutboundClientMessageOneShotJob(RouterContext ctx,
ClientMessage msg)
Send the sucker |
HandleGarlicMessageJob(RouterContext context,
GarlicMessage msg,
RouterIdentity from,
Hash fromHash)
|
GarlicMessageReceiver(RouterContext context,
GarlicMessageReceiver.CloveReceiver receiver)
|
GarlicMessageReceiver(RouterContext context,
GarlicMessageReceiver.CloveReceiver receiver,
Hash clientDestination)
|
GarlicMessageParser(RouterContext context)
|
GarlicMessageHandler(RouterContext context)
|
BuildTestMessageJob(RouterContext ctx,
RouterInfo target,
Hash replyTo,
Job onSendJob,
Job onSendFailedJob,
long timeoutMs,
int priority)
|
Constructors in net.i2p.router.networkdb.kademlia with parameters of type RouterContext |
TransientDataStore(RouterContext ctx)
|
StoreState(RouterContext ctx,
Hash key,
DataStructure data)
|
StoreState(RouterContext ctx,
Hash key,
DataStructure data,
java.util.Set toSkip)
|
StoreMessageSelector(RouterContext ctx,
long storeJobId,
RouterInfo peer,
long waitingForId,
long expiration)
|
StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DataStructure data,
Job onSuccess,
Job onFailure,
long timeoutMs)
Create a new search for the routingKey specified |
StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DataStructure data,
Job onSuccess,
Job onFailure,
long timeoutMs,
java.util.Set toSkip)
|
StartExplorersJob(RouterContext context,
KademliaNetworkDatabaseFacade facade)
|
SearchUpdateReplyFoundJob(RouterContext context,
RouterInfo peer,
SearchState state,
KademliaNetworkDatabaseFacade facade,
SearchJob job)
|
SearchState(RouterContext context,
Hash key)
|
SearchMessageSelector(RouterContext context,
RouterInfo peer,
long expiration,
SearchState state)
|
SearchJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
Job onSuccess,
Job onFailure,
long timeoutMs,
boolean keepStats,
boolean isLease)
Create a new search for the routingKey specified |
SearchJob.FailedJob(RouterContext enclosingContext,
RouterInfo peer)
|
SearchJob.FailedJob(RouterContext enclosingContext,
RouterInfo peer,
boolean penalizePeer)
Allow the choice as to whether failed searches should count against
the peer (such as if we search for a random key) |
RepublishLeaseSetJob(RouterContext ctx,
KademliaNetworkDatabaseFacade facade,
Hash destHash)
|
PersistentDataStore(RouterContext ctx,
java.lang.String dbDir,
KademliaNetworkDatabaseFacade facade)
|
PeerSelector(RouterContext ctx)
|
KademliaNetworkDatabaseFacade(RouterContext context)
|
HarvesterJob(RouterContext context,
KademliaNetworkDatabaseFacade facade)
|
ExploreKeySelectorJob(RouterContext context,
KademliaNetworkDatabaseFacade facade)
|
ExploreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key)
Create a new search for the routingKey specified |
ExpireRoutersJob(RouterContext ctx,
KademliaNetworkDatabaseFacade facade)
|
ExpireLeasesJob(RouterContext ctx,
KademliaNetworkDatabaseFacade facade)
|
DataRepublishingSelectorJob(RouterContext ctx,
KademliaNetworkDatabaseFacade facade)
|
DataPublisherJob(RouterContext ctx,
KademliaNetworkDatabaseFacade facade)
|
Constructors in net.i2p.router.transport.udp with parameters of type RouterContext |
UDPTransport(RouterContext ctx)
|
UDPSender(RouterContext ctx,
java.net.DatagramSocket socket,
java.lang.String name)
|
UDPReceiver(RouterContext ctx,
java.net.DatagramSocket socket,
java.lang.String name)
|
UDPFlooder(RouterContext ctx,
UDPTransport transport)
|
UDPEndpointTest(RouterContext ctx)
|
UDPEndpoint(RouterContext ctx,
int listenPort)
|
TimedWeightedPriorityMessageQueue(RouterContext ctx,
int[] priorityLimits,
int[] weighting,
TimedWeightedPriorityMessageQueue.FailedListener lsnr)
Build up a new queue |
PacketPusher(RouterContext ctx,
OutboundMessageFragments fragments,
UDPSender sender)
|
PacketHandler(RouterContext ctx,
UDPTransport transport,
UDPEndpoint endpoint,
EstablishmentManager establisher,
InboundMessageFragments inbound)
|
OutboundRefiller(RouterContext ctx,
OutboundMessageFragments fragments,
MessageQueue messages)
|
OutboundMessageFragments(RouterContext ctx,
UDPTransport transport)
|
OutboundEstablishState(RouterContext ctx,
java.net.InetAddress remoteHost,
int remotePort,
RouterIdentity remotePeer,
SessionKey introKey)
|
MessageReceiver(RouterContext ctx,
InboundMessageFragments frag,
UDPTransport transport)
|
InboundMessageState(RouterContext ctx,
long messageId,
Hash from)
|
InboundMessageFragments(RouterContext ctx,
OutboundMessageFragments outbound,
UDPTransport transport)
|
InboundEstablishState(RouterContext ctx,
java.net.InetAddress remoteHost,
int remotePort,
int localPort)
|
EstablishmentManager(RouterContext ctx,
UDPTransport transport)
|
ACKSender(RouterContext ctx,
InboundMessageFragments fragments,
UDPTransport transport)
|
Methods in net.i2p.router.tunnel.pool with parameters of type RouterContext |
abstract java.util.List |
TunnelPeerSelector.selectPeers(RouterContext ctx,
TunnelPoolSettings settings)
Which peers should go into the next tunnel for the given settings? |
protected int |
TunnelPeerSelector.getLength(RouterContext ctx,
TunnelPoolSettings settings)
|
protected java.util.List |
TunnelPeerSelector.selectExplicit(RouterContext ctx,
TunnelPoolSettings settings,
int length)
|
void |
TunnelBuilder.buildTunnel(RouterContext ctx,
TunnelPool pool)
Build a new tunnel per the pool's wishes (using the preferred length,
peers, ordering, etc). |
void |
TunnelBuilder.buildTunnel(RouterContext ctx,
TunnelPool pool,
boolean zeroHop)
|
java.util.List |
ExploratoryPeerSelector.selectPeers(RouterContext ctx,
TunnelPoolSettings settings)
|
java.util.List |
ClientPeerSelector.selectPeers(RouterContext ctx,
TunnelPoolSettings settings)
|
Constructors in net.i2p.router.tunnel.pool with parameters of type RouterContext |
TunnelPoolManager(RouterContext ctx)
|
TunnelPool(RouterContext ctx,
TunnelPoolManager mgr,
TunnelPoolSettings settings,
TunnelPeerSelector sel,
TunnelBuilder builder)
|
TunnelMessageHandlerBuilder(RouterContext ctx)
|
TestJob(RouterContext ctx,
PooledTunnelCreatorConfig cfg,
TunnelPool pool)
|
SendGarlicMessageJob(RouterContext ctx,
I2NPMessage payload,
RouterInfo target,
MessageSelector selector,
ReplyJob onReply,
Job onTimeout,
SessionKey sentKey,
java.util.Set sentTags)
|
RequestTunnelJob(RouterContext ctx,
TunnelCreatorConfig cfg,
Job onCreated,
Job onFailed,
int hop,
boolean isFake,
boolean isExploratory)
|
RebuildJob(RouterContext ctx,
TunnelCreatorConfig cfg,
TunnelPool pool)
|
PooledTunnelCreatorConfig(RouterContext ctx,
int length,
boolean isInbound)
Creates a new instance of PooledTunnelCreatorConfig |
PooledTunnelCreatorConfig(RouterContext ctx,
int length,
boolean isInbound,
Hash destination)
|
OnCreatedJob(RouterContext ctx,
TunnelPool pool,
PooledTunnelCreatorConfig cfg)
|
HandleTunnelCreateMessageJob(RouterContext ctx,
TunnelCreateMessage msg)
|
HandleTunnelCreateMessageJob.Builder(RouterContext ctx)
|
ExpireJob(RouterContext ctx,
TunnelCreatorConfig cfg,
TunnelPool pool)
|