| Package | Description |
|---|---|
| org.apache.directory.server.ldap.replication.provider |
| Modifier and Type | Field and Description |
|---|---|
private ReplicaEventLog |
SyncReplSearchListener.consumerMsgLog
The consumer configuration
|
| Modifier and Type | Field and Description |
|---|---|
private java.util.Map<java.lang.Integer,ReplicaEventLog> |
SyncReplRequestHandler.replicaLogMap |
private java.util.Map<java.lang.Integer,ReplicaEventLog> |
ReplicaEventLogJanitor.replicaLogMap |
| Modifier and Type | Method and Description |
|---|---|
private ReplicaEventLog |
ReplConsumerManager.convertEntryToReplica(org.apache.directory.api.ldap.model.entry.Entry entry)
Convert the stored entry to a valid ReplicaEventLog structure
|
private ReplicaEventLog |
SyncReplRequestHandler.createReplicaEventLog(java.lang.String hostName,
java.lang.String filter)
Create a new ReplicaEventLog.
|
private ReplicaEventLog |
SyncReplRequestHandler.ConsumerLogEntryChangeListener.getEventLog(OperationContext opCtx) |
private ReplicaEventLog |
SyncReplRequestHandler.getReplicaEventLog(java.lang.String cookieString)
Get the Replica event log from the replica ID found in the cookie
|
| Modifier and Type | Method and Description |
|---|---|
java.util.List<ReplicaEventLog> |
ReplConsumerManager.getReplicaEventLogs()
Get the list of consumers' configuration
|
java.util.Map<java.lang.Integer,ReplicaEventLog> |
SyncReplRequestHandler.getReplicaLogMap() |
| Modifier and Type | Method and Description |
|---|---|
void |
ReplConsumerManager.addConsumerEntry(ReplicaEventLog replica)
Add a new consumer entry in ou=consumers,ou=system
|
int |
ReplicaEventLog.compareTo(ReplicaEventLog o) |
void |
ReplConsumerManager.deleteConsumerEntry(ReplicaEventLog replica)
Delete an existing consumer entry from ou=consumers,ou=system
|
private void |
SyncReplRequestHandler.doContentUpdate(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
ReplicaEventLog replicaLog,
java.lang.String consumerCsn)
process the update of the consumer, starting from the given LastEntryCSN the consumer
has sent with the sync request.
|
private org.apache.directory.api.ldap.model.message.SearchResultDone |
SyncReplRequestHandler.doSimpleSearch(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
ReplicaEventLog replicaLog)
Process a search on the provider to get all the modified entries.
|
private void |
SyncReplRequestHandler.readResults(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
org.apache.directory.api.ldap.model.message.LdapResult ldapResult,
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.entry.Entry> cursor,
long sizeLimit,
ReplicaEventLog replicaLog)
Process the results get from a search request.
|
void |
ReplicaEventLogJanitor.removeEventLog(ReplicaEventLog replicaEventLog) |
private void |
SyncReplRequestHandler.sendContentFromLog(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest req,
ReplicaEventLog clientMsgLog,
java.lang.String fromCsn)
Send all the stored modifications to the consumer
|
void |
ReplConsumerManager.updateReplicaLastSentCsn(ReplicaEventLog replica)
Store the new CSN sent by the consumer in place of the previous one.
|
| Constructor and Description |
|---|
SyncReplSearchListener(LdapSession session,
org.apache.directory.api.ldap.model.message.SearchRequest searchRequest,
ReplicaEventLog consumerMsgLog,
boolean pushInRealTime)
Create a new instance of a consumer listener
|
| Constructor and Description |
|---|
ReplicaEventLogJanitor(DirectoryService directoryService,
java.util.Map<java.lang.Integer,ReplicaEventLog> replicaLogMap) |