/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ComputeBestServerTest.java | 113 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 D | ReplicationBrokerTest.java | 102 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 D | ComputeBestServerTest.java | 113 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 D | ComputeBestServerTest.java | 113 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 D | ReplicationBrokerTest.java | 102 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 D | ComputeBestServerTest.java | 108 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 D | ReplicationBrokerTest.java | 101 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 D | ComputeBestServerTest.java | 101 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 D | ComputeBestServerTest.java | 101 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 D | TopologyMsg.java | 60 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 D | TopologyMsg.java | 60 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 D | TopologyMsg.java | 60 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 D | ReplicationBroker.java | 708 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 D | ReplicationBroker.java | 708 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 D | ReplicationBroker.java | 699 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 D | ReplicationServerDomain.java | 1699 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 D | ReplicationServerDomain.java | 1699 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 D | ReplicationServerDomain.java | 1651 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 D | ReplicationServerHandler.java | 670 List<RSInfo> rsInfos = topoMsg.getRsList(); 672 RSInfo rsInfo = rsInfos.get(0);
|
H A D | ReplicationServerDomain.java | 1962 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 D | ReplicationServerHandler.java | 670 List<RSInfo> rsInfos = topoMsg.getRsList(); 672 RSInfo rsInfo = rsInfos.get(0);
|
H A D | ReplicationServerDomain.java | 1966 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 D | ReplicationServerHandler.java | 670 List<RSInfo> rsInfos = topoMsg.getRsList(); 672 RSInfo rsInfo = rsInfos.get(0);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 817 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 D | ReplicationBroker.java | 817 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
|