Class H2Streams

java.lang.Object

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

class H2Streams
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final StreamIdGenerator	idGenerator
private final AtomicInteger	lastLocalId
private final AtomicInteger	lastRemoteId
private final AtomicInteger	localCount
private final AtomicInteger	remoteCount
private final Map<Integer,H2Stream>	streamMap
private final Queue<H2Stream>	streams

Constructor Summary

Constructors

Constructor	Description
H2Streams(StreamIdGenerator idGenerator)

Method Summary

Modifier and Type	Method	Description
H2Stream	createActive(H2StreamChannel channel, H2StreamHandler streamHandler)
H2Stream	createReserved(H2StreamChannel channel, H2StreamHandler streamHandler)
private H2Stream	createStream(H2StreamChannel channel, H2StreamHandler streamHandler)
void	dropStreamId(int streamId)
int	generateStreamId()
int	getLastLocalId()
int	getLastRemoteId()
int	getLocalCount()
int	getRemoteCount()
(package private) boolean	hasBeenSeen(int streamId)
(package private) boolean	isClosed(H2Stream stream, int streamId)
boolean	isEmpty()
boolean	isOtherSide(int streamId)
boolean	isSameSide(int streamId)
Iterator<H2Stream>	iterator()
H2Stream	lookup(int streamId)
H2Stream	lookupSeen(int streamId)
H2Stream	lookupValid(int streamId)
H2Stream	lookupValidOrNull(int streamId)
void	resetIfExceedsMaxConcurrentLimit(H2Stream stream, int max)
void	shutdownAndReleaseAll()
void	shutdownAndReleaseAll(Exception cause)

Methods inherited from class Object

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

Field Details

idGenerator

private final StreamIdGenerator idGenerator

streamMap

private final Map<Integer,H2Stream> streamMap

streams

private final Queue<H2Stream> streams

lastLocalId

private final AtomicInteger lastLocalId

lastRemoteId

private final AtomicInteger lastRemoteId

localCount

private final AtomicInteger localCount

remoteCount

private final AtomicInteger remoteCount

Constructor Details

H2Streams

public H2Streams(StreamIdGenerator idGenerator)

Method Details

isEmpty

public boolean isEmpty()

iterator

public Iterator<H2Stream> iterator()

getLastLocalId

public int getLastLocalId()

getLastRemoteId

public int getLastRemoteId()

getLocalCount

public int getLocalCount()

getRemoteCount

public int getRemoteCount()

createStream

private H2Stream createStream(H2StreamChannel channel,
 H2StreamHandler streamHandler)

createActive

public H2Stream createActive(H2StreamChannel channel,
 H2StreamHandler streamHandler)

createReserved

public H2Stream createReserved(H2StreamChannel channel,
 H2StreamHandler streamHandler)

resetIfExceedsMaxConcurrentLimit

public void resetIfExceedsMaxConcurrentLimit(H2Stream stream,
 int max)
                                      throws IOException

Throws:

IOException

dropStreamId

public void dropStreamId(int streamId)

shutdownAndReleaseAll

public void shutdownAndReleaseAll(Exception cause)

shutdownAndReleaseAll

public void shutdownAndReleaseAll()

lookup

public H2Stream lookup(int streamId)

hasBeenSeen

boolean hasBeenSeen(int streamId)

isClosed

boolean isClosed(H2Stream stream,
 int streamId)

lookupValidOrNull

public H2Stream lookupValidOrNull(int streamId)
                           throws H2ConnectionException

Throws:

H2ConnectionException

lookupSeen

public H2Stream lookupSeen(int streamId)
                    throws H2ConnectionException

Throws:

H2ConnectionException

lookupValid

public H2Stream lookupValid(int streamId)
                     throws H2ConnectionException

Throws:

H2ConnectionException

isSameSide

public boolean isSameSide(int streamId)

isOtherSide

public boolean isOtherSide(int streamId)

generateStreamId

public int generateStreamId()