Package io.netty.incubator.channel.uring

Class LinuxSocket

java.lang.Object

io.netty.channel.unix.FileDescriptor

io.netty.channel.unix.Socket

io.netty.incubator.channel.uring.LinuxSocket

final class LinuxSocket
extends io.netty.channel.unix.Socket

A socket which provides access Linux native methods.

Field Summary

Fields

Modifier and Type	Field	Description
private static final InetAddress	INET_ANY
(package private) static final InetAddress	INET6_ANY
private static final long	MAX_UINT32_T

Fields inherited from class io.netty.channel.unix.Socket

ipv6, UDS_SUN_PATH_SIZE

Constructor Summary

Constructors

Constructor	Description
LinuxSocket(int fd)

Method Summary

Modifier and Type	Method	Description
private static InetAddress	deriveInetAddress(NetworkInterface netInterface, boolean ipv6)
(package private) io.netty.channel.socket.InternetProtocolFamily	family()
(package private) InetAddress	getInterface()
private static int	getInterface(int fd, boolean ipv6)
private static int	getIpMulticastLoop(int fd, boolean ipv6)
(package private) NetworkInterface	getNetworkInterface()
(package private) io.netty.channel.unix.PeerCredentials	getPeerCredentials()
private static io.netty.channel.unix.PeerCredentials	getPeerCredentials(int fd)
(package private) int	getSoBusyPoll()
private static int	getSoBusyPoll(int fd)
(package private) int	getTcpDeferAccept()
private static int	getTcpDeferAccept(int fd)
private static void	getTcpInfo(int fd, long[] array)
(package private) void	getTcpInfo(IOUringTcpInfo info)
(package private) int	getTcpKeepCnt()
private static int	getTcpKeepCnt(int fd)
(package private) int	getTcpKeepIdle()
private static int	getTcpKeepIdle(int fd)
(package private) int	getTcpKeepIntvl()
private static int	getTcpKeepIntvl(int fd)
(package private) long	getTcpNotSentLowAt()
private static int	getTcpNotSentLowAt(int fd)
(package private) int	getTcpUserTimeout()
private static int	getTcpUserTimeout(int fd)
(package private) int	getTimeToLive()
private static int	getTimeToLive(int fd)
private static InetAddress	inetAddress(int value)
private static int	interfaceIndex(InetAddress address)
private static int	interfaceIndex(NetworkInterface networkInterface)
(package private) boolean	isIpFreeBind()
private static int	isIpFreeBind(int fd)
(package private) boolean	isIpRecvOrigDestAddr()
private static int	isIpRecvOrigDestAddr(int fd)
(package private) boolean	isIpTransparent()
private static int	isIpTransparent(int fd)
(package private) boolean	isIpv6()
(package private) boolean	isLoopbackModeDisabled()
(package private) boolean	isTcpCork()
private static int	isTcpCork(int fd)
(package private) boolean	isTcpFastOpenConnect()
private static int	isTcpFastOpenConnect(int fd)
(package private) boolean	isTcpQuickAck()
private static int	isTcpQuickAck(int fd)
private static void	joinGroup(int fd, boolean ipv6, byte[] group, byte[] interfaceAddress, int scopeId, int interfaceIndex)
(package private) void	joinGroup(InetAddress group, NetworkInterface netInterface, InetAddress source)
private static void	joinSsmGroup(int fd, boolean ipv6, byte[] group, byte[] interfaceAddress, int scopeId, int interfaceIndex, byte[] source)
private static void	leaveGroup(int fd, boolean ipv6, byte[] group, byte[] interfaceAddress, int scopeId, int interfaceIndex)
(package private) void	leaveGroup(InetAddress group, NetworkInterface netInterface, InetAddress source)
private static void	leaveSsmGroup(int fd, boolean ipv6, byte[] group, byte[] interfaceAddress, int scopeId, int interfaceIndex, byte[] source)
boolean	markClosed()
static LinuxSocket	newSocketDgram()
static LinuxSocket	newSocketDgram(boolean ipv6)
static LinuxSocket	newSocketDomain()
static LinuxSocket	newSocketStream()
static LinuxSocket	newSocketStream(boolean ipv6)
private static void	setInterface(int fd, boolean ipv6, byte[] interfaceAddress, int scopeId, int networkInterfaceIndex)
(package private) void	setInterface(InetAddress address)
(package private) void	setIpFreeBind(boolean enabled)
private static void	setIpFreeBind(int fd, int freeBind)
private static void	setIpMulticastLoop(int fd, boolean ipv6, int enabled)
(package private) void	setIpRecvOrigDestAddr(boolean enabled)
private static void	setIpRecvOrigDestAddr(int fd, int transparent)
(package private) void	setIpTransparent(boolean enabled)
private static void	setIpTransparent(int fd, int transparent)
(package private) void	setLoopbackModeDisabled(boolean loopbackModeDisabled)
(package private) void	setNetworkInterface(NetworkInterface netInterface)
(package private) void	setSoBusyPoll(int loopMicros)
private static void	setSoBusyPoll(int fd, int loopMicros)
(package private) void	setTcpCork(boolean tcpCork)
private static void	setTcpCork(int fd, int tcpCork)
(package private) void	setTcpDeferAccept(int deferAccept)
private static void	setTcpDeferAccept(int fd, int deferAccept)
(package private) void	setTcpFastOpen(int tcpFastopenBacklog)
private static void	setTcpFastOpen(int fd, int tcpFastopenBacklog)
(package private) void	setTcpFastOpenConnect(boolean tcpFastOpenConnect)
private static void	setTcpFastOpenConnect(int fd, int tcpFastOpenConnect)
(package private) void	setTcpKeepCnt(int probes)
private static void	setTcpKeepCnt(int fd, int probes)
(package private) void	setTcpKeepIdle(int seconds)
private static void	setTcpKeepIdle(int fd, int seconds)
(package private) void	setTcpKeepIntvl(int seconds)
private static void	setTcpKeepIntvl(int fd, int seconds)
private static void	setTcpMd5Sig(int fd, boolean ipv6, byte[] address, int scopeId, byte[] key)
(package private) void	setTcpMd5Sig(InetAddress address, byte[] key)
private static void	setTcpNotSentLowAt(int fd, int tcpNotSentLowAt)
(package private) void	setTcpNotSentLowAt(long tcpNotSentLowAt)
(package private) void	setTcpQuickAck(boolean quickAck)
private static void	setTcpQuickAck(int fd, int quickAck)
(package private) void	setTcpUserTimeout(int milliseconds)
private static void	setTcpUserTimeout(int fd, int milliseconds)
(package private) void	setTimeToLive(int ttl)
private static void	setTimeToLive(int fd, int ttl)
private static InetAddress	unsafeInetAddrByName(String inetName)

Methods inherited from class io.netty.channel.unix.Socket

accept, bind, connect, disconnect, finishConnect, getIntOpt, getRawOpt, getReceiveBufferSize, getSendBufferSize, getSoError, getSoLinger, getTrafficClass, initialize, isBroadcast, isInputShutdown, isIPv6Preferred, isKeepAlive, isOutputShutdown, isReuseAddress, isReusePort, isShutdown, isTcpNoDelay, listen, localAddress, localDomainSocketAddress, newSocketDgram0, newSocketDgram0, newSocketDgram0, newSocketDomain0, newSocketDomainDgram, newSocketDomainDgram0, newSocketStream0, newSocketStream0, newSocketStream0, recv, recvAddress, recvFd, recvFrom, recvFromAddress, recvFromAddressDomainSocket, recvFromDomainSocket, remoteAddress, remoteDomainSocketAddress, send, sendAddress, sendFd, sendTo, sendTo, sendToAddress, sendToAddress, sendToAddressDomainSocket, sendToAddresses, sendToAddresses, sendToAddressesDomainSocket, sendToDomainSocket, setBroadcast, setIntOpt, setKeepAlive, setRawOpt, setReceiveBufferSize, setReuseAddress, setReusePort, setSendBufferSize, setSoLinger, setTcpNoDelay, setTrafficClass, shouldUseIpv6, shutdown, shutdown, toString, useIpv6

Methods inherited from class io.netty.channel.unix.FileDescriptor

close, equals, from, from, hashCode, intValue, isOpen, pipe, read, readAddress, write, writeAddress, writev, writevAddresses

Methods inherited from class java.lang.Object

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

Field Details

INET6_ANY

static final InetAddress INET6_ANY

INET_ANY

private static final InetAddress INET_ANY

MAX_UINT32_T

private static final long MAX_UINT32_T

See Also:

• Constant Field Values

Constructor Details

LinuxSocket

LinuxSocket(int fd)

Method Details

family

io.netty.channel.socket.InternetProtocolFamily family()

markClosed

public boolean markClosed()

Overrides:

markClosed in class io.netty.channel.unix.FileDescriptor

setTimeToLive

void setTimeToLive(int ttl)
            throws IOException

Throws:

IOException

setInterface

void setInterface(InetAddress address)
           throws IOException

Throws:

IOException

setNetworkInterface

void setNetworkInterface(NetworkInterface netInterface)
                  throws IOException

Throws:

IOException

getInterface

InetAddress getInterface()
                  throws IOException

Throws:

IOException

getNetworkInterface

NetworkInterface getNetworkInterface()
                              throws IOException

Throws:

IOException

inetAddress

private static InetAddress inetAddress(int value)

joinGroup

void joinGroup(InetAddress group,
 NetworkInterface netInterface,
 InetAddress source)
        throws IOException

Throws:

IOException

leaveGroup

void leaveGroup(InetAddress group,
 NetworkInterface netInterface,
 InetAddress source)
         throws IOException

Throws:

IOException

interfaceIndex

private static int interfaceIndex(NetworkInterface networkInterface)

interfaceIndex

private static int interfaceIndex(InetAddress address)
                           throws IOException

Throws:

IOException

setTcpDeferAccept

void setTcpDeferAccept(int deferAccept)
                throws IOException

Throws:

IOException

setTcpQuickAck

void setTcpQuickAck(boolean quickAck)
             throws IOException

Throws:

IOException

setTcpCork

void setTcpCork(boolean tcpCork)
         throws IOException

Throws:

IOException

setSoBusyPoll

void setSoBusyPoll(int loopMicros)
            throws IOException

Throws:

IOException

setTcpNotSentLowAt

void setTcpNotSentLowAt(long tcpNotSentLowAt)
                 throws IOException

Throws:

IOException

setTcpFastOpen

void setTcpFastOpen(int tcpFastopenBacklog)
             throws IOException

Throws:

IOException

setTcpFastOpenConnect

void setTcpFastOpenConnect(boolean tcpFastOpenConnect)
                    throws IOException

Throws:

IOException

isTcpFastOpenConnect

boolean isTcpFastOpenConnect()
                      throws IOException

Throws:

IOException

setTcpKeepIdle

void setTcpKeepIdle(int seconds)
             throws IOException

Throws:

IOException

setTcpKeepIntvl

void setTcpKeepIntvl(int seconds)
              throws IOException

Throws:

IOException

setTcpKeepCnt

void setTcpKeepCnt(int probes)
            throws IOException

Throws:

IOException

setTcpUserTimeout

void setTcpUserTimeout(int milliseconds)
                throws IOException

Throws:

IOException

setIpFreeBind

void setIpFreeBind(boolean enabled)
            throws IOException

Throws:

IOException

setIpTransparent

void setIpTransparent(boolean enabled)
               throws IOException

Throws:

IOException

setIpRecvOrigDestAddr

void setIpRecvOrigDestAddr(boolean enabled)
                    throws IOException

Throws:

IOException

getTimeToLive

int getTimeToLive()
           throws IOException

Throws:

IOException

getTcpInfo

void getTcpInfo(IOUringTcpInfo info)
         throws IOException

Throws:

IOException

setTcpMd5Sig

void setTcpMd5Sig(InetAddress address,
 byte[] key)
           throws IOException

Throws:

IOException

isTcpCork

boolean isTcpCork()
           throws IOException

Throws:

IOException

getSoBusyPoll

int getSoBusyPoll()
           throws IOException

Throws:

IOException

getTcpDeferAccept

int getTcpDeferAccept()
               throws IOException

Throws:

IOException

isTcpQuickAck

boolean isTcpQuickAck()
               throws IOException

Throws:

IOException

getTcpNotSentLowAt

long getTcpNotSentLowAt()
                 throws IOException

Throws:

IOException

getTcpKeepIdle

int getTcpKeepIdle()
            throws IOException

Throws:

IOException

getTcpKeepIntvl

int getTcpKeepIntvl()
             throws IOException

Throws:

IOException

getTcpKeepCnt

int getTcpKeepCnt()
           throws IOException

Throws:

IOException

getTcpUserTimeout

int getTcpUserTimeout()
               throws IOException

Throws:

IOException

isIpFreeBind

boolean isIpFreeBind()
              throws IOException

Throws:

IOException

isIpTransparent

boolean isIpTransparent()
                 throws IOException

Throws:

IOException

isIpRecvOrigDestAddr

boolean isIpRecvOrigDestAddr()
                      throws IOException

Throws:

IOException

getPeerCredentials

io.netty.channel.unix.PeerCredentials getPeerCredentials()
                                                  throws IOException

Throws:

IOException

isLoopbackModeDisabled

boolean isLoopbackModeDisabled()
                        throws IOException

Throws:

IOException

setLoopbackModeDisabled

void setLoopbackModeDisabled(boolean loopbackModeDisabled)
                      throws IOException

Throws:

IOException

deriveInetAddress

private static InetAddress deriveInetAddress(NetworkInterface netInterface,
 boolean ipv6)

isIpv6

boolean isIpv6()

newSocketStream

public static LinuxSocket newSocketStream(boolean ipv6)

newSocketStream

public static LinuxSocket newSocketStream()

newSocketDgram

public static LinuxSocket newSocketDgram(boolean ipv6)

newSocketDgram

public static LinuxSocket newSocketDgram()

newSocketDomain

public static LinuxSocket newSocketDomain()

unsafeInetAddrByName

private static InetAddress unsafeInetAddrByName(String inetName)

joinGroup

private static void joinGroup(int fd,
 boolean ipv6,
 byte[] group,
 byte[] interfaceAddress,
 int scopeId,
 int interfaceIndex)
                       throws IOException

Throws:

IOException

joinSsmGroup

private static void joinSsmGroup(int fd,
 boolean ipv6,
 byte[] group,
 byte[] interfaceAddress,
 int scopeId,
 int interfaceIndex,
 byte[] source)
                          throws IOException

Throws:

IOException

leaveGroup

private static void leaveGroup(int fd,
 boolean ipv6,
 byte[] group,
 byte[] interfaceAddress,
 int scopeId,
 int interfaceIndex)
                        throws IOException

Throws:

IOException

leaveSsmGroup

private static void leaveSsmGroup(int fd,
 boolean ipv6,
 byte[] group,
 byte[] interfaceAddress,
 int scopeId,
 int interfaceIndex,
 byte[] source)
                           throws IOException

Throws:

IOException

getTcpDeferAccept

private static int getTcpDeferAccept(int fd)
                              throws IOException

Throws:

IOException

isTcpQuickAck

private static int isTcpQuickAck(int fd)
                          throws IOException

Throws:

IOException

isTcpCork

private static int isTcpCork(int fd)
                      throws IOException

Throws:

IOException

getSoBusyPoll

private static int getSoBusyPoll(int fd)
                          throws IOException

Throws:

IOException

getTcpNotSentLowAt

private static int getTcpNotSentLowAt(int fd)
                               throws IOException

Throws:

IOException

getTcpKeepIdle

private static int getTcpKeepIdle(int fd)
                           throws IOException

Throws:

IOException

getTcpKeepIntvl

private static int getTcpKeepIntvl(int fd)
                            throws IOException

Throws:

IOException

getTcpKeepCnt

private static int getTcpKeepCnt(int fd)
                          throws IOException

Throws:

IOException

getTcpUserTimeout

private static int getTcpUserTimeout(int fd)
                              throws IOException

Throws:

IOException

getTimeToLive

private static int getTimeToLive(int fd)
                          throws IOException

Throws:

IOException

isIpFreeBind

private static int isIpFreeBind(int fd)
                         throws IOException

Throws:

IOException

isIpTransparent

private static int isIpTransparent(int fd)
                            throws IOException

Throws:

IOException

isIpRecvOrigDestAddr

private static int isIpRecvOrigDestAddr(int fd)
                                 throws IOException

Throws:

IOException

getTcpInfo

private static void getTcpInfo(int fd,
 long[] array)
                        throws IOException

Throws:

IOException

getPeerCredentials

private static io.netty.channel.unix.PeerCredentials getPeerCredentials(int fd)
                                                                 throws IOException

Throws:

IOException

isTcpFastOpenConnect

private static int isTcpFastOpenConnect(int fd)
                                 throws IOException

Throws:

IOException

setTcpDeferAccept

private static void setTcpDeferAccept(int fd,
 int deferAccept)
                               throws IOException

Throws:

IOException

setTcpQuickAck

private static void setTcpQuickAck(int fd,
 int quickAck)
                            throws IOException

Throws:

IOException

setTcpCork

private static void setTcpCork(int fd,
 int tcpCork)
                        throws IOException

Throws:

IOException

setSoBusyPoll

private static void setSoBusyPoll(int fd,
 int loopMicros)
                           throws IOException

Throws:

IOException

setTcpNotSentLowAt

private static void setTcpNotSentLowAt(int fd,
 int tcpNotSentLowAt)
                                throws IOException

Throws:

IOException

setTcpFastOpen

private static void setTcpFastOpen(int fd,
 int tcpFastopenBacklog)
                            throws IOException

Throws:

IOException

setTcpFastOpenConnect

private static void setTcpFastOpenConnect(int fd,
 int tcpFastOpenConnect)
                                   throws IOException

Throws:

IOException

setTcpKeepIdle

private static void setTcpKeepIdle(int fd,
 int seconds)
                            throws IOException

Throws:

IOException

setTcpKeepIntvl

private static void setTcpKeepIntvl(int fd,
 int seconds)
                             throws IOException

Throws:

IOException

setTcpKeepCnt

private static void setTcpKeepCnt(int fd,
 int probes)
                           throws IOException

Throws:

IOException

setTcpUserTimeout

private static void setTcpUserTimeout(int fd,
 int milliseconds)
                               throws IOException

Throws:

IOException

setIpFreeBind

private static void setIpFreeBind(int fd,
 int freeBind)
                           throws IOException

Throws:

IOException

setIpTransparent

private static void setIpTransparent(int fd,
 int transparent)
                              throws IOException

Throws:

IOException

setIpRecvOrigDestAddr

private static void setIpRecvOrigDestAddr(int fd,
 int transparent)
                                   throws IOException

Throws:

IOException

setTcpMd5Sig

private static void setTcpMd5Sig(int fd,
 boolean ipv6,
 byte[] address,
 int scopeId,
 byte[] key)
                          throws IOException

Throws:

IOException

setInterface

private static void setInterface(int fd,
 boolean ipv6,
 byte[] interfaceAddress,
 int scopeId,
 int networkInterfaceIndex)
                          throws IOException

Throws:

IOException

getInterface

private static int getInterface(int fd,
 boolean ipv6)

getIpMulticastLoop

private static int getIpMulticastLoop(int fd,
 boolean ipv6)
                               throws IOException

Throws:

IOException

setIpMulticastLoop

private static void setIpMulticastLoop(int fd,
 boolean ipv6,
 int enabled)
                                throws IOException

Throws:

IOException

setTimeToLive

private static void setTimeToLive(int fd,
 int ttl)
                           throws IOException

Throws:

IOException