/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ChangeNumberIndexer.java | 169 * @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 D | ChangeNumberIndexer.java | 169 * @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 D | ChangeNumberIndexer.java | 164 * @param domainDN 170 public boolean isReplicaOffline(DN domainDN, int serverId) argument 172 return replicasOffline.getCSN(domainDN, serverId) != null;
|
H A D | ReplicationEnvironment.java | 342 * @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 D | ReplicationServer.java | 668 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 D | ReplicationEnvironment.java | 264 * @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 D | ReplicationServer.java | 668 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 D | ReplicationEnvironment.java | 264 * @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 D | ReplicationServer.java | 648 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 D | ChangelogBackendTestCase.java | 212 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 D | ChangelogBackendTestCase.java | 212 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);
|