Searched refs:connectedDSs (Results 1 - 25 of 26) sorted by relevance

12

/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DComputeBestServerTest.java916 List<Integer> connectedDSs = null;
931 connectedDSs = new ArrayList<Integer>();
932 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs));
949 connectedDSs = new ArrayList<Integer>();
950 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs));
953 connectedDSs = new ArrayList<Integer>();
954 rsInfos.put(12, new ReplicationServerInfo(rsInfo, connectedDSs));
974 connectedDSs = new ArrayList<Integer>();
975 connectedDSs.add(1);
976 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs));
[all...]
H A DReplicationServerLoadBalancingTest.java1006 int connectedDSs = getDSConnectedToRS(j);
1007 if (connectedDSs == expectedDSNumber)
1012 finalDSsNumbers[j] = connectedDSs;
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DComputeBestServerTest.java916 List<Integer> connectedDSs = null;
931 connectedDSs = new ArrayList<Integer>();
932 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs));
949 connectedDSs = new ArrayList<Integer>();
950 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs));
953 connectedDSs = new ArrayList<Integer>();
954 rsInfos.put(12, new ReplicationServerInfo(rsInfo, connectedDSs));
974 connectedDSs = new ArrayList<Integer>();
975 connectedDSs.add(1);
976 rsInfos.put(11, new ReplicationServerInfo(rsInfo, connectedDSs));
[all...]
H A DReplicationServerLoadBalancingTest.java1006 int connectedDSs = getDSConnectedToRS(j);
1007 if (connectedDSs == expectedDSNumber)
1012 finalDSsNumbers[j] = connectedDSs;
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java134 private final Map<Integer, DataServerHandler> connectedDSs = field in class:ReplicationServerDomain
388 for (DataServerHandler dsHandler : connectedDSs.values())
636 for (DataServerHandler dsHandler : connectedDSs.values())
968 ServerHandler expectedDSInTimeout = connectedDSs.get(serverId);
1030 for (DataServerHandler dsHandler : connectedDSs.values())
1045 if (connectedDSs.containsKey(dsHandler.getServerId()))
1050 connectedDSs.get(dsHandler.getServerId()).toString(),
1102 if ( (connectedDSs.size() + connectedRSs.size() )== 1)
1117 else if (connectedDSs.containsKey(sHandler.getServerId()))
1175 connectedDSs
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java134 private final Map<Integer, DataServerHandler> connectedDSs = field in class:ReplicationServerDomain
388 for (DataServerHandler dsHandler : connectedDSs.values())
636 for (DataServerHandler dsHandler : connectedDSs.values())
968 ServerHandler expectedDSInTimeout = connectedDSs.get(serverId);
1030 for (DataServerHandler dsHandler : connectedDSs.values())
1045 if (connectedDSs.containsKey(dsHandler.getServerId()))
1050 connectedDSs.get(dsHandler.getServerId()).toString(),
1102 if ( (connectedDSs.size() + connectedRSs.size() )== 1)
1117 else if (connectedDSs.containsKey(sHandler.getServerId()))
1175 connectedDSs
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServerDomain.java126 private final Map<Integer, DataServerHandler> connectedDSs = new ConcurrentHashMap<>(); field in class:ReplicationServerDomain
376 for (DataServerHandler dsHandler : connectedDSs.values())
621 for (DataServerHandler dsHandler : connectedDSs.values())
946 ServerHandler expectedDSInTimeout = connectedDSs.get(serverId);
1008 for (DataServerHandler dsHandler : connectedDSs.values())
1023 if (connectedDSs.containsKey(dsHandler.getServerId()))
1027 connectedDSs.get(dsHandler.getServerId()), dsHandler, dsHandler.getServerId());
1077 if ( (connectedDSs.size() + connectedRSs.size() )== 1)
1092 else if (connectedDSs.containsKey(sHandler.getServerId()))
1149 connectedDSs
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java396 private Set<Integer> connectedDSs; field in class:ReplicationBroker.ReplicationServerInfo
493 * @param connectedDSs
496 ReplicationServerInfo(RSInfo rsInfo, Set<Integer> connectedDSs) argument
504 this.connectedDSs = connectedDSs;
505 this.connectedDSNumber = connectedDSs.size();
635 * @param connectedDSs The new connected DSs
637 private void update(RSInfo rsInfo, Set<Integer> connectedDSs) argument
641 this.connectedDSs = connectedDSs;
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java396 private Set<Integer> connectedDSs; field in class:ReplicationBroker.ReplicationServerInfo
493 * @param connectedDSs
496 ReplicationServerInfo(RSInfo rsInfo, Set<Integer> connectedDSs) argument
504 this.connectedDSs = connectedDSs;
505 this.connectedDSNumber = connectedDSs.size();
635 * @param connectedDSs The new connected DSs
637 private void update(RSInfo rsInfo, Set<Integer> connectedDSs) argument
641 this.connectedDSs = connectedDSs;
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java387 private Set<Integer> connectedDSs; field in class:ReplicationBroker.ReplicationServerInfo
484 * @param connectedDSs
487 ReplicationServerInfo(RSInfo rsInfo, Set<Integer> connectedDSs) argument
495 this.connectedDSs = connectedDSs;
496 this.connectedDSNumber = connectedDSs.size();
626 * @param connectedDSs The new connected DSs
628 private void update(RSInfo rsInfo, Set<Integer> connectedDSs) argument
632 this.connectedDSs = connectedDSs;
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationBrokerTest.java103 ReplicationServerInfo rsInfo, Integer... connectedDSs)
105 return assertContainsRSWithDSs(rsInfos, rsInfo, newSet(connectedDSs));
110 ReplicationServerInfo rsInfo, Set<Integer> connectedDSs)
114 assertThat(info.getConnectedDSs()).containsAll(connectedDSs);
101 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Integer... connectedDSs) argument
108 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) argument
H A DComputeBestServerTest.java1313 Set<Integer> connectedDSs)
1315 ReplicationServerInfo info = new ReplicationServerInfo(rsInfo, connectedDSs);
1312 put(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo, Set<Integer> connectedDSs) argument
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationBrokerTest.java103 ReplicationServerInfo rsInfo, Integer... connectedDSs)
105 return assertContainsRSWithDSs(rsInfos, rsInfo, newSet(connectedDSs));
110 ReplicationServerInfo rsInfo, Set<Integer> connectedDSs)
114 assertThat(info.getConnectedDSs()).containsAll(connectedDSs);
101 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Integer... connectedDSs) argument
108 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) argument
H A DComputeBestServerTest.java1313 Set<Integer> connectedDSs)
1315 ReplicationServerInfo info = new ReplicationServerInfo(rsInfo, connectedDSs);
1312 put(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo, Set<Integer> connectedDSs) argument
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DReplicationBrokerTest.java102 ReplicationServerInfo rsInfo, Integer... connectedDSs)
104 return assertContainsRSWithDSs(rsInfos, rsInfo, newHashSet(connectedDSs));
109 ReplicationServerInfo rsInfo, Set<Integer> connectedDSs)
113 assertThat(info.getConnectedDSs()).containsAll(connectedDSs);
100 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Integer... connectedDSs) argument
107 assertContainsRSWithDSs( Map<Integer, ReplicationServerInfo> rsInfos, ReplicationServerInfo rsInfo, Set<Integer> connectedDSs) argument
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java497 private List<Integer> connectedDSs = null; field in class:ReplicationBroker.ReplicationServerInfo
706 * @param connectedDSs The new connected DSs
708 public ReplicationServerInfo(RSInfo rsInfo, List<Integer> connectedDSs) argument
715 this.connectedDSs = connectedDSs;
716 this.connectedDSNumber = connectedDSs.size();
733 * @param connectedDSs The new connected DSs
735 public void update(RSInfo rsInfo, List<Integer> connectedDSs) argument
740 this.connectedDSs = connectedDSs;
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java497 private List<Integer> connectedDSs = null; field in class:ReplicationBroker.ReplicationServerInfo
706 * @param connectedDSs The new connected DSs
708 public ReplicationServerInfo(RSInfo rsInfo, List<Integer> connectedDSs) argument
715 this.connectedDSs = connectedDSs;
716 this.connectedDSNumber = connectedDSs.size();
733 * @param connectedDSs The new connected DSs
735 public void update(RSInfo rsInfo, List<Integer> connectedDSs) argument
740 this.connectedDSs = connectedDSs;
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java497 private List<Integer> connectedDSs = null; field in class:ReplicationBroker.ReplicationServerInfo
706 * @param connectedDSs The new connected DSs
708 public ReplicationServerInfo(RSInfo rsInfo, List<Integer> connectedDSs) argument
715 this.connectedDSs = connectedDSs;
716 this.connectedDSNumber = connectedDSs.size();
733 * @param connectedDSs The new connected DSs
735 public void update(RSInfo rsInfo, List<Integer> connectedDSs) argument
740 this.connectedDSs = connectedDSs;
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java806 int connectedDSs = getNbDSsConnectedToRS(j);
807 if (connectedDSs == expectedDSNumber)
812 finalDSsNumbers[j] = connectedDSs;
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java806 int connectedDSs = getNbDSsConnectedToRS(j);
807 if (connectedDSs == expectedDSNumber)
812 finalDSsNumbers[j] = connectedDSs;
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java805 int connectedDSs = getNbDSsConnectedToRS(j);
806 if (connectedDSs == expectedDSNumber)
811 finalDSsNumbers[j] = connectedDSs;
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java442 Map<Integer, DataServerHandler> connectedDSs =
444 connectedDSs.put(serverId, this);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java442 Map<Integer, DataServerHandler> connectedDSs =
444 connectedDSs.put(serverId, this);
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java1006 int connectedDSs = getDSConnectedToRS(j);
1007 if (connectedDSs == expectedDSNumber)
1012 finalDSsNumbers[j] = connectedDSs;
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DComputeBestServerTest.java1311 List<Integer> connectedDSs)
1314 new ReplicationServerInfo(rsInfo, connectedDSs);
1310 put(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo, List<Integer> connectedDSs) argument

Completed in 135 milliseconds

12