|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.javagroups.util.Util
Collection of various utility routines that can not be assigned to other classes.
Field Summary | |
static int |
MAX_PORT
|
Constructor Summary | |
Util()
|
Method Summary | |
static java.lang.String |
activeThreads()
|
static java.lang.String |
array2String(boolean[] array)
|
static java.lang.String |
array2String(int[] array)
|
static java.lang.String |
array2String(long[] array)
|
static boolean |
checkForLinux()
|
static boolean |
checkForSolaris()
|
static boolean |
checkForWindows()
|
static void |
crash()
|
static java.net.DatagramSocket |
createDatagramSocket(java.net.InetAddress addr,
int port)
Creates a DatagramSocket bound to addr. |
static java.net.ServerSocket |
createServerSocket(int start_port)
Finds first available port starting at start_port and returns server socket |
static byte[] |
defragmentBuffer(byte[][] fragments)
Concatenates smaller fragments into entire buffers. |
static void |
doubleWrite(byte[] buf,
java.io.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 |
dumpStack(boolean exit)
|
static boolean |
fileExists(java.lang.String fname)
|
static byte[][] |
fragmentBuffer(byte[] buf,
int frag_size)
Fragments a byte buffer into smaller fragments of (max.) frag_size. |
static java.lang.String |
getHostname()
|
static void |
main(java.lang.String[] args)
|
static java.lang.Object |
objectFromByteBuffer(byte[] buffer)
Creates an object from a byte buffer |
static byte[] |
objectToByteBuffer(java.lang.Object obj)
Serializes an object into a byte buffer. |
static long[] |
parseCommaDelimitedLongs(java.lang.String s)
E.g. |
static java.util.Vector |
pickSubset(java.util.Vector members,
double subset_percentage)
Selects a random subset of members according to subset_percentage and returns them. |
static java.lang.String |
print(java.lang.Throwable t)
|
static java.lang.String |
printEvent(Event evt)
|
static void |
printFragments(byte[][] frags)
|
static java.lang.String |
printMembers(java.util.Vector v)
|
static java.lang.String |
printMessage(Message msg)
Tries to read an object from the message's buffer and prints it |
static java.lang.String |
printMethodCall(Message msg)
Tries to read a MethodCall object from the message's buffer and prints it. |
static java.lang.String |
printStackTrace(java.lang.Throwable t)
Use with caution: lots of overhead |
static void |
printThreads()
|
static long |
random(long range)
Returns a random value in the range [1 - range] |
static void |
removeFile(java.lang.String fname)
|
static boolean |
sameHost(Address one,
Address two)
Checks whether 2 Addresses are on the same host |
static java.lang.String |
shortName(java.lang.String hostname)
|
static long |
sizeOf(java.lang.Object inst)
|
static long |
sizeOf(java.lang.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 |
sleepRandom(long timeout)
Sleeps between 1 and timeout milliseconds, chosen randomly. |
static boolean |
tossWeightedCoin(double probability)
Tosses a coin weighted with probability and returns true or false. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static int MAX_PORT
Constructor Detail |
public Util()
Method Detail |
public static java.lang.Object objectFromByteBuffer(byte[] buffer) throws java.lang.Exception
public static byte[] objectToByteBuffer(java.lang.Object obj) throws java.lang.Exception
public static void sleep(long timeout)
public static void sleep(long msecs, boolean busy_sleep)
public static long random(long range)
public static void sleepRandom(long timeout)
public static boolean tossWeightedCoin(double probability)
public static java.lang.String getHostname()
public static void dumpStack(boolean exit)
public static java.lang.String printStackTrace(java.lang.Throwable t)
public static java.lang.String print(java.lang.Throwable t)
public static void crash()
public static java.lang.String printEvent(Event evt)
public static java.lang.String printMessage(Message msg)
public static java.lang.String printMethodCall(Message msg)
MethodCall
object from the message's buffer and prints it.
Returns empty string if object is not a method callpublic static void printThreads()
public static java.lang.String activeThreads()
public static byte[][] fragmentBuffer(byte[] buf, int frag_size)
byte[]
).public static byte[] defragmentBuffer(byte[][] fragments)
fragments
- An array of byte buffers (byte[]
)public static void printFragments(byte[][] frags)
public static java.lang.String array2String(long[] array)
public static java.lang.String array2String(int[] array)
public static java.lang.String array2String(boolean[] array)
public static java.util.Vector pickSubset(java.util.Vector members, double subset_percentage)
public static java.lang.String printMembers(java.util.Vector v)
public static void doubleWrite(byte[] buf, java.io.OutputStream out) throws java.lang.Exception
public static long sizeOf(java.lang.String classname)
public static long sizeOf(java.lang.Object inst)
public static boolean sameHost(Address one, Address two)
public static void removeFile(java.lang.String fname)
public static boolean fileExists(java.lang.String fname)
public static long[] parseCommaDelimitedLongs(java.lang.String s)
public static java.lang.String shortName(java.lang.String hostname)
public static java.net.ServerSocket createServerSocket(int start_port)
public static java.net.DatagramSocket createDatagramSocket(java.net.InetAddress addr, int port) throws java.lang.Exception
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.public static boolean checkForLinux()
public static boolean checkForSolaris()
public static boolean checkForWindows()
public static void main(java.lang.String[] args)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |