Package | Description |
---|---|
org.opends.server.backends |
Contains various Directory Server backend implementations.
|
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.
|
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.
|
static void |
ChangelogBackend.updateCookieToMediumConsistencyPoint(MultiDomainServerState cookie,
ECLMultiDomainDBCursor cursor,
ChangeNumberIndexRecord cnIndexRecord)
Rebuilds the changelogcookie starting at the newest change number index record.
|
Modifier and Type | Method and Description |
---|---|
DBCursor<UpdateMsg> |
ReplicationServerDomain.getCursorFrom(ServerState startAfterServerState)
Creates and returns a cursor across this replication domain.
|
UpdateMsg |
ServerHandler.take()
Select the next update that must be sent to the server managed by this
ServerHandler.
|
Modifier and Type | Class and Description |
---|---|
class |
AbortedChangelogCursorException
This exception is thrown when a cursor that has been aborted is used.
|
Modifier and Type | Method and Description |
---|---|
long |
ChangeNumberIndexDB.addRecord(ChangeNumberIndexRecord record)
Add an update to the list of messages that must be saved to this DB managed
by this DB and return the changeNumber associated to this record.
|
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. |
DBCursor<ChangeNumberIndexRecord> |
ChangeNumberIndexDB.getCursorFrom(long startChangeNumber)
Generate a new
DBCursor that allows to browse the db managed by
this object and starting at the position defined by a given changeNumber. |
MultiDomainDBCursor |
ReplicationDomainDB.getCursorFrom(MultiDomainServerState startState,
DBCursor.CursorOptions options)
Generates a
DBCursor across all the domains starting before, at or
after the provided MultiDomainServerState for each domain,
depending on the provided matching and positioning strategies. |
MultiDomainDBCursor |
ReplicationDomainDB.getCursorFrom(MultiDomainServerState startState,
DBCursor.CursorOptions options,
Set<org.forgerock.opendj.ldap.Dn> excludedDomainDns)
Generates a
DBCursor across all the domains starting before, at or
after the provided MultiDomainServerState for each domain,
excluding a provided set of domain DNs. |
ChangeNumberIndexRecord |
ChangeNumberIndexDB.getNewestRecord()
Get the newest record stored in this DB.
|
ChangeNumberIndexRecord |
ChangeNumberIndexDB.getOldestRecord()
Get the oldest record stored in this DB.
|
boolean |
DBCursor.next()
Skip to the next record of the database.
|
void |
ReplicationDomainDB.notifyReplicaOffline(org.forgerock.opendj.ldap.Dn baseDN,
CSN offlineCSN)
Let the DB know this replica is going down.
|
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.
|
void |
ChangelogDB.removeDB()
Removes the changelog database directory.
|
void |
ReplicationDomainDB.removeDomain(org.forgerock.opendj.ldap.Dn baseDN)
Removes all the data relating to the specified replication domain and
shutdown all its replica databases.
|
void |
ReplicationDomainDB.replicaHeartbeat(org.forgerock.opendj.ldap.Dn baseDN,
CSN heartbeatCSN)
Let the DB know this replica is alive.
|
void |
ChangeNumberIndexDB.resetChangeNumberTo(long newFirstCN,
org.forgerock.opendj.ldap.Dn baseDN,
CSN newFirstCSN)
Resets ChangeNumber index to the given number and CSN.
|
void |
ChangelogDB.setComputeChangeNumber(boolean computeChangeNumber)
Sets whether the replication database must compute change numbers for
replicated changes.
|
void |
ChangelogDB.shutdownDB()
Shutdown the replication database.
|
Modifier and Type | Class and Description |
---|---|
class |
DecodingException
Exception thrown when a record can't be decoded properly.
|
Modifier and Type | Method and Description |
---|---|
void |
FileChangelogDB.clearDB()
Clears all records from the changelog (does not remove the changelog itself).
|
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) |
MultiDomainDBCursor |
FileChangelogDB.getCursorFrom(MultiDomainServerState startState,
DBCursor.CursorOptions options) |
MultiDomainDBCursor |
FileChangelogDB.getCursorFrom(MultiDomainServerState startState,
DBCursor.CursorOptions options,
Set<org.forgerock.opendj.ldap.Dn> excludedDomainDns) |
protected void |
DomainDBCursor.incorporateNewCursors()
Called when implementors should incorporate new cursors into the current
composite DBCursor.
|
protected void |
MultiDomainDBCursor.incorporateNewCursors()
Called when implementors should incorporate new cursors into the current
composite DBCursor.
|
boolean |
ReplicaCursor.next() |
boolean |
ECLMultiDomainDBCursor.next() |
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. |
void |
FileChangelogDB.notifyReplicaOffline(org.forgerock.opendj.ldap.Dn baseDN,
CSN offlineCSN) |
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.
|
void |
FileChangelogDB.removeDB() |
void |
FileChangelogDB.removeDomain(org.forgerock.opendj.ldap.Dn baseDN) |
void |
FileChangelogDB.replicaHeartbeat(org.forgerock.opendj.ldap.Dn baseDN,
CSN heartbeatCSN) |
void |
FileChangelogDB.setComputeChangeNumber(boolean computeChangeNumber) |
void |
FileChangelogDB.shutdownDB() |
Copyright © 2010-2017 ForgeRock AS. All Rights Reserved.