Package | Description |
---|---|
org.opends.server.controls |
Contains classes that represent specific LDAP controls and their values.
|
org.opends.server.plugins |
Contains the implementation for various Directory Server plugins.
|
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.
|
org.opends.server.tasks |
Contains implementations for various Directory Server tasks.
|
Modifier and Type | Method and Description |
---|---|
CSN |
ReplicatedRequestControl.getCSN()
Returns the CSN.
|
Constructor and Description |
---|
ReplicatedRequestControl(boolean isCritical,
CSN csn,
String entryUuid)
Constructs a new control.
|
ReplicatedRequestControl(boolean isCritical,
CSN csn,
String entryUuid,
String parentUuid)
Constructs a new control.
|
Modifier and Type | Method and Description |
---|---|
CSN |
ChangeNumberControlPlugin.ChangeNumberControl.getCSN()
Retrieves the CSN.
|
Constructor and Description |
---|
ChangeNumberControlPlugin.ChangeNumberControl(boolean isCritical,
CSN csn)
Constructs a new change number control.
|
Modifier and Type | Field and Description |
---|---|
static CSN |
CSN.MAX_CSN_VALUE
The maximum possible value for a CSN.
|
Modifier and Type | Method and Description |
---|---|
CSN |
MultiDomainServerState.getCSN(org.forgerock.opendj.ldap.Dn baseDN,
int serverId)
Returns the CSN associated to the provided replication domain's baseDN and
serverId.
|
CSN |
ServerState.getCSN(int serverId)
Returns the
CSN contained in this server state which corresponds to
the provided server ID. |
CSN |
CSNGenerator.newCSN()
Generate a new
CSN . |
static CSN |
CSN.valueOf(org.forgerock.opendj.ldap.ByteSequence bs)
Decodes the provided
toByteString() representation of a change
number. |
static CSN |
CSN.valueOf(String s)
Parses the provided
toString() representation of a CSN. |
Modifier and Type | Method and Description |
---|---|
org.forgerock.util.Pair<org.forgerock.opendj.ldap.Dn,CSN> |
MultiDomainServerState.getOldestCSNExcluding(MultiDomainServerState excludedCSNs)
Returns the oldest Pair<DN, CSN> held in current object, excluding
the provided CSNs.
|
Map<Integer,CSN> |
ServerState.getServerIdToCSNMap()
Returns a copy of this ServerState's content as a Map of serverId => CSN.
|
Map<org.forgerock.opendj.ldap.Dn,List<CSN>> |
MultiDomainServerState.getSnapshot()
Returns a snapshot of this object.
|
List<CSN> |
ServerState.getSnapshot()
Returns a snapshot of this object.
|
Iterator<CSN> |
ServerState.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
CSNGenerator.adjust(CSN number)
Adjust the lastTime of this
CSNGenerator with a CSN that we
have received from another server. |
static int |
CSN.compare(CSN csn1,
CSN csn2)
Compares this CSN with the provided CSN for order and returns a negative
number if
csn1 is older than csn2 , zero if they have the
same age, or a positive number if csn1 is newer than csn2 . |
int |
CSN.compareTo(CSN csn)
Compares this CSN with the provided CSN for order and returns a negative
number if this CSN is older than
csn , zero if they have the same
age, or a positive number if this CSN is newer than csn . |
boolean |
ServerState.cover(CSN covered)
Checks that the CSN given as a parameter is in this ServerState.
|
boolean |
MultiDomainServerState.cover(org.forgerock.opendj.ldap.Dn baseDN,
CSN csn)
Test if this object covers the provided CSN for the provided baseDN.
|
static int |
CSN.diffSeqNum(CSN csn1,
CSN csn2)
Computes the difference in number of changes between 2 CSNs.
|
boolean |
CSN.isNewerThan(CSN csn)
Returns
true if this CSN is newer than the provided CSN. |
boolean |
CSN.isNewerThanOrEqualTo(CSN csn)
Returns
true if this CSN is newer than or equal to the provided
CSN. |
boolean |
CSN.isOlderThan(CSN csn)
Returns
true if this CSN is older than the provided CSN. |
boolean |
CSN.isOlderThanOrEqualTo(CSN csn)
Returns
true if this CSN is older than or equal to the provided
CSN. |
boolean |
ServerState.removeCSN(CSN expectedCSN)
Removes the mapping to the provided CSN if it is present in this
ServerState.
|
boolean |
MultiDomainServerState.removeCSN(org.forgerock.opendj.ldap.Dn baseDN,
CSN expectedCSN)
Removes the mapping to the provided CSN if it is present in this
MultiDomainServerState.
|
boolean |
ServerState.update(CSN csn)
Forward update the Server State with a CSN.
|
boolean |
MultiDomainServerState.update(org.forgerock.opendj.ldap.Dn baseDN,
CSN csn)
Update the ServerState of the provided baseDN with the replication
CSN provided. |
Modifier and Type | Method and Description |
---|---|
CSN |
FakeOperation.getCSN()
Get the CSN.
|
static CSN |
EntryHistorical.getCSN(Entry entry)
Returns the first CSN in the
ds-sync-hist attribute of the provided entry. |
abstract CSN |
AttrHistorical.getDeleteTime()
Returns the last time when this attribute was deleted.
|
CSN |
AttrHistoricalSingle.getDeleteTime() |
CSN |
AttrHistoricalMultiple.getDeleteTime() |
CSN |
EntryHistorical.getDNDate()
Returns the lastCSN when the entry DN was modified.
|
CSN |
EntryHistorical.getOldestCSN()
Returns the oldest CSN stored in this entry historical attribute.
|
CSN |
AttrValueHistorical.getValueDeleteTime()
Get the last time when the value was deleted.
|
CSN |
AttrValueHistorical.getValueUpdateTime()
Get the last time when the value was updated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
EntryHistorical.addedOrRenamedAfter(CSN csn)
Indicates if the Entry was renamed or added after the CSN that is given as
a parameter.
|
abstract void |
AttrHistorical.processLocalOrNonConflictModification(CSN csn,
Modification mod)
This method calculates the historical information and update the hist
attribute to store the historical information for modify operation that
does not conflict with previous operation.
|
void |
AttrHistoricalSingle.processLocalOrNonConflictModification(CSN csn,
Modification mod) |
void |
AttrHistoricalMultiple.processLocalOrNonConflictModification(CSN csn,
Modification mod) |
abstract boolean |
AttrHistorical.replayOperation(Iterator<Modification> modsIterator,
CSN csn,
Entry modifiedEntry,
Modification mod)
This method will be called when replaying an operation.
|
boolean |
AttrHistoricalSingle.replayOperation(Iterator<Modification> modsIterator,
CSN csn,
Entry modifiedEntry,
Modification mod) |
boolean |
AttrHistoricalMultiple.replayOperation(Iterator<Modification> modsIterator,
CSN csn,
Entry modifiedEntry,
Modification m) |
Constructor and Description |
---|
AttrValueHistorical(org.forgerock.opendj.ldap.ByteString value,
org.forgerock.opendj.ldap.schema.AttributeType attributeType,
CSN csnUpdate,
CSN csnDelete)
Build an AttrValueHistorical for a provided attribute value, providing
the last time the provided value is either updated or deleted.
|
FakeAddOperation(CSN csn,
Entry entry)
Creates a new AddFakeOperations.
|
FakeDelOperation(org.forgerock.opendj.ldap.Dn dn,
CSN csn,
String entryUUID)
Creates a new FakeDelOperation from the provided information.
|
FakeModdnOperation(CSN csn,
Entry entry)
Creates a new FakeModdnOperation.
|
FakeModifyOperation(org.forgerock.opendj.ldap.Dn dn,
CSN csn,
String entryuuid)
Creates a new ModifyFakeOperation with the provided information.
|
FakeOperation(CSN csn)
Creates a new FakeOperation using the provided CSN.
|
Modifier and Type | Field and Description |
---|---|
protected CSN |
UpdateMsg.csn
The CSN of this update.
|
Modifier and Type | Method and Description |
---|---|
CSN |
ChangeTimeHeartbeatMsg.getCSN()
Get a CSN with the transmitted change time.
|
CSN |
UpdateMsg.getCSN()
Get the CSN from the message.
|
CSN |
OperationContext.getCSN()
Gets the CSN of the Operation.
|
CSN |
AckMsg.getCSN()
Get the CSN from the message.
|
static CSN |
OperationContext.getCSN(Operation op)
Get the CSN of an operation.
|
static CSN |
OperationContext.getCSN(PluginOperation op)
Get the CSN of an operation from the synchronization context
attached to the provided operation.
|
CSN |
ByteArrayScanner.nextCSN()
Reads the next CSN.
|
CSN |
ByteArrayScanner.nextCSNUTF8()
Reads the next CSN that was encoded as a UTF8 string.
|
Modifier and Type | Method and Description |
---|---|
ByteArrayBuilder |
ByteArrayBuilder.appendCSN(CSN csn)
Append a CSN to this ByteArrayBuilder.
|
ByteArrayBuilder |
ByteArrayBuilder.appendCSNUTF8(CSN csn)
Append a CSN to this ByteArrayBuilder by converting it to a String then
encoding that string to a UTF-8 byte array.
|
Constructor and Description |
---|
AckMsg(CSN csn)
Creates a new AckMsg from a CSN (no errors).
|
AckMsg(CSN csn,
boolean hasTimeout,
boolean hasWrongStatus,
boolean hasReplayError,
List<Integer> failedServers)
Creates a new AckMsg from a CSN (with specified error info).
|
AddContext(CSN csn,
String entryUUID,
String parentEntryUUID)
Creates a new AddContext with the provided information.
|
AddMsg(CSN csn,
org.forgerock.opendj.ldap.Dn dn,
String uniqueId,
String parentId,
Attribute objectClass,
Iterable<Attribute> userAttributes,
Iterable<Attribute> operationalAttributes)
Creates a new AddMessage.
|
AddMsg(CSN csn,
org.forgerock.opendj.ldap.Dn dn,
String entryUUID,
String parentEntryUUID,
Map<org.forgerock.opendj.ldap.schema.ObjectClass,String> objectClasses,
Map<org.forgerock.opendj.ldap.schema.AttributeType,List<Attribute>> userAttributes,
Map<org.forgerock.opendj.ldap.schema.AttributeType,List<Attribute>> operationalAttributes)
Creates a new AddMessage.
|
ChangeTimeHeartbeatMsg(CSN csn)
Constructor of a Change Time Heartbeat message providing the change time
value in a CSN.
|
DeleteContext(CSN csn,
String entryUUID)
Creates a new DeleteContext with the provided information.
|
DeleteMsg(org.forgerock.opendj.ldap.Dn dn,
CSN csn,
String entryUUID)
Creates a new delete message.
|
ModifyCommonMsg(CSN csn,
String entryUUID,
org.forgerock.opendj.ldap.Dn dn)
Creates a new ModifyCommonMsg with the given informations.
|
ModifyContext(CSN csn,
String entryUUID)
Creates a new Modify Context with the provided parameters.
|
ModifyDnContext(CSN csn,
String entryUUID,
String newSuperiorEntryUUID)
Creates a new ModifyDN Context with the provided parameters.
|
ModifyDNMsg(org.forgerock.opendj.ldap.Dn dn,
CSN csn,
String entryUUID,
String newSuperiorEntryUUID,
boolean deleteOldRdn,
String newSuperior,
String newRDN)
Construct a new Modify DN message (no mods).
|
ModifyDNMsg(org.forgerock.opendj.ldap.Dn dn,
CSN csn,
String entryUUID,
String newSuperiorEntryUUID,
boolean deleteOldRdn,
String newSuperior,
String newRDN,
List<Modification> mods)
Construct a new Modify DN message (with mods).
|
ModifyMsg(CSN csn,
org.forgerock.opendj.ldap.Dn dn,
List<Modification> mods,
String entryUUID)
Creates a new Modify message using the provided information.
|
OperationContext(CSN csn,
String entryUUID)
Create a new OperationContext.
|
ReplicaOfflineMsg(CSN offlineCSN)
Constructor of a replica offline message providing the offline timestamp in
a CSN.
|
UpdateMsg(CSN csn,
byte[] payload)
Creates a new UpdateMsg with the given informations.
|
Modifier and Type | Field and Description |
---|---|
protected CSN |
ExpectedAcksInfo.csn
The CSN of the assured update message we want acks for.
|
Modifier and Type | Method and Description |
---|---|
void |
ChangelogState.addOfflineReplica(org.forgerock.opendj.ldap.Dn baseDN,
CSN offlineCSN)
Adds the following replica information to the offline list.
|
Constructor and Description |
---|
ExpectedAcksInfo(CSN csn,
ServerHandler requesterServerHandler,
AssuredMode assuredMode,
List<Integer> expectedServers)
Creates a new ExpectedAcksInfo.
|
SafeDataExpectedAcksInfo(CSN csn,
ServerHandler requesterServerHandler,
byte safeDataLevel,
List<Integer> expectedServers)
Creates a new SafeDataExpectedAcksInfo.
|
SafeReadExpectedAcksInfo(CSN csn,
ServerHandler requesterServerHandler,
List<Integer> expectedServers,
List<Integer> wrongStatusServers)
Creates a new SafeReadExpectedAcksInfo.
|
Modifier and Type | Method and Description |
---|---|
CSN |
ChangeNumberIndexRecord.getCSN()
Getter for the replication CSN field.
|
CSN |
DBCursor.CursorOptions.getDefaultCSN()
Returns the default CSN.
|
Modifier and Type | Method and Description |
---|---|
DBCursor<UpdateMsg> |
ReplicationDomainDB.getCursorFrom(org.forgerock.opendj.ldap.Dn baseDN,
int serverId,
CSN startCSN,
DBCursor.CursorOptions options)
|
void |
ReplicationDomainDB.notifyReplicaOffline(org.forgerock.opendj.ldap.Dn baseDN,
CSN offlineCSN)
Let the DB know this replica is going down.
|
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.
|
Constructor and Description |
---|
ChangeNumberIndexRecord(org.forgerock.opendj.ldap.Dn baseDN,
CSN csn)
Builds an instance of this class, with changeNumber equal to 0.
|
ChangeNumberIndexRecord(long changeNumber,
org.forgerock.opendj.ldap.Dn baseDN,
CSN csn)
Builds an instance of this class.
|
DBCursor.CursorOptions(DBCursor.KeyMatchingStrategy keyMatchingStrategy,
DBCursor.PositionStrategy positionStrategy,
CSN defaultCSN)
Creates options with provided strategies and default CSN.
|
Modifier and Type | Method and Description |
---|---|
void |
DomainDBCursor.addReplicaDB(int serverId,
CSN startCSN)
Adds a replicaDB for this cursor to iterate over.
|
DBCursor<UpdateMsg> |
FileChangelogDB.getCursorFrom(org.forgerock.opendj.ldap.Dn baseDN,
int serverId,
CSN startCSN,
DBCursor.CursorOptions options) |
void |
FileChangelogDB.notifyReplicaOffline(org.forgerock.opendj.ldap.Dn baseDN,
CSN offlineCSN) |
void |
ChangeNumberIndexer.publishHeartbeat(org.forgerock.opendj.ldap.Dn baseDN,
CSN heartbeatCSN)
Ensures the medium consistency point is updated by heartbeats.
|
void |
FileChangelogDB.replicaHeartbeat(org.forgerock.opendj.ldap.Dn baseDN,
CSN heartbeatCSN) |
void |
ChangeNumberIndexer.replicaOffline(org.forgerock.opendj.ldap.Dn baseDN,
CSN offlineCSN)
Signals a replica went offline.
|
void |
ReplicaCursor.setOfflineCSN(CSN offlineCSN)
Sets the offline CSN to be returned by this cursor.
|
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 |
---|---|
CSN |
ReplicationDomain.getLastLocalChange()
Returns the CSN of the last Change that was fully processed by this
ReplicationDomain.
|
Modifier and Type | Method and Description |
---|---|
void |
PurgeConflictsHistoricalTask.setProgressStats(CSN lastCSN,
int purgeCount)
Set the last CSN purged and the count of purged values in order to monitor
the historical purge.
|
Copyright © 2010-2017 ForgeRock AS. All Rights Reserved.