Package org.opends.server.replication.server
This package contains the code for the Replication Server part of the Multimaster replication feature.
A replication server is responsible for:
A replication server is responsible for:
- listen for connections from ldap servers.
- Connect/manage connection to other replication servers.
- Receive changes from ldap servers.
- Forward changes to ldap server and other replication servers.
- Save changes to stable storage (includes trimming of older operations).
ReplicationServerDomain
implements the multiplexing part of the replication server. It contains method for forwarding all the received messages to thePeerServer
and to theReplicationDomainDB
objects.PeerServer
contains the code related to handler of remote server. It can manage replication servers of directory servers (may be it should be split in two different classes, one for each of these).PeerServerReader
the thread responsible for reading from the remote object.
-
Class Summary Class Description ChangelogState This is the changelog state stored in the changelogStateDB.MonitoringPublisher This thread regularly publishes monitoring information: it sends monitoring messages regarding the direct topology (directly connected DSs and RSs) to the connected RSs it sends monitoring messages regarding the whole topology (also includes the local RS) to the connected DSs Note: as of today, monitoring messages mainly contains the server state of the entities.PeerServerReader This class implement the part of the replicationServer that is reading the connection from the LDAP servers to get all the updates that were done on this replica and forward them to other servers.ReplicationServer ReplicationServer Listener.ReplicationServerConnectThread This Class is used to create a thread that is responsible for opening connection from this replication server to the other Replication Servers.ReplicationServerDomain This class define an in-memory cache that will be used to store the messages that have been received from an LDAP server or from another replication server and that should be forwarded to other servers.ReplicationServerListenThread This Class is used to create a thread that is responsible for listening on the Replication Server thread and accept new incoming connections from other replication servers or from LDAP servers.