Modifier and Type | Field and Description |
---|---|
protected PooledByteBuffer | DeflatingStreamSinkConduit.currentBuffer The streams buffer. |
Constructor and Description |
---|
PooledBufferFrameCallback(PooledByteBuffer buffer) |
PooledBuffersFrameCallback(PooledByteBuffer... buffers) |
Modifier and Type | Method and Description |
---|---|
PooledByteBuffer | ByteBufferPool.allocate() |
Modifier and Type | Method and Description |
---|---|
protected AbstractAjpClientStreamSourceChannel | AjpClientChannel.createChannel(FrameHeaderData frameHeaderData, PooledByteBuffer frameData) |
protected long | AjpClientResponseStreamSourceChannel.updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining) |
Constructor and Description |
---|
AbstractAjpClientStreamSourceChannel(AjpClientChannel framedChannel, PooledByteBuffer data, long frameDataRemaining) |
AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel, HeaderMap headers, int statusCode, String reasonPhrase, PooledByteBuffer frameData, int remaining) |
Modifier and Type | Method and Description |
---|---|
protected PooledByteBuffer[] | Http2StreamSinkChannel.allocateAll(PooledByteBuffer[] allHeaderBuffers, PooledByteBuffer currentBuffer) |
Modifier and Type | Method and Description |
---|---|
protected PooledByteBuffer[] | Http2StreamSinkChannel.allocateAll(PooledByteBuffer[] allHeaderBuffers, PooledByteBuffer currentBuffer) |
protected PooledByteBuffer[] | Http2StreamSinkChannel.allocateAll(PooledByteBuffer[] allHeaderBuffers, PooledByteBuffer currentBuffer) |
protected AbstractHttp2StreamSourceChannel | Http2Channel.createChannel(FrameHeaderData frameHeaderData, PooledByteBuffer frameData) |
Constructor and Description |
---|
Http2Channel(org.xnio.StreamConnection connectedStreamChannel, String protocol, ByteBufferPool bufferPool, PooledByteBuffer data, boolean clientSide, boolean fromUpgrade, boolean prefaceRequired, ByteBuffer initialOtherSideSettings, org.xnio.OptionMap settings) |
Http2Channel(org.xnio.StreamConnection connectedStreamChannel, String protocol, ByteBufferPool bufferPool, PooledByteBuffer data, boolean clientSide, boolean fromUpgrade, boolean prefaceRequired, org.xnio.OptionMap settings) |
Http2Channel(org.xnio.StreamConnection connectedStreamChannel, String protocol, ByteBufferPool bufferPool, PooledByteBuffer data, boolean clientSide, boolean fromUpgrade, org.xnio.OptionMap settings) |
Modifier and Type | Method and Description |
---|---|
protected PooledByteBuffer[] | SpdyStreamStreamSinkChannel.allocateAll(PooledByteBuffer[] allHeaderBuffers, PooledByteBuffer currentBuffer) |
protected PooledByteBuffer[] | SpdyStreamStreamSinkChannel.createHeaderBlock(PooledByteBuffer firstHeaderBuffer, PooledByteBuffer[] allHeaderBuffers, ByteBuffer firstBuffer, HeaderMap headers, boolean unidirectional) |
Modifier and Type | Method and Description |
---|---|
protected PooledByteBuffer[] | SpdyStreamStreamSinkChannel.allocateAll(PooledByteBuffer[] allHeaderBuffers, PooledByteBuffer currentBuffer) |
protected PooledByteBuffer[] | SpdyStreamStreamSinkChannel.allocateAll(PooledByteBuffer[] allHeaderBuffers, PooledByteBuffer currentBuffer) |
protected SpdyStreamSourceChannel | SpdyChannel.createChannel(FrameHeaderData frameHeaderData, PooledByteBuffer frameData) |
protected PooledByteBuffer[] | SpdyStreamStreamSinkChannel.createHeaderBlock(PooledByteBuffer firstHeaderBuffer, PooledByteBuffer[] allHeaderBuffers, ByteBuffer firstBuffer, HeaderMap headers, boolean unidirectional) |
protected PooledByteBuffer[] | SpdyStreamStreamSinkChannel.createHeaderBlock(PooledByteBuffer firstHeaderBuffer, PooledByteBuffer[] allHeaderBuffers, ByteBuffer firstBuffer, HeaderMap headers, boolean unidirectional) |
Constructor and Description |
---|
SpdyChannel(org.xnio.StreamConnection connectedStreamChannel, ByteBufferPool bufferPool, PooledByteBuffer data, ByteBufferPool heapBufferPool, boolean clientSide, org.xnio.OptionMap options) |
Modifier and Type | Field and Description |
---|---|
protected PooledByteBuffer | AbstractServerConnection.extraBytes Any extra bytes that were read from the channel. |
Modifier and Type | Method and Description |
---|---|
PooledByteBuffer | XnioByteBufferPool.allocate() |
PooledByteBuffer | DefaultByteBufferPool.allocate() |
PooledByteBuffer | AbstractServerConnection.getExtraBytes() |
Modifier and Type | Method and Description |
---|---|
void | DelegateOpenListener.handleEvent(org.xnio.StreamConnection channel, PooledByteBuffer additionalData) |
void | AbstractServerConnection.setExtraBytes(PooledByteBuffer extraBytes) |
static void | Connectors.ungetRequestBytes(HttpServerExchange exchange, PooledByteBuffer... buffers) Attached buffered data to the exchange. |
Modifier and Type | Method and Description |
---|---|
protected PooledByteBuffer | AbstractFramedStreamSinkChannel.createFrameFooter() |
PooledByteBuffer | SendFrameHeader.getByteBuffer() |
protected PooledByteBuffer | AbstractFramedStreamSourceChannel.processFrameData(PooledByteBuffer data, boolean lastFragmentOfFrame) |
Modifier and Type | Method and Description |
---|---|
protected abstract R | AbstractFramedChannel.createChannel(FrameHeaderData frameHeaderData, PooledByteBuffer frameData) Method that creates the actual stream source channel implementation that is in use. |
protected void | AbstractFramedStreamSourceChannel.dataReady(FrameHeaderData headerData, PooledByteBuffer frameData) Called when data has been read from the underlying channel. |
protected PooledByteBuffer | AbstractFramedStreamSourceChannel.processFrameData(PooledByteBuffer data, boolean lastFragmentOfFrame) |
boolean | AbstractFramedStreamSinkChannel.send(PooledByteBuffer pooled) Send a buffer to this channel. |
protected boolean | AbstractFramedStreamSinkChannel.sendInternal(PooledByteBuffer pooled) |
protected long | AbstractFramedStreamSourceChannel.updateFrameDataRemaining(PooledByteBuffer frameData, long frameDataRemaining) |
Constructor and Description |
---|
AbstractFramedChannel(org.xnio.StreamConnection connectedStreamChannel, ByteBufferPool bufferPool, FramePriority<C,R,S> framePriority, PooledByteBuffer readData, org.xnio.OptionMap settings) Create a new AbstractFramedChannel 8 |
AbstractFramedStreamSourceChannel(C framedChannel, PooledByteBuffer data, long frameDataRemaining) |
SendFrameHeader(int reminingInBuffer, PooledByteBuffer byteBuffer) |
SendFrameHeader(int reminingInBuffer, PooledByteBuffer byteBuffer, boolean anotherFrameRequired) |
SendFrameHeader(PooledByteBuffer byteBuffer) |
Modifier and Type | Method and Description |
---|---|
void | HttpOpenListener.handleEvent(org.xnio.StreamConnection channel, PooledByteBuffer buffer) |
void | HttpServerConnection.ungetRequestBytes(PooledByteBuffer unget) Pushes back the given data. |
Modifier and Type | Method and Description |
---|---|
void | Http2OpenListener.handleEvent(org.xnio.StreamConnection channel, PooledByteBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
void | SpdyOpenListener.handleEvent(org.xnio.StreamConnection channel, PooledByteBuffer buffer) |
Modifier and Type | Class and Description |
---|---|
class | ImmediatePooledByteBuffer |
class | ReferenceCountedPooled A reference counted pooled implementation, that basically consists of a main buffer, that can be sliced off into smaller buffers, and the underlying buffer will not be freed until all the slices and the main buffer itself have also been freed. |
Modifier and Type | Method and Description |
---|---|
PooledByteBuffer | ReferenceCountedPooled.createView(ByteBuffer newValue) |
Constructor and Description |
---|
PooledAdaptor(PooledByteBuffer buffer) |
ReferenceCountedPooled(PooledByteBuffer underlying, int referenceCount) |
ReferenceCountedPooled(PooledByteBuffer underlying, int referenceCount, ReferenceCountedPooled.FreeNotifier freeNotifier) |
Modifier and Type | Method and Description |
---|---|
protected PooledByteBuffer | StreamSourceFrameChannel.processFrameData(PooledByteBuffer frameData, boolean lastFragmentOfFrame) |
Modifier and Type | Method and Description |
---|---|
protected StreamSourceFrameChannel | WebSocketChannel.createChannel(FrameHeaderData frameHeaderData, PooledByteBuffer frameData) |
StreamSourceFrameChannel | WebSocketChannel.PartialFrame.getChannel(PooledByteBuffer data) |
protected PooledByteBuffer | StreamSourceFrameChannel.processFrameData(PooledByteBuffer frameData, boolean lastFragmentOfFrame) |
Constructor and Description |
---|
StreamSourceFrameChannel(WebSocketChannel wsChannel, WebSocketFrameType type, int rsv, boolean finalFragment, PooledByteBuffer pooled, long frameLength, Masker masker, ChannelFunction... functions) |
StreamSourceFrameChannel(WebSocketChannel wsChannel, WebSocketFrameType type, PooledByteBuffer pooled, long frameLength) |
Modifier and Type | Method and Description |
---|---|
boolean | WebSocket07FrameSinkChannel.sendInternal(PooledByteBuffer pooled) |
Modifier and Type | Method and Description |
---|---|
PooledByteBuffer | PerMessageDeflateFunction.transformForRead(PooledByteBuffer pooledBuffer, WebSocketChannel channel, boolean lastFragmentOfFrame) |
PooledByteBuffer | NoopExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer, WebSocketChannel channel, boolean lastFragmentOfFrame) |
PooledByteBuffer | ExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer, WebSocketChannel channel, boolean lastFragmentOfFrame) Transform the supplied buffer per this extension. |
PooledByteBuffer | CompositeExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer, WebSocketChannel channel, boolean lastFragmentOfFrame) |
PooledByteBuffer | PerMessageDeflateFunction.transformForWrite(PooledByteBuffer pooledBuffer, WebSocketChannel channel) |
PooledByteBuffer | NoopExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer, WebSocketChannel channel) |
PooledByteBuffer | ExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer, WebSocketChannel channel) Transform the supplied buffer per this extension. |
PooledByteBuffer | CompositeExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer, WebSocketChannel channel) |
Modifier and Type | Method and Description |
---|---|
PooledByteBuffer | PerMessageDeflateFunction.transformForRead(PooledByteBuffer pooledBuffer, WebSocketChannel channel, boolean lastFragmentOfFrame) |
PooledByteBuffer | NoopExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer, WebSocketChannel channel, boolean lastFragmentOfFrame) |
PooledByteBuffer | ExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer, WebSocketChannel channel, boolean lastFragmentOfFrame) Transform the supplied buffer per this extension. |
PooledByteBuffer | CompositeExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer, WebSocketChannel channel, boolean lastFragmentOfFrame) |
PooledByteBuffer | PerMessageDeflateFunction.transformForWrite(PooledByteBuffer pooledBuffer, WebSocketChannel channel) |
PooledByteBuffer | NoopExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer, WebSocketChannel channel) |
PooledByteBuffer | ExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer, WebSocketChannel channel) Transform the supplied buffer per this extension. |
PooledByteBuffer | CompositeExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer, WebSocketChannel channel) |
Copyright © 2015 JBoss by Red Hat. All rights reserved.