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

Class H2Stream

java.lang.Object

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

class H2Stream
extends java.lang.Object

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
H2Stream(H2StreamChannel channel, H2StreamHandler handler, java.util.function.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(java.nio.ByteBuffer src, boolean endOfStream)
(package private) void	consumeHeader(java.util.List<Header> headers, boolean endOfStream)
(package private) void	consumePromise(java.util.List<Header> headers)
(package private) void	fail(java.lang.Exception cause)
(package private) int	getId()
(package private) Timeout	getIdleTimeout()
(package private) java.util.concurrent.atomic.AtomicInteger	getInputWindow()
(package private) long	getLastActivityNanos()
(package private) java.util.concurrent.atomic.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(java.lang.Exception cause, int code)
(package private) void	localReset(java.lang.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)
java.lang.String	toString()
private void	touch()
private void	triggerClosed()
private void	triggerOpen()

Methods inherited from class java.lang.Object

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

Field Detail

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 java.util.function.Consumer<H2Stream.State> stateChangeCallback

transitionRef

private final java.util.concurrent.atomic.AtomicReference<H2Stream.State> transitionRef

released

private final java.util.concurrent.atomic.AtomicBoolean released

cancelled

private final java.util.concurrent.atomic.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 Detail

H2Stream

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

Method Detail

getId

int getId()

isReserved

boolean isReserved()

triggerOpen

private void triggerOpen()

triggerClosed

private void triggerClosed()

activate

void activate()

getOutputWindow

java.util.concurrent.atomic.AtomicInteger getOutputWindow()

getInputWindow

java.util.concurrent.atomic.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(java.util.List<Header> headers)
             throws HttpException,
                    java.io.IOException

Throws:

HttpException

java.io.IOException

consumeHeader

void consumeHeader(java.util.List<Header> headers,
                   boolean endOfStream)
            throws HttpException,
                   java.io.IOException

Throws:

HttpException

java.io.IOException

consumeData

void consumeData(java.nio.ByteBuffer src,
                 boolean endOfStream)
          throws HttpException,
                 java.io.IOException

Throws:

HttpException

java.io.IOException

isOutputReady

boolean isOutputReady()

produceOutput

void produceOutput()
            throws HttpException,
                   java.io.IOException

Throws:

HttpException

java.io.IOException

produceInputCapacityUpdate

void produceInputCapacityUpdate()
                         throws java.io.IOException

Throws:

java.io.IOException

fail

void fail(java.lang.Exception cause)

localReset

void localReset(java.lang.Exception cause,
                int code)
         throws java.io.IOException

Throws:

java.io.IOException

localReset

void localReset(java.lang.Exception cause,
                H2Error error)
         throws java.io.IOException

Throws:

java.io.IOException

localReset

void localReset(H2StreamResetException ex)
         throws java.io.IOException

Throws:

java.io.IOException

localResetCancelled

void localResetCancelled()
                  throws java.io.IOException

Throws:

java.io.IOException

handle

void handle(HttpException ex)
     throws java.io.IOException,
            HttpException

Throws:

java.io.IOException

HttpException

getPushHandlerFactory

HandlerFactory<AsyncPushConsumer> getPushHandlerFactory()

abort

boolean abort()

abortGracefully

boolean abortGracefully()
                 throws java.io.IOException

Throws:

java.io.IOException

releaseResources

void releaseResources()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

touch

private void touch()

getLastActivityNanos

long getLastActivityNanos()

getIdleTimeout

Timeout getIdleTimeout()

getPriorityValue

PriorityValue getPriorityValue()

setPriorityValue

void setPriorityValue(PriorityValue priorityValue)