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<L> |
ReadResult.getConnection()
Get the
Connection data were read from. |
Connection |
Context.getConnection()
Get the processing
Connection . |
Connection<L> |
WriteResult.getConnection()
Get the
Connection data were read from. |
Connection |
Result.getConnection()
Get
Connection , associated with the result. |
Modifier and Type | Method and Description |
---|---|
Future<Connection> |
SocketAcceptor.accept()
Accept a
Connection |
Future<Connection> |
ConnectorHandler.connect(E remoteAddress)
Creates, initializes and establishes
Connection to the specific
remoteAddress . |
Future<Connection> |
ConnectorHandler.connect(E remoteAddress,
E localAddress)
Creates, initializes
Connection , binds it to the specific local
and remote remoteAddress . |
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<L> connection) |
static <K,L> WriteResult<K,L> |
WriteResult.create(Connection<L> connection) |
static <K,L> ReadResult<K,L> |
ReadResult.create(Connection<L> connection,
K message,
L srcAddress,
int readSize) |
static <K,L> WriteResult<K,L> |
WriteResult.create(Connection<L> connection,
K message,
L dstAddress,
long writeSize) |
static Context |
Context.create(Connection connection,
Processor processor,
IOEvent ioEvent,
IOEventLifeCycleListener lifeCycleListener) |
static void |
ProcessorExecutor.execute(Connection connection,
IOEvent ioEvent,
Processor processor,
IOEventLifeCycleListener lifeCycleListener) |
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,
IOEventLifeCycleListener listener)
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)
|
Executor |
IOStrategy.getThreadPoolFor(Connection connection,
IOEvent ioEvent)
Returns an
Executor to be used to run given ioEvent
processing for the given 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. |
Context |
StandaloneProcessor.obtainContext(Connection connection) |
E |
Processor.obtainContext(Connection connection)
Creates
Context |
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. |
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. |
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>> |
Reader.read(Connection<L> connection)
Method reads data.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
AbstractReader.read(Connection<L> connection)
Method reads data.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
Reader.read(Connection<L> connection,
Buffer buffer)
Method reads data to the buffer.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
AbstractReader.read(Connection<L> connection,
Buffer buffer)
Method reads data to the buffer.
|
void |
Reader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
AbstractReader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
Reader.read(Connection<L> 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 |
StandaloneProcessorSelector.select(IOEvent ioEvent,
Connection connection)
|
Processor |
ProcessorSelector.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. |
protected void |
ReadResult.set(Connection<L> connection,
K message,
L srcAddress,
int readSize)
One method to set all the WriteResult properties.
|
protected void |
WriteResult.set(Connection<L> connection,
K message,
L dstAddress,
long writtenSize)
One method to set all the WriteResult properties.
|
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<L> connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
void |
AbstractWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> 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<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
push back logic is deprecated
|
GrizzlyFuture<WriteResult<WritableMessage,L>> |
AbstractWriter.write(Connection<L> connection,
WritableMessage message)
Method writes the
WritableMessage . |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection<L> connection,
WritableMessage message)
Method writes the
WritableMessage . |
void |
AbstractWriter.write(Connection<L> connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
void |
Writer.write(Connection<L> connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectorHandler.connect(E remoteAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes and establishes
Connection to the specific
remoteAddress . |
void |
ConnectorHandler.connect(E remoteAddress,
E localAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes
Connection , binds it to the specific local
and remote remoteAddress . |
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<L> connection) |
ReadResult(Connection<L> 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<L> connection,
int size)
Deprecated.
the size parameter will be ignored, use
Writer.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,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
static AsyncWriteQueueRecord |
AsyncWriteQueueRecord.create(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushbackHandler,
boolean isUncountable) |
boolean |
AsyncQueue.isReady(Connection connection)
Checks whether there is ready data in
AsyncQueue ,
associated with the Connection . |
void |
AsyncQueueWriter.notifyWritePossible(Connection<L> 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 |
RecordReadResult.set(Connection<L> connection,
K message,
L srcAddress,
int readSize) |
protected void |
RecordWriteResult.set(Connection<L> connection,
K message,
L dstAddress,
long writtenSize) |
protected void |
AsyncQueueRecord.set(Connection connection,
Object message,
CompletionHandler completionHandler) |
protected void |
AsyncReadQueueRecord.set(Connection connection,
Object message,
CompletionHandler completionHandler,
Interceptor interceptor) |
protected void |
AsyncWriteQueueRecord.set(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
void |
AsyncQueueWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner<WritableMessage> cloner)
Deprecated.
push back logic is deprecated
|
Constructor and Description |
---|
AsyncQueueRecord(Connection connection,
Object message,
CompletionHandler completionHandler) |
AsyncWriteQueueRecord(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
Modifier and Type | Field and Description |
---|---|
GrizzlyFuture<Connection> |
SingleEndpointPool.ConnectTimeoutTask.connectFuture |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<Connection> |
SingleEndpointPool.take()
Obtains a
Connection from the pool in non-blocking/asynchronous fashion. |
GrizzlyFuture<Connection> |
MultiEndpointPool.take(EndpointKey<E> endpointKey)
Obtains a
Connection to the specified endpoint from the pool in
non-blocking/asynchronous fashion. |
Modifier and Type | Method and Description |
---|---|
boolean |
SingleEndpointPool.attach(Connection connection)
Attaches "foreign"
Connection to the pool. |
boolean |
MultiEndpointPool.attach(EndpointKey<E> endpointKey,
Connection connection)
Attaches "foreign"
Connection to the pool. |
boolean |
SingleEndpointPool.detach(Connection connection)
Detaches a
Connection from the pool. |
boolean |
MultiEndpointPool.detach(Connection connection)
Detaches a
Connection from the pool. |
ConnectionInfo<E> |
SingleEndpointPool.getConnectionInfo(Connection connection)
Returns pooled
ConnectionInfo , that might be used for monitoring
reasons, or null if the Connection does not belong to
this pool. |
ConnectionInfo<E> |
MultiEndpointPool.getConnectionInfo(Connection connection)
Returns pooled
ConnectionInfo , that might be used for monitoring
reasons, or null if the Connection does not belong to
this pool. |
boolean |
SingleEndpointPool.isBusy(Connection connection)
Returns true only if the
Connection is registered in
the pool and is currently in busy state (used by a user), otherwise
returns false. |
boolean |
MultiEndpointPool.isBusy(Connection connection)
Returns true only if the
Connection is registered in
the pool and is currently in busy state (used by a user), otherwise
returns false. |
boolean |
SingleEndpointPool.isRegistered(Connection connection)
Returns true if the
Connection is registered in the pool
no matter if it's currently in busy or ready state, or false if
the Connection is not registered in the pool. |
boolean |
MultiEndpointPool.isRegistered(Connection connection)
Returns true if the
Connection is registered in the pool
no matter if it's currently in busy or ready state, or false if
the Connection is not registered in the pool. |
boolean |
SingleEndpointPool.release(Connection connection)
Returns the
Connection to the pool. |
boolean |
MultiEndpointPool.release(Connection connection)
Returns the
Connection to the pool. |
Modifier and Type | Method and Description |
---|---|
void |
SingleEndpointPool.take(CompletionHandler<Connection> completionHandler)
Obtains a
Connection from the pool in non-blocking/asynchronous fashion. |
void |
MultiEndpointPool.take(EndpointKey<E> endpointKey,
CompletionHandler<Connection> completionHandler)
Obtains a
Connection to the specified endpoint from the pool
in non-blocking/asynchronous fashion. |
Constructor and Description |
---|
ConnectTimeoutTask(GrizzlyFuture<Connection> future) |
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) |
static FilterChainContext |
FilterChainContext.create(Connection connection,
Closeable closeable) |
FilterChainContext |
BaseFilter.createContext(Connection connection,
FilterChainContext.Operation operation) |
void |
FilterChain.fireEventDownstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
DefaultFilterChain.fireEventDownstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
FilterChain.fireEventUpstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
DefaultFilterChain.fireEventUpstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
FilterChain.flush(Connection connection,
CompletionHandler<WriteResult> completionHandler) |
void |
DefaultFilterChain.flush(Connection connection,
CompletionHandler<WriteResult> completionHandler) |
Context |
AbstractFilterChain.obtainContext(Connection connection)
Creates
Context |
FilterChainContext |
FilterChain.obtainFilterChainContext(Connection connection) |
FilterChainContext |
AbstractFilterChain.obtainFilterChainContext(Connection connection) |
FilterChainContext |
FilterChain.obtainFilterChainContext(Connection connection,
Closeable closeable) |
FilterChainContext |
AbstractFilterChain.obtainFilterChainContext(Connection connection,
Closeable closeable) |
FilterChainContext |
FilterChain.obtainFilterChainContext(Connection connection,
Closeable closeable,
int startIdx,
int endIdx,
int currentIdx) |
FilterChainContext |
AbstractFilterChain.obtainFilterChainContext(Connection connection,
Closeable closeable,
int startIdx,
int endIdx,
int currentIdx) |
FilterChainContext |
FilterChain.obtainFilterChainContext(Connection connection,
int startIdx,
int endIdx,
int currentIdx) |
FilterChainContext |
AbstractFilterChain.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 |
LZMAContentEncoding.decode(Connection connection,
HttpContent httpContent) |
ParsingResult |
ContentEncoding.decode(Connection connection,
HttpContent httpContent)
Decode HTTP packet content represented by
HttpContent . |
ParsingResult |
GZipContentEncoding.decode(Connection connection,
HttpContent httpContent) |
HttpContent |
LZMAContentEncoding.encode(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) |
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.onContentEncodingParseResultEvent(Connection connection,
HttpHeader header,
Buffer result,
ContentEncoding contentEncoding)
This method will be called after the
ContentEncoding has been
applied. |
void |
HttpProbe.Adapter.onContentEncodingParseResultEvent(Connection connection,
HttpHeader header,
Buffer result,
ContentEncoding contentEncoding)
This method will be called after the
ContentEncoding has been
applied. |
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.onContentEncodingSerializeResultEvent(Connection connection,
HttpHeader header,
Buffer result,
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.onContentEncodingSerializeResultEvent(Connection connection,
HttpHeader header,
Buffer result,
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 | Method and Description |
---|---|
void |
AccessLogProbe.onRequestCompleteEvent(HttpServerFilter filter,
Connection connection,
Response response)
Receive notification of the completion of a
Response an possibly
trigger an access log entry generation. |
void |
AccessLogProbe.onRequestReceiveEvent(HttpServerFilter filter,
Connection connection,
Request request)
Instrument the specified
Request with an attribute marking its
received time (in nanoseconds). |
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<SocketAddress> connection) |
boolean |
AbstractNIOAsyncQueueWriter.canWrite(Connection<SocketAddress> connection,
int size)
Deprecated.
|
protected abstract void |
NIOTransport.closeConnection(Connection connection) |
protected AsyncWriteQueueRecord |
AbstractNIOAsyncQueueWriter.createRecord(Connection connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
SocketAddress dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
protected int |
AbstractNIOAsyncQueueReader.doRead(Connection connection,
AsyncReadQueueRecord queueRecord)
Performs real read on the NIO channel
|
boolean |
AbstractNIOAsyncQueueWriter.isReady(Connection connection)
Checks whether there is ready data in
AsyncQueue ,
associated with the Connection . |
boolean |
AbstractNIOAsyncQueueReader.isReady(Connection connection)
Checks whether there is ready data in
AsyncQueue ,
associated with the Connection . |
void |
AbstractNIOAsyncQueueWriter.notifyWritePossible(Connection<SocketAddress> connection,
WriteHandler writeHandler) |
void |
AbstractNIOAsyncQueueWriter.notifyWritePossible(Connection<SocketAddress> connection,
WriteHandler writeHandler,
int size)
Deprecated.
|
void |
AbstractNIOAsyncQueueWriter.onClose(Connection connection)
Callback method, which is called, when
Connection has been closed,
to let processor release a connection associated resources. |
void |
AbstractNIOAsyncQueueReader.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<SocketAddress> 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<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
MessageCloner<WritableMessage> cloner) |
void |
AbstractNIOAsyncQueueWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
AbstractNIOAsyncQueueWriter.write(Connection<SocketAddress> 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<SocketAddress> connection,
Buffer message,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor) |
void |
TemporarySelectorReader.read(Connection<SocketAddress> 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<SocketAddress> 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<SocketAddress> 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<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
TemporarySelectorWriter.write(Connection<SocketAddress> 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> |
TCPNIOTransport.connect(SocketAddress remoteAddress)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
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,
SocketAddress localAddress)
Creates, initializes socket, binds it to the specific local and remote
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(String host,
int port)
Creates, initializes and connects socket to the specific remote host
and port 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. |
protected FutureImpl<Connection> |
TCPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
protected FutureImpl<Connection> |
UDPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
Modifier and Type | Method and Description |
---|---|
protected void |
TCPNIOAsyncQueueReader.addRecord(Connection connection,
Buffer buffer,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
protected void |
UDPNIOAsyncQueueReader.addRecord(Connection connection,
Buffer buffer,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
protected void |
TCPNIOTransport.closeConnection(Connection connection) |
protected void |
UDPNIOTransport.closeConnection(Connection connection) |
void |
TCPNIOTransport.fireIOEvent(IOEvent ioEvent,
Connection connection,
IOEventLifeCycleListener listener) |
void |
UDPNIOTransport.fireIOEvent(IOEvent ioEvent,
Connection connection,
IOEventLifeCycleListener listener) |
Reader<SocketAddress> |
TCPNIOTransport.getReader(Connection connection)
Get the
Reader to read data from the Connection . |
Reader |
UDPNIOTransport.getReader(Connection connection)
Get the
Reader to read data from the Connection . |
Writer<SocketAddress> |
TCPNIOTransport.getWriter(Connection connection)
Get the
Writer to write data to the Connection . |
Writer |
UDPNIOTransport.getWriter(Connection connection)
Get the
Writer to write data to the Connection . |
protected void |
TCPNIOAsyncQueueReader.onReadyToRead(Connection connection) |
protected void |
UDPNIOAsyncQueueReader.onReadyToRead(Connection connection) |
Buffer |
TCPNIOTransport.read(Connection connection,
Buffer buffer) |
protected int |
TCPNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
protected int |
UDPNIOAsyncQueueReader.read0(Connection connection,
Buffer buffer,
ReadResult<Buffer,SocketAddress> currentResult) |
void |
TCPNIOTransport.unbind(Connection connection)
Unbinds bound
Transport connection. |
void |
TCPNIOBindingHandler.unbind(Connection connection) |
void |
UDPNIOTransport.unbind(Connection connection)
Unbinds bound
Transport connection. |
void |
UDPNIOBindingHandler.unbind(Connection connection) |
Modifier and Type | Method and Description |
---|---|
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,
CompletionHandler<Connection> completionHandler)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
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. |
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 |
TCPNIOConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
void |
UDPNIOConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
protected FutureImpl<Connection> |
TCPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
protected FutureImpl<Connection> |
UDPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
protected void |
TCPNIOConnectorHandler.connectSync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
protected void |
UDPNIOConnectorHandler.connectSync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
protected static void |
TCPNIOConnectorHandler.onConnectedAsync(TCPNIOConnection connection,
CompletionHandler<Connection> completionHandler) |
protected void |
TCPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
protected void |
TCPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
protected void |
UDPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
protected void |
UDPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
Constructor and Description |
---|
DefaultStreamReader(Connection connection) |
DefaultStreamWriter(Connection connection) |
Output(Connection connection) |
Constructor and Description |
---|
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 |
---|---|
SNIConfig |
FooBarSNIResolver.resolve(Connection connection,
String hostname) |
Modifier and Type | Method and Description |
---|---|
SNIConfig |
SNIClientConfigResolver.resolve(Connection connection)
|
SNIConfig |
SNIServerConfigResolver.resolve(Connection connection,
String hostname)
Returns
SNIConfig for the new Connection , null
value means use default SSLBaseFilter.getServerSSLEngineConfigurator() . |
Modifier and Type | Method and Description |
---|---|
Connection |
SpdySession.getConnection() |
static Connection |
NextProtoNegSupport.getConnection(SSLEngine engine) |
Modifier and Type | Method and Description |
---|---|
static void |
SpdySession.bind(Connection connection,
SpdySession spdySession) |
protected SpdySession |
SpdyHandlerFilter.createSpdySession(SpdyVersion spdyVersion,
Connection connection,
boolean isServer)
Creates
SpdySession with preconfigured initial-windows-size and
max-concurrent- |
static SpdySession |
SpdySession.get(Connection connection) |
SpdySession |
SpdyVersion.newSession(Connection<?> connection,
boolean isServer,
SpdyHandlerFilter handlerFilter) |
void |
NextProtoNegSupport.setClientSideNegotiator(Connection connection,
org.glassfish.grizzly.npn.ClientSideNegotiator negotiator) |
void |
NextProtoNegSupport.setServerSideNegotiator(Connection connection,
org.glassfish.grizzly.npn.ServerSideNegotiator negotiator) |
Constructor and Description |
---|
SpdySession(Connection<?> connection,
boolean isServer,
SpdyHandlerFilter handlerFilter) |
Constructor and Description |
---|
SpdySession3(Connection<?> connection,
boolean isServer,
SpdyHandlerFilter handlerFilter) |
Constructor and Description |
---|
SpdySession31(Connection<?> connection,
boolean isServer,
SpdyHandlerFilter handlerFilter) |
Modifier and Type | Method and Description |
---|---|
Connection |
SSLConnectionContext.getConnection() |
Modifier and Type | Method and Description |
---|---|
FilterChainContext |
SSLBaseFilter.SSLTransportFilterWrapper.createContext(Connection connection,
FilterChainContext.Operation operation) |
protected SSLConnectionContext |
SSLBaseFilter.createSslConnectionContext(Connection connection) |
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,
boolean forceBeginHandshake) |
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) |
protected SSLConnectionContext |
SSLBaseFilter.obtainSslConnectionContext(Connection connection) |
void |
SSLBaseFilter.HandshakeListener.onComplete(Connection connection) |
void |
SSLBaseFilter.HandshakeListener.onFailure(Connection connection,
Throwable t) |
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 |
SimpleDynamicNIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent) |
boolean |
AbstractIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent) |
boolean |
SimpleDynamicNIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent,
boolean isIoEventEnabled) |
boolean |
SameThreadIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent,
boolean isIoEventEnabled) |
boolean |
LeaderFollowerNIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent,
boolean isIoEventEnabled) |
boolean |
WorkerThreadIOStrategy.executeIoEvent(Connection connection,
IOEvent ioEvent,
boolean isIoEventEnabled) |
protected static void |
AbstractIOStrategy.fireIOEvent(Connection connection,
IOEvent ioEvent,
IOEventLifeCycleListener listener,
Logger logger) |
Executor |
SimpleDynamicNIOStrategy.getThreadPoolFor(Connection connection,
IOEvent ioEvent) |
Executor |
SameThreadIOStrategy.getThreadPoolFor(Connection connection,
IOEvent ioEvent) |
Executor |
AbstractIOStrategy.getThreadPoolFor(Connection connection,
IOEvent ioEvent) |
Modifier and Type | Field and Description |
---|---|
protected Connection |
AbstractStreamReader.connection |
Modifier and Type | Method and Description |
---|---|
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. |
Connection |
AbstractStreamReader.getConnection()
Get the
Connection this StreamReader 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 |
IdleTimeoutFilter.TimeoutHandler.onTimeout(Connection c) |
void |
ActivityCheckFilter.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) |
protected void |
BaseWebSocketFilter.onHandshakeFailure(Connection connection,
HandshakeException e)
The method is called when WebSocket handshake fails for the
Connection . |
static WebSocketHolder |
WebSocketHolder.set(Connection connection,
ProtocolHandler handler,
WebSocket socket) |
void |
ProtocolHandler.setConnection(Connection handler) |
protected static boolean |
BaseWebSocketFilter.webSocketInProgress(Connection connection) |
Copyright © 2015 Oracle Corporation. All rights reserved.