Uses of Class
org.opends.server.replication.common.ServerState
Package
Description
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 code for the Replication Server part of the Multimaster replication feature.
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.
-
Uses of ServerState in org.opends.server.replication.common
Modifier and TypeMethodDescriptionServerState.duplicate()
Make a duplicate of this state.MultiDomainServerState.getServerState
(Dn baseDN) Returns the ServerState associated to the provided replication domain's baseDN.Modifier and TypeMethodDescriptionvoid
CSNGenerator.adjust
(ServerState state) Adjust utility method that takes ServerState as a parameter.boolean
ServerState.cover
(ServerState covered) Check that all the CSNs in the covered serverState are also in this serverState.static CSNGenerator
CSNGenerator.newCSNGenerator
(ReplicaId replicaId, ServerState state) Create a newCSNGenerator
.void
MultiDomainServerState.replace
(Dn baseDN, ServerState serverState) Replace the ServerState of the provided baseDN with the provided server state.void
MultiDomainServerState.update
(Dn baseDN, ServerState serverState) Update the ServerState of the provided baseDN with the provided server state. -
Uses of ServerState in org.opends.server.replication.plugin
Modifier and TypeMethodDescriptionvoid
LDAPReplicationDomain.sessionInitiated
(ServerStatus initStatus, ServerState rsState, ServerState newestChangelogStateOfReplica) -
Uses of ServerState in org.opends.server.replication.protocol
Modifier and TypeMethodDescriptionMonitorMsg.getReplServerDbState()
Get the state of the replication server that sent this message.ExtendedStartMsg.getServerState()
Returns the ServerState in this message.ReplServerStartDSMsg.getServerState()
Get the serverState.ReplServerStartMsg.getServerState()
Get the serverState.ServerStartMsg.getServerState()
Get the ServerState.ByteArrayScanner.nextServerStateMustComeLast()
Reads the next ServerState.Modifier and TypeMethodDescriptionMonitorMsg.getReplicaServerStates()
Returns the map of replica Ids to server states.MonitorMsg.getRsServerStates()
Returns the map of replication server Ids to server states.Modifier and TypeMethodDescriptionByteArrayBuilder.appendServerStateMustComeLast
(ServerState serverState) Append the byte representation of a ServerState to this ByteArrayBuilder and then append a final zero byte separator.Session.performExtendedHandshake
(ServerId<?> serverId, com.forgerock.opendj.discovery.GroupId groupId, ServerState state, long heartbeatInterval) Performs extended handshake to exchange additional information.void
MonitorMsg.setReplServerDbState
(ServerState state) Sets the state of the replication server.void
MonitorMsg.setServerState
(int serverId, ServerState state, boolean isReplica) Sets server state information for a server.ModifierConstructorDescriptionExtendedStartMsg
(ServerId<?> serverId, com.forgerock.opendj.discovery.GroupId groupId, ProcessId processId, ServerState state, long heartbeatInterval) Constructs an ExtendedStartMsg replication message for sending.ReplServerStartDSMsg
(ReplicationServerId rsId, com.forgerock.opendj.util.HostPort changelogEndpoint, Dn baseDN, ServerState serverState, GenerationId generationId, boolean sslEncryption, com.forgerock.opendj.discovery.GroupId groupId, int weight, int connectedDSNumber) Create a ReplServerStartDSMsg.ReplServerStartMsg
(ReplicationServerId rsId, com.forgerock.opendj.util.HostPort changelogEndpoint, Dn baseDN, ServerState serverState, GenerationId generationId, boolean sslEncryption, com.forgerock.opendj.discovery.GroupId groupId) Create a ReplServerStartMsg.ServerStartMsg
(ReplicaId replicaId, com.forgerock.opendj.util.HostPort adminEndpoint, Dn baseDN, long heartbeatInterval, ServerState serverState, GenerationId generationId, boolean sslEncryption, com.forgerock.opendj.discovery.GroupId groupId) Creates a new ServerStartMsg. -
Uses of ServerState in org.opends.server.replication.server
Modifier and TypeMethodDescriptionReplicationServerDomain.getLatestServerState()
Returns the latest most current ServerState describing the newest CSNs for each server in this domain.ReplicationServerDomain.getOldestState()
Returns the oldest known state for the domain, made of the oldest CSN stored for each replica id.Modifier and TypeMethodDescriptionReplicationServerDomain.getPublisher
(String name, Dn baseDn, ServerState startState, ServerState endState) Returns a publisher of changes from the provided domain, using the provided states to determine the starting and ending points of each replica of the domain. -
Uses of ServerState in org.opends.server.replication.server.changelog.api
Modifier and TypeMethodDescriptionReplicationDomainDB.getDomainNewestCSNs
(Dn baseDN) Returns the newestCSN
s from the replicaDBs for each replica id in the specified replication domain.ReplicationDomainDB.getDomainOldestCSNs
(Dn baseDN) Returns the oldestCSN
s from the replicaDBs for each replica id in the specified replication domain.RemovedReplicasStates.getLastMessages()
Returns the CSNs of the last messages for all removed replicas.RemovedReplicasStates.getLastUpdates()
Returns the CSNs of the lastLDAPUpdateMsg
for all removed replicas.Modifier and TypeMethodDescriptionstatic RemovedReplicasStates
RemovedReplicasStates.fromStates
(ServerState lastUpdates, ServerState lastMessages) Initializes the removed replica states with information read from an external source, typically on disk.ReplicationDomainDB.getCursorFrom
(Dn baseDN, ServerState startState, DBCursor.CursorOptions options) Generates aDBCursor
across all the replicaDBs for the specified replication domain starting before, at or after the providedServerState
for each replicaDB, depending on the provided matching and positioning strategies.ReplicationDomainDB.getPublisherForDomain
(String name, Dn domain, ServerState startState, ServerState endState) Returns a publisher of changes from the provided domain, using the provided states to determine the starting and ending points of each replica of the domain. -
Uses of ServerState in org.opends.server.replication.server.changelog.file
Modifier and TypeMethodDescriptionFileChangelogDB.getDomainNewestCSNs
(Dn baseDN) FileChangelogDB.getDomainOldestCSNs
(Dn baseDN) ReplicationEnvironment.DomainState.lastMsgs()
Returns the value of thelastMsgs
record component.ReplicationEnvironment.DomainState.lastUpdates()
Returns the value of thelastUpdates
record component.Modifier and TypeMethodDescriptionvoid
MultiDomainDBCursor.addDomain
(Dn baseDN, ServerState startAfterState) Adds a replication domain for this cursor to iterate over.FileChangelogDB.getCursorFrom
(Dn baseDN, ServerState startState, DBCursor.CursorOptions options) FileChangelogDB.getPublisherForDomain
(String name, Dn baseDn, ServerState startState, ServerState endState) ModifierConstructorDescriptionDomainState
(Dn domainDn, String domainId, ServerState lastUpdates, ServerState lastMsgs) Creates an instance of aDomainState
record class. -
Uses of ServerState in org.opends.server.replication.service
Modifier and TypeMethodDescriptionReplicationDomain.getServerState()
Get the ServerState maintained by the Concrete class.Modifier and TypeMethodDescriptionvoid
ReplicationDomain.sessionInitiated
(ServerStatus initStatus, ServerState rsState, ServerState newestChangelogStateOfReplica) Set the initial status of the domain and perform necessary initializations.ModifierConstructorDescriptionReplicationBroker
(ServerContext serverContext, ReplicationDomain replicationDomain, ServerState state, ReplicationDomainCfg config, ReplSessionSecurity replSessionSecurity) Creates a new ReplicationServer Broker for a particular ReplicationDomain.