Package io.netty.handler.codec.http2

Class AbstractHttp2StreamChannel.Http2ChannelUnsafe

java.lang.Object

io.netty.handler.codec.http2.AbstractHttp2StreamChannel.Http2ChannelUnsafe

All Implemented Interfaces:

Channel.Unsafe

Enclosing class:

AbstractHttp2StreamChannel

private final class AbstractHttp2StreamChannel.Http2ChannelUnsafe
extends Object
implements Channel.Unsafe

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closeInitiated
private boolean	readEOS
private boolean	receivedEndOfStream
private RecvByteBufAllocator.Handle	recvHandle
private boolean	sentEndOfStream
private final VoidChannelPromise	unsafeVoidPromise
private boolean	writeDoneAndNoFlush

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Http2ChannelUnsafe()

Method Summary

Modifier and Type	Method	Description
void	beginRead()	Schedules a read operation that fills the inbound buffer of the first ChannelInboundHandler in the ChannelPipeline.
void	bind(SocketAddress localAddress, ChannelPromise promise)	Bind the SocketAddress to the Channel of the ChannelPromise and notify it once its done.
void	close(ChannelPromise promise)	Close the Channel of the ChannelPromise and notify the ChannelPromise once the operation was complete.
private void	close(ChannelPromise promise, Http2Error error)
void	closeForcibly()	Closes the Channel immediately without firing any events.
void	connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)	Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
void	deregister(ChannelPromise promise)	Deregister the Channel of the ChannelPromise from EventLoop and notify the ChannelPromise once the operation was complete.
void	disconnect(ChannelPromise promise)	Disconnect the Channel of the ChannelFuture and notify the ChannelPromise once the operation was complete.
(package private) void	doBeginRead()
(package private) void	doRead0(Http2Frame frame, RecvByteBufAllocator.Handle allocHandle)
private void	fireChannelInactiveAndDeregister(ChannelPromise promise, boolean fireChannelInactive)
private void	firstWriteComplete(ChannelFuture future, ChannelPromise promise)
void	flush()	Flush out all write operations scheduled via Channel.Unsafe.write(Object, ChannelPromise).
private void	invokeLater(Channel channel, Runnable task)
private boolean	isEndOfStream(Http2Frame frame)
SocketAddress	localAddress()	Return the SocketAddress to which is bound local or null if none.
(package private) void	notifyReadComplete(RecvByteBufAllocator.Handle allocHandle, boolean forceReadComplete, boolean inReadLoop)
ChannelOutboundBuffer	outboundBuffer()	Returns the ChannelOutboundBuffer of the Channel where the pending write requests are stored.
private Object	pollQueuedMessage()
(package private) void	readEOS()
RecvByteBufAllocator.Handle	recvBufAllocHandle()	Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.
void	register(EventLoop eventLoop, ChannelPromise promise)	Register the Channel of the ChannelPromise and notify the ChannelFuture once the registration was complete.
SocketAddress	remoteAddress()	Return the SocketAddress to which is bound remote or null if none is bound yet.
private void	resetReadStatus()
private void	safeSetSuccess(ChannelPromise promise)
private boolean	updateLocalWindowIfNeeded()
(package private) void	updateLocalWindowIfNeededAndFlush()
private Http2StreamFrame	validateStreamFrame(Http2StreamFrame frame)
ChannelPromise	voidPromise()	Return a special ChannelPromise which can be reused and passed to the operations in Channel.Unsafe.
private Throwable	wrapStreamClosedError(Throwable cause)
void	write(Object msg, ChannelPromise promise)	Schedules a write operation.
private void	writeComplete(ChannelFuture future, ChannelPromise promise)
private void	writeHttp2StreamFrame(Http2StreamFrame frame, ChannelPromise promise)
private ChannelFuture	writeWindowUpdateFrame(Http2WindowUpdateFrame windowUpdateFrame)

Methods inherited from class java.lang.Object

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

Field Details

unsafeVoidPromise

private final VoidChannelPromise unsafeVoidPromise

recvHandle

private RecvByteBufAllocator.Handle recvHandle

writeDoneAndNoFlush

private boolean writeDoneAndNoFlush

closeInitiated

private boolean closeInitiated

readEOS

private boolean readEOS

receivedEndOfStream

private boolean receivedEndOfStream

sentEndOfStream

private boolean sentEndOfStream

Constructor Details

Http2ChannelUnsafe

private Http2ChannelUnsafe()

Method Details

connect

public void connect(SocketAddress remoteAddress,
 SocketAddress localAddress,
 ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Connect the Channel of the given ChannelFuture with the given remote SocketAddress. If a specific local SocketAddress should be used it need to be given as argument. Otherwise just pass null to it. The ChannelPromise will get notified once the connect operation was complete.

Specified by:

connect in interface Channel.Unsafe

recvBufAllocHandle

public RecvByteBufAllocator.Handle recvBufAllocHandle()

Description copied from interface: Channel.Unsafe

Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.

Specified by:

recvBufAllocHandle in interface Channel.Unsafe

localAddress

public SocketAddress localAddress()

Description copied from interface: Channel.Unsafe

Return the SocketAddress to which is bound local or null if none.

Specified by:

localAddress in interface Channel.Unsafe

remoteAddress

public SocketAddress remoteAddress()

Description copied from interface: Channel.Unsafe

Return the SocketAddress to which is bound remote or null if none is bound yet.

Specified by:

remoteAddress in interface Channel.Unsafe

register

public void register(EventLoop eventLoop,
 ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Register the Channel of the ChannelPromise and notify the ChannelFuture once the registration was complete.

Specified by:

register in interface Channel.Unsafe

bind

public void bind(SocketAddress localAddress,
 ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Bind the SocketAddress to the Channel of the ChannelPromise and notify it once its done.

Specified by:

bind in interface Channel.Unsafe

disconnect

public void disconnect(ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Disconnect the Channel of the ChannelFuture and notify the ChannelPromise once the operation was complete.

Specified by:

disconnect in interface Channel.Unsafe

close

public void close(ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Close the Channel of the ChannelPromise and notify the ChannelPromise once the operation was complete.

Specified by:

close in interface Channel.Unsafe

close

private void close(ChannelPromise promise,
 Http2Error error)

closeForcibly

public void closeForcibly()

Description copied from interface: Channel.Unsafe

Closes the Channel immediately without firing any events. Probably only useful when registration attempt failed.

Specified by:

closeForcibly in interface Channel.Unsafe

deregister

public void deregister(ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Deregister the Channel of the ChannelPromise from EventLoop and notify the ChannelPromise once the operation was complete.

Specified by:

deregister in interface Channel.Unsafe

fireChannelInactiveAndDeregister

private void fireChannelInactiveAndDeregister(ChannelPromise promise,
 boolean fireChannelInactive)

safeSetSuccess

private void safeSetSuccess(ChannelPromise promise)

invokeLater

private void invokeLater(Channel channel,
 Runnable task)

beginRead

public void beginRead()

Description copied from interface: Channel.Unsafe

Schedules a read operation that fills the inbound buffer of the first ChannelInboundHandler in the ChannelPipeline. If there's already a pending read operation, this method does nothing.

Specified by:

beginRead in interface Channel.Unsafe

pollQueuedMessage

private Object pollQueuedMessage()

doBeginRead

void doBeginRead()

readEOS

void readEOS()

updateLocalWindowIfNeeded

private boolean updateLocalWindowIfNeeded()

updateLocalWindowIfNeededAndFlush

void updateLocalWindowIfNeededAndFlush()

resetReadStatus

private void resetReadStatus()

notifyReadComplete

void notifyReadComplete(RecvByteBufAllocator.Handle allocHandle,
 boolean forceReadComplete,
 boolean inReadLoop)

doRead0

void doRead0(Http2Frame frame,
 RecvByteBufAllocator.Handle allocHandle)

writeWindowUpdateFrame

private ChannelFuture writeWindowUpdateFrame(Http2WindowUpdateFrame windowUpdateFrame)

write

public void write(Object msg,
 ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Schedules a write operation.

Specified by:

write in interface Channel.Unsafe

isEndOfStream

private boolean isEndOfStream(Http2Frame frame)

writeHttp2StreamFrame

private void writeHttp2StreamFrame(Http2StreamFrame frame,
 ChannelPromise promise)

firstWriteComplete

private void firstWriteComplete(ChannelFuture future,
 ChannelPromise promise)

writeComplete

private void writeComplete(ChannelFuture future,
 ChannelPromise promise)

wrapStreamClosedError

private Throwable wrapStreamClosedError(Throwable cause)

validateStreamFrame

private Http2StreamFrame validateStreamFrame(Http2StreamFrame frame)

flush

public void flush()

Description copied from interface: Channel.Unsafe

Flush out all write operations scheduled via Channel.Unsafe.write(Object, ChannelPromise).

Specified by:

flush in interface Channel.Unsafe

voidPromise

public ChannelPromise voidPromise()

Description copied from interface: Channel.Unsafe

Return a special ChannelPromise which can be reused and passed to the operations in Channel.Unsafe. It will never be notified of a success or error and so is only a placeholder for operations that take a ChannelPromise as argument but for which you not want to get notified.

Specified by:

voidPromise in interface Channel.Unsafe

outboundBuffer

public ChannelOutboundBuffer outboundBuffer()

Description copied from interface: Channel.Unsafe

Returns the ChannelOutboundBuffer of the Channel where the pending write requests are stored.

Specified by:

outboundBuffer in interface Channel.Unsafe