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

12

/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DComputeBestServerTest.java113 Map<Integer, ReplicationServerInfo> rsInfos =
116 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
124 ReplicationServerInfo... rsInfos)
128 for (ReplicationServerInfo rsInfo : rsInfos)
155 Map<Integer, ReplicationServerInfo> rsInfos =
158 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
178 Map<Integer, ReplicationServerInfo> rsInfos =
181 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
200 Map<Integer, ReplicationServerInfo> rsInfos =
203 computeBestReplicationServer(true, -1, mySt, rsInfos, myId
123 newRSInfos( ReplicationServerInfo... rsInfos) argument
1312 put(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo, Set<Integer> connectedDSs) argument
[all...]
H A DReplicationBrokerTest.java102 Map<Integer, ReplicationServerInfo> rsInfos,
105 return assertContainsRSWithDSs(rsInfos, rsInfo, newSet(connectedDSs));
109 Map<Integer, ReplicationServerInfo> rsInfos,
112 final ReplicationServerInfo info = find(rsInfos, rsInfo.toRSInfo());
118 private ReplicationServerInfo find(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo) argument
120 for (ReplicationServerInfo info : rsInfos.values())
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);
172 assertThat(topo.rsInfos)
101 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Integer... connectedDSs) argument
108 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) argument
130 newTopology(TopologyCtorToUse toUse, Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId, Set<String> rsUrls, Map<Integer, ReplicationServerInfo> previousRSs) argument
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DComputeBestServerTest.java113 Map<Integer, ReplicationServerInfo> rsInfos =
116 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
124 ReplicationServerInfo... rsInfos)
128 for (ReplicationServerInfo rsInfo : rsInfos)
155 Map<Integer, ReplicationServerInfo> rsInfos =
158 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
178 Map<Integer, ReplicationServerInfo> rsInfos =
181 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
200 Map<Integer, ReplicationServerInfo> rsInfos =
203 computeBestReplicationServer(true, -1, mySt, rsInfos, myId
123 newRSInfos( ReplicationServerInfo... rsInfos) argument
1310 put(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo, List<Integer> connectedDSs) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DComputeBestServerTest.java113 Map<Integer, ReplicationServerInfo> rsInfos =
116 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
124 ReplicationServerInfo... rsInfos)
128 for (ReplicationServerInfo rsInfo : rsInfos)
155 Map<Integer, ReplicationServerInfo> rsInfos =
158 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
178 Map<Integer, ReplicationServerInfo> rsInfos =
181 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
200 Map<Integer, ReplicationServerInfo> rsInfos =
203 computeBestReplicationServer(true, -1, mySt, rsInfos, myId
123 newRSInfos( ReplicationServerInfo... rsInfos) argument
1312 put(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo, Set<Integer> connectedDSs) argument
[all...]
H A DReplicationBrokerTest.java102 Map<Integer, ReplicationServerInfo> rsInfos,
105 return assertContainsRSWithDSs(rsInfos, rsInfo, newSet(connectedDSs));
109 Map<Integer, ReplicationServerInfo> rsInfos,
112 final ReplicationServerInfo info = find(rsInfos, rsInfo.toRSInfo());
118 private ReplicationServerInfo find(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo) argument
120 for (ReplicationServerInfo info : rsInfos.values())
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);
172 assertThat(topo.rsInfos)
101 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Integer... connectedDSs) argument
108 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) argument
130 newTopology(TopologyCtorToUse toUse, Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId, Set<String> rsUrls, Map<Integer, ReplicationServerInfo> previousRSs) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DComputeBestServerTest.java108 Map<Integer, ReplicationServerInfo> rsInfos =
111 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
119 ReplicationServerInfo... rsInfos)
122 for (ReplicationServerInfo rsInfo : rsInfos)
149 Map<Integer, ReplicationServerInfo> rsInfos =
152 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
172 Map<Integer, ReplicationServerInfo> rsInfos =
175 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0);
194 Map<Integer, ReplicationServerInfo> rsInfos =
197 computeBestReplicationServer(true, -1, mySt, rsInfos, myId
118 newRSInfos( ReplicationServerInfo... rsInfos) argument
1308 put(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo, Set<Integer> connectedDSs) argument
[all...]
H A DReplicationBrokerTest.java101 Map<Integer, ReplicationServerInfo> rsInfos,
104 return assertContainsRSWithDSs(rsInfos, rsInfo, newHashSet(connectedDSs));
108 Map<Integer, ReplicationServerInfo> rsInfos,
111 final ReplicationServerInfo info = find(rsInfos, rsInfo.toRSInfo());
117 private ReplicationServerInfo find(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo) argument
119 for (ReplicationServerInfo info : rsInfos.values())
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);
171 assertThat(topo.rsInfos)
100 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Integer... connectedDSs) argument
107 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) argument
129 newTopology(TopologyCtorToUse toUse, Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId, Set<String> rsUrls, Map<Integer, ReplicationServerInfo> previousRSs) argument
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DComputeBestServerTest.java101 HashMap<Integer, ReplicationServerInfo> rsInfos =
113 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));
116 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);
149 HashMap<Integer, ReplicationServerInfo> rsInfos =
163 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));
166 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);
203 HashMap<Integer, ReplicationServerInfo> rsInfos =
215 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));
218 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);
253 HashMap<Integer, ReplicationServerInfo> rsInfos
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DComputeBestServerTest.java101 HashMap<Integer, ReplicationServerInfo> rsInfos =
113 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));
116 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);
149 HashMap<Integer, ReplicationServerInfo> rsInfos =
163 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));
166 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);
203 HashMap<Integer, ReplicationServerInfo> rsInfos =
215 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg));
218 computeBestReplicationServer(true, -1, mySt, rsInfos, myId1, (byte)1, 0L);
253 HashMap<Integer, ReplicationServerInfo> rsInfos
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java60 private final List<RSInfo> rsInfos; field in class:TopologyMsg
93 final List<RSInfo> rsInfos = new ArrayList<RSInfo>(Math.max(0, nRsInfo));
96 rsInfos.add(nextRSInfo(scanner, version));
101 this.rsInfos = Collections.unmodifiableList(rsInfos);
168 * @param rsInfos The list of currently connected RS servers ID.
170 public TopologyMsg(Collection<DSInfo> dsInfos, List<RSInfo> rsInfos) argument
186 if (rsInfos == null || rsInfos.isEmpty())
188 this.rsInfos
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java60 private final List<RSInfo> rsInfos; field in class:TopologyMsg
93 final List<RSInfo> rsInfos = new ArrayList<RSInfo>(Math.max(0, nRsInfo));
96 rsInfos.add(nextRSInfo(scanner, version));
101 this.rsInfos = Collections.unmodifiableList(rsInfos);
168 * @param rsInfos The list of currently connected RS servers ID.
170 public TopologyMsg(Collection<DSInfo> dsInfos, List<RSInfo> rsInfos) argument
186 if (rsInfos == null || rsInfos.isEmpty())
188 this.rsInfos
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DTopologyMsg.java60 private final List<RSInfo> rsInfos; field in class:TopologyMsg
92 final List<RSInfo> rsInfos = new ArrayList<>(Math.max(0, nRsInfo));
95 rsInfos.add(nextRSInfo(scanner, version));
100 this.rsInfos = Collections.unmodifiableList(rsInfos);
167 * @param rsInfos The list of currently connected RS servers ID.
169 public TopologyMsg(Collection<DSInfo> dsInfos, List<RSInfo> rsInfos) argument
185 if (rsInfos == null || rsInfos.isEmpty())
187 this.rsInfos
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java708 final Map<Integer, ReplicationServerInfo> rsInfos =
718 rsInfos.put(rsInfo.getServerId(), rsInfo);
722 return rsInfos;
781 Map<Integer, ReplicationServerInfo> rsInfos =
783 computeNewTopology(toRSInfos(rsInfos));
785 if (rsInfos.isEmpty())
793 rsInfos, serverId, getGroupId(), getGenerationID());
809 rsInfos.put(electedRsInfo.getServerId(), electedRsInfo);
859 if (rsInfos.size() > 0)
863 collectionToString(rsInfos
1270 RSEvaluations(int localServerId, Map<Integer, ReplicationServerInfo> rsInfos) argument
1468 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
2908 toRSInfos(Map<Integer, ReplicationServerInfo> rsInfos) argument
2981 final Map<Integer, ReplicationServerInfo> rsInfos; field in class:ReplicationBroker.Topology
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java708 final Map<Integer, ReplicationServerInfo> rsInfos =
718 rsInfos.put(rsInfo.getServerId(), rsInfo);
722 return rsInfos;
781 Map<Integer, ReplicationServerInfo> rsInfos =
783 computeNewTopology(toRSInfos(rsInfos));
785 if (rsInfos.isEmpty())
793 rsInfos, serverId, getGroupId(), getGenerationID());
809 rsInfos.put(electedRsInfo.getServerId(), electedRsInfo);
859 if (rsInfos.size() > 0)
863 collectionToString(rsInfos
1270 RSEvaluations(int localServerId, Map<Integer, ReplicationServerInfo> rsInfos) argument
1468 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
2908 toRSInfos(Map<Integer, ReplicationServerInfo> rsInfos) argument
2981 final Map<Integer, ReplicationServerInfo> rsInfos; field in class:ReplicationBroker.Topology
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java699 final Map<Integer, ReplicationServerInfo> rsInfos = new ConcurrentSkipListMap<>();
708 rsInfos.put(rsInfo.getServerId(), rsInfo);
712 return rsInfos;
772 Map<Integer, ReplicationServerInfo> rsInfos =
774 computeNewTopology(toRSInfos(rsInfos));
776 if (rsInfos.isEmpty())
784 rsInfos, serverId, getGroupId(), getGenerationID());
801 rsInfos.put(electedRsInfo.getServerId(), electedRsInfo);
849 if (!rsInfos.isEmpty())
852 Utils.joinAsString(", ", rsInfos
1248 RSEvaluations(int localServerId, Map<Integer, ReplicationServerInfo> rsInfos) argument
1444 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
2873 toRSInfos(Map<Integer, ReplicationServerInfo> rsInfos) argument
2946 final Map<Integer, ReplicationServerInfo> rsInfos; field in class:ReplicationBroker.Topology
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java1699 List<RSInfo> rsInfos = new ArrayList<RSInfo>();
1700 rsInfos.add(toRSInfo(localReplicationServer, generationId));
1702 return new TopologyMsg(dsInfos, rsInfos);
1729 List<RSInfo> rsInfos = new ArrayList<RSInfo>();
1731 rsInfos.add(toRSInfo(localReplicationServer, generationId));
1737 rsInfos.add(rsHandler.toRSInfo());
1742 return new TopologyMsg(dsInfos, rsInfos);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java1699 List<RSInfo> rsInfos = new ArrayList<RSInfo>();
1700 rsInfos.add(toRSInfo(localReplicationServer, generationId));
1702 return new TopologyMsg(dsInfos, rsInfos);
1729 List<RSInfo> rsInfos = new ArrayList<RSInfo>();
1731 rsInfos.add(toRSInfo(localReplicationServer, generationId));
1737 rsInfos.add(rsHandler.toRSInfo());
1742 return new TopologyMsg(dsInfos, rsInfos);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServerDomain.java1651 List<RSInfo> rsInfos = newArrayList(toRSInfo(localReplicationServer, generationId));
1653 return new TopologyMsg(dsInfos, rsInfos);
1680 List<RSInfo> rsInfos = new ArrayList<>();
1682 rsInfos.add(toRSInfo(localReplicationServer, generationId));
1688 rsInfos.add(rsHandler.toRSInfo());
1693 return new TopologyMsg(dsInfos, rsInfos);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java670 List<RSInfo> rsInfos = topoMsg.getRsList();
672 RSInfo rsInfo = rsInfos.get(0);
H A DReplicationServerDomain.java1962 List<RSInfo> rsInfos = new ArrayList<RSInfo>();
1966 rsInfos.add(localRSInfo);
1968 return new TopologyMsg(dsInfos, rsInfos);
1984 List<RSInfo> rsInfos = new ArrayList<RSInfo>();
1998 rsInfos.add(localRSInfo);
2005 rsInfos.add(serverHandler.toRSInfo());
2010 return new TopologyMsg(dsInfos, rsInfos);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java670 List<RSInfo> rsInfos = topoMsg.getRsList();
672 RSInfo rsInfo = rsInfos.get(0);
H A DReplicationServerDomain.java1966 List<RSInfo> rsInfos = new ArrayList<RSInfo>();
1970 rsInfos.add(localRSInfo);
1972 return new TopologyMsg(dsInfos, rsInfos);
1988 List<RSInfo> rsInfos = new ArrayList<RSInfo>();
2002 rsInfos.add(localRSInfo);
2009 rsInfos.add(serverHandler.toRSInfo());
2014 return new TopologyMsg(dsInfos, rsInfos);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java670 List<RSInfo> rsInfos = topoMsg.getRsList();
672 RSInfo rsInfo = rsInfos.get(0);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java817 Map<Integer, ReplicationServerInfo> rsInfos =
829 rsInfos.put(replicationServerInfo.getServerId(), replicationServerInfo);
833 return rsInfos;
1523 * @param rsInfos The list of available replication servers and their
1535 Map<Integer, ReplicationServerInfo> rsInfos, int localServerId,
1540 if (rsInfos.size() == 1)
1542 return rsInfos.values().iterator().next();
1555 Map<Integer, ReplicationServerInfo> bestServers = rsInfos;
1533 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java817 Map<Integer, ReplicationServerInfo> rsInfos =
829 rsInfos.put(replicationServerInfo.getServerId(), replicationServerInfo);
833 return rsInfos;
1525 * @param rsInfos
1530 Map<Integer, ReplicationServerInfo> rsInfos)
1533 this.bestRSs = rsInfos;
1719 * @param rsInfos The list of available replication servers and their
1731 Map<Integer, ReplicationServerInfo> rsInfos, int localServerId,
1734 final RSEvaluations evals = new RSEvaluations(localServerId, rsInfos);
1529 RSEvaluations(int localServerId, Map<Integer, ReplicationServerInfo> rsInfos) argument
1729 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument

Completed in 85 milliseconds

12