Package | Description |
---|---|
org.opends.server.backends |
Contains various Directory Server backend implementations.
|
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 |
ChangelogBackend.notifyChangeNumberEntryAdded(Dn baseDN,
long changeNumber,
String cookie,
UpdateMsg updateMsg)
Notifies persistent searches of this backend that a new change number entry was added to it.
|
void |
ChangelogBackend.notifyCookieEntryAdded(Dn baseDN,
UpdateMsg updateMsg)
Notifies persistent searches of this backend that a new cookie entry was added to it.
|
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 |
---|---|
UpdateMsg |
ServerHandler.take()
Select the next update that must be sent to the server managed by this ServerHandler.
|
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 |
ServerHandler.put(UpdateMsg update)
Put a new update message received.
|
void |
ReplicationServerDomain.put(UpdateMsg updateMsg,
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 |
---|---|
DBCursor<UpdateMsg> |
ReplicationDomainDB.getCursorFrom(Dn baseDN,
int serverId,
CSN startCSN,
DBCursor.CursorOptions options)
|
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 |
---|---|
boolean |
ReplicationDomainDB.publishUpdateMsg(Dn baseDN,
UpdateMsg updateMsg)
Publishes the provided change to the changelog DB for the specified serverId and replication domain.
|
Modifier and Type | Method and Description |
---|---|
UpdateMsg |
ReplicaCursor.getRecord() |
UpdateMsg |
ECLMultiDomainDBCursor.getRecord() |
Modifier and Type | Method and Description |
---|---|
DBCursor<UpdateMsg> |
FileChangelogDB.getCursorFrom(Dn baseDN,
int serverId,
CSN startCSN,
DBCursor.CursorOptions options) |
DBCursor<UpdateMsg> |
FileChangelogDB.getCursorFrom(Dn baseDN,
ServerState startState,
DBCursor.CursorOptions options) |
Modifier and Type | Method and Description |
---|---|
protected void |
ChangeNumberIndexer.notifyEntryAddedToChangelog(Dn baseDN,
long changeNumber,
MultiDomainServerState cookie,
UpdateMsg msg)
Notifies the
ChangelogBackend that a new entry has been added. |
boolean |
FileChangelogDB.publishUpdateMsg(Dn baseDN,
UpdateMsg updateMsg) |
void |
ChangeNumberIndexer.publishUpdateMsg(Dn baseDN,
UpdateMsg updateMsg)
Ensures the medium consistency point is updated by UpdateMsg.
|
Constructor and Description |
---|
ReplicaCursor(DBCursor<UpdateMsg> cursor,
CSN offlineCSN,
ReplicaId replicaId,
ReplicationDomainDB domainDB)
Creates a ReplicaCursor object with a cursor to decorate and an offlineCSN to return as part of a
ReplicaOfflineMsg.
|
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.prepareWaitForAckIfAssuredEnabled(UpdateMsg msg)
Prepare a message if it is to be sent in assured mode.
|
protected void |
ReplicationDomain.processUpdateAfterReplay(UpdateMsg msg,
String replayErrorMsg)
This method must be called after each call to
ReplicationDomain.dispatchUpdateForReplay(UpdateMsg) when
the processing of the update is completed. |
void |
ReplicationDomain.publish(UpdateMsg msg)
Publish an
UpdateMsg to the Replication Service. |
protected void |
ReplicationDomain.waitForAckIfAssuredEnabled(UpdateMsg msg)
Wait for the processing of an assured message after it has been sent, if assured replication is configured,
otherwise, do nothing.
|
Copyright 2010-2020 ForgeRock AS.