Uses of Class
org.opends.server.replication.common.Csn

Packages that use Csn

Package	Description
org.forgerock.opendj.server.leaderbasedreplication	This package contains the main class of the leader based replication.
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.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.

Uses of Csn in org.forgerock.opendj.server.leaderbasedreplication

Subclasses with type arguments of type Csn in org.forgerock.opendj.server.leaderbasedreplication

Modifier and Type	Class	Description
final class	ReplicaState	The replication state of a replica.

Methods in org.forgerock.opendj.server.leaderbasedreplication that return Csn

Modifier and Type	Method	Description
Csn	StreamId.asCsn()	Returns this stream as csn.
Csn	RegistrationToCoreExtendedRequest.csnNow()	Returns the value of the csnNow record component.
Csn	ReplicaChangelog.csnNow()	Returns a Csn representing the current time, not attached to an update.
Csn	ReplicaChangelogImpl.csnNow()
Csn	ReplicaClient.RegistrationToCoreRequest.csnNow()	Returns the value of the csnNow record component.
Csn	ReplicaState.get(StreamId streamId)	Returns the CSN associated with the provided StreamId.
Csn	ReplicaChangelog.getOldestChangeOfStream(Domain domain, StreamId streamId)	Returns the oldest change of the provided stream for the given domain.
Csn	ReplicaChangelogImpl.getOldestChangeOfStream(Domain domain, StreamId streamId)

Methods in org.forgerock.opendj.server.leaderbasedreplication that return types with arguments of type Csn

Modifier and Type	Method	Description
Iterator<Csn>	ReplicaState.iterator()

Methods in org.forgerock.opendj.server.leaderbasedreplication with parameters of type Csn

Modifier and Type	Method	Description
static StreamId	StreamId.of(Csn csn)	Creates a new StreamId from the provided Csn.
void	ReplicaState.purge(Csn purgeCsn, ReplicaId callingReplicaId)	Purge the state by deleting streams (excepting the newest for each replica) which have an older CSN than the provided CSN.
void	ReplicaChangelog.purgeUpTo(Csn purgePointThreshold)	Purges the changelog up to the provided point.
void	ReplicaChangelogImpl.purgeUpTo(Csn purgeCsn)	Removes all the changes from the changelog which have a Csn older than the one specified.
protected void	ReplicatedDomain.purgeUpTo(Csn purgeCsn)	Purge the data state by deleting streams (excepting the newest for each replica) which have an older CSN than the provided CSN.
void	ReplicaState.put(Csn csn)	Adds a StreamId starting with the provided CSN to the state.
boolean	ReplicaState.putIfMoreRecent(Csn csn)	Updates the current state with the provided CSN, creating the StreamId if necessary.
void	ReplicatedDomain.updateReplicaState(Csn csn)	Update the data state with the given CSN.

Constructors in org.forgerock.opendj.server.leaderbasedreplication with parameters of type Csn

Modifier	Constructor	Description
	RegistrationToCoreExtendedRequest(Topology.ReplicaCoordinate replicaCoordinate, Domain domain, ReplicaState dataState, ReplicaState changelogState, Csn csnNow, List<Control> controls)	Create a new RegistrationToCoreExtendedRequest.
	RegistrationToCoreRequest(Topology.ReplicaCoordinate replicaCoordinate, Domain domain, ReplicaState dataState, ReplicaState changelogState, Csn csnNow)	Creates an instance of a RegistrationToCoreRequest record class.

Uses of Csn in org.opends.server.controls

Methods in org.opends.server.controls that return Csn

Modifier and Type	Method	Description
Csn	ReplicatedRequestControl.getCsn()	Returns the CSN.

Constructors in org.opends.server.controls with parameters of type Csn

Modifier	Constructor	Description
	ReplicatedRequestControl(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

Methods in org.opends.server.plugins that return Csn

Modifier and Type	Method	Description
Csn	ChangeNumberControlPlugin.CsnResponseControl.getCsn()	Returns the CSN.

Constructors in org.opends.server.plugins with parameters of type Csn

Modifier	Constructor	Description
	CsnResponseControl(boolean isCritical, Csn csn)	Constructs a new change number control.

Uses of Csn in org.opends.server.replication.common

Classes in org.opends.server.replication.common that implement interfaces with type arguments of type Csn

Modifier and Type	Class	Description
final class	Csn	Class used to represent Change Sequence Numbers.
final class	ServerState	This class is used to associate ReplicaIds with Csns.

Fields in org.opends.server.replication.common declared as Csn

Modifier and Type	Field	Description
static final Csn	Csn.MAX_VALUE	The maximum possible value for a CSN; used for comparisons and initialization, the stream id does not count.
static final Csn	Csn.MIN_VALUE	The minimum possible value for a CSN; used for comparisons and initialization, the stream id does not count.

Methods in org.opends.server.replication.common that return Csn

Modifier and Type	Method	Description
Csn	CsnGenerator.generateCsn()	Returns the generated Csn.
Csn	CsnGenerator.generateCsnV3(long streamTimeStamp, long curTime, CsnGenerator.StreamSequenceNumberGenerator streamSeqNumGen)	Generate a new Csn using the V3 format.
Csn	MultiDomainServerState.getCsn(Dn baseDN, ReplicaId replicaId)	Returns the CSN associated to the provided replication domain's baseDN and replicaId.
Csn	ServerState.getCsn(ReplicaId replicaId)	Returns the CSN contained in this server state which corresponds to the provided replica ID.
static Csn	Csn.newCsn(long streamTimeStamp, long timeStamp, int seqNum, long streamSeqNum, ReplicaId replicaId)	Create a new Csn.
static Csn	Csn.newCsn(long streamTimeStamp, long timeStamp, int seqNum, ReplicaId replicaId)	Create a new Csn.
static Csn	Csn.newCsnV1(long timeStamp, int seqNum, int replicaId)	Create a new Csn.
static Csn	Csn.newCsnV2(long timeStamp, int seqNum, ReplicaId replicaId)	Create a new Csn.
static Csn	Csn.newestCsn(long timeStamp)	Returns the newest possible CSN for the given time.
static Csn	Csn.newestCsn(ReplicaId replicaId)	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	Csn.oldestCsn(ReplicaId replicaId)	Returns the oldest possible CSN for a replica.
static Csn	Csn.valueOf(String str)	Parses the provided Csn.toString() representation of a CSN.
static Csn	Csn.valueOf(ByteString bs)	Decodes the provided Csn.toByteString(CsnVersion) representation of a CSN.
static Csn	Csn.valueOf(ByteStringReader reader)	Decodes the provided Csn.toByteString(CsnVersion) representation of a CSN, possibly embedded in a larger sequence.

Methods in org.opends.server.replication.common that return types with arguments of type Csn

Modifier and Type	Method	Description
Map<ReplicaId, Csn>	ServerState.getReplicaIdToCsnMap()	Returns a copy of this ServerState's content as a Map of replicaId to CSN.
Map<Dn,Set<Csn>>	MultiDomainServerState.getSnapshot()	Returns a snapshot of this object.
Set<Csn>	ServerState.getSnapshot()	Returns a snapshot of this object.
Iterator<Csn>	ServerState.iterator()

Methods in org.opends.server.replication.common with parameters of type Csn

Modifier and Type	Method	Description
void	CsnGenerator.adjust(Csn csn)	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	MultiDomainServerState.cover(Dn baseDN, Csn csn)	Test if this object covers the provided CSN for the provided baseDN.
boolean	ServerState.cover(Csn covered)	Checks that the CSN given as a parameter is in this ServerState.
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.
static boolean	CsnGenerator.isSequenceBroken(Csn csn1, Csn csn2)	Checks whether the sequence is broken between two Csns.
boolean	ServerState.removeCsn(Csn expectedCsn)	Removes the mapping to the provided CSN if it is present in this ServerState.
boolean	MultiDomainServerState.update(Dn baseDN, Csn csn)	Update the ServerState of the provided baseDN with the replication Csn provided.
boolean	ServerState.update(Csn csn)	Forward update the Server State with a CSN.

Uses of Csn in org.opends.server.replication.plugin

Methods in org.opends.server.replication.plugin that return Csn

Modifier and Type	Method	Description
Csn	HistoricalAttributeValue.csn()	Returns the value of the csn record component.
abstract Csn	AttrHistorical.getDeleteTime()	Returns the last time when this attribute was deleted.
Csn	AttrHistoricalMultiple.getDeleteTime()
Csn	AttrHistoricalSingle.getDeleteTime()
Csn	EntryHistorical.getEntryAddDate()	Returns the CSN of the operation that added this entry.
Csn	EntryHistorical.getEntryModDnDate()	Returns the CSN of the operation that renamed this entry.
Csn	AttrValueHistorical.getValueDeleteTime()	Returns the last time when the value was deleted.
Csn	AttrValueHistorical.getValueUpdateTime()	Returns the last time when the value was updated.

Methods in org.opends.server.replication.plugin with parameters of type Csn

Modifier and Type	Method	Description
abstract void	AttrHistorical.attributeDeleteTime(Csn csn)	Sets the attribute delete time.
void	AttrHistoricalMultiple.attributeDeleteTime(Csn csn)
void	AttrHistoricalSingle.attributeDeleteTime(Csn csn)
static HistoricalAttributeValue	HistoricalAttributeValue.attributeModification(AttributeDescription attrDesc, HistAttrModificationKey histKey, Csn csn, ByteString attributeValue)	Returns a ds-sync-hist value encoding a modification that adds/replaces with/deletes an attribute value.
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.
Modification	AttrHistoricalMultiple.replayOperation(Csn csn, Entry modifiedEntry, Modification m)
Modification	AttrHistoricalSingle.replayOperation(Csn csn, Entry modifiedEntry, Modification mod)

Constructors in org.opends.server.replication.plugin with parameters of type Csn

Modifier	Constructor	Description
	EntryHistorical(Csn entryAddDate, Csn entryModDnDate)	Constructor.
	HistoricalAttributeValue(AttributeDescription attributeDescription, HistoricalAttributeValue.HistOperation operation, Csn csn, HistAttrModificationKey histKey, ByteString attributeValue)	Canonical constructor.

Uses of Csn in org.opends.server.replication.protocol

Methods in org.opends.server.replication.protocol that return Csn

Modifier and Type	Method	Description
Csn	OperationContext.AddContext.csn()	Returns the value of the csn record component.
Csn	OperationContext.csn()	Returns the CSN of the Operation.
Csn	OperationContext.DeleteContext.csn()	Returns the value of the csn record component.
Csn	OperationContext.ModifyContext.csn()	Returns the value of the csn record component.
Csn	OperationContext.ModifyDnContext.csn()	Returns the value of the csn record component.
Csn	ChangeTimeHeartbeatMsg.getCsn()	Get a CSN with the transmitted change time.
static Csn	OperationContext.getCsn(PluginOperation op)	Get the CSN of an operation from the synchronization context attached to the provided operation.
Csn	UpdateMsg.getCsn()	Get the CSN from the message.
Csn	ByteArrayScanner.nextCsn()	Reads the next CSN.
Csn	ByteArrayScanner.nextCsnUtf8()	Reads the next CSN that was encoded as a UTF8 string.

Methods in org.opends.server.replication.protocol with parameters of type Csn

Modifier and Type	Method	Description
ByteArrayBuilder	ByteArrayBuilder.appendCsn(Csn csn, Csn.CsnVersion version)	Append a CSN to this ByteArrayBuilder.
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.

Constructors in org.opends.server.replication.protocol with parameters of type Csn

Modifier	Constructor	Description
	AddContext(Csn csn, UUID entryUuid, UUID parentEntryUuid)	Creates an instance of a AddContext record class.
	AddMsg(Csn csn, Dn dn, UUID entryUuid, UUID parentEntryUuid, byte[] encodedAttributes, byte[] encodedEclIncludes)	Creates a new AddMessage.
	AddMsg(Csn csn, Entry entry, UUID entryUuid, UUID parentEntryUuid)	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, UUID entryUuid)	Creates an instance of a DeleteContext record class.
	DeleteMsg(Dn dn, Csn csn, UUID entryUUID)	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 an instance of a ModifyContext record class.
	ModifyDnContext(Csn csn, UUID entryUuid, UUID newSuperiorEntryUuid)	Creates an instance of a ModifyDnContext record class.
	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.
	ModifyMsg(Csn csn, Dn dn, UUID entryUUID, byte[] encodedMods, byte[] encodedEclIncludes)	Creates a new Modify message using the provided information.
	ModifyMsg(Csn csn, Dn dn, UUID entryUUID, List<Modification> mods)	Creates a new Modify message using the provided information.
	ReplicaOfflineMsg(Csn offlineCsn)	Constructor of a replica offline message providing the offline timestamp in a CSN.
	UpdateMsg(Csn csn)	Creates a new UpdateMsg with the given information.

Uses of Csn in org.opends.server.replication.server.changelog.api

Methods in org.opends.server.replication.server.changelog.api that return Csn

Modifier and Type	Method	Description
Csn	ChangeNumberIndexRecord.csn()	Returns the value of the csn record component.
Csn	UpdateRecord.getCsn()	Returns the CSN of the message.
Csn	DBCursor.CursorOptions.getDefaultCsn()	Returns the default CSN.
Csn	RemovedReplicasStates.getLastMessageCsn(ReplicaId replica)	Returns the CSN for the last LDAP message from the provided replica.
Csn	RemovedReplicasStates.getLastUpdateCsn(ReplicaId replica)	Returns the CSN for the last LdapUpdateMsg from the provided replica.
Csn	ReplicationDomainDB.getReplicaOldestCsn(DomainReplicaId domainReplicaId)	Returns the oldest Csn for the specified replica in a replication domain.
Csn	ReplicationDomainDB.ReplicaDbFileContent.newestCsn()	Returns the value of the newestCsn record component.
Csn	ReplicationDomainDB.ReplicaDbFileContent.oldestCsn()	Returns the value of the oldestCsn record component.

Methods in org.opends.server.replication.server.changelog.api that return types with arguments of type Csn

Modifier and Type	Method	Description
Map<StreamId, DBCursor<Record<Csn, UpdateMsg>>>	ReplicationDomainDB.getChangelogCursors(Dn baseDN)	Generates DBCursor for all streams of a given domain.
DBCursor<Record<Csn, UpdateMsg>>	ReplicationDomainDB.getStreamIdCursor(DomainReplicaId domainReplicaId, StreamId streamId)	Generates a DBCursor for a given stream of a replica.

Methods in org.opends.server.replication.server.changelog.api with parameters of type Csn

Modifier and Type	Method	Description
DBCursor<UpdateMsg>	ReplicationDomainDB.getCursorFrom(DomainReplicaId replica, Csn startCsn, DBCursor.CursorOptions options)	Generates a DBCursor for one replicaDB for the specified replication domain and replica id starting before, at or after the provided Csn, depending on the provided matching and positioning strategies.
void	RemovedReplicasStates.update(Csn lastUpdate, Csn lastMessage)	Updates the removed replicas states with the provided CSNs.

Constructors in org.opends.server.replication.server.changelog.api with parameters of type Csn

Modifier	Constructor	Description
	ChangeNumberIndexRecord(long changeNumber, Dn baseDn, Csn csn, MultiDomainServerState cookie)	Builds an instance of this record.
	ChangeNumberIndexRecord(Dn baseDN, Csn csn, MultiDomainServerState cookie)	Builds an instance of this record, 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 a ReplicaDbFileContent record class.

Uses of Csn in org.opends.server.replication.server.changelog.file

Methods in org.opends.server.replication.server.changelog.file that return Csn

Modifier and Type	Method	Description
Csn	FileChangelogDB.getReplicaOldestCsn(DomainReplicaId domainReplicaId)
Csn	FileChangelogDB.getStreamOldestCsn(DomainReplicaId domainReplicaId, StreamId streamId)	Returns the oldest CSN for a given stream of a replica.

Methods in org.opends.server.replication.server.changelog.file that return types with arguments of type Csn

Modifier and Type	Method	Description
Map<StreamId, DBCursor<Record<Csn, UpdateMsg>>>	FileChangelogDB.getChangelogCursors(Dn baseDN)
org.opends.server.replication.server.changelog.file.Log<Csn, StreamId, UpdateMsg>	ReplicationEnvironment.getOrCreateReplicaDB(DomainReplicaId domainReplicaId, GenerationId generationId)	Finds or creates the log used to store changes from the replication server with the given replica id and the given baseDN.
DBCursor<Record<Csn, UpdateMsg>>	FileChangelogDB.getStreamIdCursor(DomainReplicaId replicaId, StreamId streamId)	Returns a cursor for a given replicaId and streamId.

Methods in org.opends.server.replication.server.changelog.file with parameters of type Csn

Modifier and Type	Method	Description
void	DomainDBCursor.addReplicaDB(DomainReplicaId replicaId, Csn startCsn)	Adds a replicaDB for this cursor to iterate over.
DBCursor<UpdateMsg>	FileChangelogDB.getCursorFrom(DomainReplicaId replica, Csn startCsn, DBCursor.CursorOptions options)
static void	FileChangelogDB.migrateOfflineStateToChangelog(Path replicationDbDir, Path replicaIdDir, LogFileCfg logFileCfg, 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	FileChangelogDB.purgeUpTo(Csn purgeCsn)	Purges the changelog up to the provided CSN.

Uses of Csn in org.opends.server.replication.service

Methods in org.opends.server.replication.service that return Csn

Modifier and Type	Method	Description
Csn	ReplicationDomain.getLastLocalChange()	Returns the CSN of the last Change that was fully processed by this ReplicationDomain.

Uses of Csn in org.opends.server.tasks

Methods in org.opends.server.tasks with parameters of type Csn

Modifier and Type	Method	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.