Packages that use TestJob.BatchState
Package
Description
Tunnel pool management: pool lifecycle, peer selection, build scheduling and failure handling for client and exploratory tunnels.
Uses of TestJob.BatchState in net.i2p.router.tunnel.pool
Methods in net.i2p.router.tunnel.pool that return TestJob.BatchStateModifier and TypeMethodDescription(package private) static TestJob.BatchStateTestJob.batchState(RouterContext ctx) The runtime state for a router context, created on first use.Methods in net.i2p.router.tunnel.pool with parameters of type TestJob.BatchStateModifier 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.(package private) static intTestJob.claimPoolTestSlot(TestJob.BatchState state, String poolId) Claim one per-pool test-instance slot forpoolIdin a router context's runtime state.(package private) static booleanTestJob.hasPoolTestHeadroom(TestJob.BatchState state, RouterContext ctx, TunnelPool pool, int activeCount) Whether the per-pool instance budget still has room for one more test inpool.(package private) static voidTestJob.rebufferAll(TestJob.BatchState state, RouterContext ctx, List<TestJob.PendingTest> pending) Return candidates to the buffer head, preserving their order, after a gate denial or a lost claim race so the next pump run retries them instead of waiting for a sweep re-offer.(package private) static voidTestJob.rebufferOne(TestJob.BatchState state, TestJob.PendingTest p) Put one candidate back at the buffer tail, used to rotate a candidate that is denied only for its own pool behind the rest of the scan so the drain is not blocked at the head by it.(package private) voidTestJob.InstanceClaims.releaseAll(TestJob.BatchState state, TestJob instance, Long tunnelKey) Release whatever this object still holds: the running-test registration, the pool claim, and the total counter.(package private) voidTestJob.InstanceClaims.releasePool(TestJob.BatchState state) Release the per-pool claim once, under the id captured at claim time.(package private) static voidTestJob.releasePoolTestSlot(TestJob.BatchState state, String poolId) Release one per-pool test-instance slot claimed byTestJob.claimPoolTestSlot(TestJob.BatchState, String), removing the counter at zero so the map stays bounded by the number of pools.(package private) static voidTestJob.releaseTokenPermits(TestJob.BatchState state, TestJob.RoundToken token) Release the in-flight permits a round reserved, once.(package private) voidTestJob.InstanceClaims.releaseTotal(TestJob.BatchState state) Release the total counter once.(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.