Modifier and Type | Method and Description |
---|---|
NextAction |
LZMAFilter.handleClose(FilterChainContext ctx) |
NextAction |
LZMAFilter.handleRead(FilterChainContext ctx) |
NextAction |
LZMAFilter.handleWrite(FilterChainContext ctx) |
Modifier and Type | Method and Description |
---|---|
NextAction |
GZipFilter.handleClose(FilterChainContext ctx)
Method perform the clean up of GZIP encoding/decoding state on a closed
Connection . |
NextAction |
GZipFilter.handleRead(FilterChainContext ctx)
Method decodes GZIP encoded data stored in
getMessage() and,
as the result, produces a Buffer with a plain data. |
NextAction |
GZipFilter.handleWrite(FilterChainContext ctx)
Method compresses plain data stored in
getMessage() and,
as the result, produces a Buffer with a GZIP compressed data. |
Modifier and Type | Field and Description |
---|---|
protected CompletionHandler<FilterChainContext> |
FilterChainContext.operationCompletionHandler
CompletionHandler , which will be notified, when operation will be
complete. |
Modifier and Type | Method and Description |
---|---|
FilterChainContext |
FilterChainContext.copy() |
static FilterChainContext |
FilterChainContext.create(Connection connection) |
static FilterChainContext |
FilterChainContext.create(Connection connection,
Closeable closeable) |
FilterChainContext |
BaseFilter.createContext(Connection connection,
FilterChainContext.Operation operation) |
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) |
Modifier and Type | Method and Description |
---|---|
int |
FilterExecutor.defaultEndIdx(FilterChainContext context) |
int |
FilterExecutor.defaultStartIdx(FilterChainContext context) |
void |
Filter.exceptionOccurred(FilterChainContext ctx,
Throwable error)
Notification about exception, occurred on the
FilterChain |
void |
BaseFilter.exceptionOccurred(FilterChainContext ctx,
Throwable error)
Notification about exception, occurred on the
FilterChain |
ProcessorResult |
FilterChain.execute(FilterChainContext context)
Method processes occurred
IOEvent on this FilterChain . |
ProcessorResult |
DefaultFilterChain.execute(FilterChainContext ctx)
Execute this FilterChain.
|
NextAction |
FilterExecutor.execute(Filter filter,
FilterChainContext context) |
protected org.glassfish.grizzly.filterchain.DefaultFilterChain.FilterExecution |
DefaultFilterChain.executeChainPart(FilterChainContext ctx,
FilterExecutor executor,
int start,
int end,
org.glassfish.grizzly.filterchain.DefaultFilterChain.FiltersState filtersState)
|
protected NextAction |
DefaultFilterChain.executeFilter(FilterExecutor executor,
Filter currentFilter,
FilterChainContext ctx)
|
void |
FilterChain.fail(FilterChainContext context,
Throwable failure) |
void |
DefaultFilterChain.fail(FilterChainContext context,
Throwable failure) |
int |
FilterExecutor.getNextFilter(FilterChainContext context) |
int |
FilterExecutor.getPreviousFilter(FilterChainContext context) |
NextAction |
Filter.handleAccept(FilterChainContext ctx)
Execute a unit of processing work to be performed, when server channel
has accepted the client connection.
|
NextAction |
BaseFilter.handleAccept(FilterChainContext ctx)
Execute a unit of processing work to be performed, when server channel
has accepted the client connection.
|
NextAction |
TransportFilter.handleAccept(FilterChainContext ctx)
Delegates accept operation to
Transport 's specific transport
filter. |
NextAction |
Filter.handleClose(FilterChainContext ctx)
Execute a unit of processing work to be performed, when connection
has been closed.
|
NextAction |
BaseFilter.handleClose(FilterChainContext ctx)
Execute a unit of processing work to be performed, when connection
has been closed.
|
NextAction |
TransportFilter.handleClose(FilterChainContext ctx)
Delegates close operation to
Transport 's specific transport
filter. |
NextAction |
Filter.handleConnect(FilterChainContext ctx)
Execute a unit of processing work to be performed, when channel gets
connected.
|
NextAction |
BaseFilter.handleConnect(FilterChainContext ctx)
Execute a unit of processing work to be performed, when channel gets
connected.
|
NextAction |
TransportFilter.handleConnect(FilterChainContext ctx)
Delegates connect operation to
Transport 's specific transport
filter. |
NextAction |
Filter.handleEvent(FilterChainContext ctx,
FilterChainEvent event)
Handle custom event associated with the
Connection . |
NextAction |
BaseFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event)
Handle custom event associated with the
Connection . |
NextAction |
TransportFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event)
Delegates event operation to
Transport 's specific transport
filter. |
NextAction |
Filter.handleRead(FilterChainContext ctx)
Execute a unit of processing work to be performed, when channel will
become available for reading.
|
NextAction |
BaseFilter.handleRead(FilterChainContext ctx)
Execute a unit of processing work to be performed, when channel will
become available for reading.
|
NextAction |
TransportFilter.handleRead(FilterChainContext ctx)
Delegates reading operation to
Transport 's specific transport
filter. |
NextAction |
AbstractCodecFilter.handleRead(FilterChainContext ctx) |
NextAction |
Filter.handleWrite(FilterChainContext ctx)
Execute a unit of processing work to be performed, when some data should
be written on channel.
|
NextAction |
BaseFilter.handleWrite(FilterChainContext ctx)
Execute a unit of processing work to be performed, when some data should
be written on channel.
|
NextAction |
TransportFilter.handleWrite(FilterChainContext ctx)
Delegates writing operation to
Transport 's specific transport
filter. |
NextAction |
AbstractCodecFilter.handleWrite(FilterChainContext ctx) |
boolean |
FilterExecutor.hasNextFilter(FilterChainContext context,
int idx) |
boolean |
FilterExecutor.hasPreviousFilter(FilterChainContext context,
int idx) |
void |
FilterExecutor.initIndexes(FilterChainContext context) |
void |
FilterChainContext.CompletionListener.onComplete(FilterChainContext context)
The method is called, when passed
FilterChainContext processing
is complete. |
void |
FilterChainContext.CopyListener.onCopy(FilterChainContext srcContext,
FilterChainContext copiedContext)
The method is called, when passed
FilterChainContext
is copied. |
ReadResult |
FilterChain.read(FilterChainContext context) |
ReadResult |
DefaultFilterChain.read(FilterChainContext context) |
Modifier and Type | Method and Description |
---|---|
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 |
FilterChainContext.notifyDownstream(FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
FilterChainContext.notifyUpstream(FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
Modifier and Type | Method and Description |
---|---|
HttpContext |
HttpContext.attach(FilterChainContext ctx) |
protected boolean |
HttpCodecFilter.decodeHttpPacket(FilterChainContext ctx,
HttpPacketParsing httpPacket,
Buffer input) |
protected boolean |
HttpCodecFilter.decodeHttpPacketFromBuffer(FilterChainContext ctx,
HttpPacketParsing httpPacket,
Buffer input) |
protected boolean |
HttpCodecFilter.decodeHttpPacketFromBytes(FilterChainContext ctx,
HttpPacketParsing httpPacket,
Buffer inputBuffer) |
protected Buffer |
HttpCodecFilter.encodeHttpPacket(FilterChainContext ctx,
HttpHeader httpHeader,
HttpContent httpContent,
boolean isContentAlreadyEncoded) |
protected Buffer |
HttpClientFilter.encodeHttpPacket(FilterChainContext ctx,
HttpPacket input) |
protected Buffer |
HttpServerFilter.encodeHttpPacket(FilterChainContext ctx,
HttpPacket input) |
protected Buffer |
HttpCodecFilter.encodeHttpPacket(FilterChainContext ctx,
HttpPacket input) |
static HttpContext |
HttpContext.get(FilterChainContext ctx) |
NextAction |
HttpServerFilter.handleClose(FilterChainContext ctx) |
NextAction |
HttpServerFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event) |
NextAction |
HttpClientFilter.handleRead(FilterChainContext ctx)
The method is called, once we have received a
Buffer ,
which has to be transformed into HTTP response packet part. |
NextAction |
HttpServerFilter.handleRead(FilterChainContext ctx)
The method is called, once we have received a
Buffer ,
which has to be transformed into HTTP request packet part. |
NextAction |
HttpCodecFilter.handleRead(FilterChainContext ctx,
HttpPacketParsing httpPacket)
The method is called by the specific HttpCodecFilter implementation,
once we have received a
Buffer , which has to be transformed
into HTTP packet part. |
NextAction |
HttpClientFilter.handleWrite(FilterChainContext ctx) |
NextAction |
HttpCodecFilter.handleWrite(FilterChainContext ctx)
The method is called, once we need to serialize a
HttpPacket ,
which may represent HTTP packet header, content or content chunk. |
protected void |
HttpClientFilter.onHttpContentEncoded(HttpContent content,
FilterChainContext ctx) |
protected void |
HttpServerFilter.onHttpContentEncoded(HttpContent content,
FilterChainContext ctx) |
protected abstract void |
HttpCodecFilter.onHttpContentEncoded(HttpContent content,
FilterChainContext ctx)
Invoked when a HTTP body chunk has been encoded in preparation to being
transmitted to the user-agent.
|
protected void |
HttpClientFilter.onHttpContentError(HttpHeader httpHeader,
FilterChainContext ctx,
Throwable t) |
protected void |
HttpServerFilter.onHttpContentError(HttpHeader httpHeader,
FilterChainContext ctx,
Throwable t) |
protected abstract void |
HttpCodecFilter.onHttpContentError(HttpHeader httpHeader,
FilterChainContext ctx,
Throwable t)
Callback which is invoked when parsing an HTTP message payload fails.
|
protected void |
HttpClientFilter.onHttpContentParsed(HttpContent content,
FilterChainContext ctx) |
protected void |
HttpServerFilter.onHttpContentParsed(HttpContent content,
FilterChainContext ctx) |
protected abstract void |
HttpCodecFilter.onHttpContentParsed(HttpContent content,
FilterChainContext ctx)
Invoked as request/response body content has been processed by this
Filter . |
protected void |
HttpClientFilter.onHttpHeaderError(HttpHeader httpHeader,
FilterChainContext ctx,
Throwable t) |
protected void |
HttpServerFilter.onHttpHeaderError(HttpHeader httpHeader,
FilterChainContext ctx,
Throwable t) |
protected abstract void |
HttpCodecFilter.onHttpHeaderError(HttpHeader httpHeader,
FilterChainContext ctx,
Throwable t)
Callback which is invoked when parsing an HTTP message header fails.
|
protected boolean |
HttpClientFilter.onHttpHeaderParsed(HttpHeader httpHeader,
Buffer buffer,
FilterChainContext ctx) |
protected boolean |
HttpServerFilter.onHttpHeaderParsed(HttpHeader httpHeader,
Buffer buffer,
FilterChainContext ctx) |
protected abstract boolean |
HttpCodecFilter.onHttpHeaderParsed(HttpHeader httpHeader,
Buffer buffer,
FilterChainContext ctx)
Callback invoked when the HTTP message header parsing is complete.
|
protected void |
HttpClientFilter.onHttpHeadersEncoded(HttpHeader httpHeader,
FilterChainContext ctx) |
protected void |
HttpServerFilter.onHttpHeadersEncoded(HttpHeader httpHeader,
FilterChainContext ctx) |
protected abstract void |
HttpCodecFilter.onHttpHeadersEncoded(HttpHeader httpHeader,
FilterChainContext ctx)
Invoked when HTTP headers have been encoded in preparation to being
transmitted to the user-agent.
|
protected void |
HttpClientFilter.onHttpHeadersParsed(HttpHeader httpHeader,
FilterChainContext ctx) |
protected void |
HttpServerFilter.onHttpHeadersParsed(HttpHeader httpHeader,
FilterChainContext ctx) |
protected abstract void |
HttpCodecFilter.onHttpHeadersParsed(HttpHeader httpHeader,
FilterChainContext ctx)
Invoked when all headers of the packet have been parsed.
|
protected boolean |
HttpClientFilter.onHttpPacketParsed(HttpHeader httpHeader,
FilterChainContext ctx) |
protected boolean |
HttpServerFilter.onHttpPacketParsed(HttpHeader httpHeader,
FilterChainContext ctx) |
protected abstract boolean |
HttpCodecFilter.onHttpPacketParsed(HttpHeader httpHeader,
FilterChainContext ctx)
Callback method, called when
HttpPacket parsing has been completed. |
protected void |
HttpCodecFilter.onIncomingUpgrade(FilterChainContext ctx,
HttpHeader httpHeader)
The method is called, when a peer sends an upgrade HTTP packet
(either request or response).
|
protected void |
HttpClientFilter.onInitialLineEncoded(HttpHeader header,
FilterChainContext ctx) |
protected void |
HttpServerFilter.onInitialLineEncoded(HttpHeader header,
FilterChainContext ctx) |
protected abstract void |
HttpCodecFilter.onInitialLineEncoded(HttpHeader httpHeader,
FilterChainContext ctx)
Invoked when the intial response line has been encoded in preparation
to being transmitted to the user-agent.
|
protected void |
HttpClientFilter.onInitialLineParsed(HttpHeader httpHeader,
FilterChainContext ctx) |
protected void |
HttpServerFilter.onInitialLineParsed(HttpHeader httpHeader,
FilterChainContext ctx) |
protected abstract void |
HttpCodecFilter.onInitialLineParsed(HttpHeader httpHeader,
FilterChainContext ctx)
Invoked when either the request line or status line has been parsed.
|
protected void |
HttpCodecFilter.onOutgoingUpgrade(FilterChainContext ctx,
HttpHeader httpHeader) |
ParsingResult |
FixedLengthTransferEncoding.parsePacket(FilterChainContext ctx,
HttpHeader httpPacket,
Buffer input)
Parse HTTP packet payload, represented by
Buffer using specific
transfer encoding. |
ParsingResult |
TransferEncoding.parsePacket(FilterChainContext ctx,
HttpHeader httpPacket,
Buffer buffer)
Parse HTTP packet payload, represented by
Buffer using specific
transfer encoding. |
ParsingResult |
ChunkedTransferEncoding.parsePacket(FilterChainContext ctx,
HttpHeader httpPacket,
Buffer buffer)
Parse HTTP packet payload, represented by
Buffer using specific
transfer encoding. |
void |
FixedLengthTransferEncoding.prepareSerialize(FilterChainContext ctx,
HttpHeader httpHeader,
HttpContent httpContent) |
void |
TransferEncoding.prepareSerialize(FilterChainContext ctx,
HttpHeader httpHeader,
HttpContent content)
This method will be called by
HttpCodecFilter to let
TransferEncoding prepare itself for the content serialization. |
void |
ChunkedTransferEncoding.prepareSerialize(FilterChainContext ctx,
HttpHeader httpHeader,
HttpContent content)
This method will be called by
HttpCodecFilter to let
TransferEncoding prepare itself for the content serialization. |
Buffer |
FixedLengthTransferEncoding.serializePacket(FilterChainContext ctx,
HttpContent httpContent)
Serialize HTTP packet payload, represented by
HttpContent
using specific transfer encoding. |
Buffer |
TransferEncoding.serializePacket(FilterChainContext ctx,
HttpContent httpContent)
Serialize HTTP packet payload, represented by
HttpContent
using specific transfer encoding. |
Buffer |
ChunkedTransferEncoding.serializePacket(FilterChainContext ctx,
HttpContent httpContent)
Serialize HTTP packet payload, represented by
HttpContent
using specific transfer encoding. |
Modifier and Type | Method and Description |
---|---|
NextAction |
AjpHandlerFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event)
Handling Http request completion event sent by Http server filter and
send the Ajp end response message.
|
NextAction |
AjpHandlerFilter.handleRead(FilterChainContext ctx)
Handle the Ajp message.
|
NextAction |
AjpMessageFilter.handleRead(FilterChainContext ctx) |
NextAction |
AjpHandlerFilter.handleWrite(FilterChainContext ctx)
Encoding HttpResponsePacket or HttpContent to Ajp message.
|
Modifier and Type | Method and Description |
---|---|
void |
OutputBuffer.initialize(HttpHeader outputHeader,
boolean sendfileEnabled,
FilterChainContext ctx) |
void |
InputBuffer.initialize(HttpHeader httpHeader,
FilterChainContext ctx)
Per-request initialization required for the InputBuffer to function
properly.
|
Modifier and Type | Field and Description |
---|---|
protected FilterChainContext |
Response.ctx
Grizzly
FilterChain context,
related to this HTTP request/response |
protected FilterChainContext |
Request.ctx |
Modifier and Type | Method and Description |
---|---|
FilterChainContext |
Request.getContext() |
Modifier and Type | Method and Description |
---|---|
void |
HttpServerFilter.exceptionOccurred(FilterChainContext ctx,
Throwable error)
Override the default implementation to notify the
ReadHandler ,
if available, of any read error that has occurred during processing. |
NextAction |
HttpServerFilter.handleRead(FilterChainContext ctx) |
NextAction |
FileCacheFilter.handleRead(FilterChainContext ctx) |
void |
Request.initialize(HttpRequestPacket request,
FilterChainContext ctx,
HttpServerFilter httpServerFilter) |
void |
Response.initialize(Request request,
HttpResponsePacket response,
FilterChainContext ctx,
DelayedExecutor.DelayQueue<Response.SuspendTimeout> delayQueue,
HttpServerFilter serverFilter) |
protected FileCacheFilter |
StaticHttpHandlerBase.lookupFileCache(FilterChainContext fcContext) |
Modifier and Type | Method and Description |
---|---|
void |
ServerInputBuffer.initialize(Request serverRequest,
FilterChainContext ctx) |
void |
ServerOutputBuffer.initialize(Response response,
FilterChainContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
UDPNIOTransportFilter.exceptionOccurred(FilterChainContext ctx,
Throwable error) |
void |
TCPNIOTransportFilter.exceptionOccurred(FilterChainContext ctx,
Throwable error) |
NextAction |
UDPNIOTransportFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event) |
NextAction |
TCPNIOTransportFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event) |
NextAction |
UDPNIOTransportFilter.handleRead(FilterChainContext ctx) |
NextAction |
TCPNIOTransportFilter.handleRead(FilterChainContext ctx) |
NextAction |
UDPNIOTransportFilter.handleWrite(FilterChainContext ctx) |
NextAction |
TCPNIOTransportFilter.handleWrite(FilterChainContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
BackChannelFilter.exceptionOccurred(FilterChainContext ctx,
Throwable error) |
ProtocolFinder.Result |
ProtocolFinder.find(PUContext puContext,
FilterChainContext ctx)
Method is called from
PUFilter to check whether the incoming
bytes belong to the specific protocol. |
protected void |
PUFilter.findProtocol(PUContext puContext,
FilterChainContext ctx) |
NextAction |
PUFilter.handleClose(FilterChainContext ctx) |
NextAction |
PUFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event) |
NextAction |
BackChannelFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event) |
NextAction |
PUFilter.handleRead(FilterChainContext ctx) |
NextAction |
BackChannelFilter.handleRead(FilterChainContext ctx) |
NextAction |
BackChannelFilter.handleWrite(FilterChainContext ctx) |
Modifier and Type | Method and Description |
---|---|
ProtocolFinder.Result |
SSLProtocolFinder.find(PUContext puContext,
FilterChainContext ctx) |
ProtocolFinder.Result |
HttpProtocolFinder.find(PUContext puContext,
FilterChainContext ctx) |
Modifier and Type | Method and Description |
---|---|
NextAction |
EchoFilterAsync.handleRead(FilterChainContext ctx)
Handle just read operation, when some message has come and ready to be
processed.
|
NextAction |
ClientFilter.handleRead(FilterChainContext ctx)
Handle just read operation, when some message has come and ready to be
processed.
|
NextAction |
EchoFilter.handleRead(FilterChainContext ctx)
Handle just read operation, when some message has come and ready to be
processed.
|
Modifier and Type | Method and Description |
---|---|
NextAction |
GIOPClient.CustomClientFilter.handleRead(FilterChainContext ctx) |
NextAction |
GIOPFilter.handleRead(FilterChainContext ctx)
Method is called, when new data was read from the Connection and ready
to be processed.
|
NextAction |
GIOPFilter.handleWrite(FilterChainContext ctx)
Method is called, when we write a data to the Connection.
|
Modifier and Type | Method and Description |
---|---|
NextAction |
ClientDownloadFilter.handleClose(FilterChainContext ctx)
The method is called, when the client connection will get closed.
|
NextAction |
ClientDownloadFilter.handleConnect(FilterChainContext ctx)
The method is called, when a client connection gets connected to a web
server.
|
NextAction |
WebServerFilter.handleRead(FilterChainContext ctx)
The method is called once we have received some
HttpContent . |
NextAction |
ClientDownloadFilter.handleRead(FilterChainContext ctx)
The method is called, when we receive a
HttpContent from a server. |
Modifier and Type | Method and Description |
---|---|
NextAction |
LifeCycleFilter.handleAccept(FilterChainContext ctx)
Method is called, when new
Connection was
accepted by a Transport |
NextAction |
LifeCycleFilter.handleClose(FilterChainContext ctx)
Method is called, when the
Connection is getting closed |
NextAction |
LifeCycleFilter.handleConnect(FilterChainContext ctx)
Method is called, when new client
Connection was
connected to some endpoint |
Modifier and Type | Method and Description |
---|---|
ProtocolFinder.Result |
AddProtocolFinder.find(PUContext puContext,
FilterChainContext ctx)
Method is called from
PUFilter to check whether the incoming
bytes belong to the specific protocol. |
NextAction |
AddClientMessageFilter.handleRead(FilterChainContext ctx)
Handle just read operation, when some message has come and ready to be
processed.
|
NextAction |
AddServerMessageFilter.handleRead(FilterChainContext ctx)
Handle just read operation, when some message has come and ready to be
processed.
|
NextAction |
AddServiceFilter.handleRead(FilterChainContext ctx)
Handle just read operation, when some message has come and ready to be
processed.
|
NextAction |
AddClientMessageFilter.handleWrite(FilterChainContext ctx)
Method is called, when we write a data to the Connection.
|
NextAction |
AddServerMessageFilter.handleWrite(FilterChainContext ctx)
Method is called, when we write a data to the Connection.
|
Modifier and Type | Method and Description |
---|---|
ProtocolFinder.Result |
SubProtocolFinder.find(PUContext puContext,
FilterChainContext ctx)
Method is called from
PUFilter to check whether the incoming
bytes belong to the specific protocol. |
NextAction |
SubClientMessageFilter.handleRead(FilterChainContext ctx)
Handle just read operation, when some message has come and ready to be
processed.
|
NextAction |
SubServiceFilter.handleRead(FilterChainContext ctx)
Handle just read operation, when some message has come and ready to be
processed.
|
NextAction |
SubServerMessageFilter.handleRead(FilterChainContext ctx)
Handle just read operation, when some message has come and ready to be
processed.
|
NextAction |
SubClientMessageFilter.handleWrite(FilterChainContext ctx)
Method is called, when we write a data to the Connection.
|
NextAction |
SubServerMessageFilter.handleWrite(FilterChainContext ctx)
Method is called, when we write a data to the Connection.
|
Modifier and Type | Field and Description |
---|---|
Queue<FilterChainContext> |
ClientAuthFilter.ConnectionAuthInfo.pendingMessages |
Modifier and Type | Method and Description |
---|---|
NextAction |
ClientAuthFilter.handleClose(FilterChainContext ctx)
The method is called, when a connection gets closed.
|
NextAction |
ServerAuthFilter.handleClose(FilterChainContext ctx)
The method is called, when a connection gets closed.
|
NextAction |
MultiLineFilter.handleRead(FilterChainContext ctx)
The method is called once we have received a single
String line. |
NextAction |
ClientFilter.handleRead(FilterChainContext ctx)
The method is called, when we receive a message from a server.
|
NextAction |
ClientAuthFilter.handleRead(FilterChainContext ctx)
The method is called once we have received
MultiLinePacket . |
NextAction |
ServerAuthFilter.handleRead(FilterChainContext ctx)
The method is called once we have received
MultiLinePacket from
a client. |
NextAction |
MultiLineFilter.handleWrite(FilterChainContext ctx)
The method is called whem we send MultiLinePacket.
|
NextAction |
ClientAuthFilter.handleWrite(FilterChainContext ctx)
The method is called each time, when client sends a message to a server.
|
NextAction |
ServerAuthFilter.handleWrite(FilterChainContext ctx)
The method is called each time, when server sends a message to a client.
|
Modifier and Type | Method and Description |
---|---|
NextAction |
TunnelFilter.handleClose(FilterChainContext ctx)
This method will be called, to notify about
Connection closing. |
NextAction |
TunnelFilter.handleRead(FilterChainContext ctx)
This method will be called, once
Connection has some available data |
Modifier and Type | Method and Description |
---|---|
NextAction |
PrintFilter.handleRead(FilterChainContext ctx)
Execute a unit of processing work to be performed, when channel will
become available for reading.
|
Modifier and Type | Method and Description |
---|---|
NextAction |
SNIFilter.handleConnect(FilterChainContext ctx) |
NextAction |
SNIFilter.handleRead(FilterChainContext ctx) |
Modifier and Type | Method and Description |
---|---|
NextAction |
SpdyHandlerFilter.handleConnect(FilterChainContext ctx) |
NextAction |
SpdyHandlerFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event) |
NextAction |
SpdyHandlerFilter.handleRead(FilterChainContext ctx) |
NextAction |
SpdyFramingFilter.handleRead(FilterChainContext ctx) |
NextAction |
SpdyHandlerFilter.handleWrite(FilterChainContext ctx) |
NextAction |
SpdyFramingFilter.handleWrite(FilterChainContext ctx) |
protected void |
SpdyHandlerFilter.onHttpContentEncoded(HttpContent content,
FilterChainContext ctx)
Invoked when a HTTP body chunk has been encoded in preparation to being
transmitted to the user-agent.
|
protected void |
SpdyHandlerFilter.onHttpContentError(HttpHeader httpHeader,
FilterChainContext ctx,
Throwable t)
Callback which is invoked when parsing an HTTP message payload fails.
|
protected void |
SpdyHandlerFilter.onHttpContentParsed(HttpContent content,
FilterChainContext ctx)
Invoked as request/response body content has been processed by this
Filter . |
protected void |
SpdyHandlerFilter.onHttpHeaderError(HttpHeader httpHeader,
FilterChainContext ctx,
Throwable t)
Callback which is invoked when parsing an HTTP message header fails.
|
protected boolean |
SpdyHandlerFilter.onHttpHeaderParsed(HttpHeader httpHeader,
Buffer buffer,
FilterChainContext ctx)
Callback invoked when the HTTP message header parsing is complete.
|
protected void |
SpdyHandlerFilter.onHttpHeadersEncoded(HttpHeader httpHeader,
FilterChainContext ctx)
Invoked when HTTP headers have been encoded in preparation to being
transmitted to the user-agent.
|
protected void |
SpdyHandlerFilter.onHttpHeadersParsed(HttpHeader httpHeader,
FilterChainContext ctx)
Invoked when all headers of the packet have been parsed.
|
protected boolean |
SpdyHandlerFilter.onHttpPacketParsed(HttpHeader httpHeader,
FilterChainContext ctx)
Callback method, called when
HttpPacket parsing has been completed. |
protected void |
SpdyHandlerFilter.onInitialLineEncoded(HttpHeader httpHeader,
FilterChainContext ctx)
Invoked when the intial response line has been encoded in preparation
to being transmitted to the user-agent.
|
protected void |
SpdyHandlerFilter.onInitialLineParsed(HttpHeader httpHeader,
FilterChainContext ctx)
Invoked when either the request line or status line has been parsed.
|
Modifier and Type | Method and Description |
---|---|
FilterChainContext |
SSLBaseFilter.SSLTransportFilterWrapper.createContext(Connection connection,
FilterChainContext.Operation operation) |
Modifier and Type | Method and Description |
---|---|
protected Buffer |
SSLBaseFilter.doHandshakeStep(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer) |
protected Buffer |
SSLFilter.doHandshakeStep(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer,
Buffer tmpAppBuffer0) |
protected Buffer |
SSLBaseFilter.doHandshakeStep(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer,
Buffer tmpAppBuffer0) |
protected Buffer |
SSLBaseFilter.doHandshakeSync(SSLConnectionContext sslCtx,
FilterChainContext ctx,
Buffer inputBuffer,
long timeoutMillis) |
void |
SSLBaseFilter.SSLTransportFilterWrapper.exceptionOccurred(FilterChainContext ctx,
Throwable error) |
protected Object[] |
SSLBaseFilter.getPeerCertificateChain(SSLConnectionContext sslCtx,
FilterChainContext context,
boolean needClientAuth)
Obtains the certificate chain for this SSL session.
|
NextAction |
SSLBaseFilter.SSLTransportFilterWrapper.handleAccept(FilterChainContext ctx) |
NextAction |
SSLBaseFilter.SSLTransportFilterWrapper.handleClose(FilterChainContext ctx) |
NextAction |
SSLBaseFilter.SSLTransportFilterWrapper.handleConnect(FilterChainContext ctx) |
NextAction |
SSLBaseFilter.handleEvent(FilterChainContext ctx,
FilterChainEvent event) |
NextAction |
SSLBaseFilter.SSLTransportFilterWrapper.handleEvent(FilterChainContext ctx,
FilterChainEvent event) |
NextAction |
SSLBaseFilter.handleRead(FilterChainContext ctx) |
NextAction |
SSLBaseFilter.SSLTransportFilterWrapper.handleRead(FilterChainContext ctx) |
NextAction |
SSLFilter.handleWrite(FilterChainContext ctx) |
NextAction |
SSLBaseFilter.handleWrite(FilterChainContext ctx) |
NextAction |
SSLBaseFilter.SSLTransportFilterWrapper.handleWrite(FilterChainContext ctx) |
protected void |
SSLFilter.handshake(Connection<?> connection,
CompletionHandler<SSLEngine> completionHandler,
Object dstAddress,
SSLEngineConfigurator sslEngineConfigurator,
FilterChainContext context,
boolean forceBeginHandshake) |
protected void |
SSLBaseFilter.renegotiate(SSLConnectionContext sslCtx,
FilterChainContext context)
Performs an SSL renegotiation.
|
protected NextAction |
SSLBaseFilter.unwrapAll(FilterChainContext ctx,
SSLConnectionContext sslCtx) |
protected Buffer |
SSLBaseFilter.wrapAll(FilterChainContext ctx,
SSLConnectionContext sslCtx) |
Modifier and Type | Field and Description |
---|---|
protected FilterChainContext |
ProtocolHandler.ctx |
Modifier and Type | Method and Description |
---|---|
FilterChainContext |
ProtocolHandler.getFilterChainContext() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
WebSocketFilter.doServerUpgrade(FilterChainContext ctx,
HttpContent requestContent) |
NextAction |
BaseWebSocketFilter.handleClose(FilterChainContext ctx)
Method handles Grizzly
Connection close phase. |
NextAction |
WebSocketClientFilter.handleConnect(FilterChainContext ctx)
Method handles Grizzly
Connection connect phase. |
protected NextAction |
WebSocketClientFilter.handleHandshake(FilterChainContext ctx,
HttpContent content) |
protected abstract NextAction |
BaseWebSocketFilter.handleHandshake(FilterChainContext ctx,
HttpContent content)
Handle websocket handshake
|
protected NextAction |
WebSocketFilter.handleHandshake(FilterChainContext ctx,
HttpContent content) |
NextAction |
BaseWebSocketFilter.handleRead(FilterChainContext ctx)
Handle Grizzly
Connection read phase. |
NextAction |
BaseWebSocketFilter.handleWrite(FilterChainContext ctx)
Handle Grizzly
Connection write phase. |
HandShake |
ProtocolHandler.handshake(FilterChainContext ctx,
WebSocketApplication app,
HttpContent request) |
void |
HandShake.initiate(FilterChainContext ctx) |
void |
HandShake.respond(FilterChainContext ctx,
WebSocketApplication application,
HttpResponsePacket response) |
void |
ProtocolHandler.setFilterChainContext(FilterChainContext ctx) |
protected void |
BaseWebSocketFilter.setIdleTimeout(FilterChainContext ctx) |
boolean |
WebSocketEngine.upgrade(FilterChainContext ctx,
HttpContent requestContent) |
boolean |
WebSocketEngine.upgrade(FilterChainContext ctx,
HttpContent requestContent,
Mapper mapper) |
Copyright © 2015 Oracle Corporation. All rights reserved.