Uses of Class
org.opends.server.replication.common.CSN
Package
Description
Contains classes that represent specific LDAP controls and their values.
Contains the implementation for various Directory Server plugins.
This package contains utilities that can are used by all the packages below org.opends.server.replication.
This package contains the part of the Multi-master replication code that works on the Directory Server side.
This package contains the code used by the replication server and by the code running on the Directory Server side to
exchange their information.
This package contains the API for the changelog database.
This package contains a file-based log implementation for the changelog database API.
This package contains the generic of the Multi-Master replication code that works on the Directory Server side.
Contains implementations for various Directory Server tasks.
-
Uses of CSN in org.opends.server.controls
ModifierConstructorDescriptionReplicatedRequestControl
(boolean isCritical, CSN csn, UUID entryUuid) Constructs a new control.ReplicatedRequestControl
(boolean isCritical, CSN csn, UUID entryUuid, UUID parentUuid) Constructs a new control. -
Uses of CSN in org.opends.server.plugins
Modifier and TypeMethodDescriptionChangeNumberControlPlugin.CsnResponseControl.getCSN()
Retrieves the CSN.ModifierConstructorDescriptionCsnResponseControl
(boolean isCritical, CSN csn) Constructs a new change number control. -
Uses of CSN in org.opends.server.replication.common
Modifier and TypeFieldDescriptionstatic final CSN
CSN.MAX_VALUE
The maximum possible value for a CSN.static final CSN
CSN.MIN_VALUE
The minimum possible value for a CSN.Modifier and TypeMethodDescriptionReturns the CSN associated to the provided replication domain's baseDN and replicaId.Returns theCSN
contained in this server state which corresponds to the provided replica ID.CSNGenerator.newCSN()
Generate a newCSN
.static CSN
CSN.newestCsn
(long timeStamp) Return the newest possible CSN for the given time.static CSN
Returns the newest possible CSN for a replica.static CSN
CSN.oldestCsn
(long timeStamp) Returns the oldest possible CSN for the given time.static CSN
Returns the oldest possible CSN for a replica.static CSN
Parses the providedtoString()
representation of a CSN.static CSN
CSN.valueOf
(ByteString bs) Decodes the providedtoByteString(CsnVersion)
representation of a CSN.static CSN
CSN.valueOf
(ByteStringReader reader) Decodes the providedtoByteString(CsnVersion)
representation of a CSN, possibly embedded in a larger sequence.Modifier and TypeMethodDescriptionServerState.getReplicaIdToCSNMap()
Returns a copy of this ServerState's content as a Map of replicaId to CSN.MultiDomainServerState.getSnapshot()
Returns a snapshot of this object.ServerState.getSnapshot()
Returns a snapshot of this object.ServerState.iterator()
Modifier and TypeMethodDescriptionvoid
Adjust the lastTime of thisCSNGenerator
with aCSN
that we have received from another server.static int
Compares this CSN with the provided CSN for order and returns a negative number ifcsn1
is older thancsn2
, zero if they have the same age, or a positive number ifcsn1
is newer thancsn2
.int
Compares this CSN with the provided CSN for order and returns a negative number if this CSN is older thancsn
, zero if they have the same age, or a positive number if this CSN is newer thancsn
.boolean
Test if this object covers the provided CSN for the provided baseDN.boolean
Checks that the CSN given as a parameter is in this ServerState.boolean
CSN.isNewerThan
(CSN csn) Returnstrue
if this CSN is newer than the provided CSN.boolean
CSN.isNewerThanOrEqualTo
(CSN csn) Returnstrue
if this CSN is newer than or equal to the provided CSN.boolean
CSN.isOlderThan
(CSN csn) Returnstrue
if this CSN is older than the provided CSN.boolean
CSN.isOlderThanOrEqualTo
(CSN csn) Returnstrue
if this CSN is older than or equal to the provided CSN.boolean
Removes the mapping to the provided CSN if it is present in this ServerState.boolean
Update the ServerState of the provided baseDN with the replicationCSN
provided.boolean
Forward update the Server State with a CSN. -
Uses of CSN in org.opends.server.replication.plugin
Modifier and TypeMethodDescriptionabstract CSN
AttrHistorical.getDeleteTime()
Returns the last time when this attribute was deleted.AttrHistoricalMultiple.getDeleteTime()
AttrHistoricalSingle.getDeleteTime()
EntryHistorical.getEntryADDDate()
Returns the CSN of the operation that added this entry.EntryHistorical.getEntryMODDNDate()
Returns the CSN of the operation that renamed this entry.AttrValueHistorical.getValueDeleteTime()
Get the last time when the value was deleted.AttrValueHistorical.getValueUpdateTime()
Get the last time when the value was updated.Modifier and TypeMethodDescriptionvoid
EntryHistorical.addAttrHistoricalAddValue
(AttributeDescription attributeDescription, CSN csn, ByteString value) Updates this entry historical information with the provided add modification.void
EntryHistorical.addAttrHistoricalDeleteAttr
(AttributeDescription attributeDescription, CSN csn) Updates this entry historical information with the provided delete attribute modification.void
EntryHistorical.addAttrHistoricalDeleteValue
(AttributeDescription attributeDescription, CSN csn, ByteString value) Updates this entry historical information with the provided delete modification.void
EntryHistorical.addAttrHistoricalReplaceValue
(AttributeDescription attributeDescription, CSN csn, ByteString value) Updates this entry historical information with the provided replace modification.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
AttrHistoricalMultiple.processLocalOrNonConflictModification
(CSN csn, Modification mod) void
AttrHistoricalSingle.processLocalOrNonConflictModification
(CSN csn, Modification mod) abstract Modification
AttrHistorical.replayOperation
(CSN csn, Entry modifiedEntry, Modification mod) This method will be called when replaying an operation.AttrHistoricalMultiple.replayOperation
(CSN csn, Entry modifiedEntry, Modification m) AttrHistoricalSingle.replayOperation
(CSN csn, Entry modifiedEntry, Modification mod) void
EntryHistorical.setEntryADDDate
(CSN csn) Sets the CSN of the operation that added this entry.void
EntryHistorical.setEntryMODDNDate
(CSN csn) Sets the CSN of the operation that renamed this entry. -
Uses of CSN in org.opends.server.replication.protocol
Modifier and TypeMethodDescriptionChangeTimeHeartbeatMsg.getCSN()
Get a CSN with the transmitted change time.OperationContext.getCSN()
Gets the CSN of the Operation.static CSN
OperationContext.getCSN
(PluginOperation op) Get the CSN of an operation from the synchronization context attached to the provided operation.UpdateMsg.getCSN()
Get the CSN from the message.ByteArrayScanner.nextCsn()
Reads the next CSN.ByteArrayScanner.nextCsnUtf8()
Reads the next CSN that was encoded as a UTF8 string.Modifier and TypeMethodDescriptionByteArrayBuilder.appendCsn
(CSN csn, CSN.CsnVersion version) Append a CSN to this ByteArrayBuilder.ByteArrayBuilder.appendCsnUtf8
(CSN csn, CSN.CsnVersion version) Append a CSN to this ByteArrayBuilder by converting it to a String then encoding that string to a UTF-8 byte array.ModifierConstructorDescriptionAddContext
(CSN csn, UUID entryUUID, UUID parentEntryUUID) Creates a new AddContext with the provided information.AddMsg
(CSN csn, Dn dn, UUID entryUuid, UUID parentEntryUuid, byte[] encodedAttributes, byte[] encodedEclIncludes) Creates a new AddMessage.Creates a new AddMessage.Constructor of a Change Time Heartbeat message providing the change time value in a CSN.DeleteContext
(CSN csn, UUID entryUUID) Creates a new DeleteContext with the provided information.Creates a new delete message.DeleteMsg
(CSN csn, Dn dn, UUID entryUUID, String initiatorsName, byte[] encodedEclIncludes, boolean subtreeDelete) Creates a new delete message.ModifyContext
(CSN csn, UUID entryUUID) Creates a new Modify Context with the provided parameters.ModifyDnContext
(CSN csn, UUID entryUUID, UUID newSuperiorEntryUUID) Creates a new ModifyDN Context with the provided parameters.ModifyDNMsg
(Dn dn, CSN csn, UUID entryUUID, UUID newSuperiorEntryUUID, boolean deleteOldRdn, Dn newSuperior, Rdn newRDN) Construct a new Modify DN message (no mods).ModifyDNMsg
(Dn dn, CSN csn, UUID entryUUID, UUID newSuperiorEntryUUID, boolean deleteOldRdn, Dn newSuperior, Rdn newRDN, List<Modification> mods) Construct a new Modify DN message (with mods).ModifyDNMsg
(CSN csn, Dn dn, UUID entryUUID, Rdn newRdn, Dn newSuperior, UUID newSuperiorEntryUUID, boolean deleteOldRdn, byte[] encodedMods, byte[] encodedEclIncludes) Creates a new ModifyDN message.Creates a new Modify message using the provided information.Creates a new Modify message using the provided information.protected
OperationContext
(CSN csn, UUID entryUUID) Create a new OperationContext.ReplicaOfflineMsg
(CSN offlineCSN) Constructor of a replica offline message providing the offline timestamp in a CSN.Creates a new UpdateMsg with the given information. -
Uses of CSN in org.opends.server.replication.server.changelog.api
Modifier and TypeMethodDescriptionUpdateRecord.getCsn()
Returns the CSN of the message.ChangeNumberIndexRecord.getCSN()
Getter for the replication CSN field.DBCursor.CursorOptions.getDefaultCSN()
Returns the default CSN.RemovedReplicasStates.getLastMessageCsn
(ReplicaId replica) Returns the CSN for the last LDAP message from the provided replica.RemovedReplicasStates.getLastUpdateCsn
(ReplicaId replica) Returns the CSN for the lastLDAPUpdateMsg
from the provided replica.ReplicationDomainDB.ReplicaDbFileContent.newestCsn()
Returns the value of thenewestCsn
record component.ReplicationDomainDB.ReplicaDbFileContent.oldestCsn()
Returns the value of theoldestCsn
record component.Modifier and TypeMethodDescriptionReplicationDomainDB.getCursorFrom
(DomainReplicaId replica, CSN startCSN, DBCursor.CursorOptions options) void
ReplicationDomainDB.replicaHeartbeat
(Dn baseDN, CSN heartbeatCSN) Let the DB know this replica is alive.void
ChangeNumberIndexDB.resetChangeNumberTo
(long newFirstCN, Dn baseDN, CSN newFirstCSN) Resets ChangeNumber index to the given number and CSN.void
Updates the removed replicas states with the provided CSNs.ModifierConstructorDescriptionChangeNumberIndexRecord
(long changeNumber, Dn baseDN, CSN csn) Builds an instance of this class.ChangeNumberIndexRecord
(Dn baseDN, CSN csn) Builds an instance of this class, with changeNumber equal to 0.CursorOptions
(DBCursor.PositionStrategy strategy, CSN defaultCSN) Creates options with provided positioning strategy and default CSN.ReplicaDbFileContent
(CSN oldestCsn, CSN newestCsn, int numberOfUpdates, int numberOfReplicaOfflineMessages) Creates an instance of aReplicaDbFileContent
record class. -
Uses of CSN in org.opends.server.replication.server.changelog.file
Modifier and TypeMethodDescriptionvoid
DomainDBCursor.addReplicaDB
(DomainReplicaId replicaId, CSN startCSN) Adds a replicaDB for this cursor to iterate over.FileChangelogDB.getCursorFrom
(DomainReplicaId replica, CSN startCsn, DBCursor.CursorOptions options) static void
FileChangelogDB.migrateOfflineStateToChangelog
(Path replicationDbDir, Path replicaIdDir, LogCryptoCfg cryptoCfg, CSN offlineCsn) Used by upgrade only: Append the CSN at which the server/domains was considered offline if this CSN appears to be more recent than the last message already contained in the log, otherwise the changelog is not modified.void
ChangeNumberIndexer.notifyHeartbeat
(Dn baseDn, CSN heartbeatCsn) Ensures the medium consistency point is updated by heartbeats.void
FileChangelogDB.replicaHeartbeat
(Dn baseDN, CSN heartbeatCsn) -
Uses of CSN in org.opends.server.replication.service
Modifier and TypeMethodDescriptionReplicationDomain.getLastLocalChange()
Returns the CSN of the last Change that was fully processed by this ReplicationDomain. -
Uses of CSN in org.opends.server.tasks
Modifier and TypeMethodDescriptionvoid
PurgeConflictsHistoricalTask.setProgressStats
(CSN lastCSN, int purgeCount) Set the last CSN purged and the count of purged values in order to monitor the historical purge.