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(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.
|
static CSNGenerator |
CSNGenerator.newCSNGenerator(int serverId,
ServerState state)
Create a new
CSNGenerator . |
void |
MultiDomainServerState.replace(Dn baseDN,
ServerState serverState)
Replace the ServerState of the provided baseDN with the provided server state.
|
void |
MultiDomainServerState.update(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.
|
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 |
ReplServerStartMsg.getServerState()
Get the serverState.
|
ServerState |
ReplServerStartDSMsg.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,
HostPort hostPort,
Dn baseDN,
ServerState serverState,
long generationId,
boolean sslEncryption,
byte groupId,
int degradedStatusThreshold,
int weight,
int connectedDSNumber)
Create a ReplServerStartDSMsg.
|
ReplServerStartMsg(int serverId,
HostPort rsHostPort,
Dn baseDN,
ServerState serverState,
long generationId,
boolean sslEncryption,
byte groupId,
int degradedStatusThreshold)
Create a ReplServerStartMsg.
|
ServerStartMsg(int serverId2,
HostPort hostPort,
Dn baseDN,
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(Dn baseDN)
Returns the newest
CSN s from the replicaDBs for each serverId in the specified replication domain. |
ServerState |
ReplicationDomainDB.getDomainOldestCSNs(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(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(Dn baseDN) |
ServerState |
FileChangelogDB.getDomainOldestCSNs(Dn baseDN) |
Modifier and Type | Method and Description |
---|---|
void |
MultiDomainDBCursor.addDomain(Dn baseDN,
ServerState startAfterState)
Adds a replication domain for this cursor to iterate over.
|
DBCursor<UpdateMsg> |
FileChangelogDB.getCursorFrom(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> |
ReplicationDomain.getReplicaStates()
Gets the States of all the Replicas currently in the Topology.
|
Map<Integer,ServerState> |
ReplicationBroker.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,
ReplicationDomainCfg config,
ReplSessionSecurity replSessionSecurity)
Creates a new ReplicationServer Broker for a particular ReplicationDomain.
|
ReplicationDomain(ReplicationDomainCfg config,
long generationId,
ServerState serverState)
Creates a ReplicationDomain with the provided parameters.
|
Copyright 2010-2018 ForgeRock AS.