com.sleepycat.je.rep.utilint

Class RepUtils

java.lang.Object

com.sleepycat.je.rep.utilint.RepUtils

public class RepUtils
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	RepUtils.ConsistencyPolicyFormat<T extends ReplicaConsistencyPolicy> ReplicaConsistencyPolicy must be stored as a String for use with ReplicationConfig and je.properties.
static class	RepUtils.ExceptionAwareBlockingQueue<T> Like LinkedBlockingQueue, but provides a pollOrException() method that should be used instead of poll(), so that callers don't have to treat exception cases specially.
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.

Field Summary

Fields

Modifier and Type	Field and Description
static java.nio.channels.SocketChannel	CHANNEL_EOF_MARKER
static boolean	DEBUG_PRINT_THREAD
static boolean	DEBUG_PRINT_TIME

Constructor Summary

Constructors

Constructor and Description
RepUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static void	addConsistencyPolicyFormat(java.lang.String name, RepUtils.ConsistencyPolicyFormat<?> format) Define a new ConsistencyPolicyFormat.
static java.lang.Throwable	chainExceptionCause(java.lang.Throwable newt, java.lang.Throwable oldt) Chains an old outstanding exception to the tail of a new one, so it's not lost.
static java.lang.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(java.lang.String propertyValue) Converts a property string into a policy instance.
static java.nio.channels.SocketChannel	openBlockingChannel(java.net.InetSocketAddress addr, boolean tcpNoDelay, int timeout) An overloading of the above when the receive buffer size is to be defaulted.
static java.nio.channels.SocketChannel	openBlockingChannel(java.net.InetSocketAddress addr, boolean tcpNoDelay, int receiveBufferSize, int timeout) Create a socket channel with the designated properties
static void	shutdownChannel(NamedChannel namedChannel) Forces a shutdown of the channel ignoring any errors that may be encountered in the process.
static java.lang.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 java.nio.channels.SocketChannel CHANNEL_EOF_MARKER

Constructor Detail

RepUtils

public RepUtils()

Method Detail

addConsistencyPolicyFormat

public static void addConsistencyPolicyFormat(java.lang.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 java.lang.String getPropertyString(ReplicaConsistencyPolicy policy)
                                          throws java.lang.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:

java.lang.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(java.lang.String propertyValue)
                                                            throws java.lang.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:

java.lang.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 java.nio.channels.SocketChannel openBlockingChannel(java.net.InetSocketAddress addr,
                                                  boolean tcpNoDelay,
                                                  int receiveBufferSize,
                                                  int timeout)
                                                           throws java.io.IOException

Create a socket channel with the designated properties

Parameters:

addr - the remote endpoint socket address

tcpNoDelay - true, if the nagle algorithm is to be used

receiveBufferSize - the SO_RCVBUF value for the tcp window. A zero value indicates that the os level defaults should be used.

timeout - the SO_TIMEOUT to be associated with the channel

Returns:

the connected channel

Throws:

java.io.IOException

openBlockingChannel

public static java.nio.channels.SocketChannel openBlockingChannel(java.net.InetSocketAddress addr,
                                                  boolean tcpNoDelay,
                                                  int timeout)
                                                           throws java.io.IOException

An overloading of the above when the receive buffer size is to be defaulted.

Throws:

java.io.IOException

See Also:

openBlockingChannel(InetSocketAddress, boolean, int, int)

chainExceptionCause

public static java.lang.Throwable chainExceptionCause(java.lang.Throwable newt,
                                      java.lang.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 with the old cause

writeTimesString

public static java.lang.String writeTimesString(StatGroup stats)