Uses of Class
org.opends.server.replication.protocol.UpdateMsg
-
Packages that use UpdateMsg Package Description org.opends.server.backends Contains various Directory Server backend implementations.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. -
-
Uses of UpdateMsg in org.opends.server.backends
Methods in org.opends.server.backends with parameters of type UpdateMsg Modifier and Type Method Description voidChangelogBackend. notifyChangeNumberEntryAdded(DN baseDN, long changeNumber, String cookieString, UpdateMsg updateMsg)Notifies persistent searches of this backend that a new change number entry was added to it.voidChangelogBackend. notifyCookieEntryAdded(DN baseDN, UpdateMsg updateMsg)Notifies persistent searches of this backend that a new cookie entry was added to it. -
Uses of UpdateMsg in org.opends.server.replication.plugin
Methods in org.opends.server.replication.plugin with parameters of type UpdateMsg Modifier and Type Method Description booleanLDAPReplicationDomain. processUpdate(UpdateMsg updateMsg) -
Uses of UpdateMsg in org.opends.server.replication.protocol
Subclasses of UpdateMsg in org.opends.server.replication.protocol Modifier and Type Class Description classAddMsgThis class is used to exchange Add operation between LDAP servers and replication servers.classDeleteMsgObject used when sending delete information to replication servers.classLDAPUpdateMsgAbstract class that must be extended to define a message used for sending Updates between servers.classModifyCommonMsgThis class holds every common code for the modify messages (mod, moddn).classModifyDNMsgMessage used to send Modify DN information.classModifyMsgMessage used to send Modify information.classReplicaOfflineMsgClass that define messages sent by a replica (DS) to the replication server (RS) to let the RS know the date at which a replica went offline.Methods in org.opends.server.replication.protocol with parameters of type UpdateMsg Modifier and Type Method Description intUpdateMsg. compareTo(UpdateMsg msg) -
Uses of UpdateMsg in org.opends.server.replication.server
Methods in org.opends.server.replication.server that return UpdateMsg Modifier and Type Method Description UpdateMsgMsgQueue. first()Return the first UpdateMsg in the MsgQueue.UpdateMsgMsgQueue. removeFirst()Get and remove the first UpdateMsg in this MessageQueue.UpdateMsgServerHandler. take()Select the next update that must be sent to the server managed by this ServerHandler.Methods in org.opends.server.replication.server that return types with arguments of type UpdateMsg Modifier and Type Method Description DBCursor<UpdateMsg>ReplicationServerDomain. getCursorFrom(ServerState startAfterServerState)Creates and returns a cursor across this replication domain.Methods in org.opends.server.replication.server with parameters of type UpdateMsg Modifier and Type Method Description voidMsgQueue. add(UpdateMsg update)Add an UpdateMsg to this MessageQueue.voidMsgQueue. consumeUpTo(UpdateMsg finalMsg)Consumes all the messages in this queue up to and including the passed in message.booleanMsgQueue. contains(UpdateMsg msg)Returnstrueif this map contains an UpdateMsg with the same CSN as the given UpdateMsg.voidReplicationServerDomain. put(UpdateMsg updateMsg, ServerHandler sourceHandler)Add an update that has been received to the list of updates that must be forwarded to all other servers.voidServerHandler. put(UpdateMsg update)Put a new update message received. -
Uses of UpdateMsg in org.opends.server.replication.server.changelog.api
Methods in org.opends.server.replication.server.changelog.api that return types with arguments of type UpdateMsg Modifier and Type Method Description DBCursor<UpdateMsg>ReplicationDomainDB. getCursorFrom(DN baseDN, int serverId, CSN startCSN, DBCursor.CursorOptions options)DBCursor<UpdateMsg>ReplicationDomainDB. getCursorFrom(DN baseDN, ServerState startState, DBCursor.CursorOptions options)Generates aDBCursoracross all the replicaDBs for the specified replication domain starting before, at or after the providedServerStatefor each replicaDB, depending on the provided matching and positioning strategies.Methods in org.opends.server.replication.server.changelog.api with parameters of type UpdateMsg Modifier and Type Method Description booleanReplicationDomainDB. publishUpdateMsg(DN baseDN, UpdateMsg updateMsg)Publishes the provided change to the changelog DB for the specified serverId and replication domain. -
Uses of UpdateMsg in org.opends.server.replication.server.changelog.file
Methods in org.opends.server.replication.server.changelog.file that return UpdateMsg Modifier and Type Method Description UpdateMsgECLMultiDomainDBCursor. getRecord()Getter for the current record.UpdateMsgReplicaCursor. getRecord()Methods in org.opends.server.replication.server.changelog.file that return types with arguments of type UpdateMsg Modifier and Type Method Description DBCursor<UpdateMsg>FileChangelogDB. getCursorFrom(DN baseDN, int serverId, CSN startCSN, DBCursor.CursorOptions options)DBCursor<UpdateMsg>FileChangelogDB. getCursorFrom(DN baseDN, ServerState startState, DBCursor.CursorOptions options)Methods in org.opends.server.replication.server.changelog.file with parameters of type UpdateMsg Modifier and Type Method Description protected voidChangeNumberIndexer. notifyEntryAddedToChangelog(DN baseDN, long changeNumber, MultiDomainServerState cookie, UpdateMsg msg)Notifies theChangelogBackendthat a new entry has been added.voidChangeNumberIndexer. publishUpdateMsg(DN baseDN, UpdateMsg updateMsg)Ensures the medium consistency point is updated by UpdateMsg.booleanFileChangelogDB. publishUpdateMsg(DN baseDN, UpdateMsg updateMsg)Constructor parameters in org.opends.server.replication.server.changelog.file with type arguments of type UpdateMsg 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 UpdateMsg in org.opends.server.replication.service
Methods in org.opends.server.replication.service with parameters of type UpdateMsg Modifier and Type Method Description protected voidReplicationDomain. prepareWaitForAckIfAssuredEnabled(UpdateMsg msg)Prepare a message if it is to be sent in assured mode.abstract booleanReplicationDomain. processUpdate(UpdateMsg updateMsg)This method should handle the processing ofUpdateMsgreceive from remote replication entities.protected voidReplicationDomain. processUpdateDone(UpdateMsg msg, String replayErrorMsg)This method must be called after each call toReplicationDomain.processUpdate(UpdateMsg)when the processing of the update is completed.booleanReplicationDomain. publish(UpdateMsg msg)Publish anUpdateMsgto the Replication Service.protected voidReplicationDomain. waitForAckIfAssuredEnabled(UpdateMsg msg)Wait for the processing of an assured message after it has been sent, if assured replication is configured, otherwise, do nothing.
-