Packages that use BuildHandler.BuildMessageState
Package
Description
Tunnel pool management: pool lifecycle, peer selection, build scheduling and failure handling for client and exploratory tunnels.
Uses of BuildHandler.BuildMessageState in net.i2p.router.tunnel.pool
Fields in net.i2p.router.tunnel.pool declared as BuildHandler.BuildMessageStateModifier and TypeFieldDescriptionprivate final BuildHandler.BuildMessageStateBuildHandler.HandleReq._stateThe build message being handled.private final BuildHandler.BuildMessageStateBuildHandler.TimeoutReq._stateThe build message being timed out.(package private) final BuildHandler.BuildMessageStateBuildHandler.PendingLookup.stateThe message waiting on a next-hop lookup.Fields in net.i2p.router.tunnel.pool with type parameters of type BuildHandler.BuildMessageStateModifier and TypeFieldDescriptionprivate final BlockingQueue<BuildHandler.BuildMessageState> BuildHandler._inboundBuildMessagesQueue of received build messages.Methods in net.i2p.router.tunnel.pool with parameters of type BuildHandler.BuildMessageStateModifier and TypeMethodDescriptionprivate voidBuildHandler.handleReq(RouterInfo nextPeerInfo, BuildHandler.BuildMessageState state, BuildRequestRecord req, Hash nextPeer) Actually process the request and send the reply.private longBuildHandler.handleRequest(BuildHandler.BuildMessageState state, long now) Decrypt the request, lookup the RI locally, and callBuildHandler.handleReq(RouterInfo, BuildMessageState, BuildRequestRecord, Hash)if found or queue a lookup job.private voidBuildHandler.scheduleLookupDeadline(BuildHandler.BuildMessageState state, Hash nextPeer, AtomicBoolean decremented, int attempts) Schedule an independent deadline that releases this request's lookup attachment if neither callback has done so by then.Constructors in net.i2p.router.tunnel.pool with parameters of type BuildHandler.BuildMessageStateModifierConstructorDescription(package private)HandleReq(RouterContext ctx, BuildHandler.BuildMessageState state, BuildRequestRecord req, Hash nextPeer, AtomicBoolean decremented) Prepares to forward one build request.(package private)PendingLookup(BuildHandler.BuildMessageState state, BuildRequestRecord req, Hash nextPeer) Records a request waiting on a next-hop lookup.(package private)TimeoutReq(RouterContext ctx, BuildHandler.BuildMessageState state, BuildRequestRecord req, Hash nextPeer, AtomicBoolean decremented, int retriesLeft) Prepares to time out one build request.