Packages that use I2PTunnelHTTPServer.Sender
Package
Description
Implementation of preconfigured tunnels for clients and servers, including special-purpose tunnels for IRC, SOCKS, HTTP and streaming.
Uses of I2PTunnelHTTPServer.Sender in net.i2p.i2ptunnel
Fields in net.i2p.i2ptunnel declared as I2PTunnelHTTPServer.SenderModifier and TypeFieldDescriptionprivate final I2PTunnelHTTPServer.SenderI2PTunnelHTTPServer.BodyWatchdog._bodyThe sender copying the request body.Methods in net.i2p.i2ptunnel with parameters of type I2PTunnelHTTPServer.SenderModifier and TypeMethodDescriptionprivate voidI2PTunnelHTTPServer.CompressedRequestor.finishTransfer(AtomicBoolean finished, I2PTunnelHTTPServer.Sender body, I2PTunnelHTTPServer.Sender reqSender, OutputStream serverout, OutputStream browserout, I2PTunnelHTTPServer.CompressedResponseOutputStream compressedout, InputStream browserin, InputStream serverin, String req) Tear down a completed (or failed) request exactly once.(package private) static booleanI2PTunnelHTTPServer.handOffBody(ThreadPoolExecutor pool, I2PTunnelHTTPServer.Sender s, String desc) Hand off the response body to the I/O transfer pool, or run it inline when the pool is null or shut down.(package private) static booleanI2PTunnelHTTPServer.handOffBody(ThreadPoolExecutor pool, I2PTunnelHTTPServer.Sender s, String desc, Runnable onCompletion) AsI2PTunnelHTTPServer.handOffBody(ThreadPoolExecutor, Sender, String)with a completion callback invoked after the Sender finishes (success, failure, or abort), on the pool worker when submitted and on the caller otherwise.private voidI2PTunnelHTTPServer.CompressedRequestor.runOnIO(I2PTunnelHTTPServer.Sender s, String desc) Run a Sender on the dedicated I/O pool with idle-based stall detection.private voidI2PTunnelHTTPServer.CompressedRequestor.scheduleBodyWatchdog(I2PTunnelHTTPServer.Sender body, AtomicBoolean finished, Runnable finish, InputStream browserin, OutputStream browserout, InputStream serverin, OutputStream serverout) Attach aI2PTunnelHTTPServer.BodyWatchdogto a detached async body.Constructors in net.i2p.i2ptunnel with parameters of type I2PTunnelHTTPServer.SenderModifierConstructorDescription(package private)BodyWatchdog(I2PTunnelHTTPServer.Sender body, AtomicBoolean finished, Runnable finish, InputStream browserin, OutputStream browserout, InputStream serverin, OutputStream serverout, Log log) Watches a stalled response body and aborts the connection.