/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | TopologyMsg.java | 61 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 D | TopologyMsg.java | 61 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 D | TopologyMsg.java | 61 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 D | TopologyViewTest.java | 946 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 D | ProtocolCompatibilityTest.java | 1134 public void oldTopologyPDUs(String oldPdu, List<DSInfo> dsList, List<RSInfo> rsList) argument 1139 assertEquals(msg.getDsList(), dsList);
|
H A D | SynchronizationMsgTest.java | 1070 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 D | TopologyViewTest.java | 842 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 D | ProtocolCompatibilityTest.java | 1032 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 D | SynchronizationMsgTest.java | 842 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 D | TopologyViewTest.java | 946 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 D | ProtocolCompatibilityTest.java | 1134 public void oldTopologyPDUs(String oldPdu, List<DSInfo> dsList, List<RSInfo> rsList) argument 1139 assertEquals(msg.getDsList(), dsList);
|
H A D | SynchronizationMsgTest.java | 1070 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 D | TopologyViewTest.java | 842 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 D | ProtocolCompatibilityTest.java | 1032 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 D | SynchronizationMsgTest.java | 842 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 D | TopologyViewTest.java | 946 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 D | ProtocolCompatibilityTest.java | 1134 public void oldTopologyPDUs(String oldPdu, List<DSInfo> dsList, List<RSInfo> rsList) argument 1139 assertEquals(msg.getDsList(), dsList);
|
H A D | SynchronizationMsgTest.java | 1070 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 D | TopologyViewTest.java | 845 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 D | ProtocolCompatibilityTest.java | 1036 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 D | SynchronizationMsgTest.java | 839 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 D | ReplicationBroker.java | 170 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 D | ReplicationBroker.java | 167 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 D | ReplicationBroker.java | 170 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)
|