Class Summary |
BinaryProtocol |
Supplies the basic infrastructure for BinaryProtocols used to exchange
messages by the replications stream and during network based restore
operations. |
BinaryProtocol.MessageOp |
The Operations that are part of the protocol. |
BinaryProtocolStatDefinition |
Per-stat Metadata for each BinaryProtocol statistics. |
DbCacheSizeRepEnv |
Class for opening a ReplicatedEnvironment from a JE standalone utility,
DbCacheSize. |
DbDumpGroup |
|
DbFeederPrintLog |
|
DbNullNode |
|
DbRepRunAction |
|
DbStreamVerify |
For internal use only. |
DbSync |
DbSync is a utility for ensuring that a group of replication nodes have
fully caught up on the replication stream. |
FreePortLocator |
An iterator to iterate over the free ports on an interface. |
HostPortPair |
Encapsulates the functionality around dealing with HostPort string pairs
having the format:
host[:port] |
IntRunningTotalStat |
Used to create running totals across the lifetime of the StatGroup. |
LongMaxZeroStat |
For stats where the min value in the range is zero, so that sums, averages,
etc. |
LongMinZeroStat |
For stats where the min value in the range is zero, so that sums, averages,
etc. |
NamedChannel |
Packages a SocketChannel and a NameIdPair together so that logging
messages can show the node name instead of the channel toString(); |
NamedChannelWithTimeout |
NamedChannelWithTimeout permits association of timeouts with a SocketChannel. |
ReplicationFormatter |
Formatter for replication log messages |
RepUtils |
|
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. |
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. |
ServiceDispatcher |
ServiceDispatcher listens on a specific socket for service requests
and dispatches control to the service that is being requested. |
ServiceDispatcher.ExecutingRunnable |
|
ServiceDispatcher.ExecutingService |
A service that is run immediately in a thread allocated to it. |
SizeAwaitMap<K,V> |
Creates a Map, that Threads can conveniently wait on to reach a specific
size. |
SizeAwaitMapStatDefinition |
Per-stat Metadata for each SizeAwaitMap statistics. |