Modifier and Type	Class and Description
private static class	DefaultInputBuffer.InputElement Class represent input queue element

Modifier and Type	Field and Description
private volatile Termination	closeFlag
private static final AtomicReferenceFieldUpdater<DefaultInputBuffer, Termination>	closeFlagUpdater
private boolean	expectInputSwitch
private final Object	expectInputSwitchSync
private final Http2Session	http2Session
private final AtomicBoolean	inputClosed
private final BlockingQueue<DefaultInputBuffer.InputElement>	inputQueue
private volatile int	inputQueueSize
private static final AtomicIntegerFieldUpdater<DefaultInputBuffer>	inputQueueSizeUpdater
private static final Logger	LOGGER
private static final long	NULL_CONTENT_LENGTH
private long	remainingContentLength
private final Http2Stream	stream
private final Object	terminateSync

Access	Constructor and Description
pack-priv	DefaultInputBuffer(final Http2Stream stream)

Method Summary

Modifier and Type	Method and Description
private static int	bufSz(final Buffer buffer)
private HttpContent	buildBrokenHttpContent(final Throwable t)
private HttpContent	buildHttpContent(final Buffer payload) Builds `HttpContent` based on passed payload `Buffer`.
private boolean	Returns: `true` if we don't expect more content, or `false` if we do expect more content or we're not sure because content-length header was not specified by peer. checkContentLength(final int the number of bytes we've just got. newDataChunkSize) Based on content-length header (which we may have or may not), double check if the payload we've just got is last.
private void	checkEOF(final DefaultInputBuffer.InputElement the `InputElement` to check EOF status against. inputElement) Checks if the passed InputElement is input buffer EOF element.
public void	close(final Termination termination) Implements org.glassfish.grizzly.http2.StreamInputBuffer.close. Graceful input buffer close.
public boolean	isClosed() Implements org.glassfish.grizzly.http2.StreamInputBuffer.isClosed. Returns `true` if the `InputBuffer` has been closed.
public boolean	offer(final Buffer data, final boolean isLast) Implements org.glassfish.grizzly.http2.StreamInputBuffer.offer. The method is called, when new input data arrives.
private void	offer0(final DefaultInputBuffer.InputElement inputElement) The private method, which adds new InputElement to the input queue
public void	onReadEventComplete() Implements org.glassfish.grizzly.http2.StreamInputBuffer.onReadEventComplete. The method will be invoked once upstream completes READ operation processing.
private void	passPayloadUpstream(final DefaultInputBuffer.InputElement `InputElement` element to be appended to the current input queue content and sent upstream inputElement, int the current input queue size (-1 if we don't have this information at the moment). readyBuffersCount) Sends the available input data upstream.
public HttpContent	poll() Implements org.glassfish.grizzly.http2.StreamInputBuffer.poll. Retrieves available input buffer payload, waiting up to the `Connection#getReadTimeout(java.util.concurrent.TimeUnit)` wait time if necessary for payload to become available.
private Buffer	poll0() Retrieves available input buffer payload, waiting up to the `Connection#getReadTimeout(java.util.concurrent.TimeUnit)` wait time if necessary for payload to become available.
private boolean	switchOffExpectInput()
private int	switchOffExpectInputIfQueueNotEmpty()
private void	switchOnExpectInput()
public void	terminate(final Termination termination) Implements org.glassfish.grizzly.http2.StreamInputBuffer.terminate. Forcibly closes the input buffer.

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

Field Detail

closeFlag	back to summary
private volatile Termination closeFlag Annotations @SuppressWarnings:unused

closeFlagUpdater	back to summary
private static final AtomicReferenceFieldUpdater<DefaultInputBuffer, Termination> closeFlagUpdater

expectInputSwitch	back to summary
private boolean expectInputSwitch

expectInputSwitchSync	back to summary
private final Object expectInputSwitchSync

http2Session	back to summary
private final Http2Session http2Session

inputClosed	back to summary
private final AtomicBoolean inputClosed

inputQueue	back to summary
private final BlockingQueue<DefaultInputBuffer.InputElement> inputQueue

inputQueueSize	back to summary
private volatile int inputQueueSize

inputQueueSizeUpdater	back to summary
private static final AtomicIntegerFieldUpdater<DefaultInputBuffer> inputQueueSizeUpdater

LOGGER	back to summary
private static final Logger LOGGER

NULL_CONTENT_LENGTH	back to summary
private static final long NULL_CONTENT_LENGTH

remainingContentLength	back to summary
private long remainingContentLength

stream	back to summary
private final Http2Stream stream

terminateSync	back to summary
private final Object terminateSync

Constructor Detail

DefaultInputBuffer	back to summary
pack-priv DefaultInputBuffer(final Http2Stream stream)

Method Detail

bufSz	back to summary
private static int bufSz(final Buffer buffer)

buildBrokenHttpContent	back to summary
private HttpContent buildBrokenHttpContent(final Throwable t)

buildHttpContent	back to summary
private HttpContent buildHttpContent(final Buffer payload) Builds `HttpContent` based on passed payload `Buffer`. If the payload size is `0` and the input buffer has been terminated - return `HttpBrokenContent`.

checkContentLength back to summary

checkContentLength	back to summary
private boolean checkContentLength(final int newDataChunkSize) Based on content-length header (which we may have or may not), double check if the payload we've just got is last. Parameters newDataChunkSize:int the number of bytes we've just got. Returns:boolean `true` if we don't expect more content, or `false` if we do expect more content or we're not sure because content-length header was not specified by peer.

private boolean checkContentLength(final int newDataChunkSize)

Based on content-length header (which we may have or may not), double check if the payload we've just got is last.

Parameters

newDataChunkSize:int: the number of bytes we've just got.

Returns:boolean

true if we don't expect more content, or false if we do expect more content or we're not sure because content-length header was not specified by peer.

checkEOF back to summary

checkEOF	back to summary
private void checkEOF(final DefaultInputBuffer.InputElement inputElement) Checks if the passed InputElement is input buffer EOF element. Parameters inputElement:DefaultInputBuffer.InputElement the `InputElement` to check EOF status against.

private void checkEOF(final DefaultInputBuffer.InputElement inputElement)

Checks if the passed InputElement is input buffer EOF element.

Parameters

inputElement:DefaultInputBuffer.InputElement: the InputElement to check EOF status against.

close	back to summary
public void close(final Termination termination) Implements org.glassfish.grizzly.http2.StreamInputBuffer.close. Graceful input buffer close. Marks the input buffer as closed by adding Termination input element to the input queue. Annotations @Override

back to summary

public void close(final Termination termination)

Implements org.glassfish.grizzly.http2.StreamInputBuffer.close.

Graceful input buffer close. Marks the input buffer as closed by adding Termination input element to the input queue.

Annotations

@Override

isClosed back to summary

isClosed	back to summary
public boolean isClosed() Implements org.glassfish.grizzly.http2.StreamInputBuffer.isClosed. Returns `true` if the `InputBuffer` has been closed. Annotations @Override

public boolean isClosed()

Implements org.glassfish.grizzly.http2.StreamInputBuffer.isClosed.

Returns true if the InputBuffer has been closed.

Annotations

@Override

offer	back to summary
public boolean offer(final Buffer data, final boolean isLast) Implements org.glassfish.grizzly.http2.StreamInputBuffer.offer. The method is called, when new input data arrives. Annotations @Override

offer

back to summary

public boolean offer(final Buffer data, final boolean isLast)

Implements org.glassfish.grizzly.http2.StreamInputBuffer.offer.

The method is called, when new input data arrives.

Annotations

@Override

offer0	back to summary
private void offer0(final DefaultInputBuffer.InputElement inputElement) The private method, which adds new InputElement to the input queue

onReadEventComplete	back to summary
public void onReadEventComplete() Implements org.glassfish.grizzly.http2.StreamInputBuffer.onReadEventComplete. The method will be invoked once upstream completes READ operation processing. Here we have to simulate NIO OP_READ event re-registration. Annotations @Override

onReadEventComplete

back to summary

public void onReadEventComplete()

Implements org.glassfish.grizzly.http2.StreamInputBuffer.onReadEventComplete.

The method will be invoked once upstream completes READ operation processing. Here we have to simulate NIO OP_READ event re-registration.

Annotations

@Override

passPayloadUpstream back to summary

passPayloadUpstream	back to summary
private void passPayloadUpstream(final DefaultInputBuffer.InputElement inputElement, int readyBuffersCount) Sends the available input data upstream. Parameters inputElement:DefaultInputBuffer.InputElement `InputElement` element to be appended to the current input queue content and sent upstream readyBuffersCount:int the current input queue size (-1 if we don't have this information at the moment).

private void passPayloadUpstream(final DefaultInputBuffer.InputElement inputElement, int readyBuffersCount)

Sends the available input data upstream.

Parameters

inputElement:DefaultInputBuffer.InputElement: InputElement element to be appended to the current input queue content and sent upstream
readyBuffersCount:int: the current input queue size (-1 if we don't have this information at the moment).

poll back to summary

poll	back to summary
public HttpContent poll() throws IOException Implements org.glassfish.grizzly.http2.StreamInputBuffer.poll. Retrieves available input buffer payload, waiting up to the `Connection#getReadTimeout(java.util.concurrent.TimeUnit)` wait time if necessary for payload to become available. Annotations @Override Exceptions IOException: if an error occurs with the poll operation.

public HttpContent poll() throws IOException

Implements org.glassfish.grizzly.http2.StreamInputBuffer.poll.

Retrieves available input buffer payload, waiting up to the Connection#getReadTimeout(java.util.concurrent.TimeUnit) wait time if necessary for payload to become available.

Annotations

@Override

Exceptions

IOException:: if an error occurs with the poll operation.

poll0 back to summary

poll0	back to summary
private Buffer poll0() throws IOException Retrieves available input buffer payload, waiting up to the `Connection#getReadTimeout(java.util.concurrent.TimeUnit)` wait time if necessary for payload to become available. Exceptions IOException: if an error occurs with the poll operation.

private Buffer poll0() throws IOException

Retrieves available input buffer payload, waiting up to the Connection#getReadTimeout(java.util.concurrent.TimeUnit) wait time if necessary for payload to become available.

Exceptions

IOException:: if an error occurs with the poll operation.

switchOffExpectInput	back to summary
private boolean switchOffExpectInput()

switchOffExpectInputIfQueueNotEmpty	back to summary
private int switchOffExpectInputIfQueueNotEmpty()

switchOnExpectInput	back to summary
private void switchOnExpectInput()

terminate	back to summary
public void terminate(final Termination termination) Implements org.glassfish.grizzly.http2.StreamInputBuffer.terminate. Forcibly closes the input buffer. All the buffered data will be discarded. Annotations @Override

terminate

back to summary

public void terminate(final Termination termination)

Implements org.glassfish.grizzly.http2.StreamInputBuffer.terminate.

Forcibly closes the input buffer. All the buffered data will be discarded.

Annotations

@Override

org.glassfish.grizzly.http2 back to summary

private final Class DefaultInputBuffer.InputElement

Class Inheritance

extends Object

java.lang.Object
org.glassfish.grizzly.http2.DefaultInputBuffer.InputElement

Class represent input queue element

Field Summary

Modifier and Type	Field and Description
private final Object	content
private final boolean	isLast
private final boolean	isService

Constructor Summary

Access	Constructor and Description
public	InputElement(final Object content, final boolean isLast, final boolean isService)

Method Summary

Modifier and Type	Method and Description
private Buffer	toBuffer()

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

Field Detail

content	back to summary
private final Object content

isLast	back to summary
private final boolean isLast

isService	back to summary
private final boolean isService

Constructor Detail

InputElement	back to summary
public InputElement(final Object content, final boolean isLast, final boolean isService)

Method Detail

toBuffer	back to summary
private Buffer toBuffer()

pack-priv Class DefaultInputBuffer

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class DefaultInputBuffer.InputElement

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail