| Package | Description |
|---|---|
| net.i2p.router | The I2P router application handles I2P network communication. |
| net.i2p.router.client | Router-side implementation of the I2CP (I2P Client Protocol) interface for application integration. |
| net.i2p.router.dummy | Dummy implementations and stub classes for testing purposes. |
| net.i2p.router.message | Garlic message creation, parsing, and source routing for I2P communications. |
| net.i2p.router.networkdb | Network database management and coordination for the I2P distributed hash table. |
| net.i2p.router.networkdb.kademlia | Kademlia DHT implementation and floodfill router functionality for I2P. |
| net.i2p.router.peermanager | Peer management, profiling, and capacity calculation for I2P network optimization. |
| net.i2p.router.startup | The I2P startup package loads configuration when I2P is started. |
| net.i2p.router.sybil | Offline analysis tools for detecting Sybil attacks and malicious peer
coordination in the I2P network. |
| net.i2p.router.tasks | Periodic maintenance tasks and background jobs for I2P router operations. |
| net.i2p.router.transport | Transport layer implementations and management for I2P network communication. |
| net.i2p.router.tunnel.pool | Tunnel pool management, creation, and peer selection for I2P's anonymous routing system. |
| net.i2p.router.web.helpers | Helpers and handlers for the router console user interface, with these classes supporting the webapp in routerconsole.war. |
| Modifier and Type | Interface and Description |
|---|---|
interface | ReplyJobDefines an executable task that can be fired off in reply to a message |
| Modifier and Type | Class and Description |
|---|---|
class | JobImplBase implementation of a Job
For use by the router only. |
| Modifier and Type | Method and Description |
|---|---|
Job | HandlerJobBuilder.createJob(I2NPMessage receivedMessage,
RouterIdentity from,
Hash fromHash)Create a new job to handle the received message. |
Job | JobQueueRunner.getCurrentJob() |
Job | JobQueueRunner.getLastJob() |
Job | JobQueue.getLastJob()Last job that was executed. |
(package private) Job | JobQueue.getNext()Next job in queue. |
Job | OutNetMessage.getOnFailedReplyJob()If the Message selector is specified but it doesn't find a reply before
its expiration passes, this job is enqueued. |
Job | OutNetMessage.getOnFailedSendJob()If the router could not be reached or the expiration passed, this job
is enqueued. |
Job | OutNetMessage.getOnSendJob()After the message is successfully passed to the router specified, the
given job is enqueued. |
| Modifier and Type | Method and Description |
|---|---|
void | JobQueue.addJob(Job job)Enqueue the specified job for normal processing. |
void | JobQueue.addJobToTop(Job job)Enqueue the specified job to be processed at the top of the queue. |
abstract void | NetworkDatabaseFacade.lookupDestination(Hash key,
Job onFinishedJob,
long timeoutMs,
Hash fromLocalDest)Lookup using the client's tunnels
Succeeds even if LS validation fails due to unsupported sig type |
abstract void | NetworkDatabaseFacade.lookupLeaseSet(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs)Lookup a LeaseSet in the network database. |
abstract void | NetworkDatabaseFacade.lookupLeaseSet(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
Hash fromLocalDest)Lookup using the client's tunnels |
abstract void | NetworkDatabaseFacade.lookupLeaseSetRemotely(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
Hash fromLocalDest)Unconditionally lookup using the client's tunnels. |
abstract void | NetworkDatabaseFacade.lookupRouterInfo(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs)timeoutMs). |
void | JobQueue.removeJob(Job job)Remove a job from the job queue. |
abstract void | ClientManagerFacade.requestLeaseSet(Destination dest,
LeaseSet set,
long timeout,
Job onCreateJob,
Job onFailedJob)Request that a particular client authorize the Leases contained in the
LeaseSet, after which the onCreateJob is queued up. |
void | OutNetMessage.setOnFailedReplyJob(Job job)setOnFailedReplyJob. |
void | OutNetMessage.setOnFailedSendJob(Job job)setOnFailedSendJob. |
void | OutNetMessage.setOnSendJob(Job job)setOnSendJob. |
(package private) void | JobQueue.updateStats(Job job,
long doStart,
long _origStartAfter,
long duration)Update stats |
| Modifier and Type | Method and Description |
|---|---|
int | JobQueue.getJobs(Collection<Job> readyJobs,
Collection<Job> timedJobs,
Collection<Job> activeJobs,
Collection<Job> justFinishedJobs)Collect statistics about jobs currently in the queue. |
int | JobQueue.getJobs(Collection<Job> readyJobs,
Collection<Job> timedJobs,
Collection<Job> activeJobs,
Collection<Job> justFinishedJobs)Collect statistics about jobs currently in the queue. |
int | JobQueue.getJobs(Collection<Job> readyJobs,
Collection<Job> timedJobs,
Collection<Job> activeJobs,
Collection<Job> justFinishedJobs)Collect statistics about jobs currently in the queue. |
int | JobQueue.getJobs(Collection<Job> readyJobs,
Collection<Job> timedJobs,
Collection<Job> activeJobs,
Collection<Job> justFinishedJobs)Collect statistics about jobs currently in the queue. |
| Modifier and Type | Class and Description |
|---|---|
(package private) class | CreateSessionJobGiven an established connection, walk through the process of establishing the
leaseset. |
(package private) class | LookupDestJobLook up the lease of a hash, to convert it to a Destination for the client. |
(package private) class | MessageReceivedJobAsync job to notify the client that a new message is available for them,
or just send it directly if specified. |
(package private) class | ReportAbuseJobAsync job to send an abuse message to the client |
(package private) class | RequestLeaseSetJobAsync job to walk the client through generating a lease set. |
| Modifier and Type | Method and Description |
|---|---|
Job | LeaseRequestState.getOnFailed()Get the on-failed job. |
Job | LeaseRequestState.getOnGranted()Get the on-granted job. |
| Modifier and Type | Method and Description |
|---|---|
void | ClientManager.requestLeaseSet(Destination dest,
LeaseSet set,
long timeout,
Job onCreateJob,
Job onFailedJob)Request that a particular client authorize the Leases contained in the
LeaseSet, after which the onCreateJob is queued up. |
void | ClientManagerFacadeImpl.requestLeaseSet(Destination dest,
LeaseSet set,
long timeout,
Job onCreateJob,
Job onFailedJob)Request that a particular client authorize the Leases contained in the LeaseSet,
after which the onCreateJob is queued up. |
(package private) void | ClientConnectionRunner.requestLeaseSet(Hash h,
LeaseSet set,
long expirationTime,
Job onCreateJob,
Job onFailedJob)Request that a particular client authorize the Leases contained in the
LeaseSet, after which the onCreateJob is queued up. |
| Constructor and Description |
|---|
LeaseRequestState(Job onGranted,
Job onFailed,
long currentEarliestLeastDate,
long expiration,
LeaseSet requested)Create a new LeaseRequestState. |
| Modifier and Type | Method and Description |
|---|---|
void | DummyNetworkDatabaseFacade.lookupDestination(Hash key,
Job onFinishedJob,
long timeoutMs,
Hash fromLocalDest)lookupDestination. |
void | DummyNetworkDatabaseFacade.lookupLeaseSet(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs)lookupLeaseSet. |
void | DummyNetworkDatabaseFacade.lookupLeaseSet(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
Hash fromLocalDest) |
void | DummyNetworkDatabaseFacade.lookupLeaseSetRemotely(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
Hash fromLocalDest) |
void | DummyNetworkDatabaseFacade.lookupRouterInfo(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs)lookupRouterInfo. |
void | DummyClientManagerFacade.requestLeaseSet(Destination dest,
LeaseSet set,
long timeout,
Job onCreateJob,
Job onFailedJob) |
| Modifier and Type | Class and Description |
|---|---|
class | HandleGarlicMessageJobJob to handle an inbound GarlicMessage received outside of a tunnel. |
class | OutboundClientMessageOneShotJobSend a client message out an outbound tunnel and into an inbound
tunnel on the target leaseSet. |
class | SendMessageDirectJobSend a message directly to another router (not through a tunnel). |
| Modifier and Type | Method and Description |
|---|---|
Job | GarlicMessageHandler.createJob(I2NPMessage receivedMessage,
RouterIdentity from,
Hash fromHash)Create and return a job to handle this message |
| Constructor and Description |
|---|
SendMessageDirectJob(RouterContext ctx,
I2NPMessage message,
Hash toPeer,
Job onSend,
ReplyJob onSuccess,
Job onFail,
MessageSelector selector,
int timeoutMs,
int priority,
long msgIDBloomXor)Send a message directly to a peer with full options. |
SendMessageDirectJob(RouterContext ctx,
I2NPMessage message,
Hash toPeer,
ReplyJob onSuccess,
Job onFail,
MessageSelector selector,
int timeoutMs,
int priority)Send a message directly to a peer with reply handling. |
SendMessageDirectJob(RouterContext ctx,
I2NPMessage message,
Hash toPeer,
ReplyJob onSuccess,
Job onFail,
MessageSelector selector,
int timeoutMs,
int priority,
long msgIDBloomXor)Send a message directly to a peer with reply handling and XOR mask. |
| Modifier and Type | Class and Description |
|---|---|
class | HandleDatabaseLookupMessageJobHandle a lookup for a key received from a remote peer. |
class | PublishLocalRouterInfoJobPublish the local router's RouterInfo periodically. |
| Modifier and Type | Class and Description |
|---|---|
(package private) class | CleanupLURoutersJobPeriodically cleans up least-used router entries from the network database. |
(package private) class | ContactDrivenRefreshJobLightweight background job that refreshes RouterInfo for peers we recently
interacted with. |
(package private) class | DirectLookupJobAsk a connected peer for his RI. |
(package private) class | DirectLookupMatchJobOverride to not call failed() in setMessage(),
as it will be called from runJob() |
(package private) class | ExpireLeasesJobPeriodically searches through all leases to find expired ones, failing those
keys and firing up a new search for each (in case we want it later, might as
well preemptively fetch it). |
(package private) class | ExpireRoutersJobGo through the routing table pick routers that are
out of date, but don't expire routers we're actively connected to. |
class | ExploreJobRepresents an exploratory search job for a particular key in the Kademlia network database. |
(package private) class | FloodfillMonitorJobSimple job to monitor the floodfill pool. |
(package private) class | FloodfillRouterInfoFloodJobJob to flood nearby floodfill routers with our RI. |
(package private) class | FloodfillStoreJobThis class extends StoreJob to fire off a FloodfillVerifyStoreJob after a successful store. |
(package private) class | FloodfillVerifyStoreJobSend a netDb lookup to a floodfill peer - If it is found, great, but if they reply back saying
they don't know it, queue up a store of the key to a random floodfill peer again (via FloodfillStoreJob) |
(package private) class | FloodOnlyLookupMatchJobHandles match processing for flood-only search operations. |
(package private) class | FloodOnlyLookupTimeoutJobTimeout handler for flood-only search operations. |
(package private) class | FloodOnlySearchJobFlood-only search implementation for network database lookups. |
(package private) class | FloodSearchJobBase class for flood-based search operations with fallback to Kademlia. |
class | HandleFloodfillDatabaseLookupMessageJobProcesses database lookup messages received by floodfill routers. |
(package private) class | HandleFloodfillDatabaseStoreMessageJobProcesses and stores DatabaseStoreMessage data in the floodfill network database. |
(package private) class | IterativeFollowupJobPerforms targeted followup lookups during iterative search operations. |
(package private) class | IterativeLookupJobProcesses DatabaseSearchReplyMessage responses during iterative searches. |
class | IterativeSearchJobTraditional Kademlia iterative search with enhanced robustness. |
(package private) class | IterativeTimeoutJobHandles timeout events for individual peer lookups in iterative searches. |
(package private) class | ProbeStalePeerJobProbes peers to verify they are still alive, using DirectLookupJob to ask
for their RouterInfo. |
(package private) class | RefreshRoutersJobRefreshRoutersJob performs router info refresh operations periodically. |
class | RepublishLeaseSetJobPeriodically republishes a local LeaseSet to the network database. |
(package private) class | SearchJobBase class for iterative network database search operations. |
protected class | SearchJob.FailedJobCalled when a particular peer failed to respond before the timeout was
reached, or if the peer could not be contacted at all. |
(package private) class | SearchReplyJobProcesses DatabaseSearchReplyMessage responses from floodfill peers. |
(package private) class | SearchUpdateReplyFoundJobCalled after a match to a db search is found
Used only by SearchJob which is only used by ExploreJob |
(package private) class | SingleLookupJobPerforms targeted followup lookups for RouterInfo entries from search replies. |
(package private) class | SingleSearchJobPerforms a targeted lookup to a single peer for a specific key. |
(package private) class | StartExplorersJobThis job initiates exploration of the network database by selecting keys to explore
and queuing ExploreJobs up to a maximum per run. |
(package private) class | StoreJobAbstract base class for network database store operations. |
| Modifier and Type | Field and Description |
|---|---|
protected Job | FloodOnlySearchJob._onTimeoutjob to run on timeout |
| Modifier and Type | Field and Description |
|---|---|
protected List<Job> | FloodSearchJob._onFailedCallbacks for search failure. |
protected List<Job> | FloodSearchJob._onFindCallbacks for successful search completion. |
| Modifier and Type | Method and Description |
|---|---|
Job | FloodfillDatabaseStoreMessageHandler.createJob(I2NPMessage receivedMessage,
RouterIdentity from,
Hash fromHash) |
Job | FloodfillDatabaseLookupMessageHandler.createJob(I2NPMessage receivedMessage,
RouterIdentity from,
Hash fromHash)Creates a job to handle an incoming DatabaseLookupMessage, or returns null if the lookup should be dropped. |
| Modifier and Type | Method and Description |
|---|---|
(package private) void | FloodSearchJob.addDeferred(Job onFind,
Job onFailed,
long timeoutMs,
boolean isLease)Add jobs to an existing search |
int | SearchJob.addDeferred(Job onFind,
Job onFail,
long expiration,
boolean isLease)Add a deferred search to run on completion of this search. |
void | KademliaNetworkDatabaseFacade.lookupDestination(Hash key,
Job onFinishedJob,
long timeoutMs,
Hash fromLocalDest)Lookup using the client's tunnels
Succeeds even if LS validation and store fails due to unsupported sig type, expired, etc. |
void | KademliaNetworkDatabaseFacade.lookupLeaseSet(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs) |
void | KademliaNetworkDatabaseFacade.lookupLeaseSet(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
Hash fromLocalDest)Lookup using the client's tunnels
Use lookupDestination() if you don't need the LS or don't need it validated. |
void | KademliaNetworkDatabaseFacade.lookupLeaseSetRemotely(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
Hash fromLocalDest)Unconditionally lookup using the client's tunnels. |
void | KademliaNetworkDatabaseFacade.lookupRouterInfo(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs) |
void | KademliaNetworkDatabaseFacade.lookupRouterInfoRemote(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs)Look up a RouterInfo by hash, performing a network search if not locally cached. |
(package private) SearchJob | FloodfillNetworkDatabaseFacade.search(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
boolean isLease)Lookup using exploratory tunnels. |
(package private) SearchJob | KademliaNetworkDatabaseFacade.search(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
boolean isLease)Begin a kademlia style search for the key specified, which can take up to timeoutMs and
will fire the appropriate jobs on success or timeout (or if the kademlia search completes
without any match)
Unused - called only by FNDF.searchFull() from FloodSearchJob which is overridden - don't use this. |
(package private) SearchJob | FloodfillNetworkDatabaseFacade.search(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
boolean isLease,
Hash fromLocalDest)Lookup using the client's tunnels. |
(package private) SearchJob | KademliaNetworkDatabaseFacade.search(Hash key,
Job onFindJob,
Job onFailedLookupJob,
long timeoutMs,
boolean isLease,
Hash fromLocalDest)Unused - see FNDF |
(package private) void | FloodfillNetworkDatabaseFacade.sendStore(Hash key,
DatabaseEntry ds,
Job onSuccess,
Job onFailure,
long sendTimeout,
Set<Hash> toIgnore)Send out a store. |
(package private) abstract void | KademliaNetworkDatabaseFacade.sendStore(Hash key,
DatabaseEntry ds,
Job onSuccess,
Job onFailure,
long sendTimeout,
Set<Hash> toIgnore)See implementation in FNDF |
| Constructor and Description |
|---|
DirectLookupJob(RouterContext ctx,
FloodfillNetworkDatabaseFacade facade,
Hash peer,
RouterInfo oldRI,
Job onFind,
Job onFail) |
FloodfillStoreJob(RouterContext context,
FloodfillNetworkDatabaseFacade facade,
Hash key,
DatabaseEntry data,
Job onSuccess,
Job onFailure,
long timeoutMs)Create a new FloodfillStoreJob to send data to floodfills. |
FloodfillStoreJob(RouterContext context,
FloodfillNetworkDatabaseFacade facade,
Hash key,
DatabaseEntry data,
Job onSuccess,
Job onFailure,
long timeoutMs,
Set<Hash> toSkip)Create a new FloodfillStoreJob to send data to floodfills. |
FloodOnlySearchJob(RouterContext ctx,
FloodfillNetworkDatabaseFacade facade,
Hash key,
Job onFind,
Job onFailed,
int timeoutMs)For DirectLookupJob extension, RI only, different match job |
FloodOnlySearchJob(RouterContext ctx,
FloodfillNetworkDatabaseFacade facade,
Hash key,
Job onFind,
Job onFailed,
int timeoutMs,
boolean isLease) |
FloodSearchJob(RouterContext ctx,
FloodfillNetworkDatabaseFacade facade,
Hash key,
Job onFind,
Job onFailed,
int timeoutMs,
boolean isLease) |
IterativeSearchJob(RouterContext ctx,
FloodfillNetworkDatabaseFacade facade,
Hash key,
Job onFind,
Job onFailed,
int timeoutMs,
boolean isLease)Lookup using exploratory tunnels |
IterativeSearchJob(RouterContext ctx,
FloodfillNetworkDatabaseFacade facade,
Hash key,
Job onFind,
Job onFailed,
int timeoutMs,
boolean isLease,
Hash fromLocalDest)Lookup using the client's tunnels. |
SearchJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
Job onSuccess,
Job onFailure,
long timeoutMs,
boolean keepStats,
boolean isLease,
long msgIDBloomXor)Create a new search for the routingKey specified |
StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DatabaseEntry data,
Job onSuccess,
Job onFailure,
long timeoutMs)Send a data structure to the floodfills |
StoreJob(RouterContext context,
KademliaNetworkDatabaseFacade facade,
Hash key,
DatabaseEntry data,
Job onSuccess,
Job onFailure,
long timeoutMs,
Set<Hash> toSkip)Send a data structure to the floodfills, skipping certain peers |
| Modifier and Type | Class and Description |
|---|---|
class | PeerTestJobPeriodically tests selected peers to gather real-time performance data and update peer profiles. |
| Modifier and Type | Class and Description |
|---|---|
(package private) class | BootCommSystemJobThis actually boots almost everything |
(package private) class | BootNetworkDbJobstart up the network database |
(package private) class | BootPeerManagerJobstart up the peer manager |
(package private) class | BuildTrustedLinksJobFor future restricted routes. |
class | CreateRouterInfoJobWarning - misnamed. |
class | LoadClientAppsJobRun any client applications specified in clients.config. |
(package private) class | LoadRouterInfoJobRun once or twice at startup by StartupJob,
and then runs BootCommSystemJob |
(package private) class | RebuildRouterInfoJobThis used be called from StartAcceptingClientsJob but is now disabled. |
(package private) class | StartAcceptingClientsJobstart I2CP interface |
class | StartupJobThe StartupJob should be run once on router startup to initialize the system
and set things in motion. |
| Constructor and Description |
|---|
BuildTrustedLinksJob(RouterContext context,
Job next)Create a new trusted links job. |
CreateRouterInfoJob(RouterContext ctx,
Job next)Creates a new CreateRouterInfoJob. |
| Modifier and Type | Class and Description |
|---|---|
class | AnalysisSybil attack analysis implementation. |
| Modifier and Type | Class and Description |
|---|---|
class | PersistRouterInfoJobRouter information persistence and synchronization job. |
class | ReadConfigJobSimply read the router config periodically,
so that the user may make config changes externally. |
class | UpdateRoutingKeyModifierJobUpdate the routing Key modifier every day at midnight (plus on startup). |
| Modifier and Type | Method and Description |
|---|---|
OutNetMessage | OutboundMessageRegistry.registerPending(MessageSelector replySelector,
ReplyJob onReply,
Job onTimeout)Registers a new, empty OutNetMessage, with the reply and timeout jobs specified. |
| Modifier and Type | Class and Description |
|---|---|
(package private) class | ExpireJobHandles tunnel expiration in two phases for graceful shutdown. |
class | TestJobRepeatedly tests a single tunnel for its lifetime to ensure it remains functional. |
| Modifier and Type | Class and Description |
|---|---|
class | NetDbCachingJobA caching job that periodically performs:
- Reverse DNS precaching for known routers
- Introducer precaching for known routers
Ensures:
- Only one instance is ever scheduled. |