Class AbstractNioByteChannel.NioByteUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.nio.AbstractNioChannel.AbstractNioUnsafe

io.netty.channel.nio.AbstractNioByteChannel.NioByteUnsafe

All Implemented Interfaces:

Channel.Unsafe, IoHandle, AbstractNioChannel.NioUnsafe, NioIoHandle, AutoCloseable

Enclosing class:

AbstractNioByteChannel

protected class AbstractNioByteChannel.NioByteUnsafe
extends AbstractNioChannel.AbstractNioUnsafe

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	NioByteUnsafe()

Method Summary

Modifier and Type	Method	Description
final void	read()	Read from underlying SelectableChannel

Methods inherited from class AbstractNioChannel.AbstractNioUnsafe

ch, close, connect, finishConnect, flush0, forceFlush, handle, removeReadOp, selectableChannel

Modifier and Type	Method	Description
final SelectableChannel	ch()	Return underlying SelectableChannel
void	close()	Called once the IoHandle should be closed.
final void	connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)	Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
final void	finishConnect()	Finish connect
protected final void	flush0()
final void	forceFlush()
void	handle(IoRegistration registration, IoEvent event)	Be called once there is something to handle.
protected final void	removeReadOp()
SelectableChannel	selectableChannel()	The underlying SelectableChannel.

Methods inherited from class AbstractChannel.AbstractUnsafe

annotateConnectException, beginRead, bind, close, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, handleWriteError, localAddress, outboundBuffer, prepareToClose, recvBufAllocHandle, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write

Modifier and Type	Method	Description
protected final Throwable	annotateConnectException(Throwable cause, SocketAddress remoteAddress)	Appends the remote address to the message of the exceptions caused by connection attempt failure.
final void	beginRead()	Schedules a read operation that fills the inbound buffer of the first ChannelInboundHandler in the ChannelPipeline.
final 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.
protected void	close(ChannelPromise promise, Throwable cause, ClosedChannelException closeCause)
final void	closeForcibly()	Closes the Channel immediately without firing any events.
protected final void	closeIfClosed()
void	deregister(ChannelPromise promise)	Deregister the Channel of the ChannelPromise from EventLoop and notify the ChannelPromise once the operation was complete.
final void	disconnect(ChannelPromise promise)	Disconnect the Channel of the ChannelFuture and notify the ChannelPromise once the operation was complete.
protected final boolean	ensureOpen(ChannelPromise promise)
final void	flush()	Flush out all write operations scheduled via Channel.Unsafe.write(Object, ChannelPromise).
protected final void	handleWriteError(Throwable t)
final SocketAddress	localAddress()	Return the SocketAddress to which is bound local or null if none.
final ChannelOutboundBuffer	outboundBuffer()	Returns the ChannelOutboundBuffer of the Channel where the pending write requests are stored.
protected Executor	prepareToClose()	Prepares to close the Channel.
RecvByteBufAllocator.Handle	recvBufAllocHandle()	Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.
final void	register(EventLoop eventLoop, ChannelPromise promise)	Register the Channel of the ChannelPromise and notify the ChannelFuture once the registration was complete.
final SocketAddress	remoteAddress()	Return the SocketAddress to which is bound remote or null if none is bound yet.
protected final void	safeSetFailure(ChannelPromise promise, Throwable cause)	Marks the specified promise as failure.
protected final void	safeSetSuccess(ChannelPromise promise)	Marks the specified promise as success.
final void	shutdownOutput(ChannelPromise promise)	Shutdown the output portion of the corresponding Channel.
final ChannelPromise	voidPromise()	Return a special ChannelPromise which can be reused and passed to the operations in Channel.Unsafe.
final void	write(Object msg, ChannelPromise promise)	Schedules a write operation.

Methods inherited from class Object

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

Methods inherited from interface IoHandle

registered, unregistered

Modifier and Type	Method	Description
default void	registered()	Called once this IoHandle was registered and so will start to receive events via IoHandle.handle(IoRegistration, IoEvent).
default void	unregistered()	Called once this IoHandle was unregistered and so will not receive any more events via IoHandle.handle(IoRegistration, IoEvent).

Constructor Details

NioByteUnsafe

protected NioByteUnsafe()

Method Details

read

public final void read()

Description copied from interface: AbstractNioChannel.NioUnsafe

Read from underlying SelectableChannel