Class H2Stream

java.lang.Object

org.apache.hc.core5.http2.impl.nio.H2Stream

class H2Stream
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	H2Stream.State

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	cancelled
private final H2StreamChannel	channel
private final H2StreamHandler	handler
private Timeout	idleTimeout
private long	lastActivityNanos
private static final long	LINGER_TIME
private PriorityValue	priorityValue
private final AtomicBoolean	released
private boolean	remoteClosed
private boolean	reserved
private final Consumer<H2Stream.State>	stateChangeCallback
private final AtomicReference<H2Stream.State>	transitionRef

Constructor Summary

Constructors

Constructor	Description
H2Stream(H2StreamChannel channel, H2StreamHandler handler, Consumer<H2Stream.State> stateChangeCallback)

Method Summary

Modifier and Type	Method	Description
(package private) boolean	abort()
(package private) boolean	abortGracefully()
(package private) void	activate()
(package private) void	consumeData(ByteBuffer src, boolean endOfStream)
(package private) void	consumeHeader(List<Header> headers, boolean endOfStream)
(package private) void	consumePromise(List<Header> headers)
(package private) void	fail(Exception cause)
(package private) int	getId()
(package private) Timeout	getIdleTimeout()
(package private) AtomicInteger	getInputWindow()
(package private) long	getLastActivityNanos()
(package private) AtomicInteger	getOutputWindow()
(package private) PriorityValue	getPriorityValue()
(package private) HandlerFactory<AsyncPushConsumer>	getPushHandlerFactory()
(package private) void	handle(HttpException ex)
(package private) boolean	isActive()
(package private) boolean	isClosed()
(package private) boolean	isClosedPastLingerDeadline()
(package private) boolean	isLocalClosed()
(package private) boolean	isOutputReady()
private boolean	isPastLingerDeadline()
(package private) boolean	isRemoteClosed()
(package private) boolean	isReserved()
(package private) void	localReset(Exception cause, int code)
(package private) void	localReset(Exception cause, H2Error error)
(package private) void	localReset(H2StreamResetException ex)
(package private) void	localResetCancelled()
(package private) void	markRemoteClosed()
(package private) void	produceInputCapacityUpdate()
(package private) void	produceOutput()
(package private) void	releaseResources()
(package private) void	setPriorityValue(PriorityValue priorityValue)
String	toString()
private void	touch()
private void	triggerClosed()
private void	triggerOpen()

Methods inherited from class Object

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

Field Details

LINGER_TIME

private static final long LINGER_TIME

See Also:

• Constant Field Values

channel

private final H2StreamChannel channel

handler

private final H2StreamHandler handler

stateChangeCallback

private final Consumer<H2Stream.State> stateChangeCallback

transitionRef

private final AtomicReference<H2Stream.State> transitionRef

released

private final AtomicBoolean released

cancelled

private final AtomicBoolean cancelled

reserved

private volatile boolean reserved

remoteClosed

private volatile boolean remoteClosed

lastActivityNanos

private volatile long lastActivityNanos

idleTimeout

private volatile Timeout idleTimeout

priorityValue

private volatile PriorityValue priorityValue

Constructor Details

H2Stream

H2Stream(H2StreamChannel channel,
 H2StreamHandler handler,
 Consumer<H2Stream.State> stateChangeCallback)

Method Details

getId

int getId()

isReserved

boolean isReserved()

triggerOpen

private void triggerOpen()

triggerClosed

private void triggerClosed()

activate

void activate()

getOutputWindow

AtomicInteger getOutputWindow()

getInputWindow

AtomicInteger getInputWindow()

isPastLingerDeadline

private boolean isPastLingerDeadline()

isClosedPastLingerDeadline

boolean isClosedPastLingerDeadline()

isClosed

boolean isClosed()

isActive

boolean isActive()

isRemoteClosed

boolean isRemoteClosed()

markRemoteClosed

void markRemoteClosed()

isLocalClosed

boolean isLocalClosed()

consumePromise

void consumePromise(List<Header> headers)
             throws HttpException,
IOException

Throws:

HttpException

IOException

consumeHeader

void consumeHeader(List<Header> headers,
 boolean endOfStream)
            throws HttpException,
IOException

Throws:

HttpException

IOException

consumeData

void consumeData(ByteBuffer src,
 boolean endOfStream)
          throws HttpException,
IOException

Throws:

HttpException

IOException

isOutputReady

boolean isOutputReady()

produceOutput

void produceOutput()
            throws HttpException,
IOException

Throws:

HttpException

IOException

produceInputCapacityUpdate

void produceInputCapacityUpdate()
                         throws IOException

Throws:

IOException

fail

void fail(Exception cause)

localReset

void localReset(Exception cause,
 int code)
         throws IOException

Throws:

IOException

localReset

void localReset(Exception cause,
 H2Error error)
         throws IOException

Throws:

IOException

localReset

void localReset(H2StreamResetException ex)
         throws IOException

Throws:

IOException

localResetCancelled

void localResetCancelled()
                  throws IOException

Throws:

IOException

handle

void handle(HttpException ex)
     throws IOException,
HttpException

Throws:

IOException

HttpException

getPushHandlerFactory

HandlerFactory<AsyncPushConsumer> getPushHandlerFactory()

abort

boolean abort()

abortGracefully

boolean abortGracefully()
                 throws IOException

Throws:

IOException

releaseResources

void releaseResources()

toString

public String toString()

Overrides:

toString in class Object

touch

private void touch()

getLastActivityNanos

long getLastActivityNanos()

getIdleTimeout

Timeout getIdleTimeout()

getPriorityValue

PriorityValue getPriorityValue()

setPriorityValue

void setPriorityValue(PriorityValue priorityValue)