Searched defs:dsList (Results 1 - 24 of 24) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java61 private final List<DSInfo> dsList; field in class:TopologyMsg
91 List<DSInfo> dsList = new ArrayList<DSInfo>(Math.max(0, nDsInfo));
206 dsList.add(dsInfo);
258 this.dsList = Collections.unmodifiableList(dsList);
269 * @param dsList The list of currently connected DS servers ID.
272 public TopologyMsg(List<DSInfo> dsList, List<RSInfo> rsList) argument
274 if (dsList == null || dsList.isEmpty())
276 this.dsList
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java61 private final List<DSInfo> dsList; field in class:TopologyMsg
91 List<DSInfo> dsList = new ArrayList<DSInfo>(Math.max(0, nDsInfo));
206 dsList.add(dsInfo);
258 this.dsList = Collections.unmodifiableList(dsList);
269 * @param dsList The list of currently connected DS servers ID.
272 public TopologyMsg(List<DSInfo> dsList, List<RSInfo> rsList) argument
274 if (dsList == null || dsList.isEmpty())
276 this.dsList
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java61 private final List<DSInfo> dsList; field in class:TopologyMsg
91 List<DSInfo> dsList = new ArrayList<DSInfo>(Math.max(0, nDsInfo));
206 dsList.add(dsInfo);
258 this.dsList = Collections.unmodifiableList(dsList);
269 * @param dsList The list of currently connected DS servers ID.
272 public TopologyMsg(List<DSInfo> dsList, List<RSInfo> rsList) argument
274 if (dsList == null || dsList.isEmpty())
276 this.dsList
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTopologyViewTest.java946 List<DSInfo> dsList = new ArrayList<DSInfo>();
954 dsList.add(createDSInfo(DS1_ID, RS1_ID));
959 dsList.add(createDSInfo(DS1_ID, RS1_ID));
960 dsList.add(createDSInfo(DS2_ID, RS1_ID));
966 dsList.add(createDSInfo(DS1_ID, RS1_ID));
967 dsList.add(createDSInfo(DS2_ID, RS1_ID));
973 dsList.add(createDSInfo(DS1_ID, RS1_ID));
974 dsList.add(createDSInfo(DS2_ID, RS1_ID));
975 dsList.add(createDSInfo(DS3_ID, RS2_ID));
981 dsList
1160 private List<DSInfo> dsList = null; field in class:TopologyViewTest.TopoView
1163 TopoView(List<DSInfo> dsList, List<RSInfo> rsList) argument
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1134 public void oldTopologyPDUs(String oldPdu, List<DSInfo> dsList, List<RSInfo> rsList) argument
1139 assertEquals(msg.getDsList(), dsList);
H A DSynchronizationMsgTest.java1070 public void topologyMsgTest(List<DSInfo> dsList, List<RSInfo> rsList, argument
1074 TopologyMsg msg = new TopologyMsg(dsList, rsList);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTopologyViewTest.java842 List<DSInfo> dsList = new ArrayList<DSInfo>();
850 dsList.add(createDSInfo(DS1_ID, RS1_ID));
855 dsList.add(createDSInfo(DS1_ID, RS1_ID));
856 dsList.add(createDSInfo(DS2_ID, RS1_ID));
862 dsList.add(createDSInfo(DS1_ID, RS1_ID));
863 dsList.add(createDSInfo(DS2_ID, RS1_ID));
869 dsList.add(createDSInfo(DS1_ID, RS1_ID));
870 dsList.add(createDSInfo(DS2_ID, RS1_ID));
871 dsList.add(createDSInfo(DS3_ID, RS2_ID));
877 dsList
1042 private List<DSInfo> dsList; field in class:TopologyViewTest.TopoView
1045 TopoView(List<DSInfo> dsList, List<RSInfo> rsList) argument
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1032 public void oldTopologyPDUs(String oldPdu, Set<DSInfo> dsList, List<RSInfo> rsList) argument
1038 .isEqualTo(dsList);
1040 if (msg.getReplicaInfos().values().equals(dsList))
1043 // replicaInfos collection is not exactly the same as the dsList
H A DSynchronizationMsgTest.java842 public void topologyMsgTest(List<DSInfo> dsList, List<RSInfo> rsList) argument
845 TopologyMsg msg = new TopologyMsg(dsList, rsList);
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTopologyViewTest.java946 List<DSInfo> dsList = new ArrayList<DSInfo>();
954 dsList.add(createDSInfo(DS1_ID, RS1_ID));
959 dsList.add(createDSInfo(DS1_ID, RS1_ID));
960 dsList.add(createDSInfo(DS2_ID, RS1_ID));
966 dsList.add(createDSInfo(DS1_ID, RS1_ID));
967 dsList.add(createDSInfo(DS2_ID, RS1_ID));
973 dsList.add(createDSInfo(DS1_ID, RS1_ID));
974 dsList.add(createDSInfo(DS2_ID, RS1_ID));
975 dsList.add(createDSInfo(DS3_ID, RS2_ID));
981 dsList
1160 private List<DSInfo> dsList = null; field in class:TopologyViewTest.TopoView
1163 TopoView(List<DSInfo> dsList, List<RSInfo> rsList) argument
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1134 public void oldTopologyPDUs(String oldPdu, List<DSInfo> dsList, List<RSInfo> rsList) argument
1139 assertEquals(msg.getDsList(), dsList);
H A DSynchronizationMsgTest.java1070 public void topologyMsgTest(List<DSInfo> dsList, List<RSInfo> rsList, argument
1074 TopologyMsg msg = new TopologyMsg(dsList, rsList);
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTopologyViewTest.java842 List<DSInfo> dsList = new ArrayList<DSInfo>();
850 dsList.add(createDSInfo(DS1_ID, RS1_ID));
855 dsList.add(createDSInfo(DS1_ID, RS1_ID));
856 dsList.add(createDSInfo(DS2_ID, RS1_ID));
862 dsList.add(createDSInfo(DS1_ID, RS1_ID));
863 dsList.add(createDSInfo(DS2_ID, RS1_ID));
869 dsList.add(createDSInfo(DS1_ID, RS1_ID));
870 dsList.add(createDSInfo(DS2_ID, RS1_ID));
871 dsList.add(createDSInfo(DS3_ID, RS2_ID));
877 dsList
1042 private List<DSInfo> dsList; field in class:TopologyViewTest.TopoView
1045 TopoView(List<DSInfo> dsList, List<RSInfo> rsList) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1032 public void oldTopologyPDUs(String oldPdu, Set<DSInfo> dsList, List<RSInfo> rsList) argument
1038 .isEqualTo(dsList);
1040 if (msg.getReplicaInfos().values().equals(dsList))
1043 // replicaInfos collection is not exactly the same as the dsList
H A DSynchronizationMsgTest.java842 public void topologyMsgTest(List<DSInfo> dsList, List<RSInfo> rsList) argument
845 TopologyMsg msg = new TopologyMsg(dsList, rsList);
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTopologyViewTest.java946 List<DSInfo> dsList = new ArrayList<DSInfo>();
954 dsList.add(createDSInfo(DS1_ID, RS1_ID));
959 dsList.add(createDSInfo(DS1_ID, RS1_ID));
960 dsList.add(createDSInfo(DS2_ID, RS1_ID));
966 dsList.add(createDSInfo(DS1_ID, RS1_ID));
967 dsList.add(createDSInfo(DS2_ID, RS1_ID));
973 dsList.add(createDSInfo(DS1_ID, RS1_ID));
974 dsList.add(createDSInfo(DS2_ID, RS1_ID));
975 dsList.add(createDSInfo(DS3_ID, RS2_ID));
981 dsList
1160 private List<DSInfo> dsList = null; field in class:TopologyViewTest.TopoView
1163 TopoView(List<DSInfo> dsList, List<RSInfo> rsList) argument
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1134 public void oldTopologyPDUs(String oldPdu, List<DSInfo> dsList, List<RSInfo> rsList) argument
1139 assertEquals(msg.getDsList(), dsList);
H A DSynchronizationMsgTest.java1070 public void topologyMsgTest(List<DSInfo> dsList, List<RSInfo> rsList, argument
1074 TopologyMsg msg = new TopologyMsg(dsList, rsList);
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DTopologyViewTest.java845 List<DSInfo> dsList = new ArrayList<>();
853 dsList.add(createDSInfo(DS1_ID, RS1_ID));
858 dsList.add(createDSInfo(DS1_ID, RS1_ID));
859 dsList.add(createDSInfo(DS2_ID, RS1_ID));
865 dsList.add(createDSInfo(DS1_ID, RS1_ID));
866 dsList.add(createDSInfo(DS2_ID, RS1_ID));
872 dsList.add(createDSInfo(DS1_ID, RS1_ID));
873 dsList.add(createDSInfo(DS2_ID, RS1_ID));
874 dsList.add(createDSInfo(DS3_ID, RS2_ID));
880 dsList
1044 private List<DSInfo> dsList; field in class:TopologyViewTest.TopoView
1047 TopoView(List<DSInfo> dsList, List<RSInfo> rsList) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1036 public void oldTopologyPDUs(String oldPdu, Set<DSInfo> dsList, List<RSInfo> rsList) argument
1042 .isEqualTo(dsList);
1044 if (msg.getReplicaInfos().values().equals(dsList))
1047 // replicaInfos collection is not exactly the same as the dsList
H A DSynchronizationMsgTest.java839 public void topologyMsgTest(List<DSInfo> dsList, List<RSInfo> rsList) argument
842 TopologyMsg msg = new TopologyMsg(dsList, rsList);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java170 private volatile List<DSInfo> dsList = new ArrayList<DSInfo>(); field in class:ReplicationBroker
2922 return dsList;
2946 * @param dsList The list of DSinfo from which to compute things
2949 private List<Integer> computeConnectedDSs(int rsId, List<DSInfo> dsList) argument
2964 for (DSInfo dsInfo : dsList)
2985 dsList = topoMsg.getDsList();
2994 List<Integer> connectedDSs = computeConnectedDSs(rsId, dsList);
3031 for (DSInfo info : dsList)
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java167 private volatile List<DSInfo> dsList = new ArrayList<DSInfo>(); field in class:ReplicationBroker
3184 return dsList;
3206 * @param dsList The list of DSinfo from which to compute things
3209 private List<Integer> computeConnectedDSs(int rsId, List<DSInfo> dsList) argument
3224 for (DSInfo dsInfo : dsList)
3245 dsList = topoMsg.getDsList();
3254 List<Integer> connectedDSs = computeConnectedDSs(rsId, dsList);
3291 for (DSInfo info : dsList)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java170 private volatile List<DSInfo> dsList = new ArrayList<DSInfo>(); field in class:ReplicationBroker
2922 return dsList;
2946 * @param dsList The list of DSinfo from which to compute things
2949 private List<Integer> computeConnectedDSs(int rsId, List<DSInfo> dsList) argument
2964 for (DSInfo dsInfo : dsList)
2985 dsList = topoMsg.getDsList();
2994 List<Integer> connectedDSs = computeConnectedDSs(rsId, dsList);
3031 for (DSInfo info : dsList)

Completed in 91 milliseconds