Package io.netty.channel.uring
Class IoUringServerDomainSocketChannel
- java.lang.Object
-
- io.netty.util.DefaultAttributeMap
-
- io.netty.channel.AbstractChannel
-
- io.netty.channel.uring.IoUringServerDomainSocketChannel
-
- All Implemented Interfaces:
Channel,ChannelOutboundInvoker,ServerChannel,ServerDomainSocketChannel,UnixChannel,AttributeMap,java.lang.Comparable<Channel>
public final class IoUringServerDomainSocketChannel extends AbstractChannel implements ServerDomainSocketChannel
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class io.netty.channel.AbstractChannel
AbstractChannel.AbstractUnsafe
-
Nested classes/interfaces inherited from interface io.netty.channel.Channel
Channel.Unsafe
-
-
Field Summary
Fields Modifier and Type Field Description protected booleanactive
-
Constructor Summary
Constructors Constructor Description IoUringServerDomainSocketChannel()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected booleanallowMultiShotPollIn()protected voidcancelOutstandingReads(IoRegistration registration, int numOutstandingReads)Cancel all outstanding readsprotected voidcancelOutstandingWrites(IoRegistration registration, int numOutstandingWrites)Cancel all outstanding writesprotected static voidcheckResolvable(java.net.InetSocketAddress addr)ChannelConfigconfig()Returns the configuration of this channel.protected voiddoBeginRead()Schedule a read operation.protected voiddoBind(java.net.SocketAddress localAddress)Bind theChannelto theSocketAddressprotected voiddoClose()Close theChannelprotected voiddoDeregister()protected voiddoDisconnect()Disconnect thisChannelfrom its remote peerprotected voiddoRegister(ChannelPromise promise)protected voiddoWrite(ChannelOutboundBuffer in)Flush the content of the given buffer to the remote peer.FileDescriptorfd()Returns theFileDescriptorthat is used by thisChannel.protected java.lang.ObjectfilterOutboundMessage(java.lang.Object msg)Invoked when a new message is added to aChannelOutboundBufferof thisAbstractChannel, so that theChannelimplementation converts the message to another.booleanisActive()Returntrueif theChannelis active and so connected.protected booleanisCompatible(EventLoop loop)Returntrueif the givenEventLoopis compatible with this instance.booleanisOpen()Returnstrueif theChannelis open and may get active laterDomainSocketAddresslocalAddress()Returns the local address where this channel is bound to.protected java.net.SocketAddresslocalAddress0()Returns theSocketAddresswhich is bound locally.ChannelMetadatametadata()protected ByteBufnewDirectBuffer(ByteBuf buf)protected ByteBufnewDirectBuffer(java.lang.Object holder, ByteBuf buf)protected io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafenewUnsafe()Create a newAbstractChannel.AbstractUnsafeinstance which will be used for the life-time of theChannelprotected shortnextOpsId()Returns the next id that should be used when submittingIoUringIoOps.protected IoRegistrationregistration()DomainSocketAddressremoteAddress()Returns the remote address where this channel is connected to.protected java.net.SocketAddressremoteAddress0()Return theSocketAddresswhich theChannelis connected to.protected voidscheduleWriteIfNeeded(ChannelOutboundBuffer in, boolean submitAndRunNow)protected booleansocketIsEmpty(int flags)Return if the socket is guaranteed to be empty when the submitted io was executed and the completion event be created.protected voidsubmitAndRunNow()-
Methods inherited from class io.netty.channel.AbstractChannel
closeFuture, compareTo, doRegister, doShutdownOutput, equals, eventLoop, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, maxMessagesPerWrite, newChannelPipeline, newId, parent, pipeline, toString, unsafe, validateFileRegion, voidPromise
-
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, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, getOption, id, isActive, isOpen, isRegistered, isWritable, metadata, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, setOption, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
-
Methods inherited from interface io.netty.channel.unix.UnixChannel
fd
-
-
-
-
Method Detail
-
config
public ChannelConfig config()
Description copied from interface:ChannelReturns the configuration of this channel.
-
localAddress
public DomainSocketAddress localAddress()
Description copied from interface:ChannelReturns the local address where this channel is bound to. The returnedSocketAddressis supposed to be down-cast into more concrete type such asInetSocketAddressto retrieve the detailed information.- Specified by:
localAddressin interfaceChannel- Specified by:
localAddressin interfaceServerDomainSocketChannel- Overrides:
localAddressin classAbstractChannel- Returns:
- the local address of this channel.
nullif this channel is not bound.
-
remoteAddress
public DomainSocketAddress remoteAddress()
Description copied from interface:ChannelReturns the remote address where this channel is connected to. The returnedSocketAddressis supposed to be down-cast into more concrete type such asInetSocketAddressto retrieve the detailed information.- Specified by:
remoteAddressin interfaceChannel- Specified by:
remoteAddressin interfaceServerDomainSocketChannel- Overrides:
remoteAddressin classAbstractChannel- Returns:
- the remote address of this channel.
nullif this channel is not connected. If this channel is not connected but it can receive messages from arbitrary remote addresses (e.g.DatagramChannel, useDefaultAddressedEnvelope.recipient()to determine the origination of the received message as this method will returnnull.
-
doBind
protected void doBind(java.net.SocketAddress localAddress) throws java.lang.ExceptionDescription copied from class:AbstractChannelBind theChannelto theSocketAddress- Throws:
java.lang.Exception
-
metadata
public final ChannelMetadata metadata()
Description copied from interface:Channel
-
doClose
protected final void doClose() throws java.lang.ExceptionDescription copied from class:AbstractChannelClose theChannel- Throws:
java.lang.Exception
-
newUnsafe
protected final io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe newUnsafe()
Description copied from class:AbstractChannelCreate a newAbstractChannel.AbstractUnsafeinstance which will be used for the life-time of theChannel- Specified by:
newUnsafein classAbstractChannel
-
doWrite
protected final void doWrite(ChannelOutboundBuffer in)
Description copied from class:AbstractChannelFlush the content of the given buffer to the remote peer.
-
cancelOutstandingReads
protected final void cancelOutstandingReads(IoRegistration registration, int numOutstandingReads)
Cancel all outstanding reads- Parameters:
registration- theIoRegistration.numOutstandingReads- the number of outstanding reads, or-1if multi-shot was used.
-
cancelOutstandingWrites
protected final void cancelOutstandingWrites(IoRegistration registration, int numOutstandingWrites)
Cancel all outstanding writes- Parameters:
registration- theIoRegistration.numOutstandingWrites- the number of outstanding writes.
-
socketIsEmpty
protected boolean socketIsEmpty(int flags)
Return if the socket is guaranteed to be empty when the submitted io was executed and the completion event be created.- Parameters:
flags- the flags that were part of the completion- Returns:
trueif empty.
-
nextOpsId
protected final short nextOpsId()
Returns the next id that should be used when submittingIoUringIoOps.- Returns:
- opsId
-
isOpen
public final boolean isOpen()
Description copied from interface:ChannelReturnstrueif theChannelis open and may get active later
-
isActive
public boolean isActive()
Description copied from interface:ChannelReturntrueif theChannelis active and so connected.
-
fd
public final FileDescriptor fd()
Description copied from interface:UnixChannelReturns theFileDescriptorthat is used by thisChannel.- Specified by:
fdin interfaceUnixChannel
-
isCompatible
protected boolean isCompatible(EventLoop loop)
Description copied from class:AbstractChannelReturntrueif the givenEventLoopis compatible with this instance.- Specified by:
isCompatiblein classAbstractChannel
-
allowMultiShotPollIn
protected boolean allowMultiShotPollIn()
-
doDisconnect
protected void doDisconnect() throws java.lang.ExceptionDescription copied from class:AbstractChannelDisconnect thisChannelfrom its remote peer- Specified by:
doDisconnectin classAbstractChannel- Throws:
java.lang.Exception
-
doBeginRead
protected final void doBeginRead()
Description copied from class:AbstractChannelSchedule a read operation.- Specified by:
doBeginReadin classAbstractChannel
-
scheduleWriteIfNeeded
protected void scheduleWriteIfNeeded(ChannelOutboundBuffer in, boolean submitAndRunNow)
-
submitAndRunNow
protected void submitAndRunNow()
-
registration
protected final IoRegistration registration()
-
filterOutboundMessage
protected java.lang.Object filterOutboundMessage(java.lang.Object msg)
Description copied from class:AbstractChannelInvoked when a new message is added to aChannelOutboundBufferof thisAbstractChannel, so that theChannelimplementation converts the message to another. (e.g. heap buffer -> direct buffer)- Overrides:
filterOutboundMessagein classAbstractChannel
-
doRegister
protected void doRegister(ChannelPromise promise)
Description copied from class:AbstractChannelIs called after theChannelis registered with itsEventLoopas part of the register process. Subclasses may override this method- Overrides:
doRegisterin classAbstractChannel- Parameters:
promise-ChannelPromisethat must be notified once done to continue the registration.
-
doDeregister
protected final void doDeregister()
Description copied from class:AbstractChannel- Overrides:
doDeregisterin classAbstractChannel
-
checkResolvable
protected static void checkResolvable(java.net.InetSocketAddress addr)
-
localAddress0
protected final java.net.SocketAddress localAddress0()
Description copied from class:AbstractChannelReturns theSocketAddresswhich is bound locally.- Specified by:
localAddress0in classAbstractChannel
-
remoteAddress0
protected final java.net.SocketAddress remoteAddress0()
Description copied from class:AbstractChannelReturn theSocketAddresswhich theChannelis connected to.- Specified by:
remoteAddress0in classAbstractChannel
-
-