/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomainTest.java | 136 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 D | ReplicationDomainTest.java | 136 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 D | ReplicationDomainTest.java | 135 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 D | ReplicationDomain.java | 647 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 D | ReplicationBroker.java | 2892 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 D | ReplicationDomain.java | 647 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 D | ReplicationBroker.java | 2892 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 D | ReplicationDomain.java | 617 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 D | ReplicationBroker.java | 2857 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 D | TopologyMsg.java | 293 public Map<Integer, DSInfo> getReplicaInfos() method in class:TopologyMsg
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | TopologyMsg.java | 293 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 D | TopologyMsg.java | 292 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 D | ReplicationServerHandler.java | 590 for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerHandler.java | 616 for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerHandler.java | 616 for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 1773 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 D | AssuredReplicationServerTest.java | 1773 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 D | AssuredReplicationServerTest.java | 1773 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 D | ProtocolCompatibilityTest.java | 1037 Assertions.assertThat(new HashSet<DSInfo>(msg.getReplicaInfos().values())) 1040 if (msg.getReplicaInfos().values().equals(dsList))
|
H A D | SynchronizationMsgTest.java | 847 assertEquals(msg.getReplicaInfos(), newMsg.getReplicaInfos());
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1037 Assertions.assertThat(new HashSet<DSInfo>(msg.getReplicaInfos().values())) 1040 if (msg.getReplicaInfos().values().equals(dsList))
|
H A D | SynchronizationMsgTest.java | 847 assertEquals(msg.getReplicaInfos(), newMsg.getReplicaInfos());
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1041 Assertions.assertThat(new HashSet<DSInfo>(msg.getReplicaInfos().values())) 1044 if (msg.getReplicaInfos().values().equals(dsList))
|
H A D | SynchronizationMsgTest.java | 844 assertEquals(msg.getReplicaInfos(), newMsg.getReplicaInfos());
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 409 DSInfo dsInfo = ds3.getReplicaInfos().get(DS2_ID);
|