Package one.nio.net

Class NativeSocket

java.lang.Object

one.nio.net.Socket

one.nio.net.NativeSocket

All Implemented Interfaces:

Closeable, AutoCloseable, ByteChannel, Channel, ReadableByteChannel, WritableByteChannel

Direct Known Subclasses:

NativeSslSocket

class NativeSocket
extends Socket

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	ARRAY_FIELD
(package private) int	fd
private static final int	INET_FAMILY
private static final long	OFFSET_FIELD

Fields inherited from class one.nio.net.Socket

AF_INET, AF_INET6, AF_UNIX, IPTOS_LOWDELAY, IPTOS_MINCOST, IPTOS_RELIABILITY, IPTOS_THROUGHPUT, MSG_DONTROUTE, MSG_DONTWAIT, MSG_MORE, MSG_OOB, MSG_PEEK, MSG_TRUNC, MSG_WAITALL, NO_PORT, SO_BROADCAST, SO_BSDCOMPAT, SO_DEBUG, SO_DONTROUTE, SO_ERROR, SO_KEEPALIVE, SO_LINGER, SO_NO_CHECK, SO_OOBINLINE, SO_PASSCRED, SO_PEERCRED, SO_PRIORITY, SO_RCVBUF, SO_RCVLOWAT, SO_RCVTIMEO, SO_REUSEADDR, SO_REUSEPORT, SO_SNDBUF, SO_SNDLOWAT, SO_SNDTIMEO, SO_TYPE, SOCK_DGRAM, SOCK_RAW, SOCK_RDM, SOCK_SEQPACKET, SOCK_STREAM, SOL_IP, SOL_IPV6, SOL_SOCKET, SOL_TCP, SOL_UDP, TCP_CONGESTION, TCP_CORK, TCP_DEFER_ACCEPT, TCP_INFO, TCP_KEEPCNT, TCP_KEEPIDLE, TCP_KEEPINTVL, TCP_LINGER2, TCP_MAXSEG, TCP_NODELAY, TCP_QUICKACK, TCP_SYNCNT, TCP_USER_TIMEOUT, TCP_WINDOW_CLAMP

Constructor Summary

Constructors

Constructor	Description
NativeSocket(int fd)
NativeSocket(int domain, int type)

Method Summary

Modifier and Type	Method	Description
NativeSocket	accept()
(package private) final int	accept0(boolean nonblock)
NativeSocket	acceptNonBlocking()
void	bind(String host, int port, int backlog)
void	bind(InetAddress address, int port, int backlog)
(package private) final void	bind0(Object address, int port)
void	close()
void	connect(String host, int port)
void	connect(InetAddress address, int port)
(package private) final void	connect0(Object address, int port)
private byte[]	getArray(ByteBuffer src)
final boolean	getDeferAccept()
final boolean	getKeepAlive()
final InetSocketAddress	getLocalAddress()
final boolean	getNoDelay()
final int	getNotsentLowat()
private int	getOffset(ByteBuffer src)
byte[]	getOption(int level, int option)
final int	getRecvBuffer()
final InetSocketAddress	getRemoteAddress()
final boolean	getReuseAddr()
final boolean	getReusePort()
final int	getSendBuffer()
SslContext	getSslContext()
<T> T	getSslOption(SslOption<T> option)
final boolean	getTcpFastOpen()
final boolean	getThinLinearTimeouts()
final int	getTimeout()
final int	getTos()
private static int	initNatives(boolean preferIPv4)
final boolean	isBlocking()
final boolean	isOpen()
void	listen(int backlog)
int	read(byte[] data, int offset, int count, int flags)
int	read(ByteBuffer dst)
void	readFully(byte[] data, int offset, int count)
int	readRaw(long buf, int count, int flags)
InetSocketAddress	recv(ByteBuffer dst, int flags)
(package private) final int	recvFrom0(byte[] data, int offset, int maxSize, int flags, AddressHolder holder)
(package private) final int	recvFrom1(long buf, int maxSize, int flags, AddressHolder holder)
int	recvMsg(Msg msg, int flags)
(package private) final int	recvMsg0(byte[] data, Msg msg, int flags)
int	send(ByteBuffer data, int flags, String host, int port)
int	send(ByteBuffer src, int flags, InetAddress address, int port)
long	sendFile(RandomAccessFile file, long offset, long count)
(package private) long	sendFile0(int sourceFD, long offset, long count)
int	sendMsg(Msg msg, int flags)
(package private) final int	sendMsg0(byte[] data, int cmsgType, int[] cmsgData, int flags)
private int	sendTo(ByteBuffer src, int flags, Object address, int port)
(package private) final int	sendTo0(byte[] data, int offset, int size, int flags, Object address, int port)
(package private) final int	sendTo1(long buf, int size, int flags, Object address, int port)
final void	setBlocking(boolean blocking)
final void	setDeferAccept(boolean deferAccept)
final void	setKeepAlive(boolean keepAlive)
final void	setNoDelay(boolean noDelay)
final void	setNotsentLowat(int lowat)
boolean	setOption(int level, int option, byte[] value)
final void	setRecvBuffer(int recvBuf)
final void	setReuseAddr(boolean reuseAddr, boolean reusePort)
final void	setSendBuffer(int sendBuf)
final void	setTcpFastOpen(boolean tcpFastOpen)
final void	setThinLinearTimeouts(boolean thinLto)
final void	setTimeout(int timeout)
final void	setTos(int tos)
private static int	socket0(int domain, int type)
Socket	sslUnwrap()
Socket	sslWrap(SslContext context)
(package private) static Object	toNativeAddr(String host, int port)
int	write(byte[] data, int offset, int count, int flags)
int	write(ByteBuffer src)
void	writeFully(byte[] data, int offset, int count)
int	writeRaw(long buf, int count, int flags)

Methods inherited from class one.nio.net.Socket

bindInet, bindUnix, connectInet, connectUnix, create, createClientSocket, createClientSocket, createDatagramSocket, createServerSocket, createUnixSocket, fromFD, handshake, read, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

INET_FAMILY

private static final int INET_FAMILY

ARRAY_FIELD

private static final long ARRAY_FIELD

OFFSET_FIELD

private static final long OFFSET_FIELD

fd

int fd

Constructor Details

NativeSocket

NativeSocket(int domain,
 int type)
      throws IOException

Throws:

IOException

NativeSocket

NativeSocket(int fd)

Method Details

isOpen

public final boolean isOpen()

Specified by:

isOpen in interface Channel

Specified by:

isOpen in class Socket

accept

public NativeSocket accept()
                    throws IOException

Specified by:

accept in class Socket

Throws:

IOException

acceptNonBlocking

public NativeSocket acceptNonBlocking()
                               throws IOException

Overrides:

acceptNonBlocking in class Socket

Throws:

IOException

getLocalAddress

public final InetSocketAddress getLocalAddress()

Specified by:

getLocalAddress in class Socket

getRemoteAddress

public final InetSocketAddress getRemoteAddress()

Specified by:

getRemoteAddress in class Socket

sslWrap

public Socket sslWrap(SslContext context)
               throws IOException

Specified by:

sslWrap in class Socket

Throws:

IOException

sslUnwrap

public Socket sslUnwrap()

Specified by:

sslUnwrap in class Socket

getSslContext

public SslContext getSslContext()

Specified by:

getSslContext in class Socket

getSslOption

public <T> T getSslOption(SslOption<T> option)

Specified by:

getSslOption in class Socket

connect

public void connect(InetAddress address,
 int port)
             throws IOException

Specified by:

connect in class Socket

Throws:

IOException

connect

public void connect(String host,
 int port)
             throws IOException

Overrides:

connect in class Socket

Throws:

IOException

bind

public void bind(InetAddress address,
 int port,
 int backlog)
          throws IOException

Specified by:

bind in class Socket

Throws:

IOException

bind

public void bind(String host,
 int port,
 int backlog)
          throws IOException

Overrides:

bind in class Socket

Throws:

IOException

listen

public void listen(int backlog)
            throws IOException

Specified by:

listen in class Socket

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Specified by:

close in class Socket

writeRaw

public int writeRaw(long buf,
 int count,
 int flags)
             throws IOException

Specified by:

writeRaw in class Socket

Throws:

IOException

send

public int send(ByteBuffer src,
 int flags,
 InetAddress address,
 int port)
         throws IOException

Specified by:

send in class Socket

Throws:

IOException

send

public int send(ByteBuffer data,
 int flags,
 String host,
 int port)
         throws IOException

Overrides:

send in class Socket

Throws:

IOException

sendTo

private int sendTo(ByteBuffer src,
 int flags,
 Object address,
 int port)
            throws IOException

Throws:

IOException

getArray

private byte[] getArray(ByteBuffer src)
                 throws IllegalAccessException

Throws:

IllegalAccessException

getOffset

private int getOffset(ByteBuffer src)
               throws IllegalAccessException

Throws:

IllegalAccessException

write

public int write(byte[] data,
 int offset,
 int count,
 int flags)
          throws IOException

Specified by:

write in class Socket

Throws:

IOException

writeFully

public void writeFully(byte[] data,
 int offset,
 int count)
                throws IOException

Specified by:

writeFully in class Socket

Throws:

IOException

readRaw

public int readRaw(long buf,
 int count,
 int flags)
            throws IOException

Specified by:

readRaw in class Socket

Throws:

IOException

read

public int read(byte[] data,
 int offset,
 int count,
 int flags)
         throws IOException

Specified by:

read in class Socket

Throws:

IOException

recv

public InetSocketAddress recv(ByteBuffer dst,
 int flags)
                       throws IOException

Specified by:

recv in class Socket

Throws:

IOException

readFully

public void readFully(byte[] data,
 int offset,
 int count)
               throws IOException

Specified by:

readFully in class Socket

Throws:

IOException

sendFile

public long sendFile(RandomAccessFile file,
 long offset,
 long count)
              throws IOException

Specified by:

sendFile in class Socket

Throws:

IOException

read

public int read(ByteBuffer dst)
         throws IOException

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Throws:

IOException

sendMsg

public int sendMsg(Msg msg,
 int flags)
            throws IOException

Specified by:

sendMsg in class Socket

Throws:

IOException

recvMsg

public int recvMsg(Msg msg,
 int flags)
            throws IOException

Specified by:

recvMsg in class Socket

Throws:

IOException

setBlocking

public final void setBlocking(boolean blocking)

Specified by:

setBlocking in class Socket

isBlocking

public final boolean isBlocking()

Specified by:

isBlocking in class Socket

setTimeout

public final void setTimeout(int timeout)

Specified by:

setTimeout in class Socket

getTimeout

public final int getTimeout()

Specified by:

getTimeout in class Socket

setKeepAlive

public final void setKeepAlive(boolean keepAlive)

Specified by:

setKeepAlive in class Socket

getKeepAlive

public final boolean getKeepAlive()

Specified by:

getKeepAlive in class Socket

setNoDelay

public final void setNoDelay(boolean noDelay)

Specified by:

setNoDelay in class Socket

getNoDelay

public final boolean getNoDelay()

Specified by:

getNoDelay in class Socket

setTcpFastOpen

public final void setTcpFastOpen(boolean tcpFastOpen)

Specified by:

setTcpFastOpen in class Socket

getTcpFastOpen

public final boolean getTcpFastOpen()

Specified by:

getTcpFastOpen in class Socket

setDeferAccept

public final void setDeferAccept(boolean deferAccept)

Specified by:

setDeferAccept in class Socket

getDeferAccept

public final boolean getDeferAccept()

Specified by:

getDeferAccept in class Socket

setReuseAddr

public final void setReuseAddr(boolean reuseAddr,
 boolean reusePort)

Specified by:

setReuseAddr in class Socket

getReuseAddr

public final boolean getReuseAddr()

Specified by:

getReuseAddr in class Socket

getReusePort

public final boolean getReusePort()

Specified by:

getReusePort in class Socket

setRecvBuffer

public final void setRecvBuffer(int recvBuf)

Specified by:

setRecvBuffer in class Socket

getRecvBuffer

public final int getRecvBuffer()

Specified by:

getRecvBuffer in class Socket

setSendBuffer

public final void setSendBuffer(int sendBuf)

Specified by:

setSendBuffer in class Socket

getSendBuffer

public final int getSendBuffer()

Specified by:

getSendBuffer in class Socket

setTos

public final void setTos(int tos)

Specified by:

setTos in class Socket

getTos

public final int getTos()

Specified by:

getTos in class Socket

setNotsentLowat

public final void setNotsentLowat(int lowat)

Overrides:

setNotsentLowat in class Socket

getNotsentLowat

public final int getNotsentLowat()

Overrides:

getNotsentLowat in class Socket

setThinLinearTimeouts

public final void setThinLinearTimeouts(boolean thinLto)

Overrides:

setThinLinearTimeouts in class Socket

getThinLinearTimeouts

public final boolean getThinLinearTimeouts()

Overrides:

getThinLinearTimeouts in class Socket

getOption

public byte[] getOption(int level,
 int option)

Specified by:

getOption in class Socket

setOption

public boolean setOption(int level,
 int option,
 byte[] value)

Specified by:

setOption in class Socket

toNativeAddr

static Object toNativeAddr(String host,
 int port)
                    throws UnknownHostException

Throws:

UnknownHostException

initNatives

private static int initNatives(boolean preferIPv4)

socket0

private static int socket0(int domain,
 int type)
                    throws IOException

Throws:

IOException

connect0

final void connect0(Object address,
 int port)
             throws IOException

Throws:

IOException

bind0

final void bind0(Object address,
 int port)
          throws IOException

Throws:

IOException

accept0

final int accept0(boolean nonblock)
           throws IOException

Throws:

IOException

sendFile0

long sendFile0(int sourceFD,
 long offset,
 long count)
        throws IOException

Throws:

IOException

sendTo0

final int sendTo0(byte[] data,
 int offset,
 int size,
 int flags,
 Object address,
 int port)
           throws IOException

Throws:

IOException

sendTo1

final int sendTo1(long buf,
 int size,
 int flags,
 Object address,
 int port)
           throws IOException

Throws:

IOException

recvFrom0

final int recvFrom0(byte[] data,
 int offset,
 int maxSize,
 int flags,
 AddressHolder holder)
             throws IOException

Throws:

IOException

recvFrom1

final int recvFrom1(long buf,
 int maxSize,
 int flags,
 AddressHolder holder)
             throws IOException

Throws:

IOException

sendMsg0

final int sendMsg0(byte[] data,
 int cmsgType,
 int[] cmsgData,
 int flags)
            throws IOException

Throws:

IOException

recvMsg0

final int recvMsg0(byte[] data,
 Msg msg,
 int flags)
            throws IOException

Throws:

IOException