Package io.netty.incubator.channel.uring
Class AbstractIOUringChannel.AbstractUringUnsafe
java.lang.Object
io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe
- All Implemented Interfaces:
io.netty.channel.Channel.Unsafe
- Direct Known Subclasses:
AbstractIOUringServerChannel.UringServerChannelUnsafe
,AbstractIOUringStreamChannel.IOUringStreamUnsafe
,IOUringDatagramChannel.IOUringDatagramChannelUnsafe
- Enclosing class:
AbstractIOUringChannel
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close
(io.netty.channel.ChannelPromise promise) void
connect
(SocketAddress remoteAddress, SocketAddress localAddress, io.netty.channel.ChannelPromise promise) (package private) void
connectComplete
(int res) Connect was completed.private void
fireEventAndClose
(Object evt) protected final void
flush0()
private void
forceClose
(io.netty.channel.ChannelPromise promise) private void
fulfillConnectPromise
(io.netty.channel.ChannelPromise promise, boolean wasActive) private void
fulfillConnectPromise
(io.netty.channel.ChannelPromise promise, Throwable cause) (package private) final IOUringRecvByteAllocatorHandle
newIOUringHandle
(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle) (package private) final void
pollIn
(int res) Called once POLLIN event is ready to be processed(package private) final void
pollOut
(int res) Called once POLLOUT event is ready to be processed(package private) final void
pollRdHup
(int res) Called once POLLRDHUP event is ready to be processed(package private) final void
(package private) final void
readComplete
(int res, int data) protected abstract void
readComplete0
(int res, int data, int outstandingCompletes) Called once a read was completed.private void
private void
(package private) final void
protected final void
protected abstract int
Schedule a read and returns the number ofreadComplete(int, int)
calls that are expected because of the scheduled read.protected abstract int
scheduleWriteMultiple
(io.netty.channel.ChannelOutboundBuffer in) Schedule the write of multiple messages in theChannelOutboundBuffer
and returns the number ofwriteComplete(int, int)
calls that are expected because of the scheduled write.protected abstract int
Schedule the write of a single message and returns the number ofwriteComplete(int, int)
calls that are expected because of the scheduled write(package private) final void
shutdownInput
(boolean rdHup) (package private) final void
writeComplete
(int res, int data) Called once a write was completed.(package private) abstract boolean
writeComplete0
(int res, int data, int outstanding) Called once a write was completed.
-
Field Details
-
allocHandle
-
-
Constructor Details
-
AbstractUringUnsafe
AbstractUringUnsafe()
-
-
Method Details
-
scheduleWriteMultiple
protected abstract int scheduleWriteMultiple(io.netty.channel.ChannelOutboundBuffer in) Schedule the write of multiple messages in theChannelOutboundBuffer
and returns the number ofwriteComplete(int, int)
calls that are expected because of the scheduled write. -
scheduleWriteSingle
Schedule the write of a single message and returns the number ofwriteComplete(int, int)
calls that are expected because of the scheduled write -
close
public void close(io.netty.channel.ChannelPromise promise) - Specified by:
close
in interfaceio.netty.channel.Channel.Unsafe
-
forceClose
private void forceClose(io.netty.channel.ChannelPromise promise) -
flush0
protected final void flush0() -
fulfillConnectPromise
-
fulfillConnectPromise
private void fulfillConnectPromise(io.netty.channel.ChannelPromise promise, boolean wasActive) -
newIOUringHandle
final IOUringRecvByteAllocatorHandle newIOUringHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle) -
recvBufAllocHandle
- Specified by:
recvBufAllocHandle
in interfaceio.netty.channel.Channel.Unsafe
-
shutdownInput
final void shutdownInput(boolean rdHup) -
fireEventAndClose
-
schedulePollIn
final void schedulePollIn() -
processDelayedClose
final void processDelayedClose() -
readComplete
final void readComplete(int res, int data) -
readComplete0
protected abstract void readComplete0(int res, int data, int outstandingCompletes) Called once a read was completed. -
pollRdHup
final void pollRdHup(int res) Called once POLLRDHUP event is ready to be processed -
pollIn
final void pollIn(int res) Called once POLLIN event is ready to be processed -
scheduleFirstReadIfNeeded
private void scheduleFirstReadIfNeeded() -
scheduleFirstRead
private void scheduleFirstRead() -
scheduleRead
protected final void scheduleRead() -
scheduleRead0
protected abstract int scheduleRead0()Schedule a read and returns the number ofreadComplete(int, int)
calls that are expected because of the scheduled read. -
pollOut
final void pollOut(int res) Called once POLLOUT event is ready to be processed -
writeComplete
final void writeComplete(int res, int data) Called once a write was completed. -
writeComplete0
abstract boolean writeComplete0(int res, int data, int outstanding) Called once a write was completed. -
connectComplete
void connectComplete(int res) Connect was completed. -
connect
public void connect(SocketAddress remoteAddress, SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
-