Package io.netty.incubator.channel.uring

Class IOUringSocketChannel

java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.incubator.channel.uring.IOUringSocketChannel
All Implemented Interfaces:
io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.channel.socket.DuplexChannel, io.netty.channel.socket.SocketChannel, io.netty.channel.unix.UnixChannel, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>
public final class IOUringSocketChannel extends io.netty.channel.AbstractChannel implements io.netty.channel.socket.SocketChannel

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.netty.channel.AbstractChannel

    io.netty.channel.AbstractChannel.AbstractUnsafe

    Nested classes/interfaces inherited from interface io.netty.channel.Channel

    io.netty.channel.Channel.Unsafe

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected boolean
    active
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    IOUringSocketChannel()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected static void
    checkResolvable(InetSocketAddress addr)
     
    void
    clearPollFlag(int pollMask)
     
    IOUringSocketChannelConfig
    config()
     
    protected void
    doBeginRead()
     
    protected void
    doBind(SocketAddress local)
     
    protected void
    doClose()
     
    protected final void
    doDeregister()
     
    protected void
    doDisconnect()
     
    protected void
    doRegister()
     
    protected final void
    doShutdownOutput()
     
    protected void
    doWrite(io.netty.channel.ChannelOutboundBuffer in)
     
    io.netty.channel.unix.FileDescriptor
    fd()
     
    protected Object
    filterOutboundMessage(Object msg)
     
    boolean
    isActive()
     
    protected boolean
    isCompatible(io.netty.channel.EventLoop loop)
     
    boolean
    isInputShutdown()
     
    boolean
    isOpen()
     
    boolean
    isOutputShutdown()
     
    boolean
    isShutdown()
     
    InetSocketAddress
    localAddress()
     
    protected SocketAddress
    localAddress0()
     
    io.netty.channel.ChannelMetadata
    metadata()
     
    protected final io.netty.buffer.ByteBuf
    newDirectBuffer(io.netty.buffer.ByteBuf buf)
     
    protected final io.netty.buffer.ByteBuf
    newDirectBuffer(Object holder, io.netty.buffer.ByteBuf buf)
     
    protected io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe
    newUnsafe()
     
    io.netty.channel.socket.ServerSocketChannel
    parent()
     
    InetSocketAddress
    remoteAddress()
     
    protected SocketAddress
    remoteAddress0()
     
    io.netty.channel.ChannelFuture
    shutdown()
     
    io.netty.channel.ChannelFuture
    shutdown(io.netty.channel.ChannelPromise promise)
     
    io.netty.channel.ChannelFuture
    shutdownInput()
     
    io.netty.channel.ChannelFuture
    shutdownInput(io.netty.channel.ChannelPromise promise)
     
    io.netty.channel.ChannelFuture
    shutdownOutput()
     
    io.netty.channel.ChannelFuture
    shutdownOutput(io.netty.channel.ChannelPromise promise)
     

    Methods inherited from class io.netty.channel.AbstractChannel

    alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, pipeline, read, toString, unsafe, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush

    Methods inherited from class io.netty.util.DefaultAttributeMap

    attr, hasAttr

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface io.netty.util.AttributeMap

    attr, hasAttr

    Methods inherited from interface io.netty.channel.Channel

    alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, metadata, pipeline, read, unsafe

    Methods inherited from interface io.netty.channel.ChannelOutboundInvoker

    bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush

    Methods inherited from interface java.lang.Comparable

    compareTo

    Methods inherited from interface io.netty.channel.socket.DuplexChannel

    isInputShutdown, isOutputShutdown, isShutdown, shutdown, shutdown, shutdownInput, shutdownInput, shutdownOutput, shutdownOutput

  • Field Details

    • active

      protected volatile boolean active

  • Constructor Details

    • IOUringSocketChannel

      public IOUringSocketChannel()

  • Method Details

    • parent

      public io.netty.channel.socket.ServerSocketChannel parent()
      Specified by:
      parent in interface io.netty.channel.Channel
      Specified by:
      parent in interface io.netty.channel.socket.SocketChannel
      Overrides:
      parent in class io.netty.channel.AbstractChannel

    • config

      public IOUringSocketChannelConfig config()
      Specified by:
      config in interface io.netty.channel.Channel
      Specified by:
      config in interface io.netty.channel.socket.SocketChannel

    • remoteAddress

      public InetSocketAddress remoteAddress()
      Specified by:
      remoteAddress in interface io.netty.channel.Channel
      Specified by:
      remoteAddress in interface io.netty.channel.socket.SocketChannel
      Overrides:
      remoteAddress in class io.netty.channel.AbstractChannel

    • localAddress

      public InetSocketAddress localAddress()
      Specified by:
      localAddress in interface io.netty.channel.Channel
      Specified by:
      localAddress in interface io.netty.channel.socket.SocketChannel
      Overrides:
      localAddress in class io.netty.channel.AbstractChannel

    • newUnsafe

      protected io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe newUnsafe()

    • shutdown

      public io.netty.channel.ChannelFuture shutdown()
      Specified by:
      shutdown in interface io.netty.channel.socket.DuplexChannel

    • shutdown

      public io.netty.channel.ChannelFuture shutdown(io.netty.channel.ChannelPromise promise)
      Specified by:
      shutdown in interface io.netty.channel.socket.DuplexChannel

    • doShutdownOutput

      @UnstableApi protected final void doShutdownOutput() throws Exception
      Overrides:
      doShutdownOutput in class io.netty.channel.AbstractChannel
      Throws:
      Exception

    • isOutputShutdown

      public boolean isOutputShutdown()
      Specified by:
      isOutputShutdown in interface io.netty.channel.socket.DuplexChannel

    • isInputShutdown

      public boolean isInputShutdown()
      Specified by:
      isInputShutdown in interface io.netty.channel.socket.DuplexChannel

    • isShutdown

      public boolean isShutdown()
      Specified by:
      isShutdown in interface io.netty.channel.socket.DuplexChannel

    • shutdownOutput

      public io.netty.channel.ChannelFuture shutdownOutput()
      Specified by:
      shutdownOutput in interface io.netty.channel.socket.DuplexChannel

    • shutdownOutput

      public io.netty.channel.ChannelFuture shutdownOutput(io.netty.channel.ChannelPromise promise)
      Specified by:
      shutdownOutput in interface io.netty.channel.socket.DuplexChannel

    • shutdownInput

      public io.netty.channel.ChannelFuture shutdownInput()
      Specified by:
      shutdownInput in interface io.netty.channel.socket.DuplexChannel

    • shutdownInput

      public io.netty.channel.ChannelFuture shutdownInput(io.netty.channel.ChannelPromise promise)
      Specified by:
      shutdownInput in interface io.netty.channel.socket.DuplexChannel

    • doRegister

      protected void doRegister() throws Exception
      Throws:
      Exception

    • isOpen

      public boolean isOpen()
      Specified by:
      isOpen in interface io.netty.channel.Channel

    • isActive

      public boolean isActive()
      Specified by:
      isActive in interface io.netty.channel.Channel

    • metadata

      public io.netty.channel.ChannelMetadata metadata()
      Specified by:
      metadata in interface io.netty.channel.Channel

    • fd

      public io.netty.channel.unix.FileDescriptor fd()
      Specified by:
      fd in interface io.netty.channel.unix.UnixChannel

    • isCompatible

      protected boolean isCompatible(io.netty.channel.EventLoop loop)
      Specified by:
      isCompatible in class io.netty.channel.AbstractChannel

    • newDirectBuffer

      protected final io.netty.buffer.ByteBuf newDirectBuffer(io.netty.buffer.ByteBuf buf)

    • newDirectBuffer

      protected final io.netty.buffer.ByteBuf newDirectBuffer(Object holder, io.netty.buffer.ByteBuf buf)

    • doDisconnect

      protected void doDisconnect() throws Exception
      Specified by:
      doDisconnect in class io.netty.channel.AbstractChannel
      Throws:
      Exception

    • doClose

      protected void doClose() throws Exception
      Specified by:
      doClose in class io.netty.channel.AbstractChannel
      Throws:
      Exception

    • doBeginRead

      protected void doBeginRead()
      Specified by:
      doBeginRead in class io.netty.channel.AbstractChannel

    • doWrite

      protected void doWrite(io.netty.channel.ChannelOutboundBuffer in)
      Specified by:
      doWrite in class io.netty.channel.AbstractChannel

    • filterOutboundMessage

      protected Object filterOutboundMessage(Object msg)
      Overrides:
      filterOutboundMessage in class io.netty.channel.AbstractChannel

    • doDeregister

      protected final void doDeregister()
      Overrides:
      doDeregister in class io.netty.channel.AbstractChannel

    • doBind

      protected void doBind(SocketAddress local) throws Exception
      Specified by:
      doBind in class io.netty.channel.AbstractChannel
      Throws:
      Exception

    • checkResolvable

      protected static void checkResolvable(InetSocketAddress addr)

    • localAddress0

      protected SocketAddress localAddress0()
      Specified by:
      localAddress0 in class io.netty.channel.AbstractChannel

    • remoteAddress0

      protected SocketAddress remoteAddress0()
      Specified by:
      remoteAddress0 in class io.netty.channel.AbstractChannel

    • clearPollFlag

      public void clearPollFlag(int pollMask)