Class AbstractIoUringServerChannel
java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.channel.uring.AbstractIoUringChannel
io.netty.channel.uring.AbstractIoUringServerChannel
- All Implemented Interfaces:
Channel, ChannelOutboundInvoker, ServerChannel, UnixChannel, AttributeMap, Comparable<Channel>
- Direct Known Subclasses:
IoUringServerDomainSocketChannel, IoUringServerSocketChannel
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate static final classprivate final classNested classes/interfaces inherited from class AbstractIoUringChannel
AbstractIoUringChannel.AbstractUringUnsafeNested classes/interfaces inherited from class AbstractChannel
AbstractChannel.AbstractUnsafeNested classes/interfaces inherited from interface Channel
Channel.Unsafe -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final AbstractIoUringServerChannel.AcceptedAddressMemoryprivate longprivate static final ChannelMetadataFields inherited from class AbstractIoUringChannel
active, socket, writeTracker -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedAbstractIoUringServerChannel(LinuxSocket socket, boolean active) -
Method Summary
Modifier and TypeMethodDescriptionprotected final voidcancelOutstandingReads(IoRegistration registration, int numOutstandingReads) Cancel all outstanding readsprotected final voidcancelOutstandingWrites(IoRegistration registration, int numOutstandingWrites) Cancel all outstanding writesprotected final voiddoClose()Close theChannelprotected final voidFlush the content of the given buffer to the remote peer.(package private) booleanprotected final booleanfinal ChannelMetadatametadata()(package private) abstract ChannelnewChildChannel(int fd, ByteBuffer acceptedAddressMemory) protected final AbstractIoUringChannel.AbstractUringUnsafeCreate a newAbstractChannel.AbstractUnsafeinstance which will be used for the life-time of theChannelprotected booleansocketIsEmpty(int flags) Return if the socket is guaranteed to be empty when the submitted io was executed and the completion event be created.Methods inherited from class AbstractIoUringChannel
allowMultiShotPollIn, autoReadCleared, checkResolvable, doBeginRead, doBind, doDeregister, doDisconnect, doRegister, doShutdownOutput, doShutdownOutput0, fd, filterOutboundMessage, isActive, isCompatible, isOpen, localAddress0, newDirectBuffer, newDirectBuffer, nextOpsId, registration, remoteAddress0, resetCachedAddresses, schedulePollRdHup, scheduleWriteIfNeeded, submitAndRunNowMethods inherited from class AbstractChannel
closeFuture, compareTo, doRegister, equals, eventLoop, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, localAddress, maxMessagesPerWrite, newChannelPipeline, newId, parent, pipeline, remoteAddress, toString, unsafe, validateFileRegion, voidPromiseMethods inherited from class DefaultAttributeMap
attr, hasAttrMethods inherited from interface AttributeMap
attr, hasAttrMethods inherited from interface Channel
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, config, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, getOption, id, isActive, isOpen, isRegistered, isWritable, localAddress, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, setOption, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushMethods inherited from interface Comparable
compareTo
-
Field Details
-
METADATA
-
acceptedAddressMemory
-
acceptId
private long acceptId
-
-
Constructor Details
-
AbstractIoUringServerChannel
-
-
Method Details
-
isStreamSocket
protected final boolean isStreamSocket()- Specified by:
isStreamSocketin classAbstractIoUringChannel
-
metadata
Description copied from interface:Channel -
doClose
Description copied from class:AbstractChannelClose theChannel- Overrides:
doClosein classAbstractIoUringChannel- Throws:
Exception
-
newUnsafe
Description copied from class:AbstractChannelCreate a newAbstractChannel.AbstractUnsafeinstance which will be used for the life-time of theChannel- Specified by:
newUnsafein classAbstractChannel
-
doWrite
Description copied from class:AbstractChannelFlush the content of the given buffer to the remote peer.- Overrides:
doWritein classAbstractIoUringChannel
-
cancelOutstandingReads
Description copied from class:AbstractIoUringChannelCancel all outstanding reads- Specified by:
cancelOutstandingReadsin classAbstractIoUringChannel- Parameters:
registration- theIoRegistration.numOutstandingReads- the number of outstanding reads, or-1if multi-shot was used.
-
cancelOutstandingWrites
Description copied from class:AbstractIoUringChannelCancel all outstanding writes- Specified by:
cancelOutstandingWritesin classAbstractIoUringChannel- Parameters:
registration- theIoRegistration.numOutstandingWrites- the number of outstanding writes.
-
newChildChannel
- Throws:
Exception
-
socketIsEmpty
protected boolean socketIsEmpty(int flags) Description copied from class:AbstractIoUringChannelReturn if the socket is guaranteed to be empty when the submitted io was executed and the completion event be created.- Specified by:
socketIsEmptyin classAbstractIoUringChannel- Parameters:
flags- the flags that were part of the completion- Returns:
trueif empty.
-
isPollInFirst
boolean isPollInFirst()- Specified by:
isPollInFirstin classAbstractIoUringChannel
-