Searched refs:replicaInfos (Results 1 - 9 of 9) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java58 private final Map<Integer, DSInfo> replicaInfos; field in class:TopologyMsg
82 final Map<Integer, DSInfo> replicaInfos =
87 replicaInfos.put(dsInfo.getDsId(), dsInfo);
100 this.replicaInfos = Collections.unmodifiableMap(replicaInfos);
174 this.replicaInfos = Collections.emptyMap();
183 this.replicaInfos = Collections.unmodifiableMap(replicas);
214 builder.appendByte((byte) replicaInfos.size());
215 for (DSInfo dsInfo : replicaInfos.values())
266 for (DSInfo dsInfo : replicaInfos
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java58 private final Map<Integer, DSInfo> replicaInfos; field in class:TopologyMsg
82 final Map<Integer, DSInfo> replicaInfos =
87 replicaInfos.put(dsInfo.getDsId(), dsInfo);
100 this.replicaInfos = Collections.unmodifiableMap(replicaInfos);
174 this.replicaInfos = Collections.emptyMap();
183 this.replicaInfos = Collections.unmodifiableMap(replicas);
214 builder.appendByte((byte) replicaInfos.size());
215 for (DSInfo dsInfo : replicaInfos.values())
266 for (DSInfo dsInfo : replicaInfos
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DTopologyMsg.java58 private final Map<Integer, DSInfo> replicaInfos; field in class:TopologyMsg
82 final Map<Integer, DSInfo> replicaInfos = new HashMap<>(Math.max(0, nDsInfo));
86 replicaInfos.put(dsInfo.getDsId(), dsInfo);
99 this.replicaInfos = Collections.unmodifiableMap(replicaInfos);
173 this.replicaInfos = Collections.emptyMap();
182 this.replicaInfos = Collections.unmodifiableMap(replicas);
213 builder.appendByte(replicaInfos.size());
214 for (DSInfo dsInfo : replicaInfos.values())
265 for (DSInfo dsInfo : replicaInfos
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationBrokerTest.java98 assertThat(topo.replicaInfos).doesNotContainKey(CURRENT_DS.getDsId());
131 Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId,
136 final TopologyMsg topologyMsg = new TopologyMsg(replicaInfos.values(), rsInfos);
141 return new Topology(replicaInfos, rsInfos, dsServerId, rsServerId, rsUrls, previousRSs);
130 newTopology(TopologyCtorToUse toUse, Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId, Set<String> rsUrls, Map<Integer, ReplicationServerInfo> previousRSs) argument
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationBrokerTest.java98 assertThat(topo.replicaInfos).doesNotContainKey(CURRENT_DS.getDsId());
131 Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId,
136 final TopologyMsg topologyMsg = new TopologyMsg(replicaInfos.values(), rsInfos);
141 return new Topology(replicaInfos, rsInfos, dsServerId, rsServerId, rsUrls, previousRSs);
130 newTopology(TopologyCtorToUse toUse, Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId, Set<String> rsUrls, Map<Integer, ReplicationServerInfo> previousRSs) argument
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DReplicationBrokerTest.java97 assertThat(topo.replicaInfos).doesNotContainKey(CURRENT_DS.getDsId());
130 Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId,
135 final TopologyMsg topologyMsg = new TopologyMsg(replicaInfos.values(), rsInfos);
140 return new Topology(replicaInfos, rsInfos, dsServerId, rsServerId, rsUrls, previousRSs);
129 newTopology(TopologyCtorToUse toUse, Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId, Set<String> rsUrls, Map<Integer, ReplicationServerInfo> previousRSs) argument
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java884 newTopo = new Topology(oldTopo.replicaInfos, newRSInfos, getServerId(),
2894 return topology.get().replicaInfos;
2930 for (DSInfo dsInfo : newTopo.replicaInfos.values())
2974 final Map<Integer, DSInfo> replicaInfos; field in class:ReplicationBroker.Topology
2986 this.replicaInfos = Collections.emptyMap();
3012 this.replicaInfos = dsInfosToKeep == null
3038 this.replicaInfos = removeThisDs(topoMsg.getReplicaInfos(), dsServerId);
3104 for (DSInfo dsInfo : replicaInfos.values())
3164 && equals(replicaInfos, other.replicaInfos)
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java884 newTopo = new Topology(oldTopo.replicaInfos, newRSInfos, getServerId(),
2894 return topology.get().replicaInfos;
2930 for (DSInfo dsInfo : newTopo.replicaInfos.values())
2974 final Map<Integer, DSInfo> replicaInfos; field in class:ReplicationBroker.Topology
2986 this.replicaInfos = Collections.emptyMap();
3012 this.replicaInfos = dsInfosToKeep == null
3038 this.replicaInfos = removeThisDs(topoMsg.getReplicaInfos(), dsServerId);
3104 for (DSInfo dsInfo : replicaInfos.values())
3164 && equals(replicaInfos, other.replicaInfos)
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java872 newTopo = new Topology(oldTopo.replicaInfos, newRSInfos, getServerId(),
2859 return topology.get().replicaInfos;
2895 for (DSInfo dsInfo : newTopo.replicaInfos.values())
2939 final Map<Integer, DSInfo> replicaInfos; field in class:ReplicationBroker.Topology
2951 this.replicaInfos = Collections.emptyMap();
2977 this.replicaInfos = dsInfosToKeep == null
3003 this.replicaInfos = removeThisDs(topoMsg.getReplicaInfos(), dsServerId);
3068 for (DSInfo dsInfo : replicaInfos.values())
3128 && Objects.equals(replicaInfos, other.replicaInfos)
[all...]

Completed in 111 milliseconds