org.glassfish.grizzly.http2

Class Http2ClientFilter

java.lang.Object

org.glassfish.grizzly.filterchain.BaseFilter

org.glassfish.grizzly.http.HttpBaseFilter

org.glassfish.grizzly.http2.Http2BaseFilter

org.glassfish.grizzly.http2.Http2ClientFilter

All Implemented Interfaces:

Filter

public class Http2ClientFilter
extends Http2BaseFilter

Author:

oleksiys

Field Summary

Fields inherited from class org.glassfish.grizzly.http2.Http2BaseFilter

FIXED_LENGTH_ENCODING

Constructor Summary

Constructors

Constructor and Description
Http2ClientFilter()
Http2ClientFilter(DraftVersion... supportedDraftVersions)
Http2ClientFilter(ExecutorService threadPool, DraftVersion... supportedDraftVersions)

Method Summary

Modifier and Type	Method and Description
protected Http2Connection	createClientHttp2Connection(DraftVersion draftVersion, Connection connection) Creates client-side Http2Connection with preconfigured initial-windows-size and max-concurrent-streams.
protected org.glassfish.grizzly.npn.AlpnClientNegotiator	getClientAlpnNegotioator()
NextAction	handleConnect(FilterChainContext ctx) Execute a unit of processing work to be performed, when channel gets connected.
NextAction	handleEvent(FilterChainContext ctx, FilterChainEvent event) Handle custom event associated with the Connection.
NextAction	handleRead(FilterChainContext ctx) Execute a unit of processing work to be performed, when channel will become available for reading.
NextAction	handleWrite(FilterChainContext ctx) Execute a unit of processing work to be performed, when some data should be written on channel.
boolean	isNeverForceUpgrade()
boolean	isSendPushRequestUpstream()
protected SettingsFrame.SettingsFrameBuilder	prepareSettings()
protected SettingsFrame.SettingsFrameBuilder	prepareSettings(DraftVersion version)
protected SettingsFrame.SettingsFrameBuilder	prepareSettings(DraftVersion version, SettingsFrame.SettingsFrameBuilder builder)
protected void	processCompleteHeader(Http2Connection http2Connection, FilterChainContext context, HeaderBlockHead firstHeaderFrame) The method is called once complete HTTP header block arrives on Http2Connection.
protected void	processOutgoingHttpHeader(FilterChainContext ctx, Http2Connection http2Connection, HttpHeader httpHeader, HttpPacket entireHttpPacket)
void	setNeverForceUpgrade(boolean neverForceUpgrade)
void	setSendPushRequestUpstream(boolean sendPushRequestUpstream)

Methods inherited from class org.glassfish.grizzly.http2.Http2BaseFilter

checkRequestHeadersOnUpgrade, checkResponseHeadersOnUpgrade, createHttp2Connection, getHttp2UpgradeSettings, getHttp2UpgradingVersion, getInitialWindowSize, getLocalMaxFramePayloadSize, getMaxConcurrentStreams, obtainHttp2Connection, onHttpContentEncoded, onHttpContentError, onHttpContentParsed, onHttpHeaderError, onHttpHeaderParsed, onHttpHeadersEncoded, onHttpHeadersParsed, onHttpPacketParsed, onInitialLineEncoded, onInitialLineParsed, onPrefaceReceived, prepareOutgoingRequest, processFrames, sendSettings, setInitialWindowSize, setLocalMaxFramePayloadSize, setMaxConcurrentStreams

Methods inherited from class org.glassfish.grizzly.http.HttpBaseFilter

bind

Methods inherited from class org.glassfish.grizzly.filterchain.BaseFilter

createContext, exceptionOccurred, handleAccept, handleClose, onAdded, onFilterChainChanged, onRemoved, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Http2ClientFilter

public Http2ClientFilter()

Http2ClientFilter

public Http2ClientFilter(DraftVersion... supportedDraftVersions)

Http2ClientFilter

public Http2ClientFilter(ExecutorService threadPool,
                         DraftVersion... supportedDraftVersions)

Method Detail

isNeverForceUpgrade

public boolean isNeverForceUpgrade()

setNeverForceUpgrade

public void setNeverForceUpgrade(boolean neverForceUpgrade)

isSendPushRequestUpstream

public boolean isSendPushRequestUpstream()

Returns:

true if the push request has to be sent upstream, so a user have a chance to process it, or false otherwise

setSendPushRequestUpstream

public void setSendPushRequestUpstream(boolean sendPushRequestUpstream)

Parameters:

sendPushRequestUpstream - true if the push request has to be sent upstream, so a user have a chance to process it, or false otherwise

handleConnect

public NextAction handleConnect(FilterChainContext ctx)
                         throws IOException

Description copied from class: BaseFilter

Execute a unit of processing work to be performed, when channel gets connected. This Filter may either complete the required processing and return false, or delegate remaining processing to the next Filter in a FilterChain containing this Filter by returning true.

Specified by:

handleConnect in interface Filter

Overrides:

handleConnect in class BaseFilter

Parameters:

ctx - FilterChainContext

Returns:

NextAction instruction for FilterChain, how it should continue the execution

Throws:

IOException

handleRead

public NextAction handleRead(FilterChainContext ctx)
                      throws IOException

Description copied from class: BaseFilter

Execute a unit of processing work to be performed, when channel will become available for reading. This Filter may either complete the required processing and return false, or delegate remaining processing to the next Filter in a FilterChain containing this Filter by returning true.

Specified by:

handleRead in interface Filter

Overrides:

handleRead in class BaseFilter

Parameters:

ctx - FilterChainContext

Returns:

NextAction instruction for FilterChain, how it should continue the execution

Throws:

IOException

handleWrite

public NextAction handleWrite(FilterChainContext ctx)
                       throws IOException

Description copied from class: BaseFilter

Execute a unit of processing work to be performed, when some data should be written on channel. This Filter may either complete the required processing and return false, or delegate remaining processing to the next Filter in a FilterChain containing this Filter by returning true.

Specified by:

handleWrite in interface Filter

Overrides:

handleWrite in class Http2BaseFilter

Parameters:

ctx - FilterChainContext

Returns:

NextAction instruction for FilterChain, how it should continue the execution

Throws:

IOException

handleEvent

public NextAction handleEvent(FilterChainContext ctx,
                              FilterChainEvent event)
                       throws IOException

Description copied from class: BaseFilter

Handle custom event associated with the Connection. This Filter may either complete the required processing and return StopAction, or delegate remaining processing to the next Filter in a FilterChain containing this Filter by returning InvokeAction.

Specified by:

handleEvent in interface Filter

Overrides:

handleEvent in class Http2BaseFilter

Parameters:

ctx - FilterChainContext

Returns:

NextAction instruction for FilterChain, how it should continue the execution

Throws:

IOException

processOutgoingHttpHeader

protected void processOutgoingHttpHeader(FilterChainContext ctx,
                                         Http2Connection http2Connection,
                                         HttpHeader httpHeader,
                                         HttpPacket entireHttpPacket)
                                  throws IOException

Specified by:

processOutgoingHttpHeader in class Http2BaseFilter

Parameters:

ctx -

http2Connection -

httpHeader -

entireHttpPacket -

Throws:

IOException

createClientHttp2Connection

protected Http2Connection createClientHttp2Connection(DraftVersion draftVersion,
                                                      Connection connection)

Creates client-side Http2Connection with preconfigured initial-windows-size and max-concurrent-streams. Note: Should be called with disabled OP_READ (or during OP_READ processing), because peer frames must not be processed at the time this method is running.

Parameters:

draftVersion -

connection -

Returns:

Http2Connection

getClientAlpnNegotioator

protected org.glassfish.grizzly.npn.AlpnClientNegotiator getClientAlpnNegotioator()

processCompleteHeader

protected void processCompleteHeader(Http2Connection http2Connection,
                                     FilterChainContext context,
                                     HeaderBlockHead firstHeaderFrame)
                              throws IOException

Description copied from class: Http2BaseFilter

The method is called once complete HTTP header block arrives on Http2Connection.

Specified by:

processCompleteHeader in class Http2BaseFilter

Throws:

IOException

prepareSettings

protected final SettingsFrame.SettingsFrameBuilder prepareSettings()

prepareSettings

protected final SettingsFrame.SettingsFrameBuilder prepareSettings(DraftVersion version)

prepareSettings

protected SettingsFrame.SettingsFrameBuilder prepareSettings(DraftVersion version,
                                                             SettingsFrame.SettingsFrameBuilder builder)