Package dev.relism.flash.http2.stream
Class Http2StreamTable
java.lang.Object
dev.relism.flash.http2.stream.Http2StreamTable
Fixed-capacity primitive stream-id table using linear-probed open addressing.
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final int -
Constructor Summary
ConstructorsConstructorDescriptionHttp2StreamTable(int maxEntries) Http2StreamTable(int maxEntries, DataBufferPool dataBuffers) -
Method Summary
Modifier and TypeMethodDescriptionacquire(int streamId) voidadjustAllSendWindows(int delta) intcapacity()voidclear()intclosedKind(int streamId) intcopyValues(Http2Stream[] target) intbooleandetach(Http2Stream stream, int streamId) Removes a wire-closed stream from live concurrency while retaining its in-flight buffer.voidforEach(Http2StreamTable.StreamConsumer consumer) intget(int streamId) voidput(Http2Stream stream) voidrelease(Http2Stream stream) voidrememberReset(int streamId) remove(int streamId) booleanremoveIfSame(Http2Stream stream, int streamId) Removes a stream only when both its id and pooled-object identity still match.booleanretire(Http2Stream stream, int streamId) Atomically removes and recycles the matching generation of a pooled stream.intsize()
-
Field Details
-
CLOSED_UNKNOWN
public static final int CLOSED_UNKNOWN- See Also:
-
CLOSED_NORMALLY
public static final int CLOSED_NORMALLY- See Also:
-
CLOSED_BY_RESET
public static final int CLOSED_BY_RESET- See Also:
-
-
Constructor Details
-
Http2StreamTable
public Http2StreamTable(int maxEntries) -
Http2StreamTable
-
-
Method Details
-
get
-
put
-
acquire
-
release
-
remove
-
removeIfSame
Removes a stream only when both its id and pooled-object identity still match. -
retire
Atomically removes and recycles the matching generation of a pooled stream. -
detach
Removes a wire-closed stream from live concurrency while retaining its in-flight buffer. -
rememberReset
public void rememberReset(int streamId) -
closedKind
public int closedKind(int streamId) -
forEach
-
copyValues
-
adjustAllSendWindows
public void adjustAllSendWindows(int delta) -
size
public int size() -
capacity
public int capacity() -
createdCount
public int createdCount() -
freeCount
public int freeCount() -
clear
public void clear()
-