Package org.eclipse.jetty.io
package org.eclipse.jetty.io
Jetty IO : Core classes for Jetty IO subsystem
-
ClassDescriptionA convenience base implementation of
Connection.Partial implementation of EndPoint that usesFillInterestandWriteFlusher.A ByteBuffer pool where ByteBuffers are held in queues that are held in array elements.ARetainableByteBufferpool where RetainableByteBuffers are held inPools that are held in array elements.ByteArrayEndPoint.Accumulates data into a list of ByteBuffers which can then be combined into a single buffer or written to an OutputStream.This class can be used to accumulate pairs ofByteBufferandCallback, and eventually copy these into a singleByteBufferor byte array and succeed the callbacks.Simple wrapper of a ByteBuffer as an OutputStream.This class implements an output stream in which the data is written into a list of ByteBuffer, the buffer list automatically grows as data is written to it, the buffers are taken from the suppliedByteBufferPoolor freshly allocated if one is not supplied.AByteBufferpool.Factory for client-sideConnectioninstances.Wraps another ClientConnectionFactory.A holder for a list of protocol strings identifying an application protocol (for example["h2", "h2-17", "h2-16"]) and aClientConnectionFactorythat creates connections that speak that network protocol.The client-side component that connects to server sockets.Configures aClientConnector.A pair/record holding aSelectableChanneland aSocketAddressto connect to.AConnectionis associated to anEndPointso that I/O events happening on theEndPointcan be processed by theConnection.A Listener for connection events.Connectionimplementations implement this interface when they can upgrade from the protocol they speak (for example HTTP/1.1) to a different protocol (e.g.Connectionimplementations implement this interface when they can be upgraded to the protocol they speak (e.g.AConnection.Listenerthat tracks connection statistics.An abstract implementation of a timeout.CyclicTimeouts<T extends CyclicTimeouts.Expirable>An implementation of a timeout that manages manyexpirableentities whose timeouts are mostly cancelled or re-scheduled.An entity that may expire.AnEndPointimplementation based onDatagramChannel.EndPoint is the abstraction for an I/O channel that transports bytes.Marks anEndPointthat wraps anotherEndPoint.A Jetty specialization of EOFException.A Utility class to help implementEndPoint.fillInterested(Callback)by keeping state and calling the context and callback objects.An Abstract implementation of an Idle Timeout.Extension of theArrayByteBufferPoolwhose bucket sizes increase exponentially instead of linearly.A variant of theArrayRetainableByteBufferPoolthat uses buckets of buffers that increase in size by a power of 2 (eg 1k, 2k, 4k, 8k, etc.).ManagedSelectorwraps aSelectorsimplifying non-blocking operations on channels.AManagedSelector.Selectableis anEndPointthat wish to be notified of non-blocking events by theManagedSelector.A selector update to be done when the selector has been woken.A ByteBuffer pool where ByteBuffers are held in queues that are held in a Map.A listener for raw network traffic within Jetty.A specialized version ofSocketChannelEndPointthat supportsNetworkTrafficListeners.A Quiet Exception.A pooled ByteBuffer which maintains a reference count that is incremented withRetainableByteBuffer.retain()and decremented withRetainableByteBuffer.release().ARetainableByteBufferpool.Subclass ofRuntimeExceptionused to signal that there was anIOExceptionthrown by underlyingWriterA partialEndPointimplementation based onSelectableChannel.SelectorManagermanages a number ofManagedSelectors that simplify the non-blocking primitives provided by the JVM via thejava.niopackage.A listener for accept events.AnEndPointimplementation based onSocketChannel.A Utility class to help implementEndPoint.write(Callback, ByteBuffer...)by callingEndPoint.flush(ByteBuffer...)until all content is written.A listener ofWriteFlusherevents.Wrap a Writer as an OutputStream.