com.sleepycat.je.rep.utilint
Class RepUtils

java.lang.Object
  com.sleepycat.je.rep.utilint.RepUtils

public class RepUtils
extends Object

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

DEBUG_PRINT_THREAD

public static final boolean DEBUG_PRINT_THREAD

See Also:

Constant Field Values

DEBUG_PRINT_TIME

public static final boolean DEBUG_PRINT_TIME

See Also:

Constant Field Values

CHANNEL_EOF_MARKER

public static final SocketChannel CHANNEL_EOF_MARKER

Constructor Detail

RepUtils

public RepUtils()

Method Detail

addConsistencyPolicyFormat

public static void addConsistencyPolicyFormat(String name,
                                              RepUtils.ConsistencyPolicyFormat<?> format)

Define a new ConsistencyPolicyFormat. Should only be called outside of this class to add support custom policies for testing. Must be called when the system is quiescent, since the map is unsynchronized.

Parameters:

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.

getPropertyString

public static String getPropertyString(ReplicaConsistencyPolicy policy)
                                throws IllegalArgumentException

Converts a policy into a string suitable for use as a property value in a je.properties file or elsewhere.

Parameters:

policy - the policy being converted.

Returns:

the formatted string representing the policy.

Throws:

IllegalArgumentException - if the specific policy does not have a property value format, via ReplicationConfig(Properties) ctor and setter.

See Also:

getReplicaConsistencyPolicy(String)

getReplicaConsistencyPolicy

public static ReplicaConsistencyPolicy getReplicaConsistencyPolicy(String propertyValue)
                                                            throws IllegalArgumentException

Converts a property string into a policy instance.

Parameters:

propertyValue - the formatted string representing the policy.

Returns:

the policy computed from the string

Throws:

IllegalArgumentException - via ReplicationConfig(Properties) ctor and setter.

shutdownChannel

public static void shutdownChannel(NamedChannel namedChannel)

Forces a shutdown of the channel ignoring any errors that may be encountered in the process.

Parameters:

namedChannel - the channel to be shutdown

openBlockingChannel

public static SocketChannel openBlockingChannel(InetSocketAddress addr,
                                                boolean tcpNoDelay,
                                                int timeout)
                                         throws IOException

Throws:

IOException

chainExceptionCause

public static Throwable chainExceptionCause(Throwable newt,
                                            Throwable oldt)

Chains an old outstanding exception to the tail of a new one, so it's not lost.

Parameters:

newt - the new throwable

oldt - the old throwable

Returns:

the new throwable extended withthe old cause

writeTimesString

public static String writeTimesString(StatGroup stats)