Modifier and Type | Method and Description |
---|---|
Connection |
SocketBinder.bind(int port)
Binds Transport to the specific port on localhost.
|
Connection |
AbstractBindingHandler.bind(int port)
Binds Transport to the specific port on localhost.
|
Connection |
SocketBinder.bind(SocketAddress socketAddress)
Binds Transport to the specific SocketAddress.
|
Connection |
SocketBinder.bind(SocketAddress socketAddress,
int backlog)
Binds Transport to the specific SocketAddress.
|
Connection |
SocketBinder.bind(String host,
int port)
Binds Transport to the specific host and port.
|
Connection |
AbstractBindingHandler.bind(String host,
int port)
Binds Transport to the specific host and port.
|
Connection |
SocketBinder.bind(String host,
int port,
int backlog)
Binds Transport to the specific host and port.
|
Connection |
AbstractBindingHandler.bind(String host,
int port,
int backlog)
Binds Transport to the specific host and port.
|
Connection |
SocketBinder.bind(String host,
PortRange portRange,
int backlog)
Binds Transport to the specific host, and port within a
PortRange . |
Connection |
AbstractBindingHandler.bind(String host,
PortRange portRange,
int backlog)
Binds Transport to the specific host, and port within a
PortRange . |
Connection |
SocketBinder.bindToInherited()
Binds the Transport to the channel inherited from the entity that
created this Java virtual machine.
|
Connection |
ReadResult.getConnection()
Get the
Connection data were read from. |
Connection |
Context.getConnection()
Get the processing
Connection . |
Connection |
Result.getConnection()
Get
Connection , associated with the result. |
Connection |
WriteResult.getConnection()
Get the
Connection data were read from. |
Modifier and Type | Method and Description |
---|---|
Future<Connection> |
SocketAcceptor.accept()
Accept a
Connection |
Future<Connection> |
ConnectorHandler.connect(E remoteAddress)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
Future<Connection> |
ConnectorHandler.connect(E remoteAddress,
E localAddress)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
GrizzlyFuture<Connection> |
AbstractSocketConnectorHandler.connect(SocketAddress remoteAddress) |
GrizzlyFuture<Connection> |
AbstractSocketConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress) |
Future<Connection> |
SocketConnectorHandler.connect(String host,
int port)
Creates, initializes and connects socket to the specific remote host
and port and returns
Connection , representing socket. |
GrizzlyFuture<Connection> |
AbstractSocketConnectorHandler.connect(String host,
int port) |
protected abstract FutureImpl<Connection> |
AbstractSocketConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
protected FutureImpl<Connection> |
AbstractSocketConnectorHandler.makeCancellableFuture(Connection connection) |
Modifier and Type | Method and Description |
---|---|
boolean |
Writer.canWrite(Connection<L> connection)
Return
true if the connection has not exceeded it's maximum
size in bytes of pending writes, otherwise false . |
protected abstract void |
AbstractTransport.closeConnection(Connection connection)
Close the connection, managed by Transport
|
static Context |
Context.create(Connection connection) |
static <K,L> ReadResult<K,L> |
ReadResult.create(Connection connection) |
static <K,L> WriteResult<K,L> |
WriteResult.create(Connection connection) |
static <K,L> ReadResult<K,L> |
ReadResult.create(Connection connection,
K message,
L srcAddress,
int readSize) |
static <K,L> WriteResult<K,L> |
WriteResult.create(Connection connection,
K message,
L dstAddress,
int writeSize) |
static Context |
Context.create(Connection connection,
Processor processor,
IOEvent ioEvent,
IOEventProcessingHandler processingHandler) |
static void |
ProcessorExecutor.execute(Connection connection,
IOEvent ioEvent,
Processor processor,
IOEventProcessingHandler processingHandler) |
boolean |
IOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent)
The
SelectorRunner will invoke this
method to allow the strategy implementation to decide how the
IOEvent will be handled. |
boolean |
IOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent,
boolean isIoEventEnabled)
The
SelectorRunner will invoke this
method to allow the strategy implementation to decide how the
IOEvent will be handled. |
void |
Transport.fireIOEvent(IOEvent ioEvent,
Connection connection,
IOEventProcessingHandler processingHandler)
Fires specific
IOEvent on the Connection |
Reader |
Transport.getReader(Connection connection)
Get the
Reader to read data from the Connection . |
StreamReader |
StandaloneProcessor.getStreamReader(Connection connection)
|
StreamWriter |
StandaloneProcessor.getStreamWriter(Connection connection)
|
Writer |
Transport.getWriter(Connection connection)
Get the
Writer to write data to the Connection . |
protected FutureImpl<Connection> |
AbstractSocketConnectorHandler.makeCancellableFuture(Connection connection) |
void |
Writer.notifyWritePossible(Connection<L> connection,
WriteHandler writeHandler)
Registers
WriteHandler , which will be notified ones at least one
byte can be written. |
E |
Processor.obtainContext(Connection connection)
Creates
Context |
Context |
StandaloneProcessor.obtainContext(Connection connection) |
Processor |
Transport.obtainProcessor(IOEvent ioEvent,
Connection connection)
Gets the default
Processor , which will process Transport
Connection s I/O events in case, if Connection
doesn't have own Processor preferences. |
Processor |
AbstractTransport.obtainProcessor(IOEvent ioEvent,
Connection connection)
Gets the default
Processor , which will process Transport
Connection s I/O events in case, if Connection
doesn't have own Processor preferences. |
void |
ConnectionProbe.onAcceptEvent(Connection serverConnection,
Connection clientConnection)
Method will be called, when server side connection gets accepted.
|
void |
ConnectionProbe.onAcceptEvent(Connection serverConnection,
Connection clientConnection)
Method will be called, when server side connection gets accepted.
|
void |
ConnectionProbe.Adapter.onAcceptEvent(Connection serverConnection,
Connection clientConnection)
Method will be called, when server side connection gets accepted.
|
void |
ConnectionProbe.Adapter.onAcceptEvent(Connection serverConnection,
Connection clientConnection)
Method will be called, when server side connection gets accepted.
|
void |
ConnectionProbe.onBindEvent(Connection connection)
Method will be called, when server side connection gets bound.
|
void |
ConnectionProbe.Adapter.onBindEvent(Connection connection)
Method will be called, when server side connection gets bound.
|
void |
Connection.CloseListener.onClosed(Connection connection,
Connection.CloseType type)
Deprecated.
|
void |
ConnectionProbe.onCloseEvent(Connection connection)
Method will be called, when
Connection gets closed. |
void |
ConnectionProbe.Adapter.onCloseEvent(Connection connection)
Method will be called, when
Connection gets closed. |
void |
ConnectionProbe.onConnectEvent(Connection connection)
Method will be called, when client side connection gets connected (opened).
|
void |
ConnectionProbe.Adapter.onConnectEvent(Connection connection)
Method will be called, when client side connection gets connected (opened).
|
void |
ConnectionProbe.onErrorEvent(Connection connection,
Throwable error)
Method will be called, when error occurs on the
Connection . |
void |
ConnectionProbe.Adapter.onErrorEvent(Connection connection,
Throwable error)
Method will be called, when error occurs on the
Connection . |
void |
ConnectionProbe.onIOEventDisableEvent(Connection connection,
IOEvent ioEvent)
Method will be called, when
IOEvent for the specific
Connection gets disabled. |
void |
ConnectionProbe.Adapter.onIOEventDisableEvent(Connection connection,
IOEvent ioEvent)
Method will be called, when
IOEvent for the specific
Connection gets disabled. |
void |
ConnectionProbe.onIOEventEnableEvent(Connection connection,
IOEvent ioEvent)
Method will be called, when
IOEvent for the specific
Connection gets enabled. |
void |
ConnectionProbe.Adapter.onIOEventEnableEvent(Connection connection,
IOEvent ioEvent)
Method will be called, when
IOEvent for the specific
Connection gets enabled. |
void |
ConnectionProbe.onIOEventReadyEvent(Connection connection,
IOEvent ioEvent)
Method will be called, when
IOEvent for the specific
Connection gets ready. |
void |
ConnectionProbe.Adapter.onIOEventReadyEvent(Connection connection,
IOEvent ioEvent)
Method will be called, when
IOEvent for the specific
Connection gets ready. |
void |
ConnectionProbe.onReadEvent(Connection connection,
Buffer data,
int size)
Method will be called, when the
Connection has read data. |
void |
ConnectionProbe.Adapter.onReadEvent(Connection connection,
Buffer data,
int size)
Method will be called, when the
Connection has read data. |
void |
ConnectionProbe.onWriteEvent(Connection connection,
Buffer data,
long size)
Method will be called, when the
Connection has written data. |
void |
ConnectionProbe.Adapter.onWriteEvent(Connection connection,
Buffer data,
long size)
Method will be called, when the
Connection has written data. |
protected void |
AbstractSocketConnectorHandler.preConfigure(Connection connection)
Pre-configures
Connection object before actual connecting phase
will be started. |
GrizzlyFuture<ReadResult<Buffer,L>> |
AbstractReader.read(Connection connection)
Method reads data.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
Reader.read(Connection connection)
Method reads data.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
AbstractReader.read(Connection connection,
Buffer buffer)
Method reads data to the buffer.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
Reader.read(Connection connection,
Buffer buffer)
Method reads data to the buffer.
|
void |
AbstractReader.read(Connection connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
Reader.read(Connection connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
Reader.read(Connection connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler,
Interceptor<ReadResult> interceptor)
Method reads data to the buffer.
|
void |
StandaloneProcessor.read(Connection connection,
CompletionHandler completionHandler) |
void |
Processor.read(Connection connection,
CompletionHandler<ReadResult> completionHandler) |
Processor |
ChainProcessorSelector.select(IOEvent ioEvent,
Connection connection)
Selects
Processor , which will process connection event. |
Processor |
DefaultProcessorSelector.select(IOEvent ioEvent,
Connection connection)
Selects
Processor , which will process connection event. |
Processor |
StandaloneProcessorSelector.select(IOEvent ioEvent,
Connection connection)
|
Processor |
ProcessorSelector.select(IOEvent ioEvent,
Connection connection)
Selects
Processor , which will process connection event. |
void |
Context.setConnection(Connection connection)
Set the processing
Connection . |
void |
SocketBinder.unbind(Connection connection)
Unbinds bound
Transport connection. |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
AbstractWriter.write(Connection connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
void |
AbstractWriter.write(Connection connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
push back logic is deprecated
|
void |
StandaloneProcessor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler completionHandler) |
void |
Processor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler) |
void |
Processor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler,
MessageCloner messageCloner) |
void |
Processor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
StandaloneProcessor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler completionHandler,
MessageCloner messageCloner) |
void |
StandaloneProcessor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
GrizzlyFuture<WriteResult<WritableMessage,L>> |
AbstractWriter.write(Connection connection,
WritableMessage message)
Method writes the
WritableMessage . |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection connection,
WritableMessage message)
Method writes the
WritableMessage . |
void |
AbstractWriter.write(Connection connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
void |
Writer.write(Connection connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
Modifier and Type | Method and Description |
---|---|
void |
ConnectorHandler.connect(E remoteAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
void |
ConnectorHandler.connect(E remoteAddress,
E localAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
void |
AbstractSocketConnectorHandler.connect(SocketAddress remoteAddress,
CompletionHandler<Connection> completionHandler) |
void |
AbstractSocketConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
protected abstract FutureImpl<Connection> |
AbstractSocketConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
Constructor and Description |
---|
ReadResult(Connection connection) |
ReadResult(Connection connection,
K message,
L srcAddress,
int readSize) |
Modifier and Type | Field and Description |
---|---|
protected Connection |
AsyncQueueRecord.connection |
Modifier and Type | Method and Description |
---|---|
Connection |
AsyncQueueRecord.getConnection() |
Modifier and Type | Method and Description |
---|---|
boolean |
AsyncQueueWriter.canWrite(Connection connection) |
boolean |
AsyncQueueWriter.canWrite(Connection connection,
int size)
Deprecated.
the size parameter will be ignored, use
AsyncQueueWriter.canWrite(org.glassfish.grizzly.Connection) instead. |
E |
MessageCloner.clone(Connection connection,
E originalMessage)
Method will be called by
AsyncQueueWriter , when message
could not be written directly, and will be added to the queue. |
static AsyncReadQueueRecord |
AsyncReadQueueRecord.create(Connection connection,
Buffer message,
ReadResult currentResult,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
static AsyncWriteQueueRecord |
AsyncWriteQueueRecord.create(Connection connection,
WritableMessage message,
WriteResult currentResult,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushbackHandler,
boolean isEmptyRecord) |
boolean |
AsyncQueue.isReady(Connection connection)
Checks whether there is ready data in
AsyncQueue ,
associated with the Connection . |
void |
AsyncQueueWriter.notifyWritePossible(Connection connection,
WriteHandler writeHandler)
Registers
WriteHandler , which will be notified ones the
Connection is able to accept more bytes to be written. |
void |
AsyncQueueWriter.notifyWritePossible(Connection connection,
WriteHandler writeHandler,
int size)
Deprecated.
the size parameter will be ignored, use {@link #notifyWritePossible(org.glassfish.grizzly.Connection, org.glassfish.grizzly.WriteHandler) instead.
|
void |
PushBackHandler.onAccept(Connection connection,
WritableMessage message)
Deprecated.
The method is invoked once message is accepted by
Writer . |
void |
AsyncQueue.onClose(Connection connection)
Callback method, which is called, when
Connection has been closed,
to let processor release a connection associated resources. |
void |
PushBackHandler.onPushBack(Connection connection,
WritableMessage message,
PushBackContext pushBackContext)
Deprecated.
The method is invoked if message was refused by
Writer
due to I/O or memory limitations. |
protected void |
AsyncQueueRecord.set(Connection connection,
Object message,
R currentResult,
CompletionHandler completionHandler) |
protected void |
AsyncWriteQueueRecord.set(Connection connection,
WritableMessage message,
WriteResult currentResult,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isEmptyRecord) |
void |
AsyncQueueWriter.write(Connection connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner<WritableMessage> cloner)
Deprecated.
push back logic is deprecated
|
Constructor and Description |
---|
AsyncQueueRecord(Connection connection,
Object message,
R currentResult,
CompletionHandler completionHandler) |
AsyncWriteQueueRecord(Connection connection,
WritableMessage message,
WriteResult currentResult,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isEmptyRecord) |
Modifier and Type | Method and Description |
---|---|
Connection |
FilterChainContext.getConnection()
Get the
Connection , associated with the current processing. |
Modifier and Type | Method and Description |
---|---|
static FilterChainContext |
FilterChainContext.create(Connection connection) |
FilterChainContext |
BaseFilter.createContext(Connection connection,
FilterChainContext.Operation operation) |
void |
DefaultFilterChain.fireEventDownstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
FilterChain.fireEventDownstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
DefaultFilterChain.fireEventUpstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
FilterChain.fireEventUpstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
DefaultFilterChain.flush(Connection connection,
CompletionHandler<WriteResult> completionHandler) |
void |
FilterChain.flush(Connection connection,
CompletionHandler<WriteResult> completionHandler) |
Context |
AbstractFilterChain.obtainContext(Connection connection)
Creates
Context |
FilterChainContext |
AbstractFilterChain.obtainFilterChainContext(Connection connection) |
FilterChainContext |
FilterChain.obtainFilterChainContext(Connection connection) |
FilterChainContext |
AbstractFilterChain.obtainFilterChainContext(Connection connection,
int startIdx,
int endIdx,
int currentIdx) |
FilterChainContext |
FilterChain.obtainFilterChainContext(Connection connection,
int startIdx,
int endIdx,
int currentIdx) |
void |
DefaultFilterChain.read(Connection connection,
CompletionHandler<ReadResult> completionHandler) |
Processor |
FilterChainProcessorSelector.select(IOEvent ioEvent,
Connection connection)
Returns
FilterChain instance, if it's interested in processing
passed IOEvent , or null otherwise. |
void |
DefaultFilterChain.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler) |
void |
DefaultFilterChain.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler,
MessageCloner messageCloner) |
void |
DefaultFilterChain.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Connection |
HttpRequestPacket.getConnection() |
Modifier and Type | Method and Description |
---|---|
protected void |
HttpClientFilter.clearResponse(Connection connection) |
ParsingResult |
ContentEncoding.decode(Connection connection,
HttpContent httpContent)
Decode HTTP packet content represented by
HttpContent . |
ParsingResult |
GZipContentEncoding.decode(Connection connection,
HttpContent httpContent) |
ParsingResult |
LZMAContentEncoding.decode(Connection connection,
HttpContent httpContent) |
HttpContent |
ContentEncoding.encode(Connection connection,
HttpContent httpContent)
Encode HTTP packet content represented by
HttpContent . |
HttpContent |
GZipContentEncoding.encode(Connection connection,
HttpContent httpContent) |
HttpContent |
LZMAContentEncoding.encode(Connection connection,
HttpContent httpContent) |
protected static boolean |
HttpCodecFilter.isSecure(Connection connection)
flag, which indicates whether this HttpCodecFilter is dealing with
the secured HTTP packets.
|
protected static void |
KeepAlive.notifyProbesConnectionAccepted(KeepAlive keepAlive,
Connection connection)
Notify registered
KeepAliveProbe s about the "keep-alive connection accepted" event. |
protected static void |
KeepAlive.notifyProbesHit(KeepAlive keepAlive,
Connection connection,
int requestNumber)
Notify registered
KeepAliveProbe s about the "keep-alive connection hit" event. |
protected static void |
KeepAlive.notifyProbesRefused(KeepAlive keepAlive,
Connection connection)
Notify registered
KeepAliveProbe s about the "keep-alive connection refused" event. |
protected static void |
KeepAlive.notifyProbesTimeout(KeepAlive keepAlive,
Connection connection)
Notify registered
KeepAliveProbe s about the "keep-alive connection timeout" event. |
void |
KeepAliveProbe.onConnectionAcceptEvent(Connection connection)
Method will be called, when new keep-alive HTTP connection is getting established.
|
void |
KeepAliveProbe.Adapter.onConnectionAcceptEvent(Connection connection)
Method will be called, when new keep-alive HTTP connection is getting established.
|
void |
HttpProbe.onContentChunkParseEvent(Connection connection,
HttpContent content)
Method will be called, when HTTP message content chunk gets parsed
(either request or response).
|
void |
HttpProbe.Adapter.onContentChunkParseEvent(Connection connection,
HttpContent content)
Method will be called, when HTTP message content chunk gets parsed
(either request or response).
|
void |
HttpProbe.onContentChunkSerializeEvent(Connection connection,
HttpContent content)
Method will be called, when HTTP message content chunk is prepared to be
serialized (either request or response).
|
void |
HttpProbe.Adapter.onContentChunkSerializeEvent(Connection connection,
HttpContent content)
Method will be called, when HTTP message content chunk is prepared to be
serialized (either request or response).
|
void |
HttpProbe.onContentEncodingParseEvent(Connection connection,
HttpHeader header,
Buffer buffer,
ContentEncoding contentEncoding)
Method will be called, when
ContentEncoding will be applied
during the parsing/decoding of the certain HTTP message content chunk. |
void |
HttpProbe.Adapter.onContentEncodingParseEvent(Connection connection,
HttpHeader header,
Buffer buffer,
ContentEncoding contentEncoding)
Method will be called, when
ContentEncoding will be applied
during the parsing/decoding of the certain HTTP message content chunk. |
void |
HttpProbe.onContentEncodingSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer,
ContentEncoding contentEncoding)
Method will be called, when
ContentEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
void |
HttpProbe.Adapter.onContentEncodingSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer,
ContentEncoding contentEncoding)
Method will be called, when
ContentEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
void |
HttpProbe.onDataReceivedEvent(Connection connection,
Buffer buffer)
Method will be called, when
Buffer will come for processing to
the HttpCodecFilter (either request or response). |
void |
HttpProbe.Adapter.onDataReceivedEvent(Connection connection,
Buffer buffer)
Method will be called, when
Buffer will come for processing to
the HttpCodecFilter (either request or response). |
void |
HttpProbe.onDataSentEvent(Connection connection,
Buffer buffer)
Method will be called, when
Buffer , produced by the
HttpCodecFilter will be ready to go to the next
Filter in the chain and finally
written on wire. |
void |
HttpProbe.Adapter.onDataSentEvent(Connection connection,
Buffer buffer)
Method will be called, when
Buffer , produced by the
HttpCodecFilter will be ready to go to the next
Filter in the chain and finally
written on wire. |
void |
HttpProbe.onErrorEvent(Connection connection,
HttpPacket httpPacket,
Throwable error)
Method will be called, when error occurs during the
HttpCodecFilter processing. |
void |
HttpProbe.Adapter.onErrorEvent(Connection connection,
HttpPacket httpPacket,
Throwable error)
Method will be called, when error occurs during the
HttpCodecFilter processing. |
void |
HttpProbe.onHeaderParseEvent(Connection connection,
HttpHeader header,
int size)
Method will be called, when HTTP message header gets parsed
(either request or response).
|
void |
HttpProbe.Adapter.onHeaderParseEvent(Connection connection,
HttpHeader header,
int size)
Method will be called, when HTTP message header gets parsed
(either request or response).
|
void |
HttpProbe.onHeaderSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer)
Method will be called, when HTTP message header gets serialized
(either request or response).
|
void |
HttpProbe.Adapter.onHeaderSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer)
Method will be called, when HTTP message header gets serialized
(either request or response).
|
void |
KeepAliveProbe.onHitEvent(Connection connection,
int requestNumber)
Method will be called, when HTTP request comes on a kept alive connection.
|
void |
KeepAliveProbe.Adapter.onHitEvent(Connection connection,
int requestNumber)
Method will be called, when HTTP request comes on a kept alive connection.
|
void |
KeepAliveProbe.onRefuseEvent(Connection connection)
Method will be called, when the Connection could be used in the keep alive mode,
but due to KeepAlive config limitations it will be closed.
|
void |
KeepAliveProbe.Adapter.onRefuseEvent(Connection connection)
Method will be called, when the Connection could be used in the keep alive mode,
but due to KeepAlive config limitations it will be closed.
|
void |
KeepAliveProbe.onTimeoutEvent(Connection connection)
Method will be called, when the keep alive Connection idle timeout expired.
|
void |
KeepAliveProbe.Adapter.onTimeoutEvent(Connection connection)
Method will be called, when the keep alive Connection idle timeout expired.
|
void |
HttpProbe.onTransferEncodingParseEvent(Connection connection,
HttpHeader header,
Buffer buffer,
TransferEncoding transferEncoding)
Method will be called, when
TransferEncoding will be applied
during the parsing/decoding of the certain HTTP message content chunk. |
void |
HttpProbe.Adapter.onTransferEncodingParseEvent(Connection connection,
HttpHeader header,
Buffer buffer,
TransferEncoding transferEncoding)
Method will be called, when
TransferEncoding will be applied
during the parsing/decoding of the certain HTTP message content chunk. |
void |
HttpProbe.onTransferEncodingSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer,
TransferEncoding transferEncoding)
Method will be called, when
TransferEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
void |
HttpProbe.Adapter.onTransferEncodingSerializeEvent(Connection connection,
HttpHeader header,
Buffer buffer,
TransferEncoding transferEncoding)
Method will be called, when
TransferEncoding will be applied
during the serialization/encoding of the certain HTTP message content chunk. |
void |
HttpRequestPacket.setConnection(Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
ShutdownHandler.onShutdown(Connection initiator)
Method is called once AjpHandlerFilter received shutdown message.
|
Modifier and Type | Method and Description |
---|---|
void |
HttpServerProbe.onBeforeServiceEvent(HttpServerFilter filter,
Connection connection,
Request request,
HttpHandler httpHandler)
Method will be called, before invoking
HttpHandler.service(org.glassfish.grizzly.http.server.Request, org.glassfish.grizzly.http.server.Response) . |
void |
HttpServerProbe.Adapter.onBeforeServiceEvent(HttpServerFilter filter,
Connection connection,
Request request,
HttpHandler httpHandler)
Method will be called, before invoking
HttpHandler.service(org.glassfish.grizzly.http.server.Request, org.glassfish.grizzly.http.server.Response) . |
void |
HttpServerProbe.onRequestCancelEvent(HttpServerFilter filter,
Connection connection,
Request request)
Method will be called, when
Request processing is cancelled
after suspend. |
void |
HttpServerProbe.Adapter.onRequestCancelEvent(HttpServerFilter filter,
Connection connection,
Request request) |
void |
HttpServerProbe.onRequestCompleteEvent(HttpServerFilter filter,
Connection connection,
Response response)
Method will be called, when
Request processing will be completed. |
void |
HttpServerProbe.Adapter.onRequestCompleteEvent(HttpServerFilter filter,
Connection connection,
Response response)
Method will be called, when
Request processing will be completed. |
void |
HttpServerProbe.onRequestReceiveEvent(HttpServerFilter filter,
Connection connection,
Request request)
Method will be called, when new
Request will come. |
void |
HttpServerProbe.Adapter.onRequestReceiveEvent(HttpServerFilter filter,
Connection connection,
Request request)
Method will be called, when new
Request will come. |
void |
HttpServerProbe.onRequestResumeEvent(HttpServerFilter filter,
Connection connection,
Request request)
Method will be called, when
Request processing is resumed. |
void |
HttpServerProbe.Adapter.onRequestResumeEvent(HttpServerFilter filter,
Connection connection,
Request request)
Method will be called, when
Request processing is resumed. |
void |
HttpServerProbe.onRequestSuspendEvent(HttpServerFilter filter,
Connection connection,
Request request)
Method will be called, when
Request processing is suspended. |
void |
HttpServerProbe.Adapter.onRequestSuspendEvent(HttpServerFilter filter,
Connection connection,
Request request)
Method will be called, when
Request processing is suspended. |
void |
HttpServerProbe.onRequestTimeoutEvent(HttpServerFilter filter,
Connection connection,
Request request)
Method will be called, when
Request processing is timeout
after suspend. |
void |
HttpServerProbe.Adapter.onRequestTimeoutEvent(HttpServerFilter filter,
Connection connection,
Request request)
Method will be called, when
Request processing is timeout
after suspend. |
Modifier and Type | Class and Description |
---|---|
class |
NIOConnection
Common
Connection implementation for Java NIO Connections. |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractNIOAsyncQueueWriter.canWrite(Connection connection) |
boolean |
AbstractNIOAsyncQueueWriter.canWrite(Connection connection,
int size)
Deprecated.
|
protected abstract void |
NIOTransport.closeConnection(Connection connection) |
protected AsyncWriteQueueRecord |
AbstractNIOAsyncQueueWriter.createRecord(Connection connection,
WritableMessage message,
WriteResult<WritableMessage,SocketAddress> currentResult,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
SocketAddress dstAddress,
PushBackHandler pushBackHandler,
boolean isEmptyRecord) |
protected int |
AbstractNIOAsyncQueueReader.doRead(Connection connection,
AsyncReadQueueRecord queueRecord)
Performs real read on the NIO channel
|
boolean |
AbstractNIOAsyncQueueReader.isReady(Connection connection)
Checks whether there is ready data in
AsyncQueue ,
associated with the Connection . |
boolean |
AbstractNIOAsyncQueueWriter.isReady(Connection connection)
Checks whether there is ready data in
AsyncQueue ,
associated with the Connection . |
void |
AbstractNIOAsyncQueueWriter.notifyWritePossible(Connection connection,
WriteHandler writeHandler) |
void |
AbstractNIOAsyncQueueWriter.notifyWritePossible(Connection connection,
WriteHandler writeHandler,
int size)
Deprecated.
|
void |
AbstractNIOAsyncQueueReader.onClose(Connection connection)
Callback method, which is called, when
Connection has been closed,
to let processor release a connection associated resources. |
void |
AbstractNIOAsyncQueueWriter.onClose(Connection connection)
Callback method, which is called, when
Connection has been closed,
to let processor release a connection associated resources. |
protected void |
AbstractNIOAsyncQueueReader.onReadFailure(Connection connection,
AsyncReadQueueRecord failedRecord,
IOException e) |
protected abstract void |
AbstractNIOAsyncQueueReader.onReadyToRead(Connection connection) |
protected static void |
AbstractNIOAsyncQueueWriter.onWriteFailure(Connection connection,
AsyncWriteQueueRecord failedRecord,
Throwable e) |
void |
AbstractNIOAsyncQueueReader.read(Connection connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor)
Method reads data to the buffer.
|
protected abstract int |
AbstractNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
void |
AbstractNIOAsyncQueueWriter.write(Connection connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
MessageCloner<WritableMessage> cloner) |
void |
AbstractNIOAsyncQueueWriter.write(Connection connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
AbstractNIOAsyncQueueWriter.write(Connection connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner<WritableMessage> cloner)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected Buffer |
TemporarySelectorReader.acquireBuffer(Connection connection) |
boolean |
TemporarySelectorWriter.canWrite(Connection connection)
Return
true if the connection has not exceeded it's maximum
size in bytes of pending writes, otherwise false . |
void |
TemporarySelectorWriter.notifyWritePossible(Connection connection,
WriteHandler writeHandler)
Registers
WriteHandler , which will be notified ones at least one
byte can be written. |
void |
TemporarySelectorReader.read(Connection connection,
Buffer message,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor) |
void |
TemporarySelectorReader.read(Connection connection,
Buffer message,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor,
long timeout,
TimeUnit timeunit)
Method reads data to the message.
|
void |
TemporarySelectorWriter.write(Connection connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
long timeout,
TimeUnit timeunit)
Method writes the
WritableMessage to the specific address. |
void |
TemporarySelectorWriter.write(Connection connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
TemporarySelectorWriter.write(Connection connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
TemporarySelectorWriter.write(Connection connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler,
long timeout,
TimeUnit timeunit)
Method writes the
WritableMessage to the specific address. |
Modifier and Type | Class and Description |
---|---|
class |
TCPNIOConnection
Connection implementation
for the TCPNIOTransport |
class |
TCPNIOServerConnection |
class |
UDPNIOConnection
Connection implementation
for the UDPNIOTransport |
class |
UDPNIOServerConnection
Server
Connection implementation
for the UDPNIOTransport |
Modifier and Type | Method and Description |
---|---|
Connection |
UDPNIOTransport.bindToInherited() |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<Connection> |
TCPNIOServerConnection.accept()
Accept a
Connection . |
protected GrizzlyFuture<Connection> |
TCPNIOServerConnection.acceptAsync()
Asynchronously accept a
Connection |
GrizzlyFuture<Connection> |
UDPNIOTransport.connect()
Creates non-connected UDP
Connection . |
GrizzlyFuture<Connection> |
UDPNIOConnectorHandler.connect()
Creates non-connected UDP
Connection . |
GrizzlyFuture<Connection> |
UDPNIOTransport.connect(SocketAddress remoteAddress)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
GrizzlyFuture<Connection> |
TCPNIOTransport.connect(SocketAddress remoteAddress)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
GrizzlyFuture<Connection> |
UDPNIOTransport.connect(SocketAddress remoteAddress,
SocketAddress localAddress)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
GrizzlyFuture<Connection> |
TCPNIOTransport.connect(SocketAddress remoteAddress,
SocketAddress localAddress)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
GrizzlyFuture<Connection> |
UDPNIOTransport.connect(String host,
int port)
Creates, initializes and connects socket to the specific remote host
and port and returns
Connection , representing socket. |
GrizzlyFuture<Connection> |
TCPNIOTransport.connect(String host,
int port)
Creates, initializes and connects socket to the specific remote host
and port and returns
Connection , representing socket. |
protected FutureImpl<Connection> |
UDPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
protected FutureImpl<Connection> |
TCPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
Modifier and Type | Method and Description |
---|---|
protected void |
UDPNIOAsyncQueueReader.addRecord(Connection connection,
Buffer buffer,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
protected void |
TCPNIOAsyncQueueReader.addRecord(Connection connection,
Buffer buffer,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
protected void |
UDPNIOTransport.closeConnection(Connection connection) |
protected void |
TCPNIOTransport.closeConnection(Connection connection) |
void |
UDPNIOTransport.fireIOEvent(IOEvent ioEvent,
Connection connection,
IOEventProcessingHandler processingHandler) |
void |
TCPNIOTransport.fireIOEvent(IOEvent ioEvent,
Connection connection,
IOEventProcessingHandler processingHandler) |
Reader |
UDPNIOTransport.getReader(Connection connection)
Get the
Reader to read data from the Connection . |
Reader<SocketAddress> |
TCPNIOTransport.getReader(Connection connection)
Get the
Reader to read data from the Connection . |
Writer |
UDPNIOTransport.getWriter(Connection connection)
Get the
Writer to write data to the Connection . |
Writer<SocketAddress> |
TCPNIOTransport.getWriter(Connection connection)
Get the
Writer to write data to the Connection . |
protected void |
UDPNIOAsyncQueueReader.onReadyToRead(Connection connection) |
protected void |
TCPNIOAsyncQueueReader.onReadyToRead(Connection connection) |
Buffer |
TCPNIOTransport.read(Connection connection,
Buffer buffer) |
protected int |
UDPNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
TCPNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
void |
UDPNIOBindingHandler.unbind(Connection connection) |
void |
UDPNIOTransport.unbind(Connection connection)
Unbinds bound
Transport connection. |
void |
TCPNIOBindingHandler.unbind(Connection connection) |
void |
TCPNIOTransport.unbind(Connection connection)
Unbinds bound
Transport connection. |
Modifier and Type | Method and Description |
---|---|
void |
UDPNIOTransport.connect(SocketAddress remoteAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
void |
TCPNIOTransport.connect(SocketAddress remoteAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
void |
UDPNIOTransport.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
void |
UDPNIOConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
void |
TCPNIOConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
void |
TCPNIOTransport.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
protected FutureImpl<Connection> |
UDPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
protected FutureImpl<Connection> |
TCPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
protected void |
UDPNIOConnectorHandler.connectSync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
protected void |
TCPNIOConnectorHandler.connectSync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
protected static void |
TCPNIOConnectorHandler.onConnectedAsync(TCPNIOConnection connection,
CompletionHandler<Connection> completionHandler) |
protected void |
TCPNIOConnection.setConnectCompletionHandler(CompletionHandler<Connection> connectHandler) |
protected void |
UDPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
protected void |
UDPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
protected void |
TCPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
protected void |
TCPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
Constructor and Description |
---|
DefaultStreamReader(Connection connection) |
DefaultStreamWriter.Output(Connection connection) |
DefaultStreamWriter(Connection connection) |
Constructor and Description |
---|
TCPNIOServerConnection.RegisterAcceptedChannelCompletionHandler(FutureImpl<Connection> listener) |
Modifier and Type | Method and Description |
---|---|
Set<Connection> |
LifeCycleFilter.getActiveConnections()
Returns the
Set of currently active Connection s. |
Modifier and Type | Method and Description |
---|---|
Connection |
SSLConnectionContext.getConnection() |
Modifier and Type | Method and Description |
---|---|
static SSLConnectionContext |
SSLUtils.getSslConnectionContext(Connection connection) |
static SSLEngine |
SSLUtils.getSSLEngine(Connection connection) |
Future<SSLEngine> |
SSLCodec.handshake(Connection connection) |
protected void |
SSLFilter.handshake(Connection<?> connection,
CompletionHandler<SSLEngine> completionHandler,
Object dstAddress,
SSLEngineConfigurator sslEngineConfigurator,
FilterChainContext context) |
void |
SSLFilter.handshake(Connection connection,
CompletionHandler<SSLEngine> completionHandler) |
void |
SSLFilter.handshake(Connection connection,
CompletionHandler<SSLEngine> completionHandler,
Object dstAddress) |
void |
SSLFilter.handshake(Connection connection,
CompletionHandler<SSLEngine> completionHandler,
Object dstAddress,
SSLEngineConfigurator sslEngineConfigurator) |
Future<SSLEngine> |
SSLCodec.handshake(Connection connection,
SSLEngineConfigurator configurator) |
static Buffer |
SSLUtils.handshakeWrap(Connection connection,
SSLConnectionContext sslCtx,
Buffer netBuffer) |
protected void |
SSLFilter.notifyHandshakeComplete(Connection<?> connection,
SSLEngine sslEngine) |
protected void |
SSLBaseFilter.notifyHandshakeComplete(Connection<?> connection,
SSLEngine sslEngine) |
protected void |
SSLFilter.notifyHandshakeFailed(Connection connection,
Throwable t) |
protected void |
SSLBaseFilter.notifyHandshakeFailed(Connection connection,
Throwable t) |
protected void |
SSLBaseFilter.notifyHandshakeStart(Connection connection) |
void |
SSLBaseFilter.HandshakeListener.onComplete(Connection connection) |
void |
SSLBaseFilter.HandshakeListener.onStart(Connection connection) |
static void |
SSLUtils.setSSLEngine(Connection connection,
SSLEngine sslEngine) |
Constructor and Description |
---|
SSLConnectionContext(Connection connection) |
SSLSupportImpl(Connection connection) |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent) |
boolean |
SimpleDynamicNIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent) |
boolean |
SameThreadIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent,
boolean isIoEventEnabled) |
boolean |
WorkerThreadIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent,
boolean isIoEventEnabled) |
boolean |
LeaderFollowerNIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent,
boolean isIoEventEnabled) |
boolean |
SimpleDynamicNIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent,
boolean isIoEventEnabled) |
protected static void |
AbstractIOStrategy.fireIOEvent(Connection connection,
IOEvent ioEvent,
IOEventProcessingHandler ph,
Logger logger) |
protected static Executor |
AbstractIOStrategy.getWorkerThreadPool(Connection c) |
Modifier and Type | Field and Description |
---|---|
protected Connection |
AbstractStreamReader.connection |
Modifier and Type | Method and Description |
---|---|
Connection |
AbstractStreamReader.getConnection()
Get the
Connection this StreamReader belongs to. |
Connection |
StreamWriter.getConnection()
Get the
Connection this StreamWriter belongs to. |
Connection |
Stream.getConnection()
Get the
Connection this StreamReader belongs to. |
Connection |
AbstractStreamWriter.getConnection()
Get the
Connection this StreamWriter belongs to. |
Constructor and Description |
---|
AbstractStreamReader(Connection connection,
Input streamInput)
Create a new ByteBufferReader.
|
AbstractStreamWriter(Connection connection,
Output streamOutput)
Create a new ByteBufferWriter.
|
TransformerInput(Transformer<Buffer,Buffer> transformer,
Input underlyingInput,
Connection connection) |
TransformerOutput(Transformer<Buffer,Buffer> transformer,
Output underlyingOutput,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
DelayedExecutor.Resolver<Connection> |
IdleTimeoutFilter.getResolver() |
Modifier and Type | Method and Description |
---|---|
void |
ActivityCheckFilter.TimeoutHandler.onTimeout(Connection c) |
void |
IdleTimeoutFilter.TimeoutHandler.onTimeout(Connection c) |
static void |
IdleTimeoutFilter.setCustomTimeout(Connection connection,
long timeout,
TimeUnit timeunit)
Provides an override mechanism for the default timeout.
|
Constructor and Description |
---|
ActivityCheckFilter(DelayedExecutor executor,
DelayedExecutor.Worker<Connection> worker,
long timeout,
TimeUnit timeoutUnit) |
IdleTimeoutFilter(DelayedExecutor executor,
DelayedExecutor.Worker<Connection> worker,
IdleTimeoutFilter.TimeoutResolver timeoutResolver) |
Modifier and Type | Field and Description |
---|---|
protected Connection |
ProtocolHandler.connection |
Modifier and Type | Method and Description |
---|---|
Connection |
ProtocolHandler.getConnection() |
Modifier and Type | Method and Description |
---|---|
static WebSocketHolder |
WebSocketHolder.get(Connection connection) |
static WebSocket |
WebSocketHolder.getWebSocket(Connection connection) |
static boolean |
WebSocketHolder.isWebSocketInProgress(Connection connection) |
static WebSocketHolder |
WebSocketHolder.set(Connection connection,
ProtocolHandler handler,
WebSocket socket) |
void |
ProtocolHandler.setConnection(Connection handler) |
Copyright © 2013 Oracle Corporation. All Rights Reserved.