Nested and Inner Type Summary

Modifier and Type	Class and Description
public static enum	Http2Stream.State

Field Summary

Modifier and Type	Field and Description
private final AttributeHolder	attributes
private Buffer	cachedInputBuffer
private boolean	cachedIsLast
private volatile GrizzlyFuture<CloseReason>	closeFuture
private final Queue<CloseListener<T extends Closeable, C extends ICloseType>>	closeListeners
private volatile CloseReason	closeReason
private static final AtomicReferenceFieldUpdater<Http2Stream, CloseReason>	closeReasonUpdater
private volatile int	completeFinalizationCounter
private static final AtomicIntegerFieldUpdater<Http2Stream>	completeFinalizationCounterUpdater
private final boolean	exclusive
public static final String	HTTP2_PARENT_STREAM_ATTRIBUTE
public static final String	HTTP2_STREAM_ATTRIBUTE
private final Http2Session	http2Session
private static final Attribute<Http2Stream>	HTTP_RQST_HTTP2_STREAM_ATTR
private int	inboundHeaderFramesCounter
pack-priv final StreamInputBuffer	inputBuffer
pack-priv volatile boolean	isProcessingComplete
private static final Logger	LOGGER
pack-priv final StreamOutputSink	outputSink
private final int	parentStreamId
private final int	priority
private final HttpRequestPacket	request
pack-priv Http2Stream.State	state
private final int	streamId
private volatile int	unackedReadBytes
pack-priv static final AtomicIntegerFieldUpdater<Http2Stream>	unackedReadBytesUpdater
pack-priv static final int	UPGRADE_STREAM_ID

Access	Constructor and Description
protected	Http2Stream(final Http2Session the `Http2Session` for this `Http2Stream`. http2Session, final HttpRequestPacket the `HttpRequestPacket` initiating the stream. request, final int this stream's ID. streamId, final int the parent stream, if any. parentStreamId, final boolean exclusive, final int the priority of this stream. priority) Create HTTP2 stream.
protected	Http2Stream(final Http2Session the `Http2Session` for this `Http2Stream`. http2Session, final HttpRequestPacket the `HttpRequestPacket` initiating the stream. request, final int the priority of this stream. priority) Construct upgrade stream, which is half HTTP, half HTTP2

Method Summary

Modifier and Type	Method and Description
public void	addCloseListener(final CloseListener<T extends Closeable, C extends ICloseType> closeListener) Implements org.glassfish.grizzly.Closeable.addCloseListener. Add the `CloseListener`, which will be notified once the stream will be closed.
private IOException	assertCanAcceptData(final boolean fin)
pack-priv IOException	assertCanAcceptHeader(final boolean fin)
public void	assertOpen() Implements org.glassfish.grizzly.Closeable.assertOpen. Checks if this `Closeable` is open and ready to be used.
pack-priv boolean	Returns: true if the stream can receive frames, otherwise false. canReceiveFrames() Checks if the specified stream is can receive frames.
pack-priv boolean	Returns: true if the stream can send frames, otherwise false. canSendFrames() Checks if the specified stream is can send frames.
public boolean	canWrite(int length) Implements org.glassfish.grizzly.OutputSink.canWrite. Deprecated
public boolean	canWrite() Implements org.glassfish.grizzly.OutputSink.canWrite.
public GrizzlyFuture<Closeable>	close() Implements org.glassfish.grizzly.Closeable.close. Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it.
public void	close(final CompletionHandler<Closeable> completionHandler) Implements org.glassfish.grizzly.Closeable.close. Deprecated please use `close()` with the following `GrizzlyFuture#addCompletionHandler(org.glassfish.grizzly.CompletionHandler)` call Gracefully closes this stream and releases any system resources associated with it.
pack-priv void	close0(final CompletionHandler<Closeable> completionHandler, final CloseType closeType, final IOException cause, final boolean isCloseOutputGracefully) References Deprecated `CloseType` is deprecated or references (maybe indirectly) at least one deprecated element.
pack-priv void	closedRemotely() Notifies the Http2Stream that it's been closed remotely.
private void	closedStateSwitch()
public GrizzlyFuture<CloseReason>	closeFuture() Implements org.glassfish.grizzly.Closeable.closeFuture.
public void	closeSilently() Implements org.glassfish.grizzly.Closeable.closeSilently. Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it.
private void	closeStream()
public void	closeWithReason(final IOException cause) Implements org.glassfish.grizzly.Closeable.closeWithReason. Gracefully closes the `Closeable` and provides the reason description.
pack-priv void	flushInputData()
public AttributeHolder	getAttributes() Implements org.glassfish.grizzly.attributes.AttributeStorage.getAttributes. Get associated `AttributeHolder`.
pack-priv Http2Session	getHttp2Session()
public int	getId()
pack-priv int	getInboundHeaderFramesCounter()
pack-priv HttpHeader	getInputHttpHeader()
public int	getLocalWindowSize()
pack-priv HttpHeader	getOutputHttpHeader()
pack-priv StreamOutputSink	getOutputSink()
public int	getParentStreamId()
public int	getPeerWindowSize()
public int	getPriority()
public HttpRequestPacket	getRequest()
public HttpResponsePacket	getResponse()
pack-priv Http2Stream.State	Returns: the current State. getState() The state of the specified stream.
public static Http2Stream	getStreamFor(final HttpHeader httpHeader)
public int	getUnflushedWritesCount() Returns: the number of writes (not bytes), that haven't reached network layer
pack-priv boolean	Returns: true if the stream is closed, otherwise false. isClosed() Checks if the specified stream is closed.
pack-priv boolean	Returns: true if the stream is idle, otherwise false. isIdle() Checks if the specified stream is idle.
public boolean	isLocallyInitiatedStream()
public boolean	isOpen() Implements org.glassfish.grizzly.Closeable.isOpen. Is `Closeable` open and ready.
public boolean	isPushEnabled()
public boolean	isPushStream()
public void	notifyCanWrite(final WriteHandler handler, final int length) Implements org.glassfish.grizzly.OutputSink.notifyCanWrite. Deprecated Instructs the `OutputSink` to invoke the provided `WriteHandler` when it is possible to write `length` bytes (or characters).
public void	notifyCanWrite(final WriteHandler writeHandler) Implements org.glassfish.grizzly.OutputSink.notifyCanWrite. Instructs the `OutputSink` to invoke the provided `WriteHandler` when it is possible to write more bytes (or characters).
private void	notifyCloseListeners() Notify all close listeners
pack-priv void	offerInputData(final Buffer data, final boolean fin)
pack-priv void	onInputClosed()
pack-priv void	onOutputClosed()
pack-priv void	onProcessingComplete()
pack-priv void	onRcvHeaders(final boolean flag indicating if the end-of-stream has been reached isEOS) The method is called when an inbound headers are decoded for the stream, which means all the header frames arrived and we're ready to parse the headers.
private void	onReceiveEndOfStream() Transition the stream from: - OPEN -> HALF_CLOSED_REMOTE - HALF_CLOSED_LOCAL -> CLOSED
private void	onReceiveHeaders() Transition the stream from: - IDLE -> OPEN - RESERVED_REMOTE -> HALF_CLOSED_LOCAL
pack-priv void	onReceivePushPromise() Transition the stream from IDLE to RESERVED_REMOTE.
private void	onReset() Transition the stream from: - OPEN -> CLOSED - RESERVED_LOCAL -> CLOSED - RESERVED_REMOTE -> CLOSED - HALF_CLOSED_LOCAL -> CLOSED - HALF_CLOSED_REMOTE -> CLOSED
private void	onSendEndOfStream() Transition the stream from: - OPEN -> HALF_CLOSED_LOCAL - HALF_CLOSED_REMOTE -> CLOSED
private void	onSendHeaders() Transition the stream from: - IDLE -> OPEN - RESERVED_LOCAL -> HALF_CLOSED_REMOTE
pack-priv void	onSendPushPromise() Transition the stream from IDLE to RESERVED_LOCAL.
pack-priv void	onSndHeaders(final boolean flag indicating if the end-of-stream has been reached isEOS) The method is called when an outbound headers are about to be sent to the peer.
pack-priv HttpContent	pollInputData()
public boolean	removeCloseListener(final CloseListener<T extends Closeable, C extends ICloseType> closeListener) Implements org.glassfish.grizzly.Closeable.removeCloseListener. Remove the `CloseListener`.
pack-priv void	resetRemotely() Notify the Http2Stream that peer sent RST_FRAME.
public GrizzlyFuture<Closeable>	terminate() Implements org.glassfish.grizzly.Closeable.terminate. Closes this stream and releases any system resources associated with it.
public void	terminateSilently() Implements org.glassfish.grizzly.Closeable.terminateSilently. Closes this stream and releases any system resources associated with it.
public void	terminateWithReason(final IOException cause) Implements org.glassfish.grizzly.Closeable.terminateWithReason. Closes the `Closeable` and provides the reason description.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

attributes	back to summary
private final AttributeHolder attributes

cachedInputBuffer	back to summary
private Buffer cachedInputBuffer

cachedIsLast	back to summary
private boolean cachedIsLast

closeFuture	back to summary
private volatile GrizzlyFuture<CloseReason> closeFuture

closeListeners	back to summary
private final Queue<CloseListener<T extends Closeable, C extends ICloseType>> closeListeners

closeReason	back to summary
private volatile CloseReason closeReason Annotations @SuppressWarnings:unused

closeReasonUpdater	back to summary
private static final AtomicReferenceFieldUpdater<Http2Stream, CloseReason> closeReasonUpdater

completeFinalizationCounter	back to summary
private volatile int completeFinalizationCounter Annotations @SuppressWarnings:unused

completeFinalizationCounterUpdater	back to summary
private static final AtomicIntegerFieldUpdater<Http2Stream> completeFinalizationCounterUpdater

exclusive	back to summary
private final boolean exclusive

HTTP2_PARENT_STREAM_ATTRIBUTE	back to summary
public static final String HTTP2_PARENT_STREAM_ATTRIBUTE

HTTP2_STREAM_ATTRIBUTE	back to summary
public static final String HTTP2_STREAM_ATTRIBUTE

http2Session	back to summary
private final Http2Session http2Session

HTTP_RQST_HTTP2_STREAM_ATTR	back to summary
private static final Attribute<Http2Stream> HTTP_RQST_HTTP2_STREAM_ATTR

inboundHeaderFramesCounter	back to summary
private int inboundHeaderFramesCounter

inputBuffer	back to summary
pack-priv final StreamInputBuffer inputBuffer

isProcessingComplete	back to summary
pack-priv volatile boolean isProcessingComplete

LOGGER	back to summary
private static final Logger LOGGER

outputSink	back to summary
pack-priv final StreamOutputSink outputSink

parentStreamId	back to summary
private final int parentStreamId

priority	back to summary
private final int priority

request	back to summary
private final HttpRequestPacket request

state	back to summary
pack-priv Http2Stream.State state

streamId	back to summary
private final int streamId

unackedReadBytes	back to summary
private volatile int unackedReadBytes Annotations @SuppressWarnings:unused

unackedReadBytesUpdater	back to summary
pack-priv static final AtomicIntegerFieldUpdater<Http2Stream> unackedReadBytesUpdater

UPGRADE_STREAM_ID	back to summary
pack-priv static final int UPGRADE_STREAM_ID

Constructor Detail

Http2Stream back to summary

Http2Stream	back to summary
protected Http2Stream(final Http2Session http2Session, final HttpRequestPacket request, final int streamId, final int parentStreamId, final boolean exclusive, final int priority) Create HTTP2 stream. Parameters http2Session:Http2Session the `Http2Session` for this `Http2Stream`. request:HttpRequestPacket the `HttpRequestPacket` initiating the stream. streamId:int this stream's ID. parentStreamId:int the parent stream, if any. priority:int the priority of this stream.

protected Http2Stream(final Http2Session http2Session, final HttpRequestPacket request, final int streamId, final int parentStreamId, final boolean exclusive, final int priority)

Create HTTP2 stream.

Parameters

http2Session:Http2Session: the Http2Session for this Http2Stream.
request:HttpRequestPacket: the HttpRequestPacket initiating the stream.
streamId:int: this stream's ID.
parentStreamId:int: the parent stream, if any.
priority:int: the priority of this stream.

Http2Stream back to summary

Http2Stream	back to summary
protected Http2Stream(final Http2Session http2Session, final HttpRequestPacket request, final int priority) Construct upgrade stream, which is half HTTP, half HTTP2 Parameters http2Session:Http2Session the `Http2Session` for this `Http2Stream`. request:HttpRequestPacket the `HttpRequestPacket` initiating the stream. priority:int the priority of this stream.

protected Http2Stream(final Http2Session http2Session, final HttpRequestPacket request, final int priority)

Construct upgrade stream, which is half HTTP, half HTTP2

Parameters

http2Session:Http2Session: the Http2Session for this Http2Stream.
request:HttpRequestPacket: the HttpRequestPacket initiating the stream.
priority:int: the priority of this stream.

Method Detail

addCloseListener back to summary

addCloseListener	back to summary
public void addCloseListener(final CloseListener<T extends Closeable, C extends ICloseType> closeListener) Implements org.glassfish.grizzly.Closeable.addCloseListener. Doc from org.glassfish.grizzly.Closeable.addCloseListener. Add the `CloseListener`, which will be notified once the stream will be closed. Annotations @Override @SuppressWarnings:unchecked

public void addCloseListener(final CloseListener<T extends Closeable, C extends ICloseType> closeListener)

Implements org.glassfish.grizzly.Closeable.addCloseListener.

Doc from org.glassfish.grizzly.Closeable.addCloseListener.

Add the CloseListener, which will be notified once the stream will be closed.

Annotations

@Override
@SuppressWarnings:unchecked

assertCanAcceptData	back to summary
private IOException assertCanAcceptData(final boolean fin)

assertCanAcceptHeader	back to summary
pack-priv IOException assertCanAcceptHeader(final boolean fin)

assertOpen back to summary

assertOpen	back to summary
public void assertOpen() throws IOException Implements org.glassfish.grizzly.Closeable.assertOpen. Doc from org.glassfish.grizzly.Closeable.assertOpen. Checks if this `Closeable` is open and ready to be used. If this `Closeable` is closed then an IOException will be thrown Annotations @Override Exceptions IOException: giving the reason why this `Closeable` was closed.

public void assertOpen() throws IOException

Implements org.glassfish.grizzly.Closeable.assertOpen.

Doc from org.glassfish.grizzly.Closeable.assertOpen.

Checks if this Closeable is open and ready to be used. If this Closeable is closed then an IOException will be thrown

Annotations

@Override

Exceptions

IOException:: giving the reason why this Closeable was closed.

canReceiveFrames	back to summary
pack-priv boolean canReceiveFrames() Checks if the specified stream is can receive frames. Returns:boolean true if the stream can receive frames, otherwise false.

canReceiveFrames

back to summary

pack-priv boolean canReceiveFrames()

Checks if the specified stream is can receive frames.

Returns:boolean: true if the stream can receive frames, otherwise false.

canSendFrames	back to summary
pack-priv boolean canSendFrames() Checks if the specified stream is can send frames. Returns:boolean true if the stream can send frames, otherwise false.

canSendFrames

back to summary

pack-priv boolean canSendFrames()

Checks if the specified stream is can send frames.

Returns:boolean: true if the stream can send frames, otherwise false.

canWrite	back to summary
public boolean canWrite(int length) Implements org.glassfish.grizzly.OutputSink.canWrite. Deprecated Annotations @Override @Deprecated

canWrite

back to summary

public boolean canWrite(int length)

Implements org.glassfish.grizzly.OutputSink.canWrite.

Deprecated

Annotations

@Override
@Deprecated

canWrite	back to summary
public boolean canWrite() Implements org.glassfish.grizzly.OutputSink.canWrite. Annotations @Override

canWrite

back to summary

public boolean canWrite()

Implements org.glassfish.grizzly.OutputSink.canWrite.

Annotations

@Override

close	back to summary
public GrizzlyFuture<Closeable> close() Implements org.glassfish.grizzly.Closeable.close. Doc from org.glassfish.grizzly.Closeable.close. Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. Annotations @Override

back to summary

public GrizzlyFuture<Closeable> close()

Implements org.glassfish.grizzly.Closeable.close.

Doc from org.glassfish.grizzly.Closeable.close.

Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

Annotations

@Override

close back to summary

close	back to summary
public void close(final CompletionHandler<Closeable> completionHandler) Implements org.glassfish.grizzly.Closeable.close. Doc from org.glassfish.grizzly.Closeable.close. Deprecated please use `close()` with the following `GrizzlyFuture#addCompletionHandler(org.glassfish.grizzly.CompletionHandler)` call Gracefully closes this stream and releases any system resources associated with it. This operation waits for all pending output data to be flushed before closing the stream. If the stream is already closed then invoking this method has no effect. Annotations @Deprecated @Override

public void close(final CompletionHandler<Closeable> completionHandler)

Implements org.glassfish.grizzly.Closeable.close.

Doc from org.glassfish.grizzly.Closeable.close.

Deprecated

please use close() with the following GrizzlyFuture#addCompletionHandler(org.glassfish.grizzly.CompletionHandler) call

Gracefully closes this stream and releases any system resources associated with it. This operation waits for all pending output data to be flushed before closing the stream. If the stream is already closed then invoking this method has no effect.

Annotations

@Deprecated
@Override

close0	back to summary
pack-priv void close0(final CompletionHandler<Closeable> completionHandler, final CloseType closeType, final IOException cause, final boolean isCloseOutputGracefully) References Deprecated `CloseType` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information.

closedRemotely	back to summary
pack-priv void closedRemotely() Notifies the Http2Stream that it's been closed remotely.

closedStateSwitch	back to summary
private void closedStateSwitch()

closeFuture	back to summary
public GrizzlyFuture<CloseReason> closeFuture() Implements org.glassfish.grizzly.Closeable.closeFuture. Annotations @SuppressWarnings:Duplicates @Override

closeFuture

back to summary

public GrizzlyFuture<CloseReason> closeFuture()

Implements org.glassfish.grizzly.Closeable.closeFuture.

Annotations

@SuppressWarnings:Duplicates
@Override

closeSilently	back to summary
public void closeSilently() Implements org.glassfish.grizzly.Closeable.closeSilently. Doc from org.glassfish.grizzly.Closeable.closeSilently. Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. Use this method, when no completion notification is needed. Annotations @Override

closeSilently

back to summary

public void closeSilently()

Implements org.glassfish.grizzly.Closeable.closeSilently.

Doc from org.glassfish.grizzly.Closeable.closeSilently.

Gracefully (if supported by the implementation) closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. Use this method, when no completion notification is needed.

Annotations

@Override

closeStream	back to summary
private void closeStream()

closeWithReason back to summary

closeWithReason	back to summary
public void closeWithReason(final IOException cause) Implements org.glassfish.grizzly.Closeable.closeWithReason. Doc from org.glassfish.grizzly.Closeable.closeWithReason. Gracefully closes the `Closeable` and provides the reason description. This method is similar to `closeSilently()`, but additionally provides the reason why the `Closeable` will be closed. Annotations @Override

public void closeWithReason(final IOException cause)

Implements org.glassfish.grizzly.Closeable.closeWithReason.

Doc from org.glassfish.grizzly.Closeable.closeWithReason.

Gracefully closes the Closeable and provides the reason description. This method is similar to closeSilently(), but additionally provides the reason why the Closeable will be closed.

Annotations

@Override

flushInputData	back to summary
pack-priv void flushInputData() throws Http2SessionException

getAttributes back to summary

public AttributeHolder getAttributes()

Implements org.glassfish.grizzly.attributes.AttributeStorage.getAttributes.

Doc from org.glassfish.grizzly.attributes.AttributeStorage.getAttributes.

Get associated AttributeHolder. Implementation may return null if AttributeHolder wasn't initialized yet.

Annotations

@Override

getHttp2Session	back to summary
pack-priv Http2Session getHttp2Session()

getId	back to summary
public int getId()

getInboundHeaderFramesCounter	back to summary
pack-priv int getInboundHeaderFramesCounter()

getInputHttpHeader	back to summary
pack-priv HttpHeader getInputHttpHeader()

getLocalWindowSize	back to summary
public int getLocalWindowSize()

getOutputHttpHeader	back to summary
pack-priv HttpHeader getOutputHttpHeader()

getOutputSink	back to summary
pack-priv StreamOutputSink getOutputSink()

getParentStreamId	back to summary
public int getParentStreamId() Annotations @SuppressWarnings:unused

getPeerWindowSize	back to summary
public int getPeerWindowSize()

getPriority	back to summary
public int getPriority() Annotations @SuppressWarnings:unused

getRequest	back to summary
public HttpRequestPacket getRequest()

getResponse	back to summary
public HttpResponsePacket getResponse()

getState

back to summary

pack-priv Http2Stream.State getState()

The state of the specified stream.

Returns:Http2Stream.State: the current State.

getStreamFor	back to summary
public static Http2Stream getStreamFor(final HttpHeader httpHeader)

getUnflushedWritesCount	back to summary
public int getUnflushedWritesCount() Returns:int the number of writes (not bytes), that haven't reached network layer

isClosed

back to summary

pack-priv boolean isClosed()

Checks if the specified stream is closed.

Returns:boolean: true if the stream is closed, otherwise false.

isIdle

back to summary

pack-priv boolean isIdle()

Checks if the specified stream is idle.

Returns:boolean: true if the stream is idle, otherwise false.

isLocallyInitiatedStream	back to summary
public boolean isLocallyInitiatedStream()

isOpen back to summary

public boolean isOpen()

Implements org.glassfish.grizzly.Closeable.isOpen.

Doc from org.glassfish.grizzly.Closeable.isOpen.

Is Closeable open and ready. Returns true, if the Closeable is open and ready, or false otherwise.

Annotations

@Override

isPushEnabled	back to summary
public boolean isPushEnabled() Annotations @SuppressWarnings:unused

isPushStream	back to summary
public boolean isPushStream()

notifyCanWrite back to summary

public void notifyCanWrite(final WriteHandler handler, final int length)

Implements org.glassfish.grizzly.OutputSink.notifyCanWrite.

Doc from org.glassfish.grizzly.OutputSink.notifyCanWrite.

Deprecated

Instructs the OutputSink to invoke the provided WriteHandler when it is possible to write length bytes (or characters). Note that once the WriteHandler has been notified, it will not be considered for notification again at a later point in time.

Annotations

@Override
@Deprecated

notifyCanWrite back to summary

public void notifyCanWrite(final WriteHandler writeHandler)

Implements org.glassfish.grizzly.OutputSink.notifyCanWrite.

Doc from org.glassfish.grizzly.OutputSink.notifyCanWrite.

Instructs the OutputSink to invoke the provided WriteHandler when it is possible to write more bytes (or characters). Note that once the WriteHandler has been notified, it will not be considered for notification again at a later point in time.

Annotations

@Override

notifyCloseListeners

back to summary

private void notifyCloseListeners()

Notify all close listeners

Annotations

@SuppressWarnings:unchecked

offerInputData	back to summary
pack-priv void offerInputData(final Buffer data, final boolean fin) throws IOException

onInputClosed	back to summary
pack-priv void onInputClosed()

onOutputClosed	back to summary
pack-priv void onOutputClosed()

onProcessingComplete	back to summary
pack-priv void onProcessingComplete()

onRcvHeaders

back to summary

pack-priv void onRcvHeaders(final boolean isEOS) throws Http2StreamException

The method is called when an inbound headers are decoded for the stream, which means all the header frames arrived and we're ready to parse the headers.

Parameters

isEOS:boolean: flag indicating if the end-of-stream has been reached

Exceptions

Http2StreamException:: if an error occurs processing the headers frame

onReceiveEndOfStream	back to summary
private void onReceiveEndOfStream() Transition the stream from: - OPEN -> HALF_CLOSED_REMOTE - HALF_CLOSED_LOCAL -> CLOSED

onReceiveHeaders	back to summary
private void onReceiveHeaders() Transition the stream from: - IDLE -> OPEN - RESERVED_REMOTE -> HALF_CLOSED_LOCAL

onReceivePushPromise	back to summary
pack-priv void onReceivePushPromise() Transition the stream from IDLE to RESERVED_REMOTE.

onReset	back to summary
private void onReset() Transition the stream from: - OPEN -> CLOSED - RESERVED_LOCAL -> CLOSED - RESERVED_REMOTE -> CLOSED - HALF_CLOSED_LOCAL -> CLOSED - HALF_CLOSED_REMOTE -> CLOSED

onSendEndOfStream	back to summary
private void onSendEndOfStream() Transition the stream from: - OPEN -> HALF_CLOSED_LOCAL - HALF_CLOSED_REMOTE -> CLOSED

onSendHeaders	back to summary
private void onSendHeaders() Transition the stream from: - IDLE -> OPEN - RESERVED_LOCAL -> HALF_CLOSED_REMOTE

onSendPushPromise	back to summary
pack-priv void onSendPushPromise() Transition the stream from IDLE to RESERVED_LOCAL.

onSndHeaders

back to summary

pack-priv void onSndHeaders(final boolean isEOS)

The method is called when an outbound headers are about to be sent to the peer.

Parameters

isEOS:boolean: flag indicating if the end-of-stream has been reached

pollInputData	back to summary
pack-priv HttpContent pollInputData() throws IOException

removeCloseListener back to summary

public boolean removeCloseListener(final CloseListener<T extends Closeable, C extends ICloseType> closeListener)

Implements org.glassfish.grizzly.Closeable.removeCloseListener.

Doc from org.glassfish.grizzly.Closeable.removeCloseListener.

Remove the CloseListener.

Annotations

@Override

resetRemotely	back to summary
pack-priv void resetRemotely() Notify the Http2Stream that peer sent RST_FRAME.

terminate

back to summary

public GrizzlyFuture<Closeable> terminate()

Implements org.glassfish.grizzly.Closeable.terminate.

Doc from org.glassfish.grizzly.Closeable.terminate.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

Annotations

@Override

terminateSilently

back to summary

public void terminateSilently()

Implements org.glassfish.grizzly.Closeable.terminateSilently.

Doc from org.glassfish.grizzly.Closeable.terminateSilently.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. Use this method, when no completion notification is needed.

Annotations

@Override

terminateWithReason back to summary

public void terminateWithReason(final IOException cause)

Implements org.glassfish.grizzly.Closeable.terminateWithReason.

Doc from org.glassfish.grizzly.Closeable.terminateWithReason.

Closes the Closeable and provides the reason description. This method is similar to terminateSilently(), but additionally provides the reason why the Closeable will be closed.

Annotations

@Override

org.glassfish.grizzly.http2 back to summary

public final Enum Http2Stream.State

Class Inheritance

extends Enum<Http2Stream.State>

java.lang.Object
java.lang.Enum
org.glassfish.grizzly.http2.Http2Stream.State

Field Summary

Modifier and Type	Field and Description
public static final Http2Stream.State	CLOSED
public static final Http2Stream.State	HALF_CLOSED_LOCAL
public static final Http2Stream.State	HALF_CLOSED_REMOTE
public static final Http2Stream.State	IDLE
public static final Http2Stream.State	OPEN
public static final Http2Stream.State	RESERVED_LOCAL
public static final Http2Stream.State	RESERVED_REMOTE

Constructor Summary

Access	Constructor and Description
private	State()

Method Summary

Modifier and Type	Method and Description
public static Http2Stream.State	valueOf(String name)
public static Http2Stream.State[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

CLOSED	back to summary
public static final Http2Stream.State CLOSED

HALF_CLOSED_LOCAL	back to summary
public static final Http2Stream.State HALF_CLOSED_LOCAL

HALF_CLOSED_REMOTE	back to summary
public static final Http2Stream.State HALF_CLOSED_REMOTE

IDLE	back to summary
public static final Http2Stream.State IDLE

OPEN	back to summary
public static final Http2Stream.State OPEN

RESERVED_LOCAL	back to summary
public static final Http2Stream.State RESERVED_LOCAL

RESERVED_REMOTE	back to summary
public static final Http2Stream.State RESERVED_REMOTE

Constructor Detail

State	back to summary
private State()

Method Detail

valueOf	back to summary
public static Http2Stream.State valueOf(String name)

values	back to summary
public static Http2Stream.State[] values()

public Class Http2Stream

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public final Enum Http2Stream.State

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail