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 usesFillInterest
andWriteFlusher
.Abstract implementation ofRetainableByteBuffer
with reference counting.ARetainableByteBuffer
pool where RetainableByteBuffers are held inPool
s that are held in array elements.A variant of theArrayByteBufferPool
that uses buckets of buffers that increase in size by a power of 2 (e.g.A variant ofArrayByteBufferPool
that tracks buffer acquires/releases, useful to identify buffer leaks.ByteArrayEndPoint.Accumulates data into a list of ByteBuffers which can then be combined into a single buffer or written to an OutputStream.Aggregates data into a single ByteBuffer of a specified maximum size.This class can be used to accumulate pairs ofByteBuffer
andCallback
, and eventually copy these into a singleByteBuffer
or byte array and succeed the callbacks.Present a ByteBuffer as an InputStream.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 suppliedByteBufferPool
or freshly allocated if one is not supplied.A pool forRetainableByteBuffer
instances.Accumulates a sequence ofRetainableByteBuffer
that are typically created during the generation of protocol bytes.AByteBufferPool
that does not pool itsRetainableByteBuffer
s.A ByteBufferPool with an additional no-argsByteBufferPool.Sized.acquire()
method to obtain a buffer of a preconfigured specific size and type.A wrapper forByteBufferPool
instances.An accumulator ofContent.Chunk
s used to facilitate minimal copy aggregation of multiple chunks.Factory for client-sideConnection
instances.Wraps another ClientConnectionFactory.A holder for a list of protocol strings identifiers (for example["h2", "h2-17", "h2-16"]
) and aClientConnectionFactory
that creates connections that speak an application protocol such as HTTP.The client-side component that connects to server sockets.Deprecated, for removal: This API element is subject to removal in a future version.Deprecated, for removal: This API element is subject to removal in a future version.replaced byTransport
AConnection
is associated to anEndPoint
so that I/O events happening on theEndPoint
can be processed by theConnection
.A Listener for connection events.Connection
implementations implement this interface when they can upgrade from the protocol they speak (for example HTTP/1.1) to a different protocol (e.g.Connection
implementations implement this interface when they can be upgraded to the protocol they speak (e.g.AConnection.Listener
that tracks connection statistics.Namespace class that contains the definitions of acontent source
, acontent sink
and acontent chunk
.A chunk of content indicating whether it is the last chunk.Implementations of this interface may processContent.Chunk
s being copied by theContent.copy(Source, Sink, Processor, Callback)
method, so thatContent.Chunk
s of unknown types can be copied.A content sink that writes the content to its implementation (a socket, a file, etc.).A source of content that can be read with a read/demand model.An abstract implementation of a timeout.CyclicTimeouts<T extends CyclicTimeouts.Expirable>An implementation of a timeout that manages manyexpirable
entities whose timeouts are mostly cancelled or re-scheduled.An entity that may expire.AnEndPoint
implementation based onDatagramChannel
.EndPoint is the abstraction for I/O communication using bytes.A communication conduit between two peers.Interface representing bundle of SSLSession associated data.Marks anEndPoint
that 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.Common IO operations forResource
content.ManagedSelector
wraps aSelector
simplifying non-blocking operations on channels.AManagedSelector.Selectable
is anEndPoint
that wish to be notified of non-blocking events by theManagedSelector
.A selector update to be done when the selector has been woken.Memory-based implementation ofEndPoint.Pipe
.A listener for raw network traffic within Jetty.A specialized version ofSocketChannelEndPoint
that supportsNetworkTrafficListener
s.A Quiet Exception.A reference counted resource, for example one that is borrowed from a pool, that may be retained an additional number of times, and released a correspondent number of times, over its lifecycle.A reference count implementation for aRetainable
resource.A wrapper ofRetainable
instances.A pooledByteBuffer
which maintains a reference count that is incremented withRetainable.retain()
and decremented withRetainable.release()
.A wrapper forRetainableByteBuffer
instancesSubclass ofRuntimeException
used to signal that there was anIOException
thrown by underlyingWriter
A partialEndPoint
implementation based onSelectableChannel
.SelectorManager
manages a number ofManagedSelector
s that simplify the non-blocking primitives provided by the JVM via thejava.nio
package.A listener for accept events.AnEndPoint
implementation based onSocketChannel
.The low-level transport used by clients.Abstract implementation ofTransport
based on IP.Abstract implementation ofTransport
based on sockets.The TCP/IPTransport
.The stream Unix-Domain socketTransport
.The UDP/IPTransport
.The datagram Unix-Domain socketTransport
.Abstract implementation ofTransport
based on Unix-Domain sockets.A wrapper forTransport
instances to allow layering ofTransport
s.A Utility class to help implementEndPoint.write(Callback, ByteBuffer...)
by callingEndPoint.flush(ByteBuffer...)
until all content is written.Deprecated, for removal: This API element is subject to removal in a future version.functionality removed, no replacementWrap a Writer as an OutputStream.An alternate toOutputStreamWriter
that supports several optimized implementation for well knownCharset
s, specificallyStandardCharsets.UTF_8
andStandardCharsets.ISO_8859_1
.
Transport