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
abstract class AbstractIOUringChannel.AbstractUringUnsafe extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private IOUringRecvByteAllocatorHandle
allocHandle
-
Constructor Summary
Constructors Constructor Description AbstractUringUnsafe()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
close(io.netty.channel.ChannelPromise promise)
void
connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
(package private) void
connectComplete(int res)
Connect was completed.private void
fireEventAndClose(java.lang.Object evt)
protected 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, java.lang.Throwable cause)
(package private) IOUringRecvByteAllocatorHandle
newIOUringHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)
(package private) void
pollIn(int res)
Called once POLLIN event is ready to be processed(package private) void
pollOut(int res)
Called once POLLOUT event is ready to be processed(package private) void
pollRdHup(int res)
Called once POLLRDHUP event is ready to be processed(package private) void
processDelayedClose()
(package private) void
readComplete(int res, int data)
protected abstract void
readComplete0(int res, int data, int outstandingCompletes)
Called once a read was completed.IOUringRecvByteAllocatorHandle
recvBufAllocHandle()
private void
scheduleFirstRead()
private void
scheduleFirstReadIfNeeded()
(package private) void
schedulePollIn()
protected void
scheduleRead()
protected abstract int
scheduleRead0()
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
scheduleWriteSingle(java.lang.Object msg)
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) void
shutdownInput(boolean rdHup)
(package private) 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 Detail
-
allocHandle
private IOUringRecvByteAllocatorHandle allocHandle
-
-
Method Detail
-
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
protected abstract int scheduleWriteSingle(java.lang.Object msg)
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
private void fulfillConnectPromise(io.netty.channel.ChannelPromise promise, java.lang.Throwable cause)
-
fulfillConnectPromise
private void fulfillConnectPromise(io.netty.channel.ChannelPromise promise, boolean wasActive)
-
newIOUringHandle
final IOUringRecvByteAllocatorHandle newIOUringHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)
-
recvBufAllocHandle
public final IOUringRecvByteAllocatorHandle recvBufAllocHandle()
- Specified by:
recvBufAllocHandle
in interfaceio.netty.channel.Channel.Unsafe
-
shutdownInput
final void shutdownInput(boolean rdHup)
-
fireEventAndClose
private void fireEventAndClose(java.lang.Object evt)
-
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(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
-
-