zmq.io.net.tcp

Class TcpUtils

java.lang.Object

zmq.io.net.tcp.TcpUtils

public class TcpUtils
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TcpUtils.SocketOptionsProvider

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	WITH_EXTENDED_KEEPALIVE

Constructor Summary

Constructors

Modifier	Constructor and Description
private	TcpUtils()

Method Summary

Modifier and Type	Method and Description
static void	enableIpv4Mapping(java.nio.channels.SelectableChannel channel)
static Address	getPeerIpAddress(java.nio.channels.SocketChannel channel) Deprecated. Use Utils.getPeerIpAddress(SocketChannel) instead
static boolean	setIpTypeOfService(java.nio.channels.Channel channel, int tos)
private static <T> void	setOption(java.nio.channels.Channel channel, java.net.SocketOption<T> option, T value)
static boolean	setReuseAddress(java.nio.channels.Channel channel, boolean reuse)
static boolean	setTcpReceiveBuffer(java.nio.channels.Channel channel, int rcvbuf)
static boolean	setTcpSendBuffer(java.nio.channels.Channel channel, int sndbuf)
static void	tuneTcpKeepalives(java.nio.channels.Channel channel, int tcpKeepAlive, int tcpKeepAliveCnt, int tcpKeepAliveIdle, int tcpKeepAliveIntvl)
static void	tuneTcpSocket(java.nio.channels.Channel channel)
static void	unblockSocket(java.nio.channels.SelectableChannel... channels)

Methods inherited from class java.lang.Object

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

Field Detail

WITH_EXTENDED_KEEPALIVE

public static final boolean WITH_EXTENDED_KEEPALIVE

Constructor Detail

TcpUtils

private TcpUtils()

Method Detail

tuneTcpSocket

public static void tuneTcpSocket(java.nio.channels.Channel channel)
                          throws java.io.IOException

Throws:

java.io.IOException

tuneTcpKeepalives

public static void tuneTcpKeepalives(java.nio.channels.Channel channel,
                                     int tcpKeepAlive,
                                     int tcpKeepAliveCnt,
                                     int tcpKeepAliveIdle,
                                     int tcpKeepAliveIntvl)

setTcpReceiveBuffer

public static boolean setTcpReceiveBuffer(java.nio.channels.Channel channel,
                                          int rcvbuf)

setTcpSendBuffer

public static boolean setTcpSendBuffer(java.nio.channels.Channel channel,
                                       int sndbuf)

setIpTypeOfService

public static boolean setIpTypeOfService(java.nio.channels.Channel channel,
                                         int tos)

setReuseAddress

public static boolean setReuseAddress(java.nio.channels.Channel channel,
                                      boolean reuse)

setOption

private static <T> void setOption(java.nio.channels.Channel channel,
                                  java.net.SocketOption<T> option,
                                  T value)

unblockSocket

public static void unblockSocket(java.nio.channels.SelectableChannel... channels)
                          throws java.io.IOException

Throws:

java.io.IOException

enableIpv4Mapping

public static void enableIpv4Mapping(java.nio.channels.SelectableChannel channel)

getPeerIpAddress

@Deprecated
public static Address getPeerIpAddress(java.nio.channels.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

java.lang.IllegalArgumentException - if the SocketChannel is not a TCP channel