The router context, null when running without a router.

Construct the GUI bound to a running router, so it registers with the given client app manager and gets the router's context directly.

Get time until shutdown.

Is a graceful shutdown or restart in progress?

Restart the running I2P instance gracefully.

Stop the running I2P instance gracefully.

The router context, never null.

RouterApp (new way)

The router being configured.

The router being managed.

Retains the router context and helper used to manage the settings.

Retains the router context and response helper used to serve the requests.

The router context.

The router context the pool runs in.

The router context the job runs in.

The router context.

Supplies the clock the times are taken on.

The router context.

The router context.

The router context.

The router context.

The router context.

The context being cleaned up.

The router being scored.

Non-null, but take care when accessing context items before runRouter() is called as the context will not be initialized.

Retrieve the list of router contexts currently instantiated in this JVM.

Fetch the event count for an additional stat using the 60s period.

Fetch an additional stat value for cross-reference decisions.

Fetch an additional stat value using the 1-hour average.

Compute actual tunnel build success rate from event counts.

This does not use ctx.getConfigDir(), must provide a full path in filename Caller must synchronize.

Scale min/max/step with share bandwidth.

Transit bandwidth threshold for "heavy" — 80% of configured share bandwidth.

The max processing time in effect, tuned value if set else config.

Calculate a floor for per-tunnel bandwidth allocation based on participating tunnel count and total outbound bandwidth share.

Observed stat value used for autotuning.

Read the observed stat for autotuning decisions.

Read the live aggregate queue depth across all server tunnel pools.

Read the observed stat (receiveBacklogged avg per period).

UDP packet handler pool utilization (0.0-1.0).

NTCP reader pool utilization (0.0-1.0).

Current share bandwidth in bytes per second.

Recent streaming retransmission rate for this tuning cycle.

The throttle rejection-curve exponent, tuned value if set else the router.throttleRejectExponent config, clamped to the caller's [3,20] validity window.

NTCP writer pool utilization (0.0-1.0).

Whether the router is shutting down.

Log a permanent ban with RouterContext.

Remove old tuner.* properties from router.config that were written there before autotune.config was introduced.

Re-read min/max/step from autotune.config — live update, no restart.

Create a bandwidth history.

Constructor with context for immediate initialization.

A tunable parameter with the given name, description and subsystem.

Constructor.

Prepares to clean up a dead context.

Message pool for processing inbound I2NP messages.

Does not start the pumper.

Create a new JobQueueScaler.

Create a key manager.

Registers the duplicate and expiry rate stats the validator reports into.

Standard constructor.

Retains the context and loads any keys already persisted in the router config.

Create a throttle and schedule the reset of the "starting up" tunnel status.

Builds the shared gateway handling job.

System health.

Router context.

The router context.

Router context.

Create a new client listener runner for the given port.

Creates the facade without starting anything; call ClientManagerFacadeImpl.startup() to listen for I2CP connections.

Creates a new client writer runner.

Distribute a message from one client connection directly to another.

One of h or name non-null.

Create a job that delivers one received message to a client.

Create abuse report.

Creates an SSL listener on the given port, opening the client manager.

The router context.

The router context the engine runs in.

The router context.

Caller MUST call ECIESAEADEngine.startup() to get threaded generation.

Create the ratchet engine.

For the router SKM only.

The session key manager is constructed and accessed through the client manager.

The router context the facade belongs to.

The receiving router's context.

Create an empty in-memory database; nothing is read from disk.

Holds a message to deliver to a job.

The router context the parser runs in.

The router sending the messages.

Builds one clove's encrypted payload.

Make a basic DSM.

Build the unencrypted CloveSet specified by the config.

ECIES_X25519 and PQ only.

ELGAMAL_2048 only.

ELGAMAL_2048 only Called by OCMJH.

Ratchet only.

Removes expired LS fail cooldown entries.

Prunes last-valid timestamps older than the transient-gap grace window plus one cleanup interval (so a two-minute slack is kept).

Removes stale entries from the last reply request cache.

Make the top-level config, with a data clove, an optional ack clove, and an optional leaseset clove.

Called once at router startup.

Wrap a DSM in a GarlicMessage, add the fake session to the SKM.

Create a handler using fixed message-ID XOR masks, so the bloom filters can be primed identically across restarts.

Garlic message receiver that does not target a specific client destination.

Job to handle an inbound garlic message received outside of a tunnel.

Creates an OutboundCache instance and schedules periodic cache cleanup.

Schedules the actual send pass.

Send a message directly to a peer with an XOR mask.

Send a message directly to a peer with reply handling.

Sets up the job and its logger from the given router context.

The context of the cached settings.

The router answering lookups.

The router context the segments live in.

The router running the lookup.

The router context.

The router context.

Supplies the clock and the peer list.

Router context this store was constructed with.

Bucket size (K) from the property, clamped to what KBucketSet accepts.

Dynamically determines the number of explorations to run based on system state.

Create a single key and tag, for receiving a single encrypted message, and register it with the client's session key manager, to expire in the time specified.

Reads the unresponsive floodfill ban setting.

A lease is viable for a re-mint while it has at least this much time remaining: the re-sign request, floodfill propagation, and connection establishment all need the lease alive, and a tunnel closer to expiry than this is already inside the pool's proactive replacement window, so counting it would overstate the pool's health.

The search limit in effect, tuned value if set else config.

Check if the router is in a graceful or hard shutdown state.

Look up a peer's RouterInfo in the router's main NetDb, skipping the full validation performed by NetworkDatabaseFacade.lookupRouterInfoLocally(Hash).

This is now misnamed, as it is only used to determine whether to return floodfill peers only.

Refresh the cached configuration from properties at most once per CONFIG_REFRESH_MS, or immediately when the context changes.

Record the attempt and issue one non-blocking remote RI lookup with the given deadline (never past this cycle's query budget, never above the standard adaptive RouterInfo lookup cap).

Garlic wrap a message from a client or this router, destined for a router, to hide the contents from the OBEP.

Garlic wrap a message from nobody, destined for an unknown router, to hide the contents from the IBGW.

Garlic wrap a message from nobody, destined for an unknown router, to hide the contents from the IBGW.

Caller MUST call BlindCache.startup() to load persistent cache from disk.

Request is sent to; if null the job fails without sending anything.

Job to drop the peer after a lookup timeout.

Opens the job log and remembers the facade whose leasesets are expired.

New exploratory search with the given parameters and calculated concurrency level.

Allow the choice as to whether failed searches should count against the peer (such as if we search for a random key).

Record a failed store for the given peer.

Create a handler for floodfill database store messages.

Main DB.

New segmentor with the given RouterContext, containing a default, main netDb and prepared to add client netDbs.

Stores the network database and the log the flood runs under.

Create a new FloodfillStoreJob to send data to floodfills.

Match job for a flood-only search.

Remembers the flood search to fail on timeout.

Flood-only search for the given key against the floodfill network database.

Record a successful store for the given peer.

Handle an incoming floodfill DatabaseStoreMessage.

Queries one peer for a single key on behalf of an iterative search.

Binds the selector to the iterative search whose replies it matches.

Lookup using the client's tunnels.

Initializes the Kademlia-based network database facade.

PeerSelector.

Stores the facade and logger, and empties the per-peer probe cooldown map.

Stores the network database and the log the refresh runs under.

Requeue job that re-invokes searchNext.

Claims a selector id and records the peer, deadline and search state.

Opens the search's log, records the start time and initializes the peer-tracking sets.

Create job with tunnel info for reply routing.

Create a success job for tunnel delivery.

Send one DatabaseLookupMessage straight to a chosen peer over exploratory tunnels, instead of flooding the networkDb with it.

Job to manage peer exploration scheduling.

Send a data structure to the floodfills, skipping certain peers.

Starts a store tracking no skipped peers.

Build an empty volatile store, pre-sizing the entry map and the ban logger.

Schedules handling of a verification timeout.

The router context.

Opens a log for this router's reseed checker.

Clears the messages after a delay.

The router context.

The router context.

The router context.

The router context.

The base speed score of the peer.

Get the E-cap penalty, cached to avoid repeated Double.parseDouble.

The candidate-sample floor currently in effect, for logging.

Read the candidate-sample floor, honouring the configured override.

ProfileOrganizer.lookupRouterInfoUnvalidated(Hash) with the context passed in, so the fingerprint builder below is reachable from tests.

Creates a new PeerData instance by looking up all necessary information.

Opens this facade's log and builds the profile persistence helper and peer tester.

Caller should call PeerProfile.setLastHeardAbout(long) and PeerProfile.setFirstHeardAbout(long).

Schedules timeout handling when no reply arrived in time.

Creates the manager and its logger from the given context.

Construct a helper that reads and writes peer profiles under the router directory.

The router context.

Go through the files, and return a List of ClientAppConfig structures This is for the router.

The configured EncType to expect on read-in.

For each entry in apps, if the main class is an old Jetty class, migrate it to the new Jetty class, and update the Jetty config files.

Run client in a new thread.

Create a new BootNetworkDbJob.

Create a new trusted links job.

Caller must call schedule() before this event fires.

Creates the job that loads and starts the configured client apps.

Creates the job and opens its log.

Creates the runnable that loads and starts one client application class.

Passes the router context on to the JobImpl superclass.

The router context to log and act on.

The router to restart.

The router being shut down.

Delete all files listed in the delete file.

Best guess if running from a Debian package.

Create a new graceful shutdown handler.

Create a new router info persistence job.

Create a new router info republisher.

Create a new router watchdog.

Create a new routing key modifier update job.

The router context.

The router context.

Removes the leading D/E/G bandwidth marker from a visible capacity string.

The router context, which every subclass reads its configuration from.

The router context.

Fail a message and trigger failure callbacks.

The IPv6 config for the given transport style.

This returns true if the force-firewalled setting is configured, false otherwise.

Whether the NTCP transport is enabled.

Check if we support outbound IPv4 connections.

Create a lookup over the netDb's router IPs, backed by the GeoIP database.

Refiller keeping the given limiter's queues full.

Create a renderer.

Initialize the new transport.

Set up UPnP discovery and hold the transport manager to notify.

The router context.

The router context.

Create the pump for a transport, registering the rate stats it writes.

Create an inbound connected (though not established) NTCP connection.

Create an outbound unconnected NTCP connection.

Create a new outbound NTCP2 state.

Writer thread pool for the given context.

Router context.

The router context.

The router context.

The router context.

The router context.

The router context.

The router context.

The router context.

The router context.

The max concurrent establish in effect, tuned value if set else config.

Initialize or reset the packet state for reuse.

For SSU2.

Creates the message receiver and registers the fragment reassembly stats.

Creates an InboundMessageState and stores the first received fragment.

Creates the completed-message queue, sized from available memory, and registers its rate stats.

Prepare to start a new handshake with the given peer.

No state, all methods are thread-safe.

Creates the packet pusher.

A session with a remote peer over SSU2: the connection ids, the four cipher states and the header encryption keys are all fixed here, so the transport can build one without a separate handshake step.

Direct from IES2, there was never a PS2.

Have seen peer tests (as Alice) get stuck (_currentTest != null) so I've thrown some synchronizization on the methods; don't know the root cause or whether this fixes it.

Used by the packet cache factory.

Create a UDPSender with the given context, socket, name, and endpoint listener.

The router context.

The router context.

The router context.

The router context.

The router context.

The router context.

The router context.

Emit one sample covering everything accumulated so far and start over.

The per-tunnel bandwidth divisor in effect, tuned value if set else router.tunnel.perTunnelBweDivisor config, else the derived default of min(max tunnels, 100).

The transit throttle factor in effect, tuned value if set else config.

Create a preprocessor for inbound gateway tunnels.

Construct the validator, choosing a starting filter size from the configured share and the heap, then leaving the size to be retuned from measured load.

Binds the router context.

Binds the given context and receiver, storing the inbound flag.

Binds the router context and hop configuration.

Bind the sizer to the validator whose filter it will resize, keeping the share bandwidth to hand back on a resize.

Binds the router context.

Create a new outbound message distributor with bandwidth estimation.

Binds the context, config, and processor, sizing the RED queue to the allocated bandwidth.

A gateway for a single tunnel hop.

Binds the router context.

The tunnel data message to send after the lookup.

The tunnel data message dropped on lookup timeout.

For exploratory only (null destination).

Creates a new instance of TunnelDispatcher.

Creates a new TunnelGatewayPumper and starts configured number of pump threads.

For intermediate tunnel participant (not endpoint).

For inbound tunnel endpoints.

Context the cached config values came from.

Context the cached config values were read from.

The router running these tunnels.

The router context.

The router context.

The router context, for scheduling.