Package | Description |
---|---|
org.opends.server.replication.common |
This package contains utilities that can are used by all the packages
below org.opends.server.replication.
|
org.opends.server.replication.plugin |
This package contains the part of the Multi-master
replication code that works on the Directory Server side.
|
org.opends.server.replication.protocol |
This package contains the code used by the replication server and by the
code running on the Directory Server side to exchange their information.
|
org.opends.server.replication.server |
This package contains the code for the Replication Server part
of the Multimaster replication feature.
|
org.opends.server.replication.server.changelog.api |
This package contains the API for the changelog database.
|
org.opends.server.replication.server.changelog.file |
This package contains a file-based log implementation for the changelog
database API.
|
org.opends.server.replication.service |
This package contains the generic of the Multi-Master
replication code that works on the Directory Server side.
|
Modifier and Type | Method and Description |
---|---|
ServerState |
ServerState.duplicate()
Make a duplicate of this state.
|
ServerState |
MultiDomainServerState.getServerState(org.forgerock.opendj.ldap.Dn baseDN)
Returns the ServerState associated to the provided replication domain's
baseDN.
|
Modifier and Type | Method and Description |
---|---|
void |
CSNGenerator.adjust(ServerState state)
Adjust utility method that takes ServerState as a parameter.
|
boolean |
ServerState.cover(ServerState covered)
Check that all the CSNs in the covered serverState are also in this
serverState.
|
static int |
ServerState.diffChanges(ServerState ss1,
ServerState ss2)
Computes the number of changes a first server state has in advance
compared to a second server state.
|
void |
MultiDomainServerState.replace(org.forgerock.opendj.ldap.Dn baseDN,
ServerState serverState)
Replace the ServerState of the provided baseDN with the provided server
state.
|
void |
MultiDomainServerState.update(org.forgerock.opendj.ldap.Dn baseDN,
ServerState serverState)
Update the ServerState of the provided baseDN with the provided server
state.
|
boolean |
ServerState.update(ServerState serverState)
Update the Server State with a Server State.
|
Constructor and Description |
---|
CSNGenerator(int serverId,
ServerState state)
Create a new
CSNGenerator . |
Modifier and Type | Method and Description |
---|---|
void |
LDAPReplicationDomain.sessionInitiated(ServerStatus initStatus,
ServerState rsState) |
Modifier and Type | Method and Description |
---|---|
ServerState |
MonitorMsg.getLDAPServerState(int serverId)
Get the server state for the LDAP server with the provided serverId.
|
ServerState |
MonitorMsg.getReplServerDbState()
Get the state of the replication server that sent this message.
|
ServerState |
MonitorMsg.getRSServerState(int serverId)
Get the server state for the RS server with the provided serverId.
|
ServerState |
ServerStartMsg.getServerState()
Get the ServerState.
|
ServerState |
ReplServerStartDSMsg.getServerState()
Get the serverState.
|
ServerState |
ReplServerStartMsg.getServerState()
Get the serverState.
|
ServerState |
ByteArrayScanner.nextServerStateMustComeLast()
Reads the next ServerState.
|
Modifier and Type | Method and Description |
---|---|
ByteArrayBuilder |
ByteArrayBuilder.appendServerStateMustComeLast(ServerState serverState)
Append the byte representation of a ServerState to this ByteArrayBuilder
and then append a final zero byte separator.
|
void |
MonitorMsg.setReplServerDbState(ServerState state)
Sets the state of the replication server.
|
void |
MonitorMsg.setServerState(int serverId,
ServerState state,
long approxFirstMissingDate,
boolean isLDAPServer)
Sets the information of an LDAP server.
|
Constructor and Description |
---|
ReplServerStartDSMsg(int serverId,
String serverURL,
org.forgerock.opendj.ldap.Dn baseDN,
int windowSize,
ServerState serverState,
long generationId,
boolean sslEncryption,
byte groupId,
int degradedStatusThreshold,
int weight,
int connectedDSNumber)
Create a ReplServerStartDSMsg.
|
ReplServerStartMsg(int serverId,
String serverURL,
org.forgerock.opendj.ldap.Dn baseDN,
int windowSize,
ServerState serverState,
long generationId,
boolean sslEncryption,
byte groupId,
int degradedStatusThreshold)
Create a ReplServerStartMsg.
|
ServerStartMsg(int serverId2,
String serverURL,
org.forgerock.opendj.ldap.Dn baseDN,
int windowSize,
long heartbeatInterval,
ServerState serverState,
long generationId,
boolean sslEncryption,
byte groupId)
Creates a new ServerStartMsg.
|
Modifier and Type | Method and Description |
---|---|
ServerState |
ReplicationServerDomain.getLatestServerState()
Returns the latest most current ServerState describing the newest CSNs for
each server in this domain.
|
ServerState |
ReplicationServerDomain.getOldestState()
Returns the oldest known state for the domain, made of the oldest CSN
stored for each serverId.
|
Modifier and Type | Method and Description |
---|---|
DBCursor<UpdateMsg> |
ReplicationServerDomain.getCursorFrom(ServerState startAfterServerState)
Creates and returns a cursor across this replication domain.
|
Modifier and Type | Method and Description |
---|---|
ServerState |
ReplicationDomainDB.getDomainNewestCSNs(org.forgerock.opendj.ldap.Dn baseDN)
Returns the newest
CSN s from the replicaDBs for each serverId in
the specified replication domain. |
ServerState |
ReplicationDomainDB.getDomainOldestCSNs(org.forgerock.opendj.ldap.Dn baseDN)
Returns the oldest
CSN s from the replicaDBs for each serverId in
the specified replication domain. |
Modifier and Type | Method and Description |
---|---|
DBCursor<UpdateMsg> |
ReplicationDomainDB.getCursorFrom(org.forgerock.opendj.ldap.Dn baseDN,
ServerState startState,
DBCursor.CursorOptions options)
Generates a
DBCursor across all the replicaDBs for the specified
replication domain starting before, at or after the provided
ServerState for each replicaDB, depending on the provided matching
and positioning strategies. |
Modifier and Type | Method and Description |
---|---|
ServerState |
FileChangelogDB.getDomainNewestCSNs(org.forgerock.opendj.ldap.Dn baseDN) |
ServerState |
FileChangelogDB.getDomainOldestCSNs(org.forgerock.opendj.ldap.Dn baseDN) |
Modifier and Type | Method and Description |
---|---|
void |
MultiDomainDBCursor.addDomain(org.forgerock.opendj.ldap.Dn baseDN,
ServerState startAfterState)
Adds a replication domain for this cursor to iterate over.
|
DBCursor<UpdateMsg> |
FileChangelogDB.getCursorFrom(org.forgerock.opendj.ldap.Dn baseDN,
ServerState startState,
DBCursor.CursorOptions options) |
Modifier and Type | Method and Description |
---|---|
ServerState |
ReplicationDomain.getServerState()
Get the ServerState maintained by the Concrete class.
|
Modifier and Type | Method and Description |
---|---|
Map<Integer,ServerState> |
ReplicationBroker.getReplicaStates()
Gets the States of all the Replicas currently in the Topology.
|
Map<Integer,ServerState> |
ReplicationDomain.getReplicaStates()
Gets the States of all the Replicas currently in the
Topology.
|
Modifier and Type | Method and Description |
---|---|
void |
ReplicationDomain.sessionInitiated(ServerStatus initStatus,
ServerState rsState)
Set the initial status of the domain and perform necessary initializations.
|
Constructor and Description |
---|
ReplicationBroker(ReplicationDomain replicationDomain,
ServerState state,
org.forgerock.opendj.server.config.server.ReplicationDomainCfg config,
ReplSessionSecurity replSessionSecurity)
Creates a new ReplicationServer Broker for a particular ReplicationDomain.
|
ReplicationDomain(org.forgerock.opendj.server.config.server.ReplicationDomainCfg config,
long generationId,
ServerState serverState)
Creates a ReplicationDomain with the provided parameters.
|
Copyright © 2010-2017 ForgeRock AS. All Rights Reserved.