io.netty.channel

类 AbstractChannel.AbstractUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

所有已实现的接口:

Channel.Unsafe

直接已知子类:

AbstractNioChannel.AbstractNioUnsafe

封闭类:

AbstractChannel

protected abstract class AbstractChannel.AbstractUnsafe
extends java.lang.Object
implements Channel.Unsafe

Unsafe implementation which sub-classes must extend and use.

构造器概要

构造器

限定符	构造器和说明
protected	AbstractUnsafe()

方法概要

限定符和类型	方法和说明
protected java.lang.Throwable	annotateConnectException(java.lang.Throwable cause, java.net.SocketAddress remoteAddress) Appends the remote address to the message of the exceptions caused by connection attempt failure.
void	beginRead() Schedules a read operation that fills the inbound buffer of the first ChannelInboundHandler in the ChannelPipeline.
void	bind(java.net.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.
void	closeForcibly() Closes the Channel immediately without firing any events.
protected void	closeIfClosed()
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.
protected boolean	ensureOpen(ChannelPromise promise)
void	flush() Flush out all write operations scheduled via Channel.Unsafe.write(Object, ChannelPromise).
protected void	flush0()
protected void	handleWriteError(java.lang.Throwable t)
java.net.SocketAddress	localAddress() Return the SocketAddress to which is bound local or null if none.
ChannelOutboundBuffer	outboundBuffer() Returns the ChannelOutboundBuffer of the Channel where the pending write requests are stored.
protected java.util.concurrent.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.
void	register(EventLoop eventLoop, ChannelPromise promise) Register the Channel of the ChannelPromise and notify the ChannelFuture once the registration was complete.
java.net.SocketAddress	remoteAddress() Return the SocketAddress to which is bound remote or null if none is bound yet.
protected void	safeSetFailure(ChannelPromise promise, java.lang.Throwable cause) Marks the specified promise as failure.
protected void	safeSetSuccess(ChannelPromise promise) Marks the specified promise as success.
void	shutdownOutput(ChannelPromise promise) Shutdown the output portion of the corresponding Channel.
ChannelPromise	voidPromise() Return a special ChannelPromise which can be reused and passed to the operations in Channel.Unsafe.
void	write(java.lang.Object msg, ChannelPromise promise) Schedules a write operation.

从类继承的方法 java.lang.Object

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

从接口继承的方法 io.netty.channel.Channel.Unsafe

connect

构造器详细资料

AbstractUnsafe

protected AbstractUnsafe()

方法详细资料

recvBufAllocHandle

public RecvByteBufAllocator.Handle recvBufAllocHandle()

从接口复制的说明: Channel.Unsafe

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

指定者:

recvBufAllocHandle 在接口中 Channel.Unsafe

outboundBuffer

public final ChannelOutboundBuffer outboundBuffer()

从接口复制的说明: Channel.Unsafe

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

指定者:

outboundBuffer 在接口中 Channel.Unsafe

localAddress

public final java.net.SocketAddress localAddress()

从接口复制的说明: Channel.Unsafe

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

指定者:

localAddress 在接口中 Channel.Unsafe

remoteAddress

public final java.net.SocketAddress remoteAddress()

从接口复制的说明: Channel.Unsafe

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

指定者:

remoteAddress 在接口中 Channel.Unsafe

register

public final void register(EventLoop eventLoop,
                           ChannelPromise promise)

从接口复制的说明: Channel.Unsafe

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

指定者:

register 在接口中 Channel.Unsafe

bind

public final void bind(java.net.SocketAddress localAddress,
                       ChannelPromise promise)

从接口复制的说明: Channel.Unsafe

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

指定者:

bind 在接口中 Channel.Unsafe

disconnect

public final void disconnect(ChannelPromise promise)

从接口复制的说明: Channel.Unsafe

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

指定者:

disconnect 在接口中 Channel.Unsafe

close

public void close(ChannelPromise promise)

从接口复制的说明: Channel.Unsafe

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

指定者:

close 在接口中 Channel.Unsafe

shutdownOutput

@UnstableApi
public final void shutdownOutput(ChannelPromise promise)

Shutdown the output portion of the corresponding Channel. For example this will clean up the ChannelOutboundBuffer and not allow any more writes.

closeForcibly

public final void closeForcibly()

从接口复制的说明: Channel.Unsafe

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

指定者:

closeForcibly 在接口中 Channel.Unsafe

deregister

public final void deregister(ChannelPromise promise)

从接口复制的说明: Channel.Unsafe

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

指定者:

deregister 在接口中 Channel.Unsafe

beginRead

public final void beginRead()

从接口复制的说明: 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.

指定者:

beginRead 在接口中 Channel.Unsafe

write

public final void write(java.lang.Object msg,
                        ChannelPromise promise)

从接口复制的说明: Channel.Unsafe

Schedules a write operation.

指定者:

write 在接口中 Channel.Unsafe

flush

public final void flush()

从接口复制的说明: Channel.Unsafe

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

指定者:

flush 在接口中 Channel.Unsafe

flush0

protected void flush0()

handleWriteError

protected final void handleWriteError(java.lang.Throwable t)

voidPromise

public final ChannelPromise voidPromise()

从接口复制的说明: 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.

指定者:

voidPromise 在接口中 Channel.Unsafe

ensureOpen

protected final boolean ensureOpen(ChannelPromise promise)

safeSetSuccess

protected final void safeSetSuccess(ChannelPromise promise)

Marks the specified promise as success. If the promise is done already, log a message.

safeSetFailure

protected final void safeSetFailure(ChannelPromise promise,
                                    java.lang.Throwable cause)

Marks the specified promise as failure. If the promise is done already, log a message.

closeIfClosed

protected final void closeIfClosed()

annotateConnectException

protected final java.lang.Throwable annotateConnectException(java.lang.Throwable cause,
                                                             java.net.SocketAddress remoteAddress)

Appends the remote address to the message of the exceptions caused by connection attempt failure.

prepareToClose

protected java.util.concurrent.Executor prepareToClose()

Prepares to close the Channel. If this method returns an Executor, the caller must call the Executor.execute(Runnable) method with a task that calls AbstractChannel.doClose() on the returned Executor. If this method returns null, AbstractChannel.doClose() must be called from the caller thread. (i.e. EventLoop)