zmq.util

Class Utils

java.lang.Object

zmq.util.Utils

public class Utils
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.ThreadLocal<java.security.SecureRandom>	random

Constructor Summary

Constructors

Modifier	Constructor and Description
private	Utils()

Method Summary

Modifier and Type	Method and Description
static byte[]	bytes(java.nio.ByteBuffer buf)
static void	checkArgument(boolean expression, java.lang.String errorMessage)
static void	checkArgument(boolean expression, Supplier<java.lang.String> errorMessage)
static boolean	delete(java.io.File path)
static java.lang.String	dump(java.nio.ByteBuffer buffer, int pos, int limit)
static int	findOpenPort()
static Address	getLocalIpAddress(java.nio.channels.SocketChannel fd) Resolve the local address of the channel.
static Address	getPeerIpAddress(java.nio.channels.SocketChannel fd) Resolve the remote address of the channel.
static byte[]	randomBytes(int length)
static int	randomInt()
static int	randomInt(int bound)
static byte[]	realloc(byte[] src, int size)
static <T> T[]	realloc(java.lang.Class<T> klass, T[] src, int size, boolean ended)
static void	unblockSocket(java.nio.channels.SelectableChannel... channels)
static java.lang.String	unhash(int port) Finds a string whose hashcode is the number in input.
private static java.lang.StringBuilder	unhash(java.lang.StringBuilder builder, int port, char boundary)

Methods inherited from class java.lang.Object

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

Field Detail

random

private static final java.lang.ThreadLocal<java.security.SecureRandom> random

Constructor Detail

Utils

private Utils()

Method Detail

randomInt

public static int randomInt()

randomInt

public static int randomInt(int bound)

randomBytes

public static byte[] randomBytes(int length)

unhash

public static java.lang.String unhash(int port)

Finds a string whose hashcode is the number in input.

Parameters:

port - the port to find String hashcode-equivalent of. Has to be positive or 0.

Returns:

a String whose hashcode is the number in input.

unhash

private static java.lang.StringBuilder unhash(java.lang.StringBuilder builder,
                                              int port,
                                              char boundary)

findOpenPort

public static int findOpenPort()
                        throws java.io.IOException

Throws:

java.io.IOException

unblockSocket

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

Throws:

java.io.IOException

realloc

public static <T> T[] realloc(java.lang.Class<T> klass,
                              T[] src,
                              int size,
                              boolean ended)

bytes

public static byte[] bytes(java.nio.ByteBuffer buf)

realloc

public static byte[] realloc(byte[] src,
                             int size)

delete

public static boolean delete(java.io.File path)

getPeerIpAddress

public static Address getPeerIpAddress(java.nio.channels.SocketChannel fd)

Resolve the remote address of the channel.

Parameters:

fd - the channel, should be a TCP socket channel

Returns:

a new Address

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

getLocalIpAddress

public static Address getLocalIpAddress(java.nio.channels.SocketChannel fd)

Resolve the local address of the channel.

Parameters:

fd - the channel, should be a TCP socket channel

Returns:

a new Address

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

dump

public static java.lang.String dump(java.nio.ByteBuffer buffer,
                                    int pos,
                                    int limit)

checkArgument

public static void checkArgument(boolean expression,
                                 java.lang.String errorMessage)

checkArgument

public static void checkArgument(boolean expression,
                                 Supplier<java.lang.String> errorMessage)