Package | Description |
---|---|
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 |
---|---|
void |
LDAPReplicationDomain.dispatchUpdateForReplay(UpdateMsg updateMsg)
The listener thread takes care of processing dependencies between messages via
ReplicationDomain.dispatchUpdateForReplay(UpdateMsg) , dispatching updates to the replay threads. |
Modifier and Type | Class and Description |
---|---|
class |
AddMsg
This class is used to exchange Add operation between LDAP servers and replication servers.
|
class |
DeleteMsg
Object used when sending delete information to replication servers.
|
class |
LDAPUpdateMsg
Abstract class that must be extended to define a message used for sending Updates between servers.
|
class |
ModifyCommonMsg
This class holds every common code for the modify messages (mod, moddn).
|
class |
ModifyDNMsg
Message used to send Modify DN information.
|
class |
ModifyMsg
Message used to send Modify information.
|
class |
ReplicaOfflineMsg
Class that define messages sent by a replica (DS) to the replication server (RS) to let the RS know the date at which
a replica went offline.
|
Modifier and Type | Method and Description |
---|---|
int |
UpdateMsg.compareTo(UpdateMsg msg) |
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 |
---|---|
void |
ReplicationServerDomain.put(UpdateMsg updateMsg,
org.opends.server.replication.server.ServerHandler sourceHandler)
Add an update that has been received to the list of updates that must be forwarded to all other servers.
|
Modifier and Type | Method and Description |
---|---|
UpdateMsg |
UpdateRecord.getMessage()
Returns the update message.
|
UpdateMsg |
ReplicationDomainDB.getNewestMessage(DomainReplicaId replica)
Returns the newest message from the replica DB for the provided replica.
|
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. |
DBCursor<UpdateMsg> |
ReplicationDomainDB.getCursorFrom(DomainReplicaId replica,
CSN startCSN,
DBCursor.CursorOptions options)
|
Modifier and Type | Method and Description |
---|---|
static UpdateRecord |
UpdateRecord.newUpdateRecord(Dn baseDn,
UpdateMsg msg)
Creates a new update record with the provided base DN and message.
|
boolean |
ReplicationDomainDB.publishUpdateMsg(Dn baseDN,
UpdateMsg updateMsg)
Publishes the provided change to the changelog DB for the specified replica id and replication domain.
|
Modifier and Type | Method and Description |
---|---|
UpdateMsg |
FileChangelogDB.getNewestMessage(DomainReplicaId replica) |
Modifier and Type | Method and Description |
---|---|
DBCursor<UpdateMsg> |
FileChangelogDB.getCursorFrom(Dn baseDN,
ServerState startState,
DBCursor.CursorOptions options) |
DBCursor<UpdateMsg> |
FileChangelogDB.getCursorFrom(DomainReplicaId replica,
CSN startCSN,
DBCursor.CursorOptions options) |
Modifier and Type | Method and Description |
---|---|
boolean |
FileChangelogDB.publishUpdateMsg(Dn baseDN,
UpdateMsg updateMsg) |
void |
ChangeNumberIndexer.publishUpdateMsg(Dn baseDn,
UpdateMsg updateMsg)
Ensures the medium consistency point is updated by UpdateMsg.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
ReplicationDomain.dispatchUpdateForReplay(UpdateMsg updateMsg)
This method ensures this
UpdateMsg received from remote replication entities will be replayed,
by dispatching it to the replay threads. |
protected void |
ReplicationDomain.processUpdateAfterReplay(UpdateMsg msg)
This method must be called after each call to
ReplicationDomain.dispatchUpdateForReplay(UpdateMsg) when the processing of
the update is completed. |
Copyright 2010-2022 ForgeRock AS.