java.lang.Object
- io.netty.channel.AbstractChannel.AbstractUnsafe
- - io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe

All Implemented Interfaces:

Channel.Unsafe, IoHandle, IoUringIoHandle, java.lang.AutoCloseable

Direct Known Subclasses:

AbstractIoUringServerChannel.UringServerChannelUnsafe, AbstractIoUringStreamChannel.IoUringStreamUnsafe, IoUringDatagramChannel.IoUringDatagramChannelUnsafe

Enclosing class:

AbstractIoUringChannel
```
protected abstract class AbstractIoUringChannel.AbstractUringUnsafe
extends AbstractChannel.AbstractUnsafe
implements IoUringIoHandle
```

Field Summary

Fields
Modifier and Type	Field	Description
`private IoUringRecvByteAllocatorHandle`	`allocHandle`
`private boolean`	`closed`
`private ChannelPromise`	`deregisterPromise`
`private boolean`	`socketIsEmpty`

Constructor Summary

Constructors
Modifier Constructor Description

protected AbstractUringUnsafe()

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`(package private) void`	`cancelComplete0(byte op, int res, int flags, short data)`	Called once a cancel was completed.
`private boolean`	`cancelOps(boolean cancelConnect)`
`private boolean`	`canCloseNow()`
`protected boolean`	`canCloseNow0()`
`void`	`close()`	Called once the `IoHandle` should be closed.
`protected void`	`close(ChannelPromise promise, java.lang.Throwable cause, java.nio.channels.ClosedChannelException closeCause)`
`private void`	`closeNow()`
`void`	`connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)`	Connect the `Channel` of the given `ChannelFuture` with the given remote `SocketAddress`.
`(package private) void`	`connectComplete(byte op, int res, int flags, long data)`	Called once a connect was completed.
`void`	`deregister(ChannelPromise promise)`	Deregister the `Channel` of the `ChannelPromise` from `EventLoop` and notify the `ChannelPromise` once the operation was complete.
`private void`	`fillTFOInitData(MsgHdrMemory hdr, java.net.InetSocketAddress inetSocketAddress, ByteBuf initialData)`
`private void`	`fireEventAndClose(java.lang.Object evt)`
`protected void`	`flush0()`
`private void`	`fulfillConnectPromise(ChannelPromise promise, boolean wasActive)`
`private void`	`fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)`
`void`	`handle(IoRegistration registration, IoEvent ioEvent)`	Be called once there is something to handle.
`private void`	`handleDelayedClosed()`
`protected boolean`	`isReadMultishot()`
`private void`	`pollAddComplete(int res, int flags, short data)`
`private void`	`pollIn(int res, int flags, short data)`	Called once POLLIN event is ready to be processed
`private void`	`pollOut(int res)`	Called once POLLOUT event is ready to be processed
`private void`	`pollRdHup(int res)`	Called once POLLRDHUP event is ready to be processed
`private void`	`readComplete(byte op, int res, int flags, short data)`
`protected abstract void`	`readComplete0(byte op, int res, int flags, short data, int outstandingCompletes)`	Called once a read was completed.
`IoUringRecvByteAllocatorHandle`	`recvBufAllocHandle()`	Return the assigned `RecvByteBufAllocator.Handle` which will be used to allocate `ByteBuf`'s when receiving data.
`private void`	`scheduleFirstRead()`
`private void`	`scheduleFirstReadIfNeeded()`
`(package private) void`	`schedulePollIn()`
`protected void`	`scheduleRead(boolean first)`
`protected abstract int`	`scheduleRead0(boolean first, boolean socketIsEmpty)`	Schedule a read and returns the number of `readComplete(byte, int, int, short)` calls that are expected because of the scheduled read.
`protected abstract int`	`scheduleWriteMultiple(ChannelOutboundBuffer in)`	Schedule the write of multiple messages in the `ChannelOutboundBuffer` and returns the number of `writeComplete(byte, int, int, long)` 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 of `writeComplete(byte, int, int, long)` calls that are expected because of the scheduled write.
`(package private) void`	`shutdownInput(boolean allDataRead)`
`void`	`unregistered()`	Called once this `IoHandle` was unregistered and so will not receive any more events via `IoHandle.handle(IoRegistration, IoEvent)`.
`private void`	`writeComplete(byte op, int res, int flags, long data)`	Called once a write was completed.
`(package private) abstract boolean`	`writeComplete0(byte op, int res, int flags, long data, int outstanding)`	Called once a write was completed.

Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, disconnect, ensureOpen, flush, handleWriteError, localAddress, outboundBuffer, prepareToClose, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.IoHandle
registered

- Field Detail
  - allocHandle
```
private IoUringRecvByteAllocatorHandle allocHandle
```
  - closed
```
private boolean closed
```
  - socketIsEmpty
```
private boolean socketIsEmpty
```
  - deregisterPromise
```
private ChannelPromise deregisterPromise
```
- Constructor Detail
  - AbstractUringUnsafe
```
protected AbstractUringUnsafe()
```
- Method Detail
  - scheduleWriteMultiple
```
protected abstract int scheduleWriteMultiple(ChannelOutboundBuffer in)
```
    Schedule the write of multiple messages in the ChannelOutboundBuffer and returns the number of writeComplete(byte, int, int, long) 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 of writeComplete(byte, int, int, long) calls that are expected because of the scheduled write.
  - handle
```
public final void handle(IoRegistration registration,
                         IoEvent ioEvent)
```
    Description copied from interface: IoHandle
    
    Be called once there is something to handle.
    
    Specified by:
    
    handle in interface IoHandle
    
    Parameters:
    
    registration - the IoRegistration for this IoHandle.
    
    ioEvent - the IoEvent that must be handled. The IoEvent is only valid while this method is executed and so must not escape it.
  - unregistered
```
public void unregistered()
```
    Description copied from interface: IoHandle
    
    Called once this IoHandle was unregistered and so will not receive any more events via IoHandle.handle(IoRegistration, IoEvent).
    
    Specified by:
    
    unregistered in interface IoHandle
  - handleDelayedClosed
```
private void handleDelayedClosed()
```
  - pollAddComplete
```
private void pollAddComplete(int res,
                             int flags,
                             short data)
```
  - close
```
public final void close()
                 throws java.lang.Exception
```
    Description copied from interface: IoHandle
    
    Called once the IoHandle should be closed. Even once this method is called this handle might still receive events via IoHandle.handle(IoRegistration, IoEvent) (if it was previous be registered and so its IoHandle.registered() method was called) until the IoHandle.unregistered() method is called.
    
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface IoHandle
    
    Throws:
    
    java.lang.Exception
  - close
```
protected void close(ChannelPromise promise,
                     java.lang.Throwable cause,
                     java.nio.channels.ClosedChannelException closeCause)
```
    Overrides:
    
    close in class AbstractChannel.AbstractUnsafe
  - cancelOps
```
private boolean cancelOps(boolean cancelConnect)
```
  - canCloseNow
```
private boolean canCloseNow()
```
  - canCloseNow0
```
protected boolean canCloseNow0()
```
  - closeNow
```
private void closeNow()
```
  - flush0
```
protected final void flush0()
```
    Overrides:
    
    flush0 in class AbstractChannel.AbstractUnsafe
  - fulfillConnectPromise
```
private void fulfillConnectPromise(ChannelPromise promise,
                                   java.lang.Throwable cause)
```
  - fulfillConnectPromise
```
private void fulfillConnectPromise(ChannelPromise promise,
                                   boolean wasActive)
```
  - recvBufAllocHandle
```
public final IoUringRecvByteAllocatorHandle 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
    
    Overrides:
    
    recvBufAllocHandle in class AbstractChannel.AbstractUnsafe
  - shutdownInput
```
final void shutdownInput(boolean allDataRead)
```
  - fireEventAndClose
```
private void fireEventAndClose(java.lang.Object evt)
```
  - schedulePollIn
```
final void schedulePollIn()
```
  - isReadMultishot
```
protected final boolean isReadMultishot()
```
  - readComplete
```
private void readComplete(byte op,
                          int res,
                          int flags,
                          short data)
```
  - readComplete0
```
protected abstract void readComplete0(byte op,
                                      int res,
                                      int flags,
                                      short data,
                                      int outstandingCompletes)
```
    Called once a read was completed.
  - pollRdHup
```
private void pollRdHup(int res)
```
    Called once POLLRDHUP event is ready to be processed
  - pollIn
```
private void pollIn(int res,
                    int flags,
                    short data)
```
    Called once POLLIN event is ready to be processed
  - scheduleFirstReadIfNeeded
```
private void scheduleFirstReadIfNeeded()
```
  - scheduleFirstRead
```
private void scheduleFirstRead()
```
  - scheduleRead
```
protected final void scheduleRead(boolean first)
```
  - scheduleRead0
```
protected abstract int scheduleRead0(boolean first,
                                     boolean socketIsEmpty)
```
    Schedule a read and returns the number of readComplete(byte, int, int, short) calls that are expected because of the scheduled read.
    
    Parameters:
    
    first - true if this is the first read of a read loop.
    
    socketIsEmpty - true if the socket is guaranteed to be empty, false otherwise.
    
    Returns:
    
    the number of readComplete(byte, int, int, short) calls expected or -1 if readComplete(byte, int, int, short) is called until the read is cancelled (multi-shot).
  - pollOut
```
private void pollOut(int res)
```
    Called once POLLOUT event is ready to be processed
    
    Parameters:
    
    res - the result.
  - writeComplete
```
private void writeComplete(byte op,
                           int res,
                           int flags,
                           long data)
```
    Called once a write was completed.
    
    Parameters:
    
    op - the op code.
    
    res - the result.
    
    flags - the flags.
    
    data - the data that was passed when submitting the op.
  - writeComplete0
```
abstract boolean writeComplete0(byte op,
                                int res,
                                int flags,
                                long data,
                                int outstanding)
```
    Called once a write was completed.
    
    Parameters:
    
    op - the op code
    
    res - the result.
    
    flags - the flags.
    
    data - the data that was passed when submitting the op.
    
    outstanding - the outstanding write completions.
  - cancelComplete0
```
void cancelComplete0(byte op,
                     int res,
                     int flags,
                     short data)
```
    Called once a cancel was completed.
    
    Parameters:
    
    op - the op code
    
    res - the result.
    
    flags - the flags.
    
    data - the data that was passed when submitting the op.
  - connectComplete
```
void connectComplete(byte op,
                     int res,
                     int flags,
                     long data)
```
    Called once a connect was completed.
    
    Parameters:
    
    op - the op code.
    
    res - the result.
    
    flags - the flags.
    
    data - the data that was passed when submitting the op.
  - connect
```
public void connect(java.net.SocketAddress remoteAddress,
                    java.net.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
  - fillTFOInitData
```
private void fillTFOInitData(MsgHdrMemory hdr,
                             java.net.InetSocketAddress inetSocketAddress,
                             ByteBuf initialData)
                      throws java.lang.Exception
```
    Throws:
    
    java.lang.Exception
  - deregister
```
public final 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
    
    Overrides:
    
    deregister in class AbstractChannel.AbstractUnsafe

Class AbstractIoUringChannel.AbstractUringUnsafe

Field Summary

Constructor Summary

Method Summary

Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe

Methods inherited from class java.lang.Object

Methods inherited from interface io.netty.channel.IoHandle

Field Detail

allocHandle

closed

socketIsEmpty

deregisterPromise

Constructor Detail

AbstractUringUnsafe

Method Detail

scheduleWriteMultiple

scheduleWriteSingle

handle

unregistered

handleDelayedClosed

pollAddComplete

close

close

cancelOps

canCloseNow

canCloseNow0

closeNow

flush0

fulfillConnectPromise

fulfillConnectPromise

recvBufAllocHandle

shutdownInput

fireEventAndClose

schedulePollIn

isReadMultishot

readComplete

readComplete0

pollRdHup

pollIn

scheduleFirstReadIfNeeded

scheduleFirstRead

scheduleRead

scheduleRead0

pollOut

writeComplete

writeComplete0

cancelComplete0

connectComplete

connect

fillTFOInitData

deregister