Packages that use TestJob.RoundToken
Package
Description
Tunnel pool management: pool lifecycle, peer selection, build scheduling and failure handling for client and exploratory tunnels.
Uses of TestJob.RoundToken in net.i2p.router.tunnel.pool
Fields in net.i2p.router.tunnel.pool declared as TestJob.RoundTokenModifier and TypeFieldDescriptionprivate final TestJob.RoundTokenTestJob.OnTestReply._tokenThe round this reply belongs to.private final TestJob.RoundTokenTestJob.OnTestTimeout._tokenThe round being timed out.private final TestJob.RoundTokenTestJob.ReplySelector._tokenThe round this reply belongs to.Fields in net.i2p.router.tunnel.pool with type parameters of type TestJob.RoundTokenModifier and TypeFieldDescriptionprivate final AtomicReference<TestJob.RoundToken> TestJob._roundThe round currently in flight on this instance, or the most recently completed one.Methods in net.i2p.router.tunnel.pool with parameters of type TestJob.RoundTokenModifier and TypeMethodDescription(package private) voidTestJob.abandonRound(TestJob.RoundToken token) Give up a round that was armed but never made it onto the wire: mark it claimed so any straggler callback is a no-op, then return its permits.(package private) static voidTestJob.armRound(TestJob.BatchState state, AtomicReference<TestJob.RoundToken> active, TestJob.RoundToken next) Armnextas the active round and return the permits held by the round it supersedes.(package private) booleanTestJob.claimRound(TestJob.RoundToken token) Claim the round for this completion attempt.(package private) static booleanTestJob.claimRoundCompletion(TestJob.RoundToken active, TestJob.RoundToken token) First path to claim a round wins: the round must still be the active one and must not have been claimed before.(package private) voidTestJob.releaseRound(TestJob.RoundToken token) Release the in-flight permits a round reserved, once.(package private) static voidTestJob.releaseTokenPermits(TestJob.BatchState state, TestJob.RoundToken token) Release the in-flight permits a round reserved, once.(package private) booleanTestJob.reserveInFlight(TestJob.RoundToken token) Reserve the in-flight permits a round needs before it goes on the wire, and arm the round as this instance's active one.(package private) TestJob.InFlightRefusalTestJob.reserveInFlightForToken(TestJob.RoundToken token) Reserve in-flight permits and arm the round, reporting which gate refused it so the caller can log a specific reason.(package private) static TestJob.InFlightRefusalTestJob.reserveInFlightWithReason(TestJob.BatchState state, int maxConcurrent, String poolId, int poolBudget, TestJob.RoundToken token) Take the global and per-pool in-flight permits for a round, atomically, reporting which gate refused it.private booleanTestJob.sendTest(I2NPMessage m, int testPeriod, TestJob.RoundToken token) Send the tunnel test message through the selected tunnels.(package private) static booleanTestJob.tryReserveInFlight(TestJob.BatchState state, int maxConcurrent, String poolId, int poolBudget, TestJob.RoundToken token) Take the global and per-pool in-flight permits for a round, atomically.Method parameters in net.i2p.router.tunnel.pool with type arguments of type TestJob.RoundTokenModifier and TypeMethodDescription(package private) static voidTestJob.armRound(TestJob.BatchState state, AtomicReference<TestJob.RoundToken> active, TestJob.RoundToken next) Armnextas the active round and return the permits held by the round it supersedes.Constructors in net.i2p.router.tunnel.pool with parameters of type TestJob.RoundTokenModifierConstructorDescriptionOnTestReply(TestJob.RoundToken token) Handle the test reply and report the result.OnTestTimeout(long now, TestJob.RoundToken token) Handle a test timeout, reporting failure.ReplySelector(long id, TestJob.RoundToken token) Remembers which message id and round this selector is waiting on.