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
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.(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.