Uses of Class
org.opends.server.replication.common.CSN
Packages that use CSN
Package
Description
This package contains the main class of the leader based replication.
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.forgerock.opendj.server.leaderbasedreplication
Fields in org.forgerock.opendj.server.leaderbasedreplication declared as CSNModifier and TypeFieldDescriptionstatic final CSNTopology.DomainState.NO_PURGE_CSNThe initial PP.static final CSNTopology.DomainState.NO_SCP_CSNThe initial SCP.Methods in org.forgerock.opendj.server.leaderbasedreplication that return CSNModifier and TypeMethodDescriptionStreamId.asCsn()Returns this stream as csn.ConsistentCore.ReplicaStateUpdateRequest.csnNow()Returns the value of thecsnNowrecord component.ReplicaChangelog.csnNow()Returns a CSN representing the current time, not attached to an update.Returns the CSN associated with the provided StreamId.ReplicaChangelog.getOldestChangeOfStream(StreamId streamId) Returns the oldest change of the provided stream.FetchChangelogUpdatesControl.getReplicaPurgePoint()Returns the starting point of the replication request control.FetchChangelogUpdatesControl.getReplicaStableConsistencyPoint()Returns the stable consistency point of the replication request control.Topology.DomainState.purgePoint()Returns the value of thepurgePointrecord component.FetchChangelogUpdatesControl.FetchChangelogUpdatesInfo.replicaPurgePoint()Returns the value of thereplicaPurgePointrecord component.FetchChangelogUpdatesControl.FetchChangelogUpdatesInfo.replicaScp()Returns the value of thereplicaScprecord component.Topology.DomainState.stableConsistencyPoint()Returns the value of thestableConsistencyPointrecord component.Methods in org.forgerock.opendj.server.leaderbasedreplication that return types with arguments of type CSNMethods in org.forgerock.opendj.server.leaderbasedreplication with parameters of type CSNModifier and TypeMethodDescriptionstatic StreamIdvoidPurges the changelog up to the provided point.voidPurge the state by deleting streams (excepting the newest for each replica) which have an older CSN than the provided CSN.voidAdds a StreamId starting with the provided CSN to the state.booleanReplicaState.putIfMoreRecent(CSN csn) Updates the current state with the provided CSN, creating the StreamId if necessary.voidExecutionContext.updateDataState(CSN csn) Updates the data state of the replica.Constructors in org.forgerock.opendj.server.leaderbasedreplication with parameters of type CSNModifierConstructorDescriptionDomainState(CSN stableConsistencyPoint, CSN purgePoint) Creates an instance of aDomainStaterecord class.FetchChangelogUpdatesInfo(GenerationId generationId, ReplicaId serverId, GroupId groupId, ReplicaState replicaState, CSN replicaScp, CSN replicaPurgePoint, boolean isReplicaData) Creates an instance of aFetchChangelogUpdatesInforecord class.ReplicaStateUpdateRequest(Topology.ReplicaCoordinate replicaCoordinate, ReplicaState dataState, ReplicaState changelogState, CSN csnNow) Creates an instance of aReplicaStateUpdateRequestrecord class. -
Uses of CSN in org.opends.server.controls
Methods in org.opends.server.controls that return CSNConstructors in org.opends.server.controls with parameters of type CSNModifierConstructorDescriptionReplicatedRequestControl(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 CSNModifier and TypeMethodDescriptionChangeNumberControlPlugin.CsnResponseControl.getCSN()Retrieves the CSN.Constructors in org.opends.server.plugins with parameters of type CSNModifierConstructorDescriptionCsnResponseControl(boolean isCritical, CSN csn) Constructs a new change number control. -
Uses of CSN in org.opends.server.replication.common
Fields in org.opends.server.replication.common declared as CSNModifier and TypeFieldDescriptionstatic final CSNCSN.MAX_VALUEThe maximum possible value for a CSN; used for comparisons and initialization, the stream id does not count.static final CSNCSN.MIN_VALUEThe 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 CSNModifier and TypeMethodDescriptionCSNGenerator.generateCsn()Generate a newCSN.Returns the CSN associated to the provided replication domain's baseDN and replicaId.Returns theCSNcontained in this server state which corresponds to the provided replica ID.static CSNCreate a newCSN.static CSNCSN.newCsnV1(long timeStamp, int seqNum, int replicaId) Create a newCSN.static CSNCreate a newCSN.static CSNCSN.newestCsn(long timeStamp) Return the newest possible CSN for the given time.static CSNReturns the newest possible CSN for a replica.static CSNCSN.oldestCsn(long timeStamp) Returns the oldest possible CSN for the given time.static CSNReturns the oldest possible CSN for a replica.static CSNParses the providedtoString()representation of a CSN.static CSNCSN.valueOf(ByteString bs) Decodes the providedtoByteString(CsnVersion)representation of a CSN.static CSNCSN.valueOf(ByteStringReader reader) Decodes the providedtoByteString(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 CSNModifier 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()Methods in org.opends.server.replication.common with parameters of type CSNModifier and TypeMethodDescriptionvoidAdjust the lastTime of thisCSNGeneratorwith aCSNthat we have received from another server.static intCompares this CSN with the provided CSN for order and returns a negative number ifcsn1is older thancsn2, zero if they have the same age, or a positive number ifcsn1is newer thancsn2.intCompares 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.booleanTest if this object covers the provided CSN for the provided baseDN.booleanChecks that the CSN given as a parameter is in this ServerState.booleanCSN.isNewerThan(CSN csn) Returnstrueif this CSN is newer than the provided CSN.booleanCSN.isNewerThanOrEqualTo(CSN csn) Returnstrueif this CSN is newer than or equal to the provided CSN.booleanCSN.isOlderThan(CSN csn) Returnstrueif this CSN is older than the provided CSN.booleanCSN.isOlderThanOrEqualTo(CSN csn) Returnstrueif this CSN is older than or equal to the provided CSN.booleanRemoves the mapping to the provided CSN if it is present in this ServerState.booleanUpdate the ServerState of the provided baseDN with the replicationCSNprovided.booleanForward 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 CSNModifier and TypeMethodDescriptionabstract CSNAttrHistorical.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.Methods in org.opends.server.replication.plugin with parameters of type CSNModifier and TypeMethodDescriptionvoidEntryHistorical.addAttrHistoricalAddValue(AttributeDescription attributeDescription, CSN csn, ByteString value) Updates this entry historical information with the provided add modification.voidEntryHistorical.addAttrHistoricalDeleteAttr(AttributeDescription attributeDescription, CSN csn) Updates this entry historical information with the provided delete attribute modification.voidEntryHistorical.addAttrHistoricalDeleteValue(AttributeDescription attributeDescription, CSN csn, ByteString value) Updates this entry historical information with the provided delete modification.voidEntryHistorical.addAttrHistoricalReplaceValue(AttributeDescription attributeDescription, CSN csn, ByteString value) Updates this entry historical information with the provided replace modification.abstract voidAttrHistorical.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.voidAttrHistoricalMultiple.processLocalOrNonConflictModification(CSN csn, Modification mod) voidAttrHistoricalSingle.processLocalOrNonConflictModification(CSN csn, Modification mod) abstract ModificationAttrHistorical.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) voidEntryHistorical.setEntryADDDate(CSN csn) Sets the CSN of the operation that added this entry.voidEntryHistorical.setEntryMODDNDate(CSN csn) Sets the CSN of the operation that renamed this entry. -
Uses of CSN in org.opends.server.replication.protocol
Methods in org.opends.server.replication.protocol that return CSNModifier and TypeMethodDescriptionOperationContext.AddContext.csn()Returns the value of thecsnrecord component.OperationContext.csn()Gets the CSN of the Operation.OperationContext.DeleteContext.csn()Returns the value of thecsnrecord component.OperationContext.ModifyContext.csn()Returns the value of thecsnrecord component.OperationContext.ModifyDnContext.csn()Returns the value of thecsnrecord component.ChangeTimeHeartbeatMsg.getCSN()Get a CSN with the transmitted change time.static CSNOperationContext.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.Methods in org.opends.server.replication.protocol with parameters of type CSNModifier 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.Constructors in org.opends.server.replication.protocol with parameters of type CSNModifierConstructorDescriptionAddContext(CSN csn, UUID entryUuid, UUID parentEntryUuid) Creates an instance of aAddContextrecord class.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 an instance of aDeleteContextrecord class.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 aModifyContextrecord class.ModifyDnContext(CSN csn, UUID entryUuid, UUID newSuperiorEntryUuid) Creates an instance of aModifyDnContextrecord 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.Creates a new Modify message using the provided information.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.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 CSNModifier and TypeMethodDescriptionChangeNumberIndexRecord.csn()Returns the value of thecsnrecord component.UpdateRecord.getCsn()Returns the CSN of the message.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 lastLDAPUpdateMsgfrom the provided replica.ReplicationDomainDB.getReplicaOldestCsn(DomainReplicaId domainReplicaId) Returns the oldestCSNfor the specified replica in a replication domain.ReplicationDomainDB.ReplicaDbFileContent.newestCsn()Returns the value of thenewestCsnrecord component.ReplicationDomainDB.ReplicaDbFileContent.oldestCsn()Returns the value of theoldestCsnrecord component.Methods in org.opends.server.replication.server.changelog.api that return types with arguments of type CSNModifier and TypeMethodDescriptionReplicationDomainDB.getChangelogCursors(Dn baseDN) GeneratesDBCursorfor all streams of a given domain.ReplicationDomainDB.getStreamIdCursor(DomainReplicaId domainReplicaId, StreamId streamId) Generates aDBCursorfor a given stream of a replica.Methods in org.opends.server.replication.server.changelog.api with parameters of type CSNModifier and TypeMethodDescriptionReplicationDomainDB.getCursorFrom(DomainReplicaId replica, CSN startCSN, DBCursor.CursorOptions options) voidUpdates the removed replicas states with the provided CSNs.Constructors in org.opends.server.replication.server.changelog.api with parameters of type CSNModifierConstructorDescriptionChangeNumberIndexRecord(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 aReplicaDbFileContentrecord class. -
Uses of CSN in org.opends.server.replication.server.changelog.file
Methods in org.opends.server.replication.server.changelog.file that return CSNModifier and TypeMethodDescriptionFileChangelogDB.getReplicaOldestCsn(DomainReplicaId domainReplicaId) 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 CSNModifier and TypeMethodDescriptionFileChangelogDB.getChangelogCursors(Dn baseDN) 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.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 CSNModifier and TypeMethodDescriptionvoidDomainDBCursor.addReplicaDB(DomainReplicaId replicaId, CSN startCSN) Adds a replicaDB for this cursor to iterate over.FileChangelogDB.getCursorFrom(DomainReplicaId replica, CSN startCsn, DBCursor.CursorOptions options) static voidFileChangelogDB.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.voidFileChangelogDB.purgeUpTo(DomainReplicaId domain, CSN purgeCsn) Purges the changelog of a domain up to the provided CSN. -
Uses of CSN in org.opends.server.replication.service
Methods in org.opends.server.replication.service that return CSNModifier 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
Methods in org.opends.server.tasks with parameters of type CSNModifier and TypeMethodDescriptionvoidPurgeConflictsHistoricalTask.setProgressStats(CSN lastCSN, int purgeCount) Set the last CSN purged and the count of purged values in order to monitor the historical purge.