org.apache.qpid.server.store.berkeleydb.replication

Class ReplicatedEnvironmentFacade

java.lang.Object

org.apache.qpid.server.store.berkeleydb.replication.ReplicatedEnvironmentFacade

All Implemented Interfaces:

com.sleepycat.je.rep.StateChangeListener, EnvironmentFacade

public class ReplicatedEnvironmentFacade
extends Object
implements EnvironmentFacade, com.sleepycat.je.rep.StateChangeListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReplicatedEnvironmentFacade.ReplicationNodeImpl
static class	ReplicatedEnvironmentFacade.State

Field Summary

Fields

Modifier and Type	Field and Description
static String	DB_PING_SOCKET_TIMEOUT_PROPERTY_NAME
static String	ENVIRONMENT_RESTART_RETRY_LIMIT_PROPERTY_NAME
static String	EXECUTOR_SHUTDOWN_TIMEOUT_PROPERTY_NAME
static String	MASTER_TRANSFER_TIMEOUT_PROPERTY_NAME
static String	PERMITTED_NODE_LIST
static String	REMOTE_NODE_MONITOR_INTERVAL_PROPERTY_NAME
static String	REMOTE_NODE_MONITOR_TIMEOUT_PROPERTY_NAME
static com.sleepycat.je.Durability.ReplicaAckPolicy	REPLICA_REPLICA_ACKNOWLEDGMENT_POLICY

Fields inherited from interface org.apache.qpid.server.store.berkeleydb.EnvironmentFacade

CACHE_MODE_DEFAULT, CACHE_MODE_PROPERTY_NAME, DEFAULT_LOG_HANDLER_CLEANER_PROTECTED_FILES_LIMIT, ENVCONFIG_DEFAULTS, LOG_HANDLER_CLEANER_PROTECTED_FILES_LIMIT_PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
ReplicatedEnvironmentFacade(ReplicatedEnvironmentConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
com.sleepycat.je.Transaction	beginTransaction(com.sleepycat.je.TransactionConfig transactionConfig)
void	checkpoint(boolean force)
int	cleanLog()
com.sleepycat.je.Database	clearDatabase(String name, com.sleepycat.je.DatabaseConfig databaseConfig)
void	close()
void	closeDatabase(String databaseName)
void	commit(com.sleepycat.je.Transaction tx, boolean syncCommit)
<X> com.google.common.util.concurrent.ListenableFuture<X>	commitAsync(com.sleepycat.je.Transaction tx, X val)
static Collection<String>	connectToHelperNodeAndCheckPermittedHosts(String nodeName, String hostPort, String groupName, String helperNodeName, String helperHostPort, int dbPingSocketTimeout)
static Set<String>	convertApplicationStateBytesToPermittedNodeList(byte[] applicationState)
void	flushLog()
void	flushLogFailed(RuntimeException e)
Map<String,Object>	getDatabaseStatistics(String database, boolean reset)
Map<String,Map<String,Object>>	getEnvironmentStatistics(boolean reset)
ReplicatedEnvironmentFacade.State	getFacadeState()
String	getGroupName()
String	getHelperHostPort()
String	getHostPort()
long	getJoinTime()
long	getLastKnownReplicationTransactionId()
com.sleepycat.je.Durability	getMessageStoreDurability()
String	getNodeName()
Set<com.sleepycat.je.rep.ReplicationNode>	getNodes()
String	getNodeState()
int	getNumberOfElectableGroupMembers()
long	getTotalLogSize()
Map<String,Object>	getTransactionStatistics(boolean reset)
RuntimeException	handleDatabaseException(String contextMessage, RuntimeException dbe)
boolean	isCoalescingSync()
boolean	isDesignatedPrimary()
boolean	isMaster()
com.sleepycat.je.Database	openDatabase(String name, com.sleepycat.je.DatabaseConfig databaseConfig)
com.sleepycat.je.Sequence	openSequence(com.sleepycat.je.Database database, com.sleepycat.je.DatabaseEntry sequenceKey, com.sleepycat.je.SequenceConfig sequenceConfig)
void	reduceSizeOnDisk()
boolean	removeNodeFromGroup(String nodeName)
void	setCacheSize(long cacheSize)
Future<Void>	setDesignatedPrimary(boolean isPrimary)
Future<Void>	setElectableGroupSizeOverride(int electableGroupOverride)
void	setMessageStoreDurability(com.sleepycat.je.Durability.SyncPolicy localTransactionSynchronizationPolicy, com.sleepycat.je.Durability.SyncPolicy remoteTransactionSynchronizationPolicy, com.sleepycat.je.Durability.ReplicaAckPolicy replicaAcknowledgmentPolicy) This method should only be invoked from configuration thread on virtual host activation.
void	setPermittedNodes(Collection<String> permittedNodes)
Future<Void>	setPriority(int priority)
void	setReplicationGroupListener(ReplicationGroupListener replicationGroupListener)
void	setStateChangeListener(com.sleepycat.je.rep.StateChangeListener stateChangeListener)
void	stateChange(com.sleepycat.je.rep.StateChangeEvent stateChangeEvent)
Future<Void>	transferMasterAsynchronously(String nodeName)
Future<Void>	transferMasterToSelfAsynchronously()
void	updateMutableConfig(ConfiguredObject<?> object)
void	upgradeIfNecessary(ConfiguredObject<?> parent)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MASTER_TRANSFER_TIMEOUT_PROPERTY_NAME

public static final String MASTER_TRANSFER_TIMEOUT_PROPERTY_NAME

See Also:

Constant Field Values

DB_PING_SOCKET_TIMEOUT_PROPERTY_NAME

public static final String DB_PING_SOCKET_TIMEOUT_PROPERTY_NAME

See Also:

Constant Field Values

REMOTE_NODE_MONITOR_INTERVAL_PROPERTY_NAME

public static final String REMOTE_NODE_MONITOR_INTERVAL_PROPERTY_NAME

See Also:

Constant Field Values

REMOTE_NODE_MONITOR_TIMEOUT_PROPERTY_NAME

public static final String REMOTE_NODE_MONITOR_TIMEOUT_PROPERTY_NAME

See Also:

Constant Field Values

ENVIRONMENT_RESTART_RETRY_LIMIT_PROPERTY_NAME

public static final String ENVIRONMENT_RESTART_RETRY_LIMIT_PROPERTY_NAME

See Also:

Constant Field Values

EXECUTOR_SHUTDOWN_TIMEOUT_PROPERTY_NAME

public static final String EXECUTOR_SHUTDOWN_TIMEOUT_PROPERTY_NAME

See Also:

Constant Field Values

REPLICA_REPLICA_ACKNOWLEDGMENT_POLICY

public static final com.sleepycat.je.Durability.ReplicaAckPolicy REPLICA_REPLICA_ACKNOWLEDGMENT_POLICY

PERMITTED_NODE_LIST

public static final String PERMITTED_NODE_LIST

See Also:

Constant Field Values

Constructor Detail

ReplicatedEnvironmentFacade

public ReplicatedEnvironmentFacade(ReplicatedEnvironmentConfiguration configuration)

Method Detail

beginTransaction

public com.sleepycat.je.Transaction beginTransaction(com.sleepycat.je.TransactionConfig transactionConfig)

Specified by:

beginTransaction in interface EnvironmentFacade

commit

public void commit(com.sleepycat.je.Transaction tx,
                   boolean syncCommit)

Specified by:

commit in interface EnvironmentFacade

commitAsync

public <X> com.google.common.util.concurrent.ListenableFuture<X> commitAsync(com.sleepycat.je.Transaction tx,
                                                                             X val)

Specified by:

commitAsync in interface EnvironmentFacade

close

public void close()

Specified by:

close in interface EnvironmentFacade

handleDatabaseException

public RuntimeException handleDatabaseException(String contextMessage,
                                                RuntimeException dbe)

Specified by:

handleDatabaseException in interface EnvironmentFacade

openDatabase

public com.sleepycat.je.Database openDatabase(String name,
                                              com.sleepycat.je.DatabaseConfig databaseConfig)

Specified by:

openDatabase in interface EnvironmentFacade

clearDatabase

public com.sleepycat.je.Database clearDatabase(String name,
                                               com.sleepycat.je.DatabaseConfig databaseConfig)

Specified by:

clearDatabase in interface EnvironmentFacade

closeDatabase

public void closeDatabase(String databaseName)

Specified by:

closeDatabase in interface EnvironmentFacade

openSequence

public com.sleepycat.je.Sequence openSequence(com.sleepycat.je.Database database,
                                              com.sleepycat.je.DatabaseEntry sequenceKey,
                                              com.sleepycat.je.SequenceConfig sequenceConfig)

Specified by:

openSequence in interface EnvironmentFacade

stateChange

public void stateChange(com.sleepycat.je.rep.StateChangeEvent stateChangeEvent)

Specified by:

stateChange in interface com.sleepycat.je.rep.StateChangeListener

getTotalLogSize

public long getTotalLogSize()

Specified by:

getTotalLogSize in interface EnvironmentFacade

reduceSizeOnDisk

public void reduceSizeOnDisk()

Specified by:

reduceSizeOnDisk in interface EnvironmentFacade

flushLog

public void flushLog()

Specified by:

flushLog in interface EnvironmentFacade

setCacheSize

public void setCacheSize(long cacheSize)

Specified by:

setCacheSize in interface EnvironmentFacade

updateMutableConfig

public void updateMutableConfig(ConfiguredObject<?> object)

Specified by:

updateMutableConfig in interface EnvironmentFacade

cleanLog

public int cleanLog()

Specified by:

cleanLog in interface EnvironmentFacade

checkpoint

public void checkpoint(boolean force)

Specified by:

checkpoint in interface EnvironmentFacade

getEnvironmentStatistics

public Map<String,Map<String,Object>> getEnvironmentStatistics(boolean reset)

Specified by:

getEnvironmentStatistics in interface EnvironmentFacade

getTransactionStatistics

public Map<String,Object> getTransactionStatistics(boolean reset)

Specified by:

getTransactionStatistics in interface EnvironmentFacade

getDatabaseStatistics

public Map<String,Object> getDatabaseStatistics(String database,
                                                boolean reset)

Specified by:

getDatabaseStatistics in interface EnvironmentFacade

flushLogFailed

public void flushLogFailed(RuntimeException e)

Specified by:

flushLogFailed in interface EnvironmentFacade

getNodes

public Set<com.sleepycat.je.rep.ReplicationNode> getNodes()

getGroupName

public String getGroupName()

getNodeName

public String getNodeName()

getHostPort

public String getHostPort()

getHelperHostPort

public String getHelperHostPort()

getMessageStoreDurability

public com.sleepycat.je.Durability getMessageStoreDurability()

isCoalescingSync

public boolean isCoalescingSync()

getNodeState

public String getNodeState()

isDesignatedPrimary

public boolean isDesignatedPrimary()

setDesignatedPrimary

public Future<Void> setDesignatedPrimary(boolean isPrimary)

setPriority

public Future<Void> setPriority(int priority)

setElectableGroupSizeOverride

public Future<Void> setElectableGroupSizeOverride(int electableGroupOverride)

transferMasterToSelfAsynchronously

public Future<Void> transferMasterToSelfAsynchronously()

transferMasterAsynchronously

public Future<Void> transferMasterAsynchronously(String nodeName)

removeNodeFromGroup

public boolean removeNodeFromGroup(String nodeName)

getJoinTime

public long getJoinTime()

getLastKnownReplicationTransactionId

public long getLastKnownReplicationTransactionId()

upgradeIfNecessary

public void upgradeIfNecessary(ConfiguredObject<?> parent)

Specified by:

upgradeIfNecessary in interface EnvironmentFacade

getFacadeState

public ReplicatedEnvironmentFacade.State getFacadeState()

setStateChangeListener

public void setStateChangeListener(com.sleepycat.je.rep.StateChangeListener stateChangeListener)

getNumberOfElectableGroupMembers

public int getNumberOfElectableGroupMembers()

isMaster

public boolean isMaster()

setReplicationGroupListener

public void setReplicationGroupListener(ReplicationGroupListener replicationGroupListener)

setMessageStoreDurability

public void setMessageStoreDurability(com.sleepycat.je.Durability.SyncPolicy localTransactionSynchronizationPolicy,
                                      com.sleepycat.je.Durability.SyncPolicy remoteTransactionSynchronizationPolicy,
                                      com.sleepycat.je.Durability.ReplicaAckPolicy replicaAcknowledgmentPolicy)

This method should only be invoked from configuration thread on virtual host activation. Otherwise, invocation of this method whilst coalescing committer is committing transactions might result in transaction aborts.

setPermittedNodes

public void setPermittedNodes(Collection<String> permittedNodes)

convertApplicationStateBytesToPermittedNodeList

public static Set<String> convertApplicationStateBytesToPermittedNodeList(byte[] applicationState)

connectToHelperNodeAndCheckPermittedHosts

public static Collection<String> connectToHelperNodeAndCheckPermittedHosts(String nodeName,
                                                                           String hostPort,
                                                                           String groupName,
                                                                           String helperNodeName,
                                                                           String helperHostPort,
                                                                           int dbPingSocketTimeout)