Package io.netty.incubator.channel.uring
Class AbstractIOUringServerChannel
- java.lang.Object
-
- io.netty.util.DefaultAttributeMap
-
- io.netty.channel.AbstractChannel
-
- io.netty.incubator.channel.uring.AbstractIOUringChannel
-
- io.netty.incubator.channel.uring.AbstractIOUringServerChannel
-
- All Implemented Interfaces:
io.netty.channel.Channel
,io.netty.channel.ChannelOutboundInvoker
,io.netty.channel.ServerChannel
,io.netty.channel.unix.UnixChannel
,io.netty.util.AttributeMap
,java.lang.Comparable<io.netty.channel.Channel>
- Direct Known Subclasses:
IOUringServerSocketChannel
abstract class AbstractIOUringServerChannel extends AbstractIOUringChannel implements io.netty.channel.ServerChannel
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) class
AbstractIOUringServerChannel.UringServerChannelUnsafe
-
Nested classes/interfaces inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel
AbstractIOUringChannel.AbstractUringUnsafe
-
-
Field Summary
Fields Modifier and Type Field Description private java.nio.ByteBuffer
acceptedAddressLengthMemory
private long
acceptedAddressLengthMemoryAddress
private java.nio.ByteBuffer
acceptedAddressMemory
private long
acceptedAddressMemoryAddress
-
Fields inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel
active, socket
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractIOUringServerChannel(LinuxSocket socket, boolean active)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected void
doClose()
protected void
doWrite(io.netty.channel.ChannelOutboundBuffer in)
AbstractIOUringChannel
getChannel()
(package private) abstract io.netty.channel.Channel
newChildChannel(int fd, long acceptedAddressMemoryAddress, long acceptedAddressLengthMemoryAddress)
protected AbstractIOUringChannel.AbstractUringUnsafe
newUnsafe()
-
Methods inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel
checkResolvable, clearPollFlag, doBeginRead, doBind, doDeregister, doDisconnect, doRegister, fd, filterOutboundMessage, ioScheduled, ioUringUnsafe, isActive, isCompatible, isOpen, localAddress0, metadata, newDirectBuffer, newDirectBuffer, remoteAddress0, resetCachedAddresses, schedulePollRdHup, submissionQueue
-
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, doShutdownOutput, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, unsafe, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface io.netty.channel.Channel
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, config, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, localAddress, metadata, parent, pipeline, read, remoteAddress, 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
-
-
-
-
Field Detail
-
acceptedAddressMemory
private final java.nio.ByteBuffer acceptedAddressMemory
-
acceptedAddressLengthMemory
private final java.nio.ByteBuffer acceptedAddressLengthMemory
-
acceptedAddressMemoryAddress
private final long acceptedAddressMemoryAddress
-
acceptedAddressLengthMemoryAddress
private final long acceptedAddressLengthMemoryAddress
-
-
Constructor Detail
-
AbstractIOUringServerChannel
protected AbstractIOUringServerChannel(LinuxSocket socket, boolean active)
-
-
Method Detail
-
doClose
protected void doClose() throws java.lang.Exception
- Overrides:
doClose
in classAbstractIOUringChannel
- Throws:
java.lang.Exception
-
newUnsafe
protected AbstractIOUringChannel.AbstractUringUnsafe newUnsafe()
- Specified by:
newUnsafe
in classAbstractIOUringChannel
-
doWrite
protected void doWrite(io.netty.channel.ChannelOutboundBuffer in)
- Overrides:
doWrite
in classAbstractIOUringChannel
-
getChannel
public AbstractIOUringChannel getChannel()
-
newChildChannel
abstract io.netty.channel.Channel newChildChannel(int fd, long acceptedAddressMemoryAddress, long acceptedAddressLengthMemoryAddress) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-