Uses of Class
org.opends.server.replication.common.CSN
-
Packages that use CSN Package Description 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. -
-
Uses of CSN in org.opends.server.plugins
Methods in org.opends.server.plugins that return CSN Modifier and Type Method Description CSNChangeNumberControlPlugin.ChangeNumberControl. getCSN()Retrieves the CSN.Constructors in org.opends.server.plugins with parameters of type CSN Constructor Description ChangeNumberControl(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 CSN Modifier and Type Field Description static CSNCSN. MAX_CSN_VALUEThe maximum possible value for a CSN.Methods in org.opends.server.replication.common that return CSN Modifier and Type Method Description CSNMultiDomainServerState. getCSN(DN baseDN, int serverId)Returns the CSN associated to the provided replication domain's baseDN and serverId.CSNServerState. getCSN(int serverId)Returns theCSNcontained in this server state which corresponds to the provided server ID.CSNCSNGenerator. newCSN()Generate a newCSN.static CSNCSN. valueOf(String s)Parses the providedtoString()representation of a CSN.static CSNCSN. valueOf(ByteSequence bs)Decodes the providedtoByteString()representation of a change number.Methods in org.opends.server.replication.common that return types with arguments of type CSN Modifier and Type Method Description org.forgerock.util.Pair<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<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()Methods in org.opends.server.replication.common with parameters of type CSN Modifier and Type Method Description voidCSNGenerator. adjust(CSN number)Adjust the lastTime of thisCSNGeneratorwith aCSNthat we have received from another server.static intCSN. compare(CSN csn1, CSN csn2)Compares 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.intCSN. compareTo(CSN csn)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.booleanMultiDomainServerState. cover(DN baseDN, CSN csn)Test if this object covers the provided CSN for the provided baseDN.booleanServerState. cover(CSN covered)Checks that the CSN given as a parameter is in this ServerState.static intCSN. diffSeqNum(CSN csn1, CSN csn2)Computes the difference in number of changes between 2 CSNs.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.booleanMultiDomainServerState. removeCSN(DN baseDN, CSN expectedCSN)Removes the mapping to the provided CSN if it is present in this MultiDomainServerState.booleanServerState. removeCSN(CSN expectedCSN)Removes the mapping to the provided CSN if it is present in this ServerState.booleanMultiDomainServerState. update(DN baseDN, CSN csn)Update the ServerState of the provided baseDN with the replicationCSNprovided.booleanServerState. 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 CSNFakeOperation. getCSN()Get the CSN.abstract CSNAttrHistorical. getDeleteTime()Returns the last time when this attribute was deleted.CSNAttrHistoricalMultiple. getDeleteTime()CSNAttrHistoricalSingle. getDeleteTime()CSNEntryHistorical. getDNDate()Returns the lastCSN when the entry DN was modified.CSNEntryHistorical. getOldestCSN()Returns the oldest CSN stored in this entry historical attribute.CSNAttrValueHistorical. getValueDeleteTime()Get the last time when the value was deleted.CSNAttrValueHistorical. getValueUpdateTime()Get 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 booleanEntryHistorical. addedOrRenamedAfter(CSN csn)Indicates if the Entry was renamed or added after the CSN that is given as a parameter.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 booleanAttrHistorical. replayOperation(Iterator<Modification> modsIterator, CSN csn, Entry modifiedEntry, Modification mod)This method will be called when replaying an operation.booleanAttrHistoricalMultiple. replayOperation(Iterator<Modification> modsIterator, CSN csn, Entry modifiedEntry, Modification m)booleanAttrHistoricalSingle. replayOperation(Iterator<Modification> modsIterator, CSN csn, Entry modifiedEntry, Modification mod)Constructors in org.opends.server.replication.plugin with parameters of type CSN Constructor Description AttrValueHistorical(ByteString value, 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(DN dn, CSN csn, String entryUUID)Creates a new FakeDelOperation from the provided information.FakeModdnOperation(CSN csn, Entry entry)Creates a new FakeModdnOperation.FakeModifyOperation(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. -
Uses of CSN in org.opends.server.replication.protocol
Fields in org.opends.server.replication.protocol declared as CSN Modifier and Type Field Description protected CSNUpdateMsg. csnThe CSN of this update.Methods in org.opends.server.replication.protocol that return CSN Modifier and Type Method Description CSNAckMsg. getCSN()Get the CSN from the message.CSNChangeTimeHeartbeatMsg. getCSN()Get a CSN with the transmitted change time.CSNOperationContext. getCSN()Gets the CSN of the Operation.static CSNOperationContext. getCSN(Operation op)Get the CSN of an operation.static CSNOperationContext. getCSN(PluginOperation op)Get the CSN of an operation from the synchronization context attached to the provided operation.CSNUpdateMsg. getCSN()Get the CSN from the message.CSNByteArrayScanner. nextCSN()Reads the next CSN.CSNByteArrayScanner. 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 ByteArrayBuilderByteArrayBuilder. appendCSN(CSN csn)Append a CSN to this ByteArrayBuilder.ByteArrayBuilderByteArrayBuilder. 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.Constructors in org.opends.server.replication.protocol with parameters of type CSN Constructor 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, DN dn, String entryUUID, String parentEntryUUID, Map<ObjectClass,String> objectClasses, Map<AttributeType,List<Attribute>> userAttributes, Map<AttributeType,List<Attribute>> operationalAttributes)Creates a new AddMessage.AddMsg(CSN csn, DN dn, String uniqueId, String parentId, Attribute objectClass, Iterable<Attribute> userAttributes, Iterable<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(DN dn, CSN csn, String entryUUID)Creates a new delete message.ModifyCommonMsg(CSN csn, String entryUUID, 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(DN dn, CSN csn, String entryUUID, String newSuperiorEntryUUID, boolean deleteOldRdn, String newSuperior, String newRDN)Construct a new Modify DN message (no mods).ModifyDNMsg(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, 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. -
Uses of CSN in org.opends.server.replication.server
Fields in org.opends.server.replication.server declared as CSN Modifier and Type Field Description protected CSNExpectedAcksInfo. csnThe CSN of the assured update message we want acks for.Methods in org.opends.server.replication.server with parameters of type CSN Modifier and Type Method Description voidChangelogState. addOfflineReplica(DN baseDN, CSN offlineCSN)Adds the following replica information to the offline list.Constructors in org.opends.server.replication.server with parameters of type CSN Constructor 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. -
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 CSNChangeNumberIndexRecord. getCSN()Getter for the replication CSN field.CSNDBCursor.CursorOptions. getDefaultCSN()Returns the default CSN.Methods in org.opends.server.replication.server.changelog.api with parameters of type CSN Modifier and Type Method Description DBCursor<UpdateMsg>ReplicationDomainDB. getCursorFrom(DN baseDN, int serverId, CSN startCSN, DBCursor.CursorOptions options)voidReplicationDomainDB. notifyReplicaOffline(DN baseDN, CSN offlineCSN)Let the DB know this replica is going down.voidReplicationDomainDB. replicaHeartbeat(DN baseDN, CSN heartbeatCSN)Let the DB know this replica is alive.voidChangeNumberIndexDB. resetChangeNumberTo(long newFirstCN, DN baseDN, CSN newFirstCSN)Resets ChangeNumber index to the given number and CSN.Constructors in org.opends.server.replication.server.changelog.api with parameters of type CSN Constructor Description ChangeNumberIndexRecord(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.KeyMatchingStrategy keyMatchingStrategy, DBCursor.PositionStrategy positionStrategy, CSN defaultCSN)Creates options with provided strategies and default CSN. -
Uses of CSN in org.opends.server.replication.server.changelog.file
Methods in org.opends.server.replication.server.changelog.file with parameters of type CSN Modifier and Type Method Description voidDomainDBCursor. addReplicaDB(int serverId, CSN startCSN)Adds a replicaDB for this cursor to iterate over.DBCursor<UpdateMsg>FileChangelogDB. getCursorFrom(DN baseDN, int serverId, CSN startCSN, DBCursor.CursorOptions options)voidFileChangelogDB. notifyReplicaOffline(DN baseDN, CSN offlineCSN)voidChangeNumberIndexer. publishHeartbeat(DN baseDN, CSN heartbeatCSN)Ensures the medium consistency point is updated by heartbeats.voidFileChangelogDB. replicaHeartbeat(DN baseDN, CSN heartbeatCSN)voidChangeNumberIndexer. replicaOffline(DN baseDN, CSN offlineCSN)Signals a replica went offline.voidReplicaCursor. setOfflineCSN(CSN offlineCSN)Sets the offline CSN to be returned by this cursor.Constructors in org.opends.server.replication.server.changelog.file with parameters of type CSN Constructor 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. -
Uses of CSN in org.opends.server.replication.service
Methods in org.opends.server.replication.service that return CSN Modifier and Type Method Description CSNReplicationDomain. getLastLocalChange()Returns the CSN of the last Change that was fully processed by this ReplicationDomain.Methods in org.opends.server.replication.service with parameters of type CSN Modifier and Type Method Description voidDSRSShutdownSync. replicaOfflineMsgDispatched(DN baseDN, CSN offlineCSN, Collection<Integer> replicationServerIds)Message has been queued for the replication servers which must forward it.voidDSRSShutdownSync. replicaOfflineMsgForwarded(DN baseDN, CSN forwardedCSN, int replicationServerId)Message has been forwarded to one of the replication servers it was queued for.voidDSRSShutdownSync. replicaOfflineMsgNotSent(DN baseDN, CSN offlineCSN)The message which was announced was not sent after all: the broker had no session to write it to, or was stopped before it could.voidDSRSShutdownSync. replicaOfflineMsgSent(DN baseDN, CSN offlineCSN)Message is about to be sent. -
Uses of CSN in org.opends.server.tasks
Methods in org.opends.server.tasks with parameters of type CSN Modifier and Type Method Description voidPurgeConflictsHistoricalTask. setProgressStats(CSN lastCSN, int purgeCount)Set the last CSN purged and the count of purged values in order to monitor the historical purge.
-