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

Class H2Streams

java.lang.Object

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

class H2Streams
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private StreamIdGenerator	idGenerator
private java.util.concurrent.atomic.AtomicInteger	lastLocalId
private java.util.concurrent.atomic.AtomicInteger	lastRemoteId
private java.util.concurrent.atomic.AtomicInteger	localCount
private java.util.concurrent.atomic.AtomicInteger	remoteCount
private java.util.Map<java.lang.Integer,H2Stream>	streamMap
private java.util.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)
java.util.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(java.lang.Exception cause)

Methods inherited from class java.lang.Object

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

Field Detail

idGenerator

private final StreamIdGenerator idGenerator

streamMap

private final java.util.Map<java.lang.Integer,H2Stream> streamMap

streams

private final java.util.Queue<H2Stream> streams

lastLocalId

private final java.util.concurrent.atomic.AtomicInteger lastLocalId

lastRemoteId

private final java.util.concurrent.atomic.AtomicInteger lastRemoteId

localCount

private final java.util.concurrent.atomic.AtomicInteger localCount

remoteCount

private final java.util.concurrent.atomic.AtomicInteger remoteCount

Constructor Detail

H2Streams

public H2Streams(StreamIdGenerator idGenerator)

Method Detail

isEmpty

public boolean isEmpty()

iterator

public java.util.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 java.io.IOException

Throws:

java.io.IOException

dropStreamId

public void dropStreamId(int streamId)

shutdownAndReleaseAll

public void shutdownAndReleaseAll(java.lang.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()