Class TcpUtils

java.lang.Object

zmq.io.net.tcp.TcpUtils

public class TcpUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	TcpUtils.OptionSetter<S>

Constructor Summary

Constructors

Modifier	Constructor	Description
private	TcpUtils()

Method Summary

Modifier and Type	Method	Description
static void	enableIpv4Mapping(SelectableChannel channel)
static Address	getPeerIpAddress(SocketChannel channel)
static boolean	setIpTypeOfService(Channel channel, int tos)
private static void	setOption(Channel channel, TcpUtils.OptionSetter<Socket> setter)	A single setter method, used when the option doesn't apply to a ServerSocket
private static void	setOption(Channel channel, TcpUtils.OptionSetter<Socket> setter, TcpUtils.OptionSetter<ServerSocket> serverSetter)
static boolean	setReuseAddress(Channel channel, boolean reuse)
static boolean	setTcpReceiveBuffer(Channel channel, int rcvbuf)
static boolean	setTcpSendBuffer(Channel channel, int sndbuf)
static void	tuneTcpKeepalives(SocketChannel channel, int tcpKeepAlive, int tcpKeepAliveCnt, int tcpKeepAliveIdle, int tcpKeepAliveIntvl)
static void	tuneTcpSocket(SocketChannel channel)
static void	unblockSocket(SelectableChannel... channels)

Methods inherited from class Object

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

Constructor Details

TcpUtils

private TcpUtils()

Method Details

tuneTcpSocket

public static void tuneTcpSocket(SocketChannel channel)
                          throws IOException

Throws:

IOException

setTcpReceiveBuffer

public static boolean setTcpReceiveBuffer(Channel channel,
 int rcvbuf)

setTcpSendBuffer

public static boolean setTcpSendBuffer(Channel channel,
 int sndbuf)

setIpTypeOfService

public static boolean setIpTypeOfService(Channel channel,
 int tos)

setReuseAddress

public static boolean setReuseAddress(Channel channel,
 boolean reuse)

tuneTcpKeepalives

public static void tuneTcpKeepalives(SocketChannel channel,
 int tcpKeepAlive,
 int tcpKeepAliveCnt,
 int tcpKeepAliveIdle,
 int tcpKeepAliveIntvl)

setOption

private static void setOption(Channel channel,
 TcpUtils.OptionSetter<Socket> setter)

A single setter method, used when the option doesn't apply to a ServerSocket

Parameters:

channel -

setter -

setOption

private static void setOption(Channel channel,
 TcpUtils.OptionSetter<Socket> setter,
 TcpUtils.OptionSetter<ServerSocket> serverSetter)

unblockSocket

public static void unblockSocket(SelectableChannel... channels)
                          throws IOException

Throws:

IOException

enableIpv4Mapping

public static void enableIpv4Mapping(SelectableChannel channel)

getPeerIpAddress

public static Address getPeerIpAddress(SocketChannel channel)