Modifier and Type | Field | Description |
---|---|---|
protected PooledByteBuffer |
DeflatingStreamSinkConduit.currentBuffer |
The streams buffer.
|
Constructor | Description |
---|---|
PooledBufferFrameCallback(PooledByteBuffer buffer) |
|
PooledBuffersFrameCallback(PooledByteBuffer... buffers) |
Modifier and Type | Method | Description |
---|---|---|
PooledByteBuffer |
ByteBufferPool.allocate() |
Modifier and Type | Method | Description |
---|---|---|
protected AbstractAjpClientStreamSourceChannel |
AjpClientChannel.createChannel(FrameHeaderData frameHeaderData,
PooledByteBuffer frameData) |
|
protected long |
AjpClientResponseStreamSourceChannel.updateFrameDataRemaining(PooledByteBuffer frameData,
long frameDataRemaining) |
Constructor | Description |
---|---|
AbstractAjpClientStreamSourceChannel(AjpClientChannel framedChannel,
PooledByteBuffer data,
long frameDataRemaining) |
|
AjpClientResponseStreamSourceChannel(AjpClientChannel framedChannel,
HeaderMap headers,
int statusCode,
java.lang.String reasonPhrase,
PooledByteBuffer frameData,
int remaining) |
Modifier and Type | Method | Description |
---|---|---|
protected PooledByteBuffer[] |
Http2StreamSinkChannel.allocateAll(PooledByteBuffer[] allHeaderBuffers,
PooledByteBuffer currentBuffer) |
Modifier and Type | Method | Description |
---|---|---|
protected PooledByteBuffer[] |
Http2StreamSinkChannel.allocateAll(PooledByteBuffer[] allHeaderBuffers,
PooledByteBuffer currentBuffer) |
|
protected AbstractHttp2StreamSourceChannel |
Http2Channel.createChannel(FrameHeaderData frameHeaderData,
PooledByteBuffer frameData) |
|
protected AbstractHttp2StreamSourceChannel |
Http2Channel.createChannelImpl(FrameHeaderData frameHeaderData,
PooledByteBuffer frameData) |
|
protected long |
Http2StreamSourceChannel.updateFrameDataRemaining(PooledByteBuffer data,
long frameDataRemaining) |
Constructor | Description |
---|---|
Http2Channel(org.xnio.StreamConnection connectedStreamChannel,
java.lang.String protocol,
ByteBufferPool bufferPool,
PooledByteBuffer data,
boolean clientSide,
boolean fromUpgrade,
boolean prefaceRequired,
java.nio.ByteBuffer initialOtherSideSettings,
org.xnio.OptionMap settings) |
|
Http2Channel(org.xnio.StreamConnection connectedStreamChannel,
java.lang.String protocol,
ByteBufferPool bufferPool,
PooledByteBuffer data,
boolean clientSide,
boolean fromUpgrade,
boolean prefaceRequired,
org.xnio.OptionMap settings) |
|
Http2Channel(org.xnio.StreamConnection connectedStreamChannel,
java.lang.String protocol,
ByteBufferPool bufferPool,
PooledByteBuffer data,
boolean clientSide,
boolean fromUpgrade,
org.xnio.OptionMap settings) |
Modifier and Type | Field | Description |
---|---|---|
protected PooledByteBuffer |
AbstractServerConnection.extraBytes |
Any extra bytes that were read from the channel.
|
Modifier and Type | Method | Description |
---|---|---|
PooledByteBuffer |
DefaultByteBufferPool.allocate() |
|
PooledByteBuffer |
XnioByteBufferPool.allocate() |
|
PooledByteBuffer |
AbstractServerConnection.getExtraBytes() |
Modifier and Type | Method | 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 | Description |
---|---|---|
PooledByteBuffer |
SendFrameHeader.getByteBuffer() |
|
protected PooledByteBuffer |
AbstractFramedStreamSinkChannel.preWriteTransform(PooledByteBuffer body) |
|
protected PooledByteBuffer |
AbstractFramedStreamSourceChannel.processFrameData(PooledByteBuffer data,
boolean lastFragmentOfFrame) |
Modifier and Type | Method | 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 |
AbstractFramedStreamSinkChannel.preWriteTransform(PooledByteBuffer body) |
|
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 | 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(int reminingInBuffer,
PooledByteBuffer byteBuffer,
boolean anotherFrameRequired,
java.nio.ByteBuffer trailer) |
|
SendFrameHeader(PooledByteBuffer byteBuffer) |
Modifier and Type | Method | Description |
---|---|---|
void |
HttpOpenListener.handleEvent(org.xnio.StreamConnection channel,
PooledByteBuffer buffer) |
|
void |
HttpServerConnection.ungetRequestBytes(PooledByteBuffer unget) |
Pushes back the given data.
|
Modifier and Type | Method | Description |
---|---|---|
void |
Http2OpenListener.handleEvent(org.xnio.StreamConnection channel,
PooledByteBuffer buffer) |
Modifier and Type | Class | 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 | Description |
---|---|---|
PooledByteBuffer |
ReferenceCountedPooled.createView(java.nio.ByteBuffer newValue) |
Constructor | Description |
---|---|
PooledAdaptor(PooledByteBuffer buffer) |
|
ReferenceCountedPooled(PooledByteBuffer underlying,
int referenceCount) |
|
ReferenceCountedPooled(PooledByteBuffer underlying,
int referenceCount,
ReferenceCountedPooled.FreeNotifier freeNotifier) |
Modifier and Type | Method | Description |
---|---|---|
protected PooledByteBuffer |
StreamSourceFrameChannel.processFrameData(PooledByteBuffer frameData,
boolean lastFragmentOfFrame) |
Modifier and Type | Method | Description |
---|---|---|
protected StreamSourceFrameChannel |
WebSocketChannel.createChannel(FrameHeaderData frameHeaderData,
PooledByteBuffer frameData) |
|
StreamSourceFrameChannel |
WebSocketChannel.PartialFrame.getChannel(PooledByteBuffer data) |
|
protected PooledByteBuffer |
StreamSourceFrameChannel.processFrameData(PooledByteBuffer frameData,
boolean lastFragmentOfFrame) |
|
static void |
WebSockets.sendBinary(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<java.lang.Void> callback) |
Sends a complete binary message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendBinary(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<java.lang.Void> callback,
long timeoutmillis) |
Sends a complete binary message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static <T> void |
WebSockets.sendBinary(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<T> callback,
T context) |
Sends a complete binary message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static <T> void |
WebSockets.sendBinary(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<T> callback,
T context,
long timeoutmillis) |
Sends a complete binary message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendBinaryBlocking(PooledByteBuffer pooledData,
WebSocketChannel wsChannel) |
Sends a complete binary message using blocking IO
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendPing(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<java.lang.Void> callback) |
Sends a complete ping message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendPing(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<java.lang.Void> callback,
long timeoutmillis) |
Sends a complete ping message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static <T> void |
WebSockets.sendPing(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<T> callback,
T context) |
Sends a complete ping message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static <T> void |
WebSockets.sendPing(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<T> callback,
T context,
long timeoutmillis) |
Sends a complete ping message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendPingBlocking(PooledByteBuffer pooledData,
WebSocketChannel wsChannel) |
Sends a complete ping message using blocking IO
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendPong(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<java.lang.Void> callback) |
Sends a complete pong message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendPong(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<java.lang.Void> callback,
long timeoutmillis) |
Sends a complete pong message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static <T> void |
WebSockets.sendPong(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<T> callback,
T context) |
Sends a complete pong message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static <T> void |
WebSockets.sendPong(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<T> callback,
T context,
long timeoutmillis) |
Sends a complete pong message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendPongBlocking(PooledByteBuffer pooledData,
WebSocketChannel wsChannel) |
Sends a complete pong message using blocking IO
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendText(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<java.lang.Void> callback) |
Sends a complete text message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendText(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<java.lang.Void> callback,
long timeoutmillis) |
Sends a complete text message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static <T> void |
WebSockets.sendText(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<T> callback,
T context) |
Sends a complete text message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static <T> void |
WebSockets.sendText(PooledByteBuffer pooledData,
WebSocketChannel wsChannel,
WebSocketCallback<T> callback,
T context,
long timeoutmillis) |
Sends a complete text message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
static void |
WebSockets.sendTextBlocking(PooledByteBuffer pooledData,
WebSocketChannel wsChannel) |
Sends a complete text message, invoking the callback when complete
Automatically frees the pooled byte buffer when done.
|
Constructor | 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 | Description |
---|---|---|
protected PooledByteBuffer |
WebSocket07FrameSinkChannel.preWriteTransform(PooledByteBuffer body) |
Modifier and Type | Method | Description |
---|---|---|
protected PooledByteBuffer |
WebSocket07FrameSinkChannel.preWriteTransform(PooledByteBuffer body) |
Modifier and Type | Method | Description |
---|---|---|
PooledByteBuffer |
CompositeExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer,
StreamSourceFrameChannel channel,
boolean lastFragementOfMessage) |
|
PooledByteBuffer |
ExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer,
StreamSourceFrameChannel channel,
boolean lastFragmentOfMessage) |
Transform the supplied buffer per this extension.
|
PooledByteBuffer |
NoopExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer,
StreamSourceFrameChannel channel,
boolean lastFragmentOfFrame) |
|
PooledByteBuffer |
PerMessageDeflateFunction.transformForRead(PooledByteBuffer pooledBuffer,
StreamSourceFrameChannel channel,
boolean lastFragmentOfMessage) |
|
PooledByteBuffer |
CompositeExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer,
StreamSinkFrameChannel channel,
boolean lastFrame) |
|
PooledByteBuffer |
ExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer,
StreamSinkFrameChannel channel,
boolean lastFrame) |
Transform the supplied buffer per this extension.
|
PooledByteBuffer |
NoopExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer,
StreamSinkFrameChannel channel,
boolean lastFrame) |
|
PooledByteBuffer |
PerMessageDeflateFunction.transformForWrite(PooledByteBuffer pooledBuffer,
StreamSinkFrameChannel channel,
boolean lastFrame) |
Modifier and Type | Method | Description |
---|---|---|
PooledByteBuffer |
CompositeExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer,
StreamSourceFrameChannel channel,
boolean lastFragementOfMessage) |
|
PooledByteBuffer |
ExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer,
StreamSourceFrameChannel channel,
boolean lastFragmentOfMessage) |
Transform the supplied buffer per this extension.
|
PooledByteBuffer |
NoopExtensionFunction.transformForRead(PooledByteBuffer pooledBuffer,
StreamSourceFrameChannel channel,
boolean lastFragmentOfFrame) |
|
PooledByteBuffer |
PerMessageDeflateFunction.transformForRead(PooledByteBuffer pooledBuffer,
StreamSourceFrameChannel channel,
boolean lastFragmentOfMessage) |
|
PooledByteBuffer |
CompositeExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer,
StreamSinkFrameChannel channel,
boolean lastFrame) |
|
PooledByteBuffer |
ExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer,
StreamSinkFrameChannel channel,
boolean lastFrame) |
Transform the supplied buffer per this extension.
|
PooledByteBuffer |
NoopExtensionFunction.transformForWrite(PooledByteBuffer pooledBuffer,
StreamSinkFrameChannel channel,
boolean lastFrame) |
|
PooledByteBuffer |
PerMessageDeflateFunction.transformForWrite(PooledByteBuffer pooledBuffer,
StreamSinkFrameChannel channel,
boolean lastFrame) |
Copyright © 2018. All rights reserved.