Top Description Fields Constructors Methods

org.glassfish.grizzly.http2

public Class Http2SessionOutputSink

Class Inheritance

extends Object

java.lang.Object
org.glassfish.grizzly.http2.Http2SessionOutputSink

Imports

java.util.LinkedList, .List, java.util.concurrent.atomic.AtomicBoolean, .AtomicInteger, java.util.concurrent.locks.LockSupport, java.util.logging.Level, .Logger, org.glassfish.grizzly.Buffer, .CompletionHandler, .Grizzly, .WriteHandler, .WriteResult, org.glassfish.grizzly.asyncqueue.MessageCloner, .TaskQueue, org.glassfish.grizzly.http2.frames.DataFrame, .ErrorCode, .Http2Frame

Class represents an output sink associated with specific Http2Session and is responsible for session (connection) level flow control.

Author: Alexey Stashok

Field Summary

Modifier and Type	Field and Description
private final AtomicInteger	availConnectionWindowSize
protected final Http2Session	http2Session
private static final Logger	LOGGER
private static final int	MAX_FRAME_PAYLOAD_SIZE
private static final int	MAX_OUTPUT_QUEUE_SIZE
private final TaskQueue<Http2OutputQueueRecord>	outputQueue
private final List<Http2Frame>	tmpFramesList
private final AtomicBoolean	writerLock

Constructor Summary

Access	Constructor and Description
public	Http2SessionOutputSink(Http2Session session)

Method Summary

Modifier and Type	Method and Description
protected boolean	canWrite()
public void	close()
private void	flushOutputQueue()
protected Http2FrameCodec	frameCodec()
protected int	getAvailablePeerConnectionWindowSize()
protected void	notifyCanWrite(final WriteHandler writeHandler)
protected void	onPeerWindowUpdate(final int delta)
protected void	writeDataDownStream(final Http2Stream stream, final List<Http2Frame> headerFrames, Buffer data, final CompletionHandler<WriteResult<K, L>> completionHandler, final MessageCloner<Buffer> messageCloner, final boolean isLast)
protected void	writeDownStream(final Http2Frame frame)
protected void	writeDownStream(final List<Http2Frame> frames)
protected <K> void	writeDownStream(final K anyMessage, final CompletionHandler<WriteResult<K, L>> completionHandler, final MessageCloner<Buffer> messageCloner)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

availConnectionWindowSize	back to summary
private final AtomicInteger availConnectionWindowSize

http2Session	back to summary
protected final Http2Session http2Session

LOGGER	back to summary
private static final Logger LOGGER

MAX_FRAME_PAYLOAD_SIZE	back to summary
private static final int MAX_FRAME_PAYLOAD_SIZE

MAX_OUTPUT_QUEUE_SIZE	back to summary
private static final int MAX_OUTPUT_QUEUE_SIZE

outputQueue	back to summary
private final TaskQueue<Http2OutputQueueRecord> outputQueue

tmpFramesList	back to summary
private final List<Http2Frame> tmpFramesList

writerLock	back to summary
private final AtomicBoolean writerLock

Constructor Detail

Http2SessionOutputSink	back to summary
public Http2SessionOutputSink(Http2Session session)

Method Detail

canWrite	back to summary
protected boolean canWrite()

close	back to summary
public void close()

flushOutputQueue	back to summary
private void flushOutputQueue()

frameCodec	back to summary
protected Http2FrameCodec frameCodec()

getAvailablePeerConnectionWindowSize	back to summary
protected int getAvailablePeerConnectionWindowSize()

notifyCanWrite	back to summary
protected void notifyCanWrite(final WriteHandler writeHandler)

onPeerWindowUpdate	back to summary
protected void onPeerWindowUpdate(final int delta) throws Http2SessionException

writeDataDownStream	back to summary
protected void writeDataDownStream(final Http2Stream stream, final List<Http2Frame> headerFrames, Buffer data, final CompletionHandler<WriteResult<K, L>> completionHandler, final MessageCloner<Buffer> messageCloner, final boolean isLast)

writeDownStream	back to summary
protected void writeDownStream(final Http2Frame frame)

writeDownStream	back to summary
protected void writeDownStream(final List<Http2Frame> frames)

writeDownStream	back to summary
protected <K> void writeDownStream(final K anyMessage, final CompletionHandler<WriteResult<K, L>> completionHandler, final MessageCloner<Buffer> messageCloner) Annotations @SuppressWarnings:unchecked