Package zmq.io.net.tcp

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 final class	TcpUtils.SocketOptionsProvider

Field Summary

Fields

Modifier and Type	Field	Description
static final boolean	WITH_EXTENDED_KEEPALIVE

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)	Deprecated. Use Utils.getPeerIpAddress(SocketChannel) instead
static boolean	setIpTypeOfService(Channel channel, int tos)
private static <T> void	setOption(Channel channel, SocketOption<T> option, T value)
static boolean	setReuseAddress(Channel channel, boolean reuse)
static boolean	setTcpReceiveBuffer(Channel channel, int rcvbuf)
static boolean	setTcpSendBuffer(Channel channel, int sndbuf)
static void	tuneTcpKeepalives(Channel channel, int tcpKeepAlive, int tcpKeepAliveCnt, int tcpKeepAliveIdle, int tcpKeepAliveIntvl)
static void	tuneTcpSocket(Channel channel)
static void	unblockSocket(SelectableChannel... channels)

Methods inherited from class java.lang.Object

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

Field Details

WITH_EXTENDED_KEEPALIVE

public static final boolean WITH_EXTENDED_KEEPALIVE

Constructor Details

TcpUtils

private TcpUtils()

Method Details

tuneTcpSocket

public static void tuneTcpSocket(Channel channel)
                          throws IOException

Throws:

IOException

tuneTcpKeepalives

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

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)

setOption

private static <T> void setOption(Channel channel,
 SocketOption<T> option,
 T value)

unblockSocket

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

Throws:

IOException

enableIpv4Mapping

public static void enableIpv4Mapping(SelectableChannel channel)

getPeerIpAddress

@Deprecated
public static Address getPeerIpAddress(SocketChannel channel)

Deprecated.

Use Utils.getPeerIpAddress(SocketChannel) instead

Return the Address of the channel

Parameters:

channel - the channel, should be a TCP socket channel

Returns:

The Address of the channel

Throws:

ZError.IOException - if the channel is closed or an I/O errors occurred

IllegalArgumentException - if the SocketChannel is not a TCP channel