Util (JBoss Application Server: Build 7.1.2.Final API)

java.lang.Object
- org.jgroups.util.Util

```
public class Util
extends Object
```
Collection of various utility routines that can not be assigned to other classes.

Author:

Bela Ban

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class Util.AddressScope

Nested Classes
Modifier and Type	Class and Description
`static class`	`Util.AddressScope`

Field Summary

Fields
Modifier and Type	Field and Description
`protected static int`	`CCHM_CONCURRENCY_LEVEL`
`protected static int`	`CCHM_INITIAL_CAPACITY`
`protected static float`	`CCHM_LOAD_FACTOR`
`static int`	`MAX_LIST_PRINT_SIZE` The max size of an address list, e.g.
`static int`	`MAX_PORT`

Constructor Summary

Constructors
Constructor and Description

Util()

Constructors
Constructor and Description
`Util()`

Method Summary

Methods
Modifier and Type	Method and Description
`protected static void`	`_printThreads(ThreadMXBean bean, long[] ids, StringBuilder sb)`
`static String`	`activeThreads()`
`static void`	`addFlush(Channel ch, FLUSH flush)`
`static boolean`	`all(Collection c, Object obj)` Returns true if all elements of c match obj
`static String`	`array2String(boolean[] array)`
`static String`	`array2String(int[] array)`
`static String`	`array2String(long[] array)`
`static String`	`array2String(Object[] array)`
`static String`	`array2String(short[] array)`
`static void`	`assertEquals(Object val1, Object val2)`
`static void`	`assertEquals(String message, Object val1, Object val2)`
`static void`	`assertFalse(boolean condition)`
`static void`	`assertFalse(String message, boolean condition)`
`static void`	`assertNotNull(Object val)`
`static void`	`assertNotNull(String message, Object val)`
`static void`	`assertNull(String message, Object val)`
`static void`	`assertTrue(boolean condition)`
`static void`	`assertTrue(String message, boolean condition)`
`static String`	`attributeNameToMethodName(String attr_name)`
`static Message`	`byteBufferToMessage(byte[] buffer, int offset, int length)`
`static boolean`	`checkForHp()`
`static boolean`	`checkForLinux()`
`static boolean`	`checkForMac()`
`static boolean`	`checkForSolaris()`
`static boolean`	`checkForWindows()`
`static void`	`checkIfValidAddress(InetAddress bind_addr, String prot_name)`
`static byte`	`clearFlags(byte bits, byte flag)`
`static void`	`close(Channel... channels)`
`static void`	`close(Channel ch)`
`static void`	`close(Connection conn)`
`static void`	`close(DatagramSocket my_sock)`
`static void`	`close(InputStream inp)`
`static void`	`close(OutputStream out)`
`static void`	`close(ServerSocket s)`
`static void`	`close(Socket s)`
`static byte[]`	`collectionToByteBuffer(Collection<Address> c)`
`static String[]`	`components(String path, String separator)`
`static List<Range>`	`computeFragOffsets(byte[] buf, int frag_size)`
`static List<Range>`	`computeFragOffsets(int offset, int length, int frag_size)` Given a buffer and a fragmentation size, compute a list of fragmentation offset/length pairs, and return them in a list.
`static void`	`connect(Socket sock, SocketAddress dest, int sock_conn_timeout)` Utility method.
`static boolean`	`containsViewId(Collection<View> views, ViewId vid)`
`static void`	`crash()`
`static JChannel`	`createChannel(Protocol... prots)`
`static <K,V> ConcurrentMap<K,V>`	`createConcurrentMap()`
`static <K,V> ConcurrentMap<K,V>`	`createConcurrentMap(int initial_capacity)`
`static <K,V> ConcurrentMap<K,V>`	`createConcurrentMap(int initial_capacity, float load_factor, int concurrency_level)`
`static DatagramSocket`	`createDatagramSocket(SocketFactory factory, String service_name, InetAddress addr, int port)` Creates a DatagramSocket bound to addr.
`static <K,V> Map<K,V>`	`createHashMap()`
`static MulticastSocket`	`createMulticastSocket(SocketFactory factory, String service_name, InetAddress mcast_addr, int port, Log log)`
`static Address`	`createRandomAddress()`
`static Address`	`createRandomAddress(String name)`
`static ServerSocket`	`createServerSocket(SocketFactory factory, String service_name, InetAddress bind_addr, int start_port)`
`static ServerSocket`	`createServerSocket(SocketFactory factory, String service_name, InetAddress bind_addr, int start_port, int end_port)` Finds first available port starting at start_port and returns server socket.
`static Object[][]`	`createTimer()`
`static View`	`createView(Address coord, long id, Address... members)`
`static long`	`decode(byte[] buf)`
`static byte[]`	`decodeLength(byte len)`
`static long[]`	`decodeLongSequence(byte[] buf)`
`static byte[]`	`defragmentBuffer(byte[][] fragments)` Concatenates smaller fragments into entire buffers.
`static List<Address>`	`determineLeftMembers(List<Address> old_mbrs, List<Address> new_mbrs)` Returns all members that left between 2 views.
`static Collection<Address>`	`determineMergeCoords(Map<Address,View> map)` This is the same or a subset of `determineMergeParticipants(java.util.Map)` and contains only members which are currently sub-partition coordinators.
`static Collection<Address>`	`determineMergeParticipants(Map<Address,View> map)` Determines the members which take part in a merge.
`static int`	`discardUntilNewLine(InputStream in)` Reads and discards all characters from the input stream until a \r\n or EOF is encountered
`static void`	`doubleWrite(byte[] buf, int offset, int length, OutputStream out)` Makes sure that we detect when a peer connection is in the closed state (not closed while we send data, but before we send data).
`static void`	`doubleWrite(byte[] buf, OutputStream out)` Makes sure that we detect when a peer connection is in the closed state (not closed while we send data, but before we send data).
`static String`	`dumpQueue(Queue q)` Debugging method used to dump the content of a protocol queue in a condensed form.
`static String`	`dumpThreads()`
`static byte[]`	`encode(long num)`
`static byte`	`encodeLength(byte len1, byte len2)` Encodes the number of bytes needed into a single byte.
`static byte[]`	`encodeLongSequence(long highest_delivered, long highest_received)` Encode the highest delivered and received seqnos.
`static boolean`	`fileExists(String fname)`
`static String`	`format(double value)`
`static byte[][]`	`fragmentBuffer(byte[] buf, int frag_size)`
`static byte[][]`	`fragmentBuffer(byte[] buf, int frag_size, int length)` Fragments a byte buffer into smaller fragments of (max.) frag_size.
`static String`	`generateList(Collection c, String separator)`
`static String`	`generateLocalName()`
`static InetAddress`	`getAddress(NetworkInterface intf, Util.AddressScope scope)` Returns the first address on the given interface on the current host, which satisfies scope
`static InetAddress`	`getAddress(Util.AddressScope scope)` Returns the first address on any interface of the current host, which satisfies scope
`static Collection<InetAddress>`	`getAllAvailableAddresses()`
`static List<NetworkInterface>`	`getAllAvailableInterfaces()`
`static Field[]`	`getAllDeclaredFields(Class clazz)`
`static Field[]`	`getAllDeclaredFieldsWithAnnotations(Class clazz, Class<? extends Annotation>... annotations)`
`static Method[]`	`getAllDeclaredMethods(Class clazz)`
`static Method[]`	`getAllDeclaredMethodsWithAnnotations(Class clazz, Class<? extends Annotation>... annotations)`
`static InetAddress`	`getBindAddress(Properties props)` Returns the address of the interface to use defined by bind_addr and bind_interface
`protected static byte`	`getByteAt(long num, int index)`
`static Field`	`getField(Class clazz, String field_name)`
`static ThreadGroup`	`getGlobalThreadGroup()`
`static StackType`	`getIpStackType()`
`static InetAddress`	`getLocalhost(StackType ip_version)` IP related utilities
`static MBeanServer`	`getMBeanServer()`
`static InetAddress`	`getNonLoopbackAddress()` Returns the first non-loopback address on any interface on the current host.
`static String`	`getProperty(String s)`
`static String`	`getProperty(String[] system_props, Properties props, String prop_name, boolean ignore_sysprops, String default_value)` Returns a value associated wither with one or more system properties, or found in the props map
`static int`	`getRank(View view, Address addr)` Returns the rank of a member in a given view
`static InputStream`	`getResourceAsStream(String name, Class clazz)`
`static short`	`getScope(Message msg)`
`static String`	`getStackTrace(Throwable t)`
`static short`	`incrCounter()`
`static boolean`	`interfaceHasIPAddresses(NetworkInterface intf, StackType ip_version)` A function to check if an interface supports an IP version (i.e has addresses defined for that IP version).
`static boolean`	`interruptAndWaitToDie(Thread t)`
`static boolean`	`interruptAndWaitToDie(Thread t, long timeout)`
`static boolean`	`isBindAddressPropertyIgnored()`
`static boolean`	`isCoordinator(JChannel ch)`
`static boolean`	`isCoordinator(View view, Address local_addr)`
`static boolean`	`isFlagSet(byte bits, byte flag)`
`static boolean`	`isStackAvailable(boolean ipv4)`
`static int`	`keyPress(String msg)`
`static List<Address>`	`leftMembers(Collection<Address> old_list, Collection<Address> new_list)`
`static List<Address>`	`leftMembers(View one, View two)` Returns a list of members which left from view one to two
`static Class`	`loadClass(String classname, Class clazz)` Tries to load the class from the current thread's context class loader.
`static String`	`mapToString(Map<? extends Object,? extends Object> map)`
`static boolean`	`match(long[] a1, long[] a2)`
`static boolean`	`match(Object obj1, Object obj2)`
`static String`	`md5(String source)` Converts a java.lang.String in to a MD5 hashed String
`static Buffer`	`messageToByteBuffer(Message msg)`
`static String`	`methodNameToAttributeName(String methodName)`
`static Buffer`	`msgListToByteBuffer(List<Message> xmit_list)` Marshalls a list of messages.
`static <T> List<T>`	`newElements(List<T> old_list, List<T> new_list)`
`static List<Address>`	`newMembers(List<Address> old_list, List<Address> new_list)`
`static Object`	`objectFromByteBuffer(byte[] buffer)` Creates an object from a byte buffer
`static Object`	`objectFromByteBuffer(byte[] buffer, int offset, int length)`
`static Object`	`objectFromStream(DataInput in)`
`static byte[]`	`objectToByteBuffer(Object obj)` Serializes/Streams an object into a byte buffer.
`static void`	`objectToStream(Object obj, DataOutput out)`
`static List<IpAddress>`	`parseCommaDelimitedHosts(String hosts, int port_range)` Input is "daddy[8880],sindhu[8880],camille[5555].
`static List<InetSocketAddress>`	`parseCommaDelimitedHosts2(String hosts, int port_range)` Input is "daddy[8880],sindhu[8880],camille[5555].
`static int[]`	`parseCommaDelimitedInts(String s)` Parses comma-delimited longs; e.g., 2000,4000,8000.
`static long[]`	`parseCommaDelimitedLongs(String s)` Parses comma-delimited longs; e.g., 2000,4000,8000.
`static List<String>`	`parseCommaDelimitedStrings(String l)` e.g.
`static List<NetworkInterface>`	`parseInterfaceList(String s)`
`static RejectedExecutionHandler`	`parseRejectionPolicy(String rejection_policy)`
`static String`	`parseString(ByteBuffer buf)`
`static String`	`parseString(ByteBuffer buf, boolean discard_whitespace)`
`static String`	`parseString(DataInput in)`
`static List<String>`	`parseStringList(String l, String separator)`
`static <T> T`	`pickNext(List<T> list, T obj)` Returns the object next to element in list
`static <T> List<T>`	`pickNext(List<T> list, T obj, int num)` Returns the next min(N,list.size()) elements after obj
`static Object`	`pickRandomElement(List list)`
`static Object`	`pickRandomElement(Object[] array)`
`static List<Address>`	`pickSubset(List<Address> members, double subset_percentage)` Selects a random subset of members according to subset_percentage and returns them.
`static <T> String`	`print(Collection<T> objs)`
`static String`	`print(List<NetworkInterface> interfaces)`
`static <T> String`	`print(Map<T,T> map)`
`static String`	`print(Throwable t)`
`static String`	`printBytes(double bytes)`
`static String`	`printBytes(long bytes)` MByte nowadays doesn't mean 1024 * 1024 bytes, but 1 million bytes, see http://en.wikipedia.org/wiki/Megabyte
`static String`	`printEvent(Event evt)`
`static void`	`printFragments(byte[][] frags)`
`static <T> String`	`printListWithDelimiter(Collection<T> list, String delimiter)`
`static <T> String`	`printListWithDelimiter(Collection<T> list, String delimiter, int limit)`
`static <T> String`	`printMapWithDelimiter(Map<T,T> map, String delimiter)`
`static String`	`printMessage(Message msg)` Tries to read an object from the message's buffer and prints it
`static String`	`printPingData(List<PingData> rsps)`
`static String`	`printStackTrace(Throwable t)` Use with caution: lots of overhead
`static void`	`printThreads()`
`static String`	`printTime(long time, TimeUnit unit)`
`static String`	`printViews(Collection<View> views)`
`static void`	`prompt(String s)`
`static long`	`random(long range)` Returns a random value in the range [1 - range]
`static Address`	`readAddress(DataInput in)`
`static Collection<? extends Address>`	`readAddresses(DataInput in, Class cl)`
`static AuthToken`	`readAuthToken(DataInput in)`
`static byte[]`	`readByteBuffer(DataInput in)`
`static double`	`readBytesDouble(String input)`
`static int`	`readBytesInteger(String input)`
`static long`	`readBytesLong(String input)`
`static Class<?>`	`readClass(DataInput in)`
`static String`	`readContents(InputStream input)`
`static double`	`readDoubleFromStdin(String message)`
`static String`	`readFile(String filename)`
`static Streamable`	`readGenericStreamable(DataInput in)`
`static int`	`readIntFromStdin(String message)`
`static String`	`readLine(InputStream in)` Reads a line of text.
`static long`	`readLong(DataInput in)`
`static long`	`readLongFromStdin(String message)`
`static long[]`	`readLongSequence(DataInput in)`
`static int`	`readNewLine(ByteBuffer buf)`
`static Object`	`readObject(DataInput in)`
`static Streamable`	`readStreamable(Class clazz, DataInput in)`
`static String`	`readString(DataInput in)`
`static String`	`readStringFromStdin(String message)`
`static View`	`readView(DataInput in)`
`static ViewId`	`readViewId(DataInput in)`
`static void`	`registerChannel(JChannel channel, String name)`
`static String`	`replaceProperties(String string, Properties props)` Go through the input string and replace any occurance of ${p} with the props.getProperty(p) value.
`static void`	`runAsync(Runnable task, ThreadFactory factory, ThreadGroup group, String thread_name)` Runs a task on a separate thread
`static boolean`	`sameHost(Address one, Address two)` Checks whether 2 Addresses are on the same host
`static byte`	`setFlag(byte bits, byte flag)`
`static void`	`setScope(Message msg, short scope)`
`static String`	`sha(String source)` Converts a java.lang.String in to a SHA hashed String
`static String`	`shortName(InetAddress hostname)`
`static String`	`shortName(String hostname)`
`static void`	`shutdown(Channel ch)` Drops messages to/from other members and then closes the channel.
`static int`	`size(Address addr)`
`static long`	`size(Collection<? extends Address> addrs)` Returns the marshalled size of a Collection of Addresses.
`static byte`	`size(long number)`
`static byte`	`size(long hd, long hr)` Writes 2 longs, where the second long needs to be >= the first (we only write the delta !)
`static int`	`size(View view)`
`static int`	`size(ViewId vid)`
`static long`	`sizeOf(Object inst)`
`static int`	`sizeOf(Streamable inst)`
`static long`	`sizeOf(String classname)`
`static void`	`sleep(long timeout)` Sleep for timeout msecs.
`static void`	`sleep(long msecs, boolean busy_sleep)` On most UNIX systems, the minimum sleep time is 10-20ms.
`static void`	`sleep(long timeout, int nanos)`
`static void`	`sleepRandom(long floor, long ceiling)` Sleeps between floor and ceiling milliseconds, chosen randomly
`static List<String>`	`split(String input, int separator)`
`static boolean`	`startFlush(Channel c)`
`static boolean`	`startFlush(Channel c, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling)`
`static boolean`	`startFlush(Channel c, List<Address> flushParticipants)`
`static boolean`	`startFlush(Channel c, List<Address> flushParticipants, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling)`
`static Streamable`	`streamableFromByteBuffer(Class<? extends Streamable> cl, byte[] buffer)`
`static Streamable`	`streamableFromByteBuffer(Class<? extends Streamable> cl, byte[] buffer, int offset, int length)`
`static byte[]`	`streamableToByteBuffer(Streamable obj)`
`static String`	`substituteVariable(String val)` Replaces variables of ${var:default} with System.getProperty(var, default).
`static boolean`	`tossWeightedCoin(double probability)` Tosses a coin weighted with probability and returns true or false.
`static InetAddress`	`validateBindAddressFromInterface(InetAddress bind_addr, String bind_interface_str)` Method used by PropertyConverters.BindInterface to check that a bind_address is consistent with a specified interface Idea: 1.
`static void`	`verifyRejectionPolicy(String str)`
`static void`	`waitUntilAllChannelsHaveSameSize(long timeout, long interval, Channel... channels)` Blocks until all channels have the same view
`static void`	`writeAddress(Address addr, DataOutput out)`
`static void`	`writeAddresses(Collection<? extends Address> v, DataOutput out)` Writes a Vector of Addresses.
`static void`	`writeAuthToken(AuthToken token, DataOutput out)`
`static void`	`writeByteBuffer(byte[] buf, DataOutput out)`
`static void`	`writeByteBuffer(byte[] buf, int offset, int length, DataOutput out)`
`static void`	`writeClass(Class<?> classObject, DataOutput out)`
`static void`	`writeFully(ByteBuffer buf, WritableByteChannel out)` if we were to register for OP_WRITE and send the remaining data on readyOps for this channel we have to either block the caller thread or queue the message buffers that may arrive while waiting for OP_WRITE.
`static void`	`writeGenericStreamable(Streamable obj, DataOutput out)`
`static void`	`writeLong(long num, DataOutput out)`
`static void`	`writeLongSequence(long highest_delivered, long highest_received, DataOutput out)`
`static void`	`writeObject(Object obj, DataOutput out)`
`static void`	`writeStreamable(Streamable obj, DataOutput out)`
`static void`	`writeString(ByteBuffer buf, String s)`
`static void`	`writeString(String s, DataOutput out)`
`static void`	`writeView(View view, DataOutput out)`
`static void`	`writeViewId(ViewId vid, DataOutput out)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail
- MAX_PORT
```
public static final int MAX_PORT
```
  See Also:
  Constant Field Values
- CCHM_INITIAL_CAPACITY
```
protected static int CCHM_INITIAL_CAPACITY
```
- CCHM_LOAD_FACTOR
```
protected static float CCHM_LOAD_FACTOR
```
- CCHM_CONCURRENCY_LEVEL
```
protected static int CCHM_CONCURRENCY_LEVEL
```
- MAX_LIST_PRINT_SIZE
```
public static int MAX_LIST_PRINT_SIZE
```
  The max size of an address list, e.g. used in View or Digest when toString() is called. Limiting this reduces the amount of log data

Constructor Detail
- Util
```
public Util()
```

Method Detail

getGlobalThreadGroup

public static ThreadGroup getGlobalThreadGroup()

assertTrue

public static void assertTrue(boolean condition)

assertTrue

public static void assertTrue(String message,
              boolean condition)

assertFalse

public static void assertFalse(boolean condition)

assertFalse

public static void assertFalse(String message,
               boolean condition)

assertEquals

public static void assertEquals(String message,
                Object val1,
                Object val2)

assertEquals

public static void assertEquals(Object val1,
                Object val2)

assertNotNull

public static void assertNotNull(String message,
                 Object val)

assertNotNull

public static void assertNotNull(Object val)

assertNull

public static void assertNull(String message,
              Object val)

waitUntilAllChannelsHaveSameSize
```
public static void waitUntilAllChannelsHaveSameSize(long timeout,
                                    long interval,
                                    Channel... channels)
                                             throws TimeoutException
```
Blocks until all channels have the same view

Parameters:
timeout - How long to wait (max in ms)
interval - Check every interval ms
channels - The channels which should form the view. The expected view size is channels.length. Must be non-null

Throws:

TimeoutException

addFlush

public static void addFlush(Channel ch,
            FLUSH flush)

setScope

public static void setScope(Message msg,
            short scope)

getScope

public static short getScope(Message msg)

connect

public static void connect(Socket sock,
           SocketAddress dest,
           int sock_conn_timeout)
                    throws IOException

Utility method. If the dest address is IPv6, convert scoped link-local addrs into unscoped ones

Parameters:: sock -; dest -; sock_conn_timeout -
Throws:: IOException

close

public static void close(InputStream inp)

close

public static void close(OutputStream out)

close
```
public static void close(Socket s)
```

close

public static void close(ServerSocket s)

close

public static void close(DatagramSocket my_sock)

close
```
public static void close(Channel ch)
```

close

public static void close(Channel... channels)

close

public static void close(Connection conn)

shutdown
```
public static void shutdown(Channel ch)
                     throws Exception
```
Drops messages to/from other members and then closes the channel. Note that this member won't get excluded from the view until failure detection has kicked in and the new coord installed the new view

Throws:

Exception

setFlag

public static byte setFlag(byte bits,
           byte flag)

isFlagSet

public static boolean isFlagSet(byte bits,
                byte flag)

clearFlags

public static byte clearFlags(byte bits,
              byte flag)

objectFromByteBuffer

public static Object objectFromByteBuffer(byte[] buffer)
                                   throws Exception

Creates an object from a byte buffer

Throws:: Exception

objectFromByteBuffer

public static Object objectFromByteBuffer(byte[] buffer,
                          int offset,
                          int length)
                                   throws Exception

Throws:: Exception

objectToByteBuffer
```
public static byte[] objectToByteBuffer(Object obj)
                                 throws Exception
```
Serializes/Streams an object into a byte buffer. The object has to implement interface Serializable or Externalizable or Streamable.

Throws:

Exception

objectToStream

public static void objectToStream(Object obj,
                  DataOutput out)
                           throws Exception

Throws:: Exception

objectFromStream

public static Object objectFromStream(DataInput in)
                               throws Exception

Throws:: Exception

streamableFromByteBuffer

public static Streamable streamableFromByteBuffer(Class<? extends Streamable> cl,
                                  byte[] buffer)
                                           throws Exception

Throws:: Exception

streamableFromByteBuffer

public static Streamable streamableFromByteBuffer(Class<? extends Streamable> cl,
                                  byte[] buffer,
                                  int offset,
                                  int length)
                                           throws Exception

Throws:: Exception

streamableToByteBuffer

public static byte[] streamableToByteBuffer(Streamable obj)
                                     throws Exception

Throws:: Exception

collectionToByteBuffer

public static byte[] collectionToByteBuffer(Collection<Address> c)
                                     throws Exception

Throws:: Exception

writeAuthToken

public static void writeAuthToken(AuthToken token,
                  DataOutput out)
                           throws Exception

Throws:: Exception

readAuthToken

public static AuthToken readAuthToken(DataInput in)
                               throws Exception

Throws:: Exception

writeView

public static void writeView(View view,
             DataOutput out)
                      throws Exception

Throws:: Exception

readView

public static View readView(DataInput in)
                     throws Exception

Throws:: Exception

writeViewId

public static void writeViewId(ViewId vid,
               DataOutput out)
                        throws Exception

Throws:: Exception

readViewId

public static ViewId readViewId(DataInput in)
                         throws Exception

Throws:: Exception

writeAddress

public static void writeAddress(Address addr,
                DataOutput out)
                         throws Exception

Throws:: Exception

readAddress

public static Address readAddress(DataInput in)
                           throws Exception

Throws:: Exception

size
```
public static int size(Address addr)
```

size
```
public static int size(View view)
```

size
```
public static int size(ViewId vid)
```

writeAddresses

public static void writeAddresses(Collection<? extends Address> v,
                  DataOutput out)
                           throws Exception

Writes a Vector of Addresses. Can contain 65K addresses at most

Parameters:: v - A Collection; out -
Throws:: Exception

readAddresses

public static Collection<? extends Address> readAddresses(DataInput in,
                                          Class cl)
                                                   throws Exception

Parameters:: in -; cl - The type of Collection, e.g. ArrayList.class
Returns:: Collection of Address objects
Throws:: Exception

size
```
public static long size(Collection<? extends Address> addrs)
```
Returns the marshalled size of a Collection of Addresses. Assumes elements are of the same type !

Parameters:
addrs - Collection

Returns:
long size

writeStreamable

public static void writeStreamable(Streamable obj,
                   DataOutput out)
                            throws Exception

Throws:: Exception

readStreamable

public static Streamable readStreamable(Class clazz,
                        DataInput in)
                                 throws Exception

Throws:: Exception

writeGenericStreamable

public static void writeGenericStreamable(Streamable obj,
                          DataOutput out)
                                   throws Exception

Throws:: Exception

readGenericStreamable

public static Streamable readGenericStreamable(DataInput in)
                                        throws Exception

Throws:: Exception

writeClass

public static void writeClass(Class<?> classObject,
              DataOutput out)
                       throws Exception

Throws:: Exception

readClass

public static Class<?> readClass(DataInput in)
                          throws Exception

Throws:: Exception

writeObject

public static void writeObject(Object obj,
               DataOutput out)
                        throws Exception

Throws:: Exception

readObject

public static Object readObject(DataInput in)
                         throws Exception

Throws:: Exception

writeString

public static void writeString(String s,
               DataOutput out)
                        throws Exception

Throws:: Exception

readString

public static String readString(DataInput in)
                         throws Exception

Throws:: Exception

readFile

public static String readFile(String filename)
                       throws FileNotFoundException

Throws:: FileNotFoundException

readContents

public static String readContents(InputStream input)

parseString

public static String parseString(DataInput in)

readStringFromStdin

public static String readStringFromStdin(String message)
                                  throws Exception

Throws:: Exception

readLongFromStdin

public static long readLongFromStdin(String message)
                              throws Exception

Throws:: Exception

readDoubleFromStdin

public static double readDoubleFromStdin(String message)
                                  throws Exception

Throws:: Exception

readIntFromStdin

public static int readIntFromStdin(String message)
                            throws Exception

Throws:: Exception

writeByteBuffer

public static void writeByteBuffer(byte[] buf,
                   DataOutput out)
                            throws Exception

Throws:: Exception

writeByteBuffer

public static void writeByteBuffer(byte[] buf,
                   int offset,
                   int length,
                   DataOutput out)
                            throws Exception

Throws:: Exception

readByteBuffer

public static byte[] readByteBuffer(DataInput in)
                             throws Exception

Throws:: Exception

messageToByteBuffer

public static Buffer messageToByteBuffer(Message msg)
                                  throws Exception

Throws:: Exception

byteBufferToMessage

public static Message byteBufferToMessage(byte[] buffer,
                          int offset,
                          int length)
                                   throws Exception

Throws:: Exception

msgListToByteBuffer

public static Buffer msgListToByteBuffer(List<Message> xmit_list)
                                  throws Exception

Marshalls a list of messages.

Parameters:: xmit_list - LinkedList
Returns:: Buffer
Throws:: Exception

match

public static boolean match(Object obj1,
            Object obj2)

match

public static boolean match(long[] a1,
            long[] a2)

sleep
```
public static void sleep(long timeout)
```
Sleep for timeout msecs. Returns when timeout has elapsed or thread was interrupted

sleep

public static void sleep(long timeout,
         int nanos)

sleep
```
public static void sleep(long msecs,
         boolean busy_sleep)
```
On most UNIX systems, the minimum sleep time is 10-20ms. Even if we specify sleep(1), the thread will sleep for at least 10-20ms. On Windows, sleep() seems to be implemented as a busy sleep, that is the thread never relinquishes control and therefore the sleep(x) is exactly x ms long.

keyPress

public static int keyPress(String msg)

random
```
public static long random(long range)
```
Returns a random value in the range [1 - range]

sleepRandom

public static void sleepRandom(long floor,
               long ceiling)

Sleeps between floor and ceiling milliseconds, chosen randomly

tossWeightedCoin
```
public static boolean tossWeightedCoin(double probability)
```
Tosses a coin weighted with probability and returns true or false. Example: if probability=0.8, chances are that in 80% of all cases, true will be returned and false in 20%.

dumpThreads
```
public static String dumpThreads()
```

_printThreads

protected static void _printThreads(ThreadMXBean bean,
                 long[] ids,
                 StringBuilder sb)

interruptAndWaitToDie

public static boolean interruptAndWaitToDie(Thread t)

interruptAndWaitToDie

public static boolean interruptAndWaitToDie(Thread t,
                            long timeout)

dumpQueue
```
public static String dumpQueue(Queue q)
```
Debugging method used to dump the content of a protocol queue in a condensed form. Useful to follow the evolution of the queue's content in time.

printStackTrace

public static String printStackTrace(Throwable t)

Use with caution: lots of overhead

getStackTrace

public static String getStackTrace(Throwable t)

print

public static String print(Throwable t)

crash
```
public static void crash()
```

printEvent

public static String printEvent(Event evt)

printMessage
```
public static String printMessage(Message msg)
```
Tries to read an object from the message's buffer and prints it

mapToString

public static String mapToString(Map<? extends Object,? extends Object> map)

printThreads
```
public static void printThreads()
```

activeThreads
```
public static String activeThreads()
```

printBytes
```
public static String printBytes(long bytes)
```
MByte nowadays doesn't mean 1024 * 1024 bytes, but 1 million bytes, see http://en.wikipedia.org/wiki/Megabyte

Parameters:
bytes -

Returns:

printTime

public static String printTime(long time,
               TimeUnit unit)

format

public static String format(double value)

readBytesLong

public static long readBytesLong(String input)

readBytesInteger

public static int readBytesInteger(String input)

readBytesDouble

public static double readBytesDouble(String input)

printBytes

public static String printBytes(double bytes)

split

public static List<String> split(String input,
                 int separator)

components

public static String[] components(String path,
                  String separator)

fragmentBuffer
```
public static byte[][] fragmentBuffer(byte[] buf,
                      int frag_size,
                      int length)
```
Fragments a byte buffer into smaller fragments of (max.) frag_size. Example: a byte buffer of 1024 bytes and a frag_size of 248 gives 4 fragments of 248 bytes each and 1 fragment of 32 bytes.

Returns:
An array of byte buffers (byte[]).

fragmentBuffer

public static byte[][] fragmentBuffer(byte[] buf,
                      int frag_size)

computeFragOffsets
```
public static List<Range> computeFragOffsets(int offset,
                             int length,
                             int frag_size)
```
Given a buffer and a fragmentation size, compute a list of fragmentation offset/length pairs, and return them in a list. Example:
Buffer is 10 bytes, frag_size is 4 bytes. Return value will be ({0,4}, {4,4}, {8,2}). This is a total of 3 fragments: the first fragment starts at 0, and has a length of 4 bytes, the second fragment starts at offset 4 and has a length of 4 bytes, and the last fragment starts at offset 8 and has a length of 2 bytes.

Parameters:
frag_size -

Returns:
List. A List of offset/length pairs

computeFragOffsets

public static List<Range> computeFragOffsets(byte[] buf,
                             int frag_size)

defragmentBuffer
```
public static byte[] defragmentBuffer(byte[][] fragments)
```
Concatenates smaller fragments into entire buffers.

Parameters:
fragments - An array of byte buffers (byte[])

Returns:
A byte buffer

printFragments

public static void printFragments(byte[][] frags)

encode

public static byte[] encode(long num)

getByteAt

protected static byte getByteAt(long num,
             int index)

decode

public static long decode(byte[] buf)

writeLong

public static void writeLong(long num,
             DataOutput out)
                      throws Exception

Throws:: Exception

readLong

public static long readLong(DataInput in)
                     throws Exception

Throws:: Exception

encodeLongSequence
```
public static byte[] encodeLongSequence(long highest_delivered,
                        long highest_received)
```
Encode the highest delivered and received seqnos. The assumption is that the latter is always >= the former, and highest received is not much higher than highest delivered.

Parameters:
highest_delivered -
highest_received -

Returns:

size
```
public static byte size(long number)
```

size
```
public static byte size(long hd,
        long hr)
```
Writes 2 longs, where the second long needs to be >= the first (we only write the delta !)

Parameters:
hd -
hr -

Returns:

decodeLongSequence

public static long[] decodeLongSequence(byte[] buf)

writeLongSequence

public static void writeLongSequence(long highest_delivered,
                     long highest_received,
                     DataOutput out)
                              throws Exception

Throws:: Exception

readLongSequence

public static long[] readLongSequence(DataInput in)
                               throws Exception

Throws:: Exception

encodeLength
```
public static byte encodeLength(byte len1,
                byte len2)
```
Encodes the number of bytes needed into a single byte. The first number is encoded in the first nibble (the first 4 bits), the second number in the second nibble

Parameters:
len1 - The number of bytes needed to store a long. Must be between 0 and 8
len2 - The number of bytes needed to store a long. Must be between 0 and 8

Returns:
The byte storing the 2 numbers len1 and len2

decodeLength

public static byte[] decodeLength(byte len)

printListWithDelimiter

public static <T> String printListWithDelimiter(Collection<T> list,
                                String delimiter)

printListWithDelimiter

public static <T> String printListWithDelimiter(Collection<T> list,
                                String delimiter,
                                int limit)

printMapWithDelimiter

public static <T> String printMapWithDelimiter(Map<T,T> map,
                               String delimiter)

array2String

public static String array2String(long[] array)

array2String

public static String array2String(short[] array)

array2String

public static String array2String(int[] array)

array2String

public static String array2String(boolean[] array)

array2String

public static String array2String(Object[] array)

all

public static boolean all(Collection c,
          Object obj)

Returns true if all elements of c match obj

leftMembers

public static List<Address> leftMembers(View one,
                        View two)

Returns a list of members which left from view one to two

Parameters:: one -; two -
Returns:

leftMembers

public static List<Address> leftMembers(Collection<Address> old_list,
                        Collection<Address> new_list)

newMembers

public static List<Address> newMembers(List<Address> old_list,
                       List<Address> new_list)

newElements

public static <T> List<T> newElements(List<T> old_list,
                      List<T> new_list)

pickSubset
```
public static List<Address> pickSubset(List<Address> members,
                       double subset_percentage)
```
Selects a random subset of members according to subset_percentage and returns them. Picks no member twice from the same membership. If the percentage is smaller than 1 -> picks 1 member.

containsViewId

public static boolean containsViewId(Collection<View> views,
                     ViewId vid)

determineMergeParticipants
```
public static Collection<Address> determineMergeParticipants(Map<Address,View> map)
```
Determines the members which take part in a merge. The resulting list consists of all merge coordinators plus members outside a merge partition, e.g. for views A={B,A,C}, B={B,C} and C={B,C}, the merge coordinator is B, but the merge participants are B and A.

Parameters:
map -

Returns:

determineMergeCoords
```
public static Collection<Address> determineMergeCoords(Map<Address,View> map)
```
This is the same or a subset of determineMergeParticipants(java.util.Map) and contains only members which are currently sub-partition coordinators.

Parameters:
map -

Returns:

getRank
```
public static int getRank(View view,
          Address addr)
```
Returns the rank of a member in a given view

Parameters:
view - The view
addr - The address of a member

Returns:
A value between 1 and view.size(). The first member has rank 1, the second 2 and so on. If the member is not found, 0 is returned

pickRandomElement

public static Object pickRandomElement(List list)

pickRandomElement

public static Object pickRandomElement(Object[] array)

pickNext
```
public static <T> T pickNext(List<T> list,
             T obj)
```
Returns the object next to element in list

Type Parameters:
T -
Parameters:
list -
obj -

Returns:

pickNext

public static <T> List<T> pickNext(List<T> list,
                   T obj,
                   int num)

Returns the next min(N,list.size()) elements after obj

createView

public static View createView(Address coord,
              long id,
              Address... members)

createChannel

public static JChannel createChannel(Protocol... prots)
                              throws Exception

Throws:: Exception

createRandomAddress

public static Address createRandomAddress()

createRandomAddress

public static Address createRandomAddress(String name)

createTimer

public static Object[][] createTimer()

determineLeftMembers

public static List<Address> determineLeftMembers(List<Address> old_mbrs,
                                 List<Address> new_mbrs)

Returns all members that left between 2 views. All members that are element of old_mbrs but not element of new_mbrs are returned.

printViews

public static String printViews(Collection<View> views)

print

public static <T> String print(Collection<T> objs)

print

public static <T> String print(Map<T,T> map)

printPingData

public static String printPingData(List<PingData> rsps)

doubleWrite
```
public static void doubleWrite(byte[] buf,
               OutputStream out)
                        throws Exception
```
Makes sure that we detect when a peer connection is in the closed state (not closed while we send data, but before we send data). Two writes ensure that, if the peer closed the connection, the first write will send the peer from FIN to RST state, and the second will cause a signal (Exception).

Throws:

Exception

doubleWrite
```
public static void doubleWrite(byte[] buf,
               int offset,
               int length,
               OutputStream out)
                        throws Exception
```
Makes sure that we detect when a peer connection is in the closed state (not closed while we send data, but before we send data). Two writes ensure that, if the peer closed the connection, the first write will send the peer from FIN to RST state, and the second will cause a signal (Exception).

Throws:

Exception

writeFully
```
public static void writeFully(ByteBuffer buf,
              WritableByteChannel out)
                       throws Exception
```
if we were to register for OP_WRITE and send the remaining data on readyOps for this channel we have to either block the caller thread or queue the message buffers that may arrive while waiting for OP_WRITE. Instead of the above approach this method will continuously write to the channel until the buffer sent fully.

Throws:

Exception

sizeOf

public static long sizeOf(String classname)

sizeOf

public static long sizeOf(Object inst)

sizeOf

public static int sizeOf(Streamable inst)

loadClass
```
public static Class loadClass(String classname,
              Class clazz)
                       throws ClassNotFoundException
```
Tries to load the class from the current thread's context class loader. If not successful, tries to load the class from the current instance.

Parameters:
classname - Desired class.
clazz - Class object used to obtain a class loader if no context class loader is available.

Returns:
Class, or null on failure.

Throws:

ClassNotFoundException

getAllDeclaredFields

public static Field[] getAllDeclaredFields(Class clazz)

getAllDeclaredFieldsWithAnnotations

public static Field[] getAllDeclaredFieldsWithAnnotations(Class clazz,
                                          Class<? extends Annotation>... annotations)

getAllDeclaredMethods

public static Method[] getAllDeclaredMethods(Class clazz)

getAllDeclaredMethodsWithAnnotations

public static Method[] getAllDeclaredMethodsWithAnnotations(Class clazz,
                                            Class<? extends Annotation>... annotations)

getField

public static Field getField(Class clazz,
             String field_name)

getResourceAsStream

public static InputStream getResourceAsStream(String name,
                              Class clazz)

sameHost

public static boolean sameHost(Address one,
               Address two)

Checks whether 2 Addresses are on the same host

fileExists

public static boolean fileExists(String fname)

verifyRejectionPolicy

public static void verifyRejectionPolicy(String str)
                                  throws Exception

Throws:: Exception

parseRejectionPolicy

public static RejectedExecutionHandler parseRejectionPolicy(String rejection_policy)

parseCommaDelimitedInts
```
public static int[] parseCommaDelimitedInts(String s)
```
Parses comma-delimited longs; e.g., 2000,4000,8000. Returns array of long, or null.

parseCommaDelimitedLongs
```
public static long[] parseCommaDelimitedLongs(String s)
```
Parses comma-delimited longs; e.g., 2000,4000,8000. Returns array of long, or null.

parseCommaDelimitedStrings
```
public static List<String> parseCommaDelimitedStrings(String l)
```
e.g. "bela,jeannette,michelle" --> List{"bela", "jeannette", "michelle"}

parseCommaDelimitedHosts

public static List<IpAddress> parseCommaDelimitedHosts(String hosts,
                                       int port_range)
                                                throws UnknownHostException

Input is "daddy[8880],sindhu[8880],camille[5555]. Returns a list of IpAddresses

Throws:: UnknownHostException

parseCommaDelimitedHosts2

public static List<InetSocketAddress> parseCommaDelimitedHosts2(String hosts,
                                                int port_range)

Input is "daddy[8880],sindhu[8880],camille[5555]. Return List of InetSocketAddress

parseStringList

public static List<String> parseStringList(String l,
                           String separator)

parseString

public static String parseString(ByteBuffer buf)

parseString

public static String parseString(ByteBuffer buf,
                 boolean discard_whitespace)

readNewLine

public static int readNewLine(ByteBuffer buf)

discardUntilNewLine
```
public static int discardUntilNewLine(InputStream in)
```
Reads and discards all characters from the input stream until a \r\n or EOF is encountered

Parameters:
in -

Returns:

readLine
```
public static String readLine(InputStream in)
                       throws IOException
```
Reads a line of text. A line is considered to be terminated by any one of a line feed ('\n'), a carriage return ('\r'), or a carriage return followed immediately by a linefeed.

Returns:
A String containing the contents of the line, not including any line-termination characters, or null if the end of the stream has been reached

Throws:

IOException - If an I/O error occurs

writeString

public static void writeString(ByteBuffer buf,
               String s)

parseInterfaceList

public static List<NetworkInterface> parseInterfaceList(String s)
                                                 throws Exception

Parameters:: s -
Returns:: List
Throws:: Exception

print

public static String print(List<NetworkInterface> interfaces)

shortName

public static String shortName(String hostname)

startFlush

public static boolean startFlush(Channel c,
                 List<Address> flushParticipants,
                 int numberOfAttempts,
                 long randomSleepTimeoutFloor,
                 long randomSleepTimeoutCeiling)

startFlush

public static boolean startFlush(Channel c,
                 List<Address> flushParticipants)

startFlush

public static boolean startFlush(Channel c,
                 int numberOfAttempts,
                 long randomSleepTimeoutFloor,
                 long randomSleepTimeoutCeiling)

startFlush

public static boolean startFlush(Channel c)

shortName

public static String shortName(InetAddress hostname)

generateLocalName

public static String generateLocalName()

incrCounter
```
public static short incrCounter()
```

createConcurrentMap

public static <K,V> ConcurrentMap<K,V> createConcurrentMap(int initial_capacity,
                                           float load_factor,
                                           int concurrency_level)

createConcurrentMap

public static <K,V> ConcurrentMap<K,V> createConcurrentMap(int initial_capacity)

createConcurrentMap

public static <K,V> ConcurrentMap<K,V> createConcurrentMap()

createHashMap

public static <K,V> Map<K,V> createHashMap()

createServerSocket

public static ServerSocket createServerSocket(SocketFactory factory,
                              String service_name,
                              InetAddress bind_addr,
                              int start_port)

createServerSocket

public static ServerSocket createServerSocket(SocketFactory factory,
                              String service_name,
                              InetAddress bind_addr,
                              int start_port,
                              int end_port)
                                       throws Exception

Finds first available port starting at start_port and returns server socket. Will not bind to port >end_port. Sets srv_port

Throws:: Exception

createDatagramSocket
```
public static DatagramSocket createDatagramSocket(SocketFactory factory,
                                  String service_name,
                                  InetAddress addr,
                                  int port)
                                           throws Exception
```
Creates a DatagramSocket bound to addr. If addr is null, socket won't be bound. If address is already in use, start_port will be incremented until a socket can be created.

Parameters:
addr - The InetAddress to which the socket should be bound. If null, the socket will not be bound.
port - The port which the socket should use. If 0, a random port will be used. If > 0, but port is already in use, it will be incremented until an unused port is found, or until MAX_PORT is reached.

Throws:

Exception

createMulticastSocket

public static MulticastSocket createMulticastSocket(SocketFactory factory,
                                    String service_name,
                                    InetAddress mcast_addr,
                                    int port,
                                    Log log)
                                             throws IOException

Throws:: IOException

getBindAddress

public static InetAddress getBindAddress(Properties props)
                                  throws UnknownHostException,
                                         SocketException

Returns the address of the interface to use defined by bind_addr and bind_interface

Parameters:: props -
Returns:
Throws:: UnknownHostException; SocketException

validateBindAddressFromInterface
```
public static InetAddress validateBindAddressFromInterface(InetAddress bind_addr,
                                           String bind_interface_str)
                                                    throws UnknownHostException,
                                                           SocketException
```
Method used by PropertyConverters.BindInterface to check that a bind_address is consistent with a specified interface Idea: 1. We are passed a bind_addr, which may be null 2. If non-null, check that bind_addr is on bind_interface - if not, throw exception, otherwise, return the original bind_addr 3. If null, get first non-loopback address on bind_interface, using stack preference to get the IP version. If no non-loopback address, then just return null (i.e. the bind_interface did not influence the decision).

Throws:

UnknownHostException

SocketException

checkForLinux
```
public static boolean checkForLinux()
```

checkForHp
```
public static boolean checkForHp()
```

checkForSolaris

public static boolean checkForSolaris()

checkForWindows

public static boolean checkForWindows()

checkForMac
```
public static boolean checkForMac()
```

prompt
```
public static void prompt(String s)
```

getLocalhost

public static InetAddress getLocalhost(StackType ip_version)
                                throws UnknownHostException

IP related utilities

Throws:: UnknownHostException

getNonLoopbackAddress

public static InetAddress getNonLoopbackAddress()
                                         throws SocketException

Returns the first non-loopback address on any interface on the current host.

Throws:: SocketException

getAddress

public static InetAddress getAddress(Util.AddressScope scope)
                              throws SocketException

Returns the first address on any interface of the current host, which satisfies scope

Throws:: SocketException

getAddress
```
public static InetAddress getAddress(NetworkInterface intf,
                     Util.AddressScope scope)
```
Returns the first address on the given interface on the current host, which satisfies scope

Parameters:
intf - the interface to be checked

interfaceHasIPAddresses

public static boolean interfaceHasIPAddresses(NetworkInterface intf,
                              StackType ip_version)
                                       throws UnknownHostException

A function to check if an interface supports an IP version (i.e has addresses defined for that IP version).

Parameters:: intf -
Returns:
Throws:: UnknownHostException

getIpStackType

public static StackType getIpStackType()

isStackAvailable

public static boolean isStackAvailable(boolean ipv4)

getAllAvailableInterfaces

public static List<NetworkInterface> getAllAvailableInterfaces()
                                                        throws SocketException

Throws:: SocketException

getAllAvailableAddresses

public static Collection<InetAddress> getAllAvailableAddresses()

checkIfValidAddress

public static void checkIfValidAddress(InetAddress bind_addr,
                       String prot_name)
                                throws Exception

Throws:: Exception

getProperty
```
public static String getProperty(String[] system_props,
                 Properties props,
                 String prop_name,
                 boolean ignore_sysprops,
                 String default_value)
```
Returns a value associated wither with one or more system properties, or found in the props map

Parameters:
system_props -
props - List of properties read from the configuration file
prop_name - The name of the property, will be removed from props if found
ignore_sysprops - If true, system properties are not used and the values will only be retrieved from props (not system_props)
default_value - Used to return a default value if the properties or system properties didn't have the value

Returns:
The value, or null if not found

isBindAddressPropertyIgnored

public static boolean isBindAddressPropertyIgnored()

isCoordinator

public static boolean isCoordinator(JChannel ch)

isCoordinator

public static boolean isCoordinator(View view,
                    Address local_addr)

getMBeanServer

public static MBeanServer getMBeanServer()

registerChannel

public static void registerChannel(JChannel channel,
                   String name)

generateList

public static String generateList(Collection c,
                  String separator)

replaceProperties
```
public static String replaceProperties(String string,
                       Properties props)
```
Go through the input string and replace any occurance of ${p} with the props.getProperty(p) value. If there is no such property p defined, then the ${p} reference will remain unchanged. If the property reference is of the form ${p:v} and there is no such property p, then the default value v will be returned. If the property reference is of the form ${p1,p2} or ${p1,p2:v} then the primary and the secondary properties will be tried in turn, before returning either the unchanged input, or the default value. The property ${/} is replaced with System.getProperty("file.separator") value and the property ${:} is replaced with System.getProperty("path.separator").

Parameters:
string - - the string with possible ${} references
props - - the source for ${x} property ref values, null means use System.getProperty()

Returns:
the input string with all property references replaced if any. If there are no valid references the input string will be returned.

Throws:

{@link - java.security.AccessControlException} when not authorised to retrieved system properties

substituteVariable
```
public static String substituteVariable(String val)
```
Replaces variables of ${var:default} with System.getProperty(var, default). If no variables are found, returns the same string, otherwise a copy of the string with variables substituted

Parameters:
val -

Returns:
A string with vars replaced, or the same string if no vars found

getProperty

public static String getProperty(String s)

md5
```
public static String md5(String source)
```
Converts a java.lang.String in to a MD5 hashed String

Parameters:
source - the source String

Returns:
the MD5 hashed version of the string

sha
```
public static String sha(String source)
```
Converts a java.lang.String in to a SHA hashed String

Parameters:
source - the source String

Returns:
the MD5 hashed version of the string

methodNameToAttributeName

public static String methodNameToAttributeName(String methodName)

attributeNameToMethodName

public static String attributeNameToMethodName(String attr_name)

runAsync

public static void runAsync(Runnable task,
            ThreadFactory factory,
            ThreadGroup group,
            String thread_name)

Runs a task on a separate thread

Parameters:: task -; factory -; group -; thread_name -

Class Util

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

MAX_PORT

CCHM_INITIAL_CAPACITY

CCHM_LOAD_FACTOR

CCHM_CONCURRENCY_LEVEL

MAX_LIST_PRINT_SIZE

Constructor Detail

Util

Method Detail

getGlobalThreadGroup

assertTrue

assertTrue

assertFalse

assertFalse

assertEquals

assertEquals

assertNotNull

assertNotNull

assertNull

waitUntilAllChannelsHaveSameSize

addFlush

setScope

getScope

connect

close

close

close

close

close

close

close

close

shutdown

setFlag

isFlagSet

clearFlags

objectFromByteBuffer

objectFromByteBuffer

objectToByteBuffer

objectToStream

objectFromStream

streamableFromByteBuffer

streamableFromByteBuffer

streamableToByteBuffer

collectionToByteBuffer

writeAuthToken

readAuthToken

writeView

readView

writeViewId

readViewId

writeAddress

readAddress

size

size

size

writeAddresses

readAddresses

size

writeStreamable

readStreamable

writeGenericStreamable

readGenericStreamable

writeClass

readClass

writeObject

readObject

writeString

readString

readFile

readContents

parseString

readStringFromStdin

readLongFromStdin