io.netty.channel.unix

Class Socket

java.lang.Object

io.netty.channel.unix.FileDescriptor

io.netty.channel.unix.Socket

public final class Socket
extends FileDescriptor

Provides a JNI bridge to native socket operations. Internal usage only!

Field Summary

Fields

Modifier and Type	Field and Description
private static Errors.NativeConnectException	CONNECT_REFUSED_EXCEPTION
private static Errors.NativeIoException	CONNECTION_RESET_EXCEPTION_SENDMSG
private static Errors.NativeIoException	CONNECTION_RESET_SHUTDOWN_EXCEPTION
private static Errors.NativeConnectException	FINISH_CONNECT_REFUSED_EXCEPTION
private static java.nio.channels.ClosedChannelException	SEND_TO_ADDRESS_CLOSED_CHANNEL_EXCEPTION
private static Errors.NativeIoException	SEND_TO_ADDRESS_CONNECTION_RESET_EXCEPTION
private static java.nio.channels.ClosedChannelException	SEND_TO_ADDRESSES_CLOSED_CHANNEL_EXCEPTION
private static java.nio.channels.ClosedChannelException	SEND_TO_CLOSED_CHANNEL_EXCEPTION
private static Errors.NativeIoException	SEND_TO_CONNECTION_RESET_EXCEPTION
private static java.nio.channels.ClosedChannelException	SHUTDOWN_CLOSED_CHANNEL_EXCEPTION

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

fd, state

Constructor Summary

Constructors

Constructor and Description
Socket(int fd)

Method Summary

Modifier and Type	Method and Description
int	accept(byte[] addr)
private static int	accept(int fd, byte[] addr)
private static int	bind(int fd, byte[] address, int scopeId, int port)
void	bind(java.net.SocketAddress socketAddress)
private static int	bindDomainSocket(int fd, byte[] path)
private static int	connect(int fd, byte[] address, int scopeId, int port)
boolean	connect(java.net.SocketAddress socketAddress)
private static int	connectDomainSocket(int fd, byte[] path)
boolean	finishConnect()
private static int	finishConnect(int fd)
int	getReceiveBufferSize()
private static int	getReceiveBufferSize(int fd)
int	getSendBufferSize()
private static int	getSendBufferSize(int fd)
int	getSoError()
private static int	getSoError(int fd)
int	getSoLinger()
private static int	getSoLinger(int fd)
int	getTcpDeferAccept()
private static int	getTcpDeferAccept(int fd)
boolean	isInputShutdown()
boolean	isKeepAlive()
private static int	isKeepAlive(int fd)
boolean	isOutputShutdown()
boolean	isShutdown()
boolean	isTcpCork()
private static int	isTcpCork(int fd)
boolean	isTcpNoDelay()
private static int	isTcpNoDelay(int fd)
boolean	isTcpQuickAck()
private static int	isTcpQuickAck(int fd)
void	listen(int backlog)
private static int	listen(int fd, int backlog)
java.net.InetSocketAddress	localAddress()
private static byte[]	localAddress(int fd)
static Socket	newSocketDgram()
private static int	newSocketDgramFd()
static Socket	newSocketDomain()
private static int	newSocketDomainFd()
static Socket	newSocketStream()
private static int	newSocketStreamFd()
DatagramSocketAddress	recvFrom(java.nio.ByteBuffer buf, int pos, int limit)
private static DatagramSocketAddress	recvFrom(int fd, java.nio.ByteBuffer buf, int pos, int limit)
private static DatagramSocketAddress	recvFromAddress(int fd, long memoryAddress, int pos, int limit)
DatagramSocketAddress	recvFromAddress(long memoryAddress, int pos, int limit)
java.net.InetSocketAddress	remoteAddress()
private static byte[]	remoteAddress(int fd)
int	sendTo(java.nio.ByteBuffer buf, int pos, int limit, java.net.InetAddress addr, int port)
private static int	sendTo(int fd, java.nio.ByteBuffer buf, int pos, int limit, byte[] address, int scopeId, int port)
private static int	sendToAddress(int fd, long memoryAddress, int pos, int limit, byte[] address, int scopeId, int port)
int	sendToAddress(long memoryAddress, int pos, int limit, java.net.InetAddress addr, int port)
private static int	sendToAddresses(int fd, long memoryAddress, int length, byte[] address, int scopeId, int port)
int	sendToAddresses(long memoryAddress, int length, java.net.InetAddress addr, int port)
void	setKeepAlive(boolean keepAlive)
private static void	setKeepAlive(int fd, int keepAlive)
void	setReceiveBufferSize(int receiveBufferSize)
private static void	setReceiveBufferSize(int fd, int receiveBufferSize)
void	setSendBufferSize(int sendBufferSize)
private static void	setSendBufferSize(int fd, int sendBufferSize)
void	setSoLinger(int soLinger)
private static void	setSoLinger(int fd, int soLinger)
void	setTcpCork(boolean tcpCork)
private static void	setTcpCork(int fd, int tcpCork)
void	setTcpDeferAccept(int deferAccept)
private static void	setTcpDeferAccept(int fd, int deferAccept)
void	setTcpNoDelay(boolean tcpNoDelay)
private static void	setTcpNoDelay(int fd, int tcpNoDelay)
void	setTcpQuickAck(boolean quickAck)
private static void	setTcpQuickAck(int fd, int quickAck)
void	shutdown()
void	shutdown(boolean read, boolean write)
private static int	shutdown(int fd, boolean read, boolean write)
java.lang.String	toString()

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

casState, close, equals, from, from, hashCode, inputShutdown, intValue, isClosed, isInputShutdown, isOpen, isOutputShutdown, outputShutdown, pipe, read, readAddress, write, writeAddress, writev, writevAddresses

Methods inherited from class java.lang.Object

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

Field Detail

SHUTDOWN_CLOSED_CHANNEL_EXCEPTION

private static final java.nio.channels.ClosedChannelException SHUTDOWN_CLOSED_CHANNEL_EXCEPTION

SEND_TO_CLOSED_CHANNEL_EXCEPTION

private static final java.nio.channels.ClosedChannelException SEND_TO_CLOSED_CHANNEL_EXCEPTION

SEND_TO_ADDRESS_CLOSED_CHANNEL_EXCEPTION

private static final java.nio.channels.ClosedChannelException SEND_TO_ADDRESS_CLOSED_CHANNEL_EXCEPTION

SEND_TO_ADDRESSES_CLOSED_CHANNEL_EXCEPTION

private static final java.nio.channels.ClosedChannelException SEND_TO_ADDRESSES_CLOSED_CHANNEL_EXCEPTION

SEND_TO_CONNECTION_RESET_EXCEPTION

private static final Errors.NativeIoException SEND_TO_CONNECTION_RESET_EXCEPTION

SEND_TO_ADDRESS_CONNECTION_RESET_EXCEPTION

private static final Errors.NativeIoException SEND_TO_ADDRESS_CONNECTION_RESET_EXCEPTION

CONNECTION_RESET_EXCEPTION_SENDMSG

private static final Errors.NativeIoException CONNECTION_RESET_EXCEPTION_SENDMSG

CONNECTION_RESET_SHUTDOWN_EXCEPTION

private static final Errors.NativeIoException CONNECTION_RESET_SHUTDOWN_EXCEPTION

FINISH_CONNECT_REFUSED_EXCEPTION

private static final Errors.NativeConnectException FINISH_CONNECT_REFUSED_EXCEPTION

CONNECT_REFUSED_EXCEPTION

private static final Errors.NativeConnectException CONNECT_REFUSED_EXCEPTION

Constructor Detail

Socket

public Socket(int fd)

Method Detail

shutdown

public void shutdown()
              throws java.io.IOException

Throws:

java.io.IOException

shutdown

public void shutdown(boolean read,
                     boolean write)
              throws java.io.IOException

Throws:

java.io.IOException

isShutdown

public boolean isShutdown()

isInputShutdown

public boolean isInputShutdown()

isOutputShutdown

public boolean isOutputShutdown()

sendTo

public int sendTo(java.nio.ByteBuffer buf,
                  int pos,
                  int limit,
                  java.net.InetAddress addr,
                  int port)
           throws java.io.IOException

Throws:

java.io.IOException

sendToAddress

public int sendToAddress(long memoryAddress,
                         int pos,
                         int limit,
                         java.net.InetAddress addr,
                         int port)
                  throws java.io.IOException

Throws:

java.io.IOException

sendToAddresses

public int sendToAddresses(long memoryAddress,
                           int length,
                           java.net.InetAddress addr,
                           int port)
                    throws java.io.IOException

Throws:

java.io.IOException

recvFrom

public DatagramSocketAddress recvFrom(java.nio.ByteBuffer buf,
                                      int pos,
                                      int limit)
                               throws java.io.IOException

Throws:

java.io.IOException

recvFromAddress

public DatagramSocketAddress recvFromAddress(long memoryAddress,
                                             int pos,
                                             int limit)
                                      throws java.io.IOException

Throws:

java.io.IOException

connect

public boolean connect(java.net.SocketAddress socketAddress)
                throws java.io.IOException

Throws:

java.io.IOException

finishConnect

public boolean finishConnect()
                      throws java.io.IOException

Throws:

java.io.IOException

bind

public void bind(java.net.SocketAddress socketAddress)
          throws java.io.IOException

Throws:

java.io.IOException

listen

public void listen(int backlog)
            throws java.io.IOException

Throws:

java.io.IOException

accept

public int accept(byte[] addr)
           throws java.io.IOException

Throws:

java.io.IOException

remoteAddress

public java.net.InetSocketAddress remoteAddress()

localAddress

public java.net.InetSocketAddress localAddress()

getReceiveBufferSize

public int getReceiveBufferSize()
                         throws java.io.IOException

Throws:

java.io.IOException

getSendBufferSize

public int getSendBufferSize()
                      throws java.io.IOException

Throws:

java.io.IOException

isKeepAlive

public boolean isKeepAlive()
                    throws java.io.IOException

Throws:

java.io.IOException

isTcpNoDelay

public boolean isTcpNoDelay()
                     throws java.io.IOException

Throws:

java.io.IOException

isTcpCork

public boolean isTcpCork()
                  throws java.io.IOException

Throws:

java.io.IOException

getSoLinger

public int getSoLinger()
                throws java.io.IOException

Throws:

java.io.IOException

getTcpDeferAccept

public int getTcpDeferAccept()
                      throws java.io.IOException

Throws:

java.io.IOException

isTcpQuickAck

public boolean isTcpQuickAck()
                      throws java.io.IOException

Throws:

java.io.IOException

getSoError

public int getSoError()
               throws java.io.IOException

Throws:

java.io.IOException

setKeepAlive

public void setKeepAlive(boolean keepAlive)
                  throws java.io.IOException

Throws:

java.io.IOException

setReceiveBufferSize

public void setReceiveBufferSize(int receiveBufferSize)
                          throws java.io.IOException

Throws:

java.io.IOException

setSendBufferSize

public void setSendBufferSize(int sendBufferSize)
                       throws java.io.IOException

Throws:

java.io.IOException

setTcpNoDelay

public void setTcpNoDelay(boolean tcpNoDelay)
                   throws java.io.IOException

Throws:

java.io.IOException

setTcpCork

public void setTcpCork(boolean tcpCork)
                throws java.io.IOException

Throws:

java.io.IOException

setSoLinger

public void setSoLinger(int soLinger)
                 throws java.io.IOException

Throws:

java.io.IOException

setTcpDeferAccept

public void setTcpDeferAccept(int deferAccept)
                       throws java.io.IOException

Throws:

java.io.IOException

setTcpQuickAck

public void setTcpQuickAck(boolean quickAck)
                    throws java.io.IOException

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class FileDescriptor

newSocketStream

public static Socket newSocketStream()

newSocketDgram

public static Socket newSocketDgram()

newSocketDomain

public static Socket newSocketDomain()

shutdown

private static int shutdown(int fd,
                            boolean read,
                            boolean write)

connect

private static int connect(int fd,
                           byte[] address,
                           int scopeId,
                           int port)

connectDomainSocket

private static int connectDomainSocket(int fd,
                                       byte[] path)

finishConnect

private static int finishConnect(int fd)

bind

private static int bind(int fd,
                        byte[] address,
                        int scopeId,
                        int port)

bindDomainSocket

private static int bindDomainSocket(int fd,
                                    byte[] path)

listen

private static int listen(int fd,
                          int backlog)

accept

private static int accept(int fd,
                          byte[] addr)

remoteAddress

private static byte[] remoteAddress(int fd)

localAddress

private static byte[] localAddress(int fd)

sendTo

private static int sendTo(int fd,
                          java.nio.ByteBuffer buf,
                          int pos,
                          int limit,
                          byte[] address,
                          int scopeId,
                          int port)

sendToAddress

private static int sendToAddress(int fd,
                                 long memoryAddress,
                                 int pos,
                                 int limit,
                                 byte[] address,
                                 int scopeId,
                                 int port)

sendToAddresses

private static int sendToAddresses(int fd,
                                   long memoryAddress,
                                   int length,
                                   byte[] address,
                                   int scopeId,
                                   int port)

recvFrom

private static DatagramSocketAddress recvFrom(int fd,
                                              java.nio.ByteBuffer buf,
                                              int pos,
                                              int limit)
                                       throws java.io.IOException

Throws:

java.io.IOException

recvFromAddress

private static DatagramSocketAddress recvFromAddress(int fd,
                                                     long memoryAddress,
                                                     int pos,
                                                     int limit)
                                              throws java.io.IOException

Throws:

java.io.IOException

newSocketStreamFd

private static int newSocketStreamFd()

newSocketDgramFd

private static int newSocketDgramFd()

newSocketDomainFd

private static int newSocketDomainFd()

getReceiveBufferSize

private static int getReceiveBufferSize(int fd)
                                 throws java.io.IOException

Throws:

java.io.IOException

getSendBufferSize

private static int getSendBufferSize(int fd)
                              throws java.io.IOException

Throws:

java.io.IOException

isKeepAlive

private static int isKeepAlive(int fd)
                        throws java.io.IOException

Throws:

java.io.IOException

isTcpNoDelay

private static int isTcpNoDelay(int fd)
                         throws java.io.IOException

Throws:

java.io.IOException

isTcpCork

private static int isTcpCork(int fd)
                      throws java.io.IOException

Throws:

java.io.IOException

getSoLinger

private static int getSoLinger(int fd)
                        throws java.io.IOException

Throws:

java.io.IOException

getSoError

private static int getSoError(int fd)
                       throws java.io.IOException

Throws:

java.io.IOException

getTcpDeferAccept

private static int getTcpDeferAccept(int fd)
                              throws java.io.IOException

Throws:

java.io.IOException

isTcpQuickAck

private static int isTcpQuickAck(int fd)
                          throws java.io.IOException

Throws:

java.io.IOException

setKeepAlive

private static void setKeepAlive(int fd,
                                 int keepAlive)
                          throws java.io.IOException

Throws:

java.io.IOException

setReceiveBufferSize

private static void setReceiveBufferSize(int fd,
                                         int receiveBufferSize)
                                  throws java.io.IOException

Throws:

java.io.IOException

setSendBufferSize

private static void setSendBufferSize(int fd,
                                      int sendBufferSize)
                               throws java.io.IOException

Throws:

java.io.IOException

setTcpNoDelay

private static void setTcpNoDelay(int fd,
                                  int tcpNoDelay)
                           throws java.io.IOException

Throws:

java.io.IOException

setTcpCork

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

Throws:

java.io.IOException

setSoLinger

private static void setSoLinger(int fd,
                                int soLinger)
                         throws java.io.IOException

Throws:

java.io.IOException

setTcpDeferAccept

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

Throws:

java.io.IOException

setTcpQuickAck

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

Throws:

java.io.IOException