Searched refs:getReplicaInfos (Results 1 - 25 of 30) sorted by relevance

12

/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationDomainTest.java136 for (DSInfo serverInfo : domain1.getReplicaInfos().values())
157 assertExpectedServerStatuses(domain1.getReplicaInfos(),
159 assertExpectedServerStatuses(domain2.getReplicaInfos(),
386 for (DSInfo remoteDS : domain.getReplicaInfos().values())
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationDomainTest.java136 for (DSInfo serverInfo : domain1.getReplicaInfos().values())
157 assertExpectedServerStatuses(domain1.getReplicaInfos(),
159 assertExpectedServerStatuses(domain2.getReplicaInfos(),
386 for (DSInfo remoteDS : domain.getReplicaInfos().values())
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DReplicationDomainTest.java135 for (DSInfo serverInfo : domain1.getReplicaInfos().values())
156 assertExpectedServerStatuses(domain1.getReplicaInfos(),
158 assertExpectedServerStatuses(domain2.getReplicaInfos(),
381 for (DSInfo remoteDS : domain.getReplicaInfos().values())
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java647 public Map<Integer, DSInfo> getReplicaInfos() method in class:ReplicationDomain
649 return broker.getReplicaInfos();
664 return getReplicaInfos().get(dsId);
1429 * {@link #getReplicaInfos()} method.
1477 ieCtx.startList.addAll(getReplicaInfos().keySet());
1480 for (DSInfo dsi : getReplicaInfos().values())
1496 for (DSInfo dsi : getReplicaInfos().values())
1685 for (DSInfo dsi : getReplicaInfos().values())
1743 replicasWeAreWaitingFor.addAll(getReplicaInfos().keySet());
2180 * {@link #getReplicaInfos()} metho
[all...]
H A DReplicationBroker.java2892 public Map<Integer, DSInfo> getReplicaInfos() method in class:ReplicationBroker
3038 this.replicaInfos = removeThisDs(topoMsg.getReplicaInfos(), dsServerId);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java647 public Map<Integer, DSInfo> getReplicaInfos() method in class:ReplicationDomain
649 return broker.getReplicaInfos();
664 return getReplicaInfos().get(dsId);
1429 * {@link #getReplicaInfos()} method.
1477 ieCtx.startList.addAll(getReplicaInfos().keySet());
1480 for (DSInfo dsi : getReplicaInfos().values())
1496 for (DSInfo dsi : getReplicaInfos().values())
1685 for (DSInfo dsi : getReplicaInfos().values())
1743 replicasWeAreWaitingFor.addAll(getReplicaInfos().keySet());
2180 * {@link #getReplicaInfos()} metho
[all...]
H A DReplicationBroker.java2892 public Map<Integer, DSInfo> getReplicaInfos() method in class:ReplicationBroker
3038 this.replicaInfos = removeThisDs(topoMsg.getReplicaInfos(), dsServerId);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationDomain.java617 public Map<Integer, DSInfo> getReplicaInfos() method in class:ReplicationDomain
619 return broker.getReplicaInfos();
634 return getReplicaInfos().get(dsId);
1400 * {@link #getReplicaInfos()} method.
1448 ieCtx.startList.addAll(getReplicaInfos().keySet());
1451 for (DSInfo dsi : getReplicaInfos().values())
1467 for (DSInfo dsi : getReplicaInfos().values())
1655 for (DSInfo dsi : getReplicaInfos().values())
1716 replicasWeAreWaitingFor.addAll(getReplicaInfos().keySet());
2152 * {@link #getReplicaInfos()} metho
[all...]
H A DReplicationBroker.java2857 public Map<Integer, DSInfo> getReplicaInfos() method in class:ReplicationBroker
3003 this.replicaInfos = removeThisDs(topoMsg.getReplicaInfos(), dsServerId);
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java293 public Map<Integer, DSInfo> getReplicaInfos() method in class:TopologyMsg
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java293 public Map<Integer, DSInfo> getReplicaInfos() method in class:TopologyMsg
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DTopologyMsg.java292 public Map<Integer, DSInfo> getReplicaInfos() method in class:TopologyMsg
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServerHandler.java590 for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java616 for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java616 for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DAssuredReplicationServerTest.java1773 dsInfo = fakeRd.getReplicaInfos();
3014 DSInfo dsInfo = fakeRd1.getReplicaInfos().get(FDS2_ID);
3139 final DSInfo dsInfo = domain.getReplicaInfos().get(dsId);
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DAssuredReplicationServerTest.java1773 dsInfo = fakeRd.getReplicaInfos();
3014 DSInfo dsInfo = fakeRd1.getReplicaInfos().get(FDS2_ID);
3139 final DSInfo dsInfo = domain.getReplicaInfos().get(dsId);
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DAssuredReplicationServerTest.java1773 dsInfo = fakeRd.getReplicaInfos();
3018 DSInfo dsInfo = fakeRd1.getReplicaInfos().get(FDS2_ID);
3143 final DSInfo dsInfo = domain.getReplicaInfos().get(dsId);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1037 Assertions.assertThat(new HashSet<DSInfo>(msg.getReplicaInfos().values()))
1040 if (msg.getReplicaInfos().values().equals(dsList))
H A DSynchronizationMsgTest.java847 assertEquals(msg.getReplicaInfos(), newMsg.getReplicaInfos());
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1037 Assertions.assertThat(new HashSet<DSInfo>(msg.getReplicaInfos().values()))
1040 if (msg.getReplicaInfos().values().equals(dsList))
H A DSynchronizationMsgTest.java847 assertEquals(msg.getReplicaInfos(), newMsg.getReplicaInfos());
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1041 Assertions.assertThat(new HashSet<DSInfo>(msg.getReplicaInfos().values()))
1044 if (msg.getReplicaInfos().values().equals(dsList))
H A DSynchronizationMsgTest.java844 assertEquals(msg.getReplicaInfos(), newMsg.getReplicaInfos());
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java409 DSInfo dsInfo = ds3.getReplicaInfos().get(DS2_ID);

Completed in 108 milliseconds

12