/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ComputeBestServerTest.java | 916 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 D | ReplicationServerLoadBalancingTest.java | 1006 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 D | ComputeBestServerTest.java | 916 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 D | ReplicationServerLoadBalancingTest.java | 1006 int connectedDSs = getDSConnectedToRS(j); 1007 if (connectedDSs == expectedDSNumber) 1012 finalDSsNumbers[j] = connectedDSs;
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 134 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 D | ReplicationServerDomain.java | 134 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 D | ReplicationServerDomain.java | 126 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 D | ReplicationBroker.java | 396 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 D | ReplicationBroker.java | 396 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 D | ReplicationBroker.java | 387 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 D | ReplicationBrokerTest.java | 103 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 D | ComputeBestServerTest.java | 1313 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 D | ReplicationBrokerTest.java | 103 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 D | ComputeBestServerTest.java | 1313 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 D | ReplicationBrokerTest.java | 102 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 D | ReplicationBroker.java | 497 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 D | ReplicationBroker.java | 497 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 D | ReplicationBroker.java | 497 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 D | ReplicationServerLoadBalancingTest.java | 806 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 D | ReplicationServerLoadBalancingTest.java | 806 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 D | ReplicationServerLoadBalancingTest.java | 805 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 D | DataServerHandler.java | 442 Map<Integer, DataServerHandler> connectedDSs = 444 connectedDSs.put(serverId, this);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | DataServerHandler.java | 442 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 D | ReplicationServerLoadBalancingTest.java | 1006 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 D | ComputeBestServerTest.java | 1311 List<Integer> connectedDSs) 1314 new ReplicationServerInfo(rsInfo, connectedDSs); 1310 put(Map<Integer, ReplicationServerInfo> rsInfos, RSInfo rsInfo, List<Integer> connectedDSs) argument
|