| Modifier and Type | Field and Description |
|---|---|
| private final Object | |
| private int | |
| private SendFrameHeader | |
| private int | |
| private volatile boolean | |
| private final int |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| protected PooledByteBuffer[] | |
| protected void | channelForciblyClosed()
Overrides io. Called when a channel has been forcibly closed, and data (frames) have already been written. |
| pack-priv void | |
| protected final SendFrameHeader | |
| protected abstract SendFrameHeader | |
| pack-priv SendFrameHeader | |
| public int | |
| protected int | Returns: The number of bytes that can be sentThis method should be called before sending. |
| protected void | handleFlushComplete(boolean channelClosed)
Overrides io.
|
| pack-priv void | |
| pack-priv void |
| flowControlLock | back to summary |
|---|---|
| private final Object flowControlLock | |
| flowControlWindow | back to summary |
|---|---|
| private int flowControlWindow | |
| header | back to summary |
|---|---|
| private SendFrameHeader header Hides io. | |
| initialWindowSize | back to summary |
|---|---|
| private int initialWindowSize | |
| reset | back to summary |
|---|---|
| private volatile boolean reset | |
| streamId | back to summary |
|---|---|
| private final int streamId | |
| Http2StreamSinkChannel | back to summary |
|---|---|
| pack-priv Http2StreamSinkChannel(Http2Channel channel, int streamId) | |
| allocateAll | back to summary |
|---|---|
| protected PooledByteBuffer[] allocateAll(PooledByteBuffer[] allHeaderBuffers, PooledByteBuffer currentBuffer) | |
| channelForciblyClosed | back to summary |
|---|---|
| protected void channelForciblyClosed() throws IOException Overrides io. Doc from io. Called when a channel has been forcibly closed, and data (frames) have already been written. The action this should take is protocol dependent, e.g. for SPDY a RST_STREAM should be sent, for websockets the channel should be closed. By default this will just close the underlying channel
| |
| clearHeader | back to summary |
|---|---|
| pack-priv void clearHeader() | |
| createFrameHeader | back to summary |
|---|---|
| protected final SendFrameHeader createFrameHeader() Overrides io.
| |
| createFrameHeaderImpl | back to summary |
|---|---|
| protected abstract SendFrameHeader createFrameHeaderImpl() | |
| generateSendFrameHeader | back to summary |
|---|---|
| pack-priv SendFrameHeader generateSendFrameHeader() | |
| getStreamId | back to summary |
|---|---|
| public int getStreamId() | |
| grabFlowControlBytes | back to summary |
|---|---|
| protected int grabFlowControlBytes(int toSend) This method should be called before sending. It will return the amount of data that can be sent, taking into account the stream and connection flow control windows, and the toSend parameter. It will decrement the flow control windows by the amount that can be sent, so this method should only be called as a frame is being queued.
| |
| handleFlushComplete | back to summary |
|---|---|
| protected void handleFlushComplete(boolean channelClosed) Overrides io.
| |
| rstStream | back to summary |
|---|---|
| pack-priv void rstStream() Method that is invoked when the stream is reset. | |
| updateFlowControlWindow | back to summary |
|---|---|
| pack-priv void updateFlowControlWindow(final int delta) throws IOException | |