|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sleepycat.je.rep.utilint.RepUtils
public class RepUtils
Nested Class Summary | |
---|---|
static interface |
RepUtils.ConsistencyPolicyFormat<T extends ReplicaConsistencyPolicy>
ReplicaConsistencyPolicy must be stored as a String for use with ReplicationConfig and je.properties. |
static class |
RepUtils.ExceptionAwareCountDownLatch
Like CountDownLatch, but makes provision in the await for the await, or more specifically the new awaitOrException method to be exited via an exception. |
static class |
RepUtils.MapOver<R,E>
Lisp inspired Map function. |
Field Summary | |
---|---|
static SocketChannel |
CHANNEL_EOF_MARKER
|
static boolean |
DEBUG_PRINT_THREAD
|
static boolean |
DEBUG_PRINT_TIME
|
Constructor Summary | |
---|---|
RepUtils()
|
Method Summary | |
---|---|
static void |
addConsistencyPolicyFormat(String name,
RepUtils.ConsistencyPolicyFormat<?> format)
Define a new ConsistencyPolicyFormat. |
static Throwable |
chainExceptionCause(Throwable newt,
Throwable oldt)
Chains an old outstanding exception to the tail of a new one, so it's not lost. |
static String |
getPropertyString(ReplicaConsistencyPolicy policy)
Converts a policy into a string suitable for use as a property value in a je.properties file or elsewhere. |
static ReplicaConsistencyPolicy |
getReplicaConsistencyPolicy(String propertyValue)
Converts a property string into a policy instance. |
static SocketChannel |
openBlockingChannel(InetSocketAddress addr,
boolean tcpNoDelay,
int timeout)
|
static void |
shutdownChannel(NamedChannel namedChannel)
Forces a shutdown of the channel ignoring any errors that may be encountered in the process. |
static String |
writeTimesString(StatGroup stats)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final boolean DEBUG_PRINT_THREAD
public static final boolean DEBUG_PRINT_TIME
public static final SocketChannel CHANNEL_EOF_MARKER
Constructor Detail |
---|
public RepUtils()
Method Detail |
---|
public static void addConsistencyPolicyFormat(String name, RepUtils.ConsistencyPolicyFormat<?> format)
name
- must be the first part of the policy string with a
non-letter delimiter following it, or must be the entire policy string.format
- to register.public static String getPropertyString(ReplicaConsistencyPolicy policy) throws IllegalArgumentException
policy
- the policy being converted.
IllegalArgumentException
- if the specific policy does not have a
property value format, via ReplicationConfig(Properties) ctor and
setter.getReplicaConsistencyPolicy(String)
public static ReplicaConsistencyPolicy getReplicaConsistencyPolicy(String propertyValue) throws IllegalArgumentException
propertyValue
- the formatted string representing the policy.
IllegalArgumentException
- via ReplicationConfig(Properties) ctor
and setter.public static void shutdownChannel(NamedChannel namedChannel)
namedChannel
- the channel to be shutdownpublic static SocketChannel openBlockingChannel(InetSocketAddress addr, boolean tcpNoDelay, int timeout) throws IOException
IOException
public static Throwable chainExceptionCause(Throwable newt, Throwable oldt)
newt
- the new throwableoldt
- the old throwable
public static String writeTimesString(StatGroup stats)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |