Searched defs:domainDN (Results 1 - 11 of 11) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexer.java169 * @param domainDN
175 public boolean isReplicaOffline(DN domainDN, int serverId) argument
177 return replicasOffline.getCSN(domainDN, serverId) != null;
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexer.java169 * @param domainDN
175 public boolean isReplicaOffline(DN domainDN, int serverId) argument
177 return replicasOffline.getCSN(domainDN, serverId) != null;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DChangeNumberIndexer.java164 * @param domainDN
170 public boolean isReplicaOffline(DN domainDN, int serverId) argument
172 return replicasOffline.getCSN(domainDN, serverId) != null;
H A DReplicationEnvironment.java342 * @param domainDN
352 Log<CSN, UpdateMsg> getOrCreateReplicaDB(final DN domainDN, final int serverId, final long generationId) argument
357 logger.trace("ReplicationEnvironment.getOrCreateReplicaDB(%s, %s, %s)", domainDN, serverId, generationId);
367 domainId = domains.get(domainDN);
370 domainId = createDomainId(domainDN);
375 changelogState.addServerIdToDomain(serverId, domainDN);
379 changelogState.setDomainGenerationId(domainDN, generationId);
388 ERR_CHANGELOG_UNABLE_TO_CREATE_REPLICA_DB.get(domainDN.toString(), serverId, generationId), e);
441 * @param domainDN
446 void clearGenerationId(final DN domainDN) throw argument
524 notifyReplicaOffline(DN domainDN, CSN offlineCSN) argument
566 notifyReplicaOnline(DN domainDN, int serverId) argument
677 readStateForServerId(DN domainDN, File serverIdPath, ChangelogState state) argument
689 readOfflineStateFile(final File offlineFile, DN domainDN) argument
713 createDomainId(final DN domainDN) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServer.java668 for (DN domainDN : activeDomains) {
669 currentStartingCookie.append(domainDN).append(":").append(cookie.getServerState(domainDN)).append(";");
685 for (DN domainDN : missingActiveDomains)
687 missingDomains.append(domainDN).append(":;");
709 private boolean isCookieOutdatedForDomain(MultiDomainServerState cookie, DN domainDN) argument
711 final ServerState domainOldestState = getReplicationServerDomain(domainDN).getOldestState();
712 final ServerState providedState = cookie.getServerState(domainDN);
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DReplicationEnvironment.java264 * @param domainDN
274 Log<CSN, UpdateMsg> getOrCreateReplicaDB(final DN domainDN, final int serverId, final long generationId) argument
279 debug("ReplicationEnvironment.getOrCreateReplicaDB(" + domainDN + ", " + serverId + ", " + generationId + ")");
289 domainId = domains.get(domainDN);
292 domainId = createDomainId(domainDN);
297 changelogState.addServerIdToDomain(serverId, domainDN);
301 changelogState.setDomainGenerationId(domainDN, generationId);
309 ERR_CHANGELOG_UNABLE_TO_CREATE_REPLICA_DB.get(domainDN.toString(), serverId, generationId), e);
359 * @param domainDN
364 void clearGenerationId(final DN domainDN) throw argument
423 notifyReplicaOffline(DN domainDN, CSN offlineCSN) argument
469 notifyReplicaOnline(DN domainDN, int serverId) argument
580 readStateForServerId(DN domainDN, File serverIdPath, ChangelogState state) argument
592 readOfflineStateFile(final File offlineFile, DN domainDN) argument
616 createDomainId(final DN domainDN) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServer.java668 for (DN domainDN : activeDomains) {
669 currentStartingCookie.append(domainDN).append(":").append(cookie.getServerState(domainDN)).append(";");
685 for (DN domainDN : missingActiveDomains)
687 missingDomains.append(domainDN).append(":;");
709 private boolean isCookieOutdatedForDomain(MultiDomainServerState cookie, DN domainDN) argument
711 final ServerState domainOldestState = getReplicationServerDomain(domainDN).getOldestState();
712 final ServerState providedState = cookie.getServerState(domainDN);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DReplicationEnvironment.java264 * @param domainDN
274 Log<CSN, UpdateMsg> getOrCreateReplicaDB(final DN domainDN, final int serverId, final long generationId) argument
279 debug("ReplicationEnvironment.getOrCreateReplicaDB(" + domainDN + ", " + serverId + ", " + generationId + ")");
289 domainId = domains.get(domainDN);
292 domainId = createDomainId(domainDN);
297 changelogState.addServerIdToDomain(serverId, domainDN);
301 changelogState.setDomainGenerationId(domainDN, generationId);
309 ERR_CHANGELOG_UNABLE_TO_CREATE_REPLICA_DB.get(domainDN.toString(), serverId, generationId), e);
359 * @param domainDN
364 void clearGenerationId(final DN domainDN) throw argument
423 notifyReplicaOffline(DN domainDN, CSN offlineCSN) argument
469 notifyReplicaOnline(DN domainDN, int serverId) argument
580 readStateForServerId(DN domainDN, File serverIdPath, ChangelogState state) argument
592 readOfflineStateFile(final File offlineFile, DN domainDN) argument
616 createDomainId(final DN domainDN) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServer.java648 for (DN domainDN : activeDomains) {
649 currentStartingCookie.append(domainDN).append(":").append(cookie.getServerState(domainDN)).append(";");
671 private boolean isCookieOutdatedForDomain(MultiDomainServerState cookie, DN domainDN) argument
673 final ServerState providedState = cookie.getServerState(domainDN);
680 final ServerState domainOldestState = getReplicationServerDomain(domainDN).getOldestState();
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/backends/
H A DChangelogBackendTestCase.java212 private Pair<ReplicationBroker, LDAPReplicationDomain> enableReplication(DN domainDN, int serverId, argument
215 ReplicationBroker broker = openReplicationSession(domainDN, serverId, 100, replicationPort, timeout);
216 DomainFakeCfg domainConf = newFakeCfg(domainDN, serverId, replicationPort);
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/backends/
H A DChangelogBackendTestCase.java212 private Pair<ReplicationBroker, LDAPReplicationDomain> enableReplication(DN domainDN, int serverId, argument
215 ReplicationBroker broker = openReplicationSession(domainDN, serverId, 100, replicationPort, timeout);
216 DomainFakeCfg domainConf = newFakeCfg(domainDN, serverId, replicationPort);

Completed in 56 milliseconds