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(org.forgerock.opendj.ldap.Dn baseDN,
long changeNumber,
String cookieString,
UpdateMsg updateMsg)
Notifies persistent searches of this backend that a new change number entry was added to it.
|
void |
ChangelogBackend.notifyCookieEntryAdded(org.forgerock.opendj.ldap.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 |
---|---|
boolean |
LDAPReplicationDomain.processUpdate(UpdateMsg updateMsg) |
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 |
MsgQueue.first()
Return the first UpdateMsg in the MsgQueue.
|
UpdateMsg |
MsgQueue.removeFirst()
Get and remove the first UpdateMsg in this MessageQueue.
|
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 |
MsgQueue.add(UpdateMsg update)
Add an UpdateMsg to this MessageQueue.
|
void |
MsgQueue.consumeUpTo(UpdateMsg finalMsg)
Consumes all the messages in this queue up to and including the passed in
message.
|
boolean |
MsgQueue.contains(UpdateMsg msg)
Returns true if this map contains an UpdateMsg
with the same CSN as the given UpdateMsg.
|
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(org.forgerock.opendj.ldap.Dn baseDN,
int serverId,
CSN startCSN,
DBCursor.CursorOptions options)
|
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 |
---|---|
boolean |
ReplicationDomainDB.publishUpdateMsg(org.forgerock.opendj.ldap.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()
Getter for the current record.
|
Modifier and Type | Method and Description |
---|---|
DBCursor<UpdateMsg> |
FileChangelogDB.getCursorFrom(org.forgerock.opendj.ldap.Dn baseDN,
int serverId,
CSN startCSN,
DBCursor.CursorOptions options) |
DBCursor<UpdateMsg> |
FileChangelogDB.getCursorFrom(org.forgerock.opendj.ldap.Dn baseDN,
ServerState startState,
DBCursor.CursorOptions options) |
Modifier and Type | Method and Description |
---|---|
protected void |
ChangeNumberIndexer.notifyEntryAddedToChangelog(org.forgerock.opendj.ldap.Dn baseDN,
long changeNumber,
MultiDomainServerState cookie,
UpdateMsg msg)
Notifies the
ChangelogBackend that a new entry has been added. |
boolean |
FileChangelogDB.publishUpdateMsg(org.forgerock.opendj.ldap.Dn baseDN,
UpdateMsg updateMsg) |
void |
ChangeNumberIndexer.publishUpdateMsg(org.forgerock.opendj.ldap.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 |
---|---|
protected void |
ReplicationDomain.prepareWaitForAckIfAssuredEnabled(UpdateMsg msg)
Prepare a message if it is to be sent in assured mode.
|
abstract boolean |
ReplicationDomain.processUpdate(UpdateMsg updateMsg)
This method should handle the processing of
UpdateMsg receive from
remote replication entities. |
protected void |
ReplicationDomain.processUpdateDone(UpdateMsg msg,
String replayErrorMsg)
This method must be called after each call to
ReplicationDomain.processUpdate(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-2017 ForgeRock AS. All Rights Reserved.