/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBrokerTest.java | 33 import org.opends.server.replication.service.ReplicationBroker.ReplicationServerInfo; 60 private final ReplicationServerInfo CURRENT_RS = rsInfo(CURRENT_RS_ID, 62 private final ReplicationServerInfo MISSING_RS = rsInfo(MISSING_RS_ID, 64 private final ReplicationServerInfo ANOTHER_RS = rsInfo(ANOTHER_RS_ID); 74 private ReplicationServerInfo rsInfo(int rsServerId, Integer... dsIds) 78 return new ReplicationServerInfo(info, newSet(dsIds)); 81 private Map<Integer, ReplicationServerInfo> newMap(ReplicationServerInfo... infos) 87 final Map<Integer, ReplicationServerInfo> map = 88 new HashMap<Integer, ReplicationServerInfo>(); [all...] |
H A D | ComputeBestServerTest.java | 46 import org.opends.server.replication.service.ReplicationBroker.ReplicationServerInfo; 113 Map<Integer, ReplicationServerInfo> rsInfos = 123 private Map<Integer, ReplicationServerInfo> newRSInfos( 124 ReplicationServerInfo... rsInfos) 126 Map<Integer, ReplicationServerInfo> results = 127 new HashMap<Integer, ReplicationServerInfo>(); 128 for (ReplicationServerInfo rsInfo : rsInfos) 135 private ReplicationServerInfo newRSInfo(int serverId, String serverURL, 138 return ReplicationServerInfo.newInstance(new ReplServerStartMsg(serverId, 155 Map<Integer, ReplicationServerInfo> rsInfo [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBrokerTest.java | 33 import org.opends.server.replication.service.ReplicationBroker.ReplicationServerInfo; 60 private final ReplicationServerInfo CURRENT_RS = rsInfo(CURRENT_RS_ID, 62 private final ReplicationServerInfo MISSING_RS = rsInfo(MISSING_RS_ID, 64 private final ReplicationServerInfo ANOTHER_RS = rsInfo(ANOTHER_RS_ID); 74 private ReplicationServerInfo rsInfo(int rsServerId, Integer... dsIds) 78 return new ReplicationServerInfo(info, newSet(dsIds)); 81 private Map<Integer, ReplicationServerInfo> newMap(ReplicationServerInfo... infos) 87 final Map<Integer, ReplicationServerInfo> map = 88 new HashMap<Integer, ReplicationServerInfo>(); [all...] |
H A D | ComputeBestServerTest.java | 46 import org.opends.server.replication.service.ReplicationBroker.ReplicationServerInfo; 113 Map<Integer, ReplicationServerInfo> rsInfos = 123 private Map<Integer, ReplicationServerInfo> newRSInfos( 124 ReplicationServerInfo... rsInfos) 126 Map<Integer, ReplicationServerInfo> results = 127 new HashMap<Integer, ReplicationServerInfo>(); 128 for (ReplicationServerInfo rsInfo : rsInfos) 135 private ReplicationServerInfo newRSInfo(int serverId, String serverURL, 138 return ReplicationServerInfo.newInstance(new ReplServerStartMsg(serverId, 155 Map<Integer, ReplicationServerInfo> rsInfo [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 = 102 new HashMap<Integer, ReplicationServerInfo>(); 113 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg)); 115 ReplicationServerInfo bestServer = 149 HashMap<Integer, ReplicationServerInfo> rsInfos = 150 new HashMap<Integer, ReplicationServerInfo>(); 163 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg)); 165 ReplicationServerInfo bestServer = 203 HashMap<Integer, ReplicationServerInfo> rsInfos = 204 new HashMap<Integer, ReplicationServerInfo>(); [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 = 102 new HashMap<Integer, ReplicationServerInfo>(); 113 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg)); 115 ReplicationServerInfo bestServer = 149 HashMap<Integer, ReplicationServerInfo> rsInfos = 150 new HashMap<Integer, ReplicationServerInfo>(); 163 rsInfos.put(11, ReplicationServerInfo.newInstance(replServerStartMsg)); 165 ReplicationServerInfo bestServer = 203 HashMap<Integer, ReplicationServerInfo> rsInfos = 204 new HashMap<Integer, ReplicationServerInfo>(); [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/ |
H A D | ReplicationBrokerTest.java | 33 import org.opends.server.replication.service.ReplicationBroker.ReplicationServerInfo; 60 private final ReplicationServerInfo CURRENT_RS = rsInfo(CURRENT_RS_ID, 62 private final ReplicationServerInfo MISSING_RS = rsInfo(MISSING_RS_ID, 64 private final ReplicationServerInfo ANOTHER_RS = rsInfo(ANOTHER_RS_ID); 74 private ReplicationServerInfo rsInfo(int rsServerId, Integer... dsIds) 78 return new ReplicationServerInfo(info, newHashSet(dsIds)); 81 private Map<Integer, ReplicationServerInfo> newMap(ReplicationServerInfo... infos) 87 final Map<Integer, ReplicationServerInfo> map = new HashMap<>(); 88 for (ReplicationServerInfo inf [all...] |
H A D | ComputeBestServerTest.java | 43 import org.opends.server.replication.service.ReplicationBroker.ReplicationServerInfo; 108 Map<Integer, ReplicationServerInfo> rsInfos = 118 private Map<Integer, ReplicationServerInfo> newRSInfos( 119 ReplicationServerInfo... rsInfos) 121 Map<Integer, ReplicationServerInfo> results = new HashMap<>(); 122 for (ReplicationServerInfo rsInfo : rsInfos) 129 private ReplicationServerInfo newRSInfo(int serverId, String serverURL, 132 return ReplicationServerInfo.newInstance(new ReplServerStartMsg(serverId, 149 Map<Integer, ReplicationServerInfo> rsInfos = 172 Map<Integer, ReplicationServerInfo> rsInfo [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ComputeBestServerTest.java | 47 import org.opends.server.replication.service.ReplicationBroker.ReplicationServerInfo; 113 Map<Integer, ReplicationServerInfo> rsInfos = 123 private Map<Integer, ReplicationServerInfo> newRSInfos( 124 ReplicationServerInfo... rsInfos) 126 Map<Integer, ReplicationServerInfo> results = 127 new HashMap<Integer, ReplicationServerInfo>(); 128 for (ReplicationServerInfo rsInfo : rsInfos) 135 private ReplicationServerInfo newRSInfo(int serverId, String serverURL, 138 return ReplicationServerInfo.newInstance(new ReplServerStartMsg(serverId, 155 Map<Integer, ReplicationServerInfo> rsInfo [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 79 private final ReplicationServerInfo rsInfo; 91 private ConnectedRS(ReplicationServerInfo rsInfo, Session session) 383 static class ReplicationServerInfo class in class:ReplicationBroker 403 * Create a new instance of ReplicationServerInfo wrapping the passed 411 private static ReplicationServerInfo newInstance( 414 final ReplicationServerInfo rsInfo = newInstance(msg); 420 * Create a new instance of ReplicationServerInfo wrapping the passed 427 static ReplicationServerInfo newInstance(ReplicationMsg msg) 433 return new ReplicationServerInfo((ReplServerStartMsg) msg); 438 return new ReplicationServerInfo((ReplServerStartDSMs 453 private ReplicationServerInfo(ReplServerStartMsg msg) method in class:ReplicationBroker.ReplicationServerInfo 473 private ReplicationServerInfo(ReplServerStartDSMsg msg) method in class:ReplicationBroker.ReplicationServerInfo 496 ReplicationServerInfo(RSInfo rsInfo, Set<Integer> connectedDSs) method in class:ReplicationBroker.ReplicationServerInfo [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 79 private final ReplicationServerInfo rsInfo; 91 private ConnectedRS(ReplicationServerInfo rsInfo, Session session) 383 static class ReplicationServerInfo class in class:ReplicationBroker 403 * Create a new instance of ReplicationServerInfo wrapping the passed 411 private static ReplicationServerInfo newInstance( 414 final ReplicationServerInfo rsInfo = newInstance(msg); 420 * Create a new instance of ReplicationServerInfo wrapping the passed 427 static ReplicationServerInfo newInstance(ReplicationMsg msg) 433 return new ReplicationServerInfo((ReplServerStartMsg) msg); 438 return new ReplicationServerInfo((ReplServerStartDSMs 453 private ReplicationServerInfo(ReplServerStartMsg msg) method in class:ReplicationBroker.ReplicationServerInfo 473 private ReplicationServerInfo(ReplServerStartDSMsg msg) method in class:ReplicationBroker.ReplicationServerInfo 496 ReplicationServerInfo(RSInfo rsInfo, Set<Integer> connectedDSs) method in class:ReplicationBroker.ReplicationServerInfo [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 76 private final ReplicationServerInfo rsInfo; 88 private ConnectedRS(ReplicationServerInfo rsInfo, Session session) 374 static class ReplicationServerInfo class in class:ReplicationBroker 394 * Create a new instance of ReplicationServerInfo wrapping the passed 402 private static ReplicationServerInfo newInstance( 405 final ReplicationServerInfo rsInfo = newInstance(msg); 411 * Create a new instance of ReplicationServerInfo wrapping the passed 418 static ReplicationServerInfo newInstance(ReplicationMsg msg) 424 return new ReplicationServerInfo((ReplServerStartMsg) msg); 429 return new ReplicationServerInfo((ReplServerStartDSMs 444 private ReplicationServerInfo(ReplServerStartMsg msg) method in class:ReplicationBroker.ReplicationServerInfo 464 private ReplicationServerInfo(ReplServerStartDSMsg msg) method in class:ReplicationBroker.ReplicationServerInfo 487 ReplicationServerInfo(RSInfo rsInfo, Set<Integer> connectedDSs) method in class:ReplicationBroker.ReplicationServerInfo [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 178 private volatile Map<Integer, ReplicationServerInfo> replicationServerInfos 354 * Sets the locally configured flag for the passed ReplicationServerInfo 359 ReplicationServerInfo replicationServerInfo) 361 // Determine if the passed ReplicationServerInfo has a URL that is present 366 // The ReplicationServerInfo has been generated from a server with 480 public static class ReplicationServerInfo class in class:ReplicationBroker 502 * Create a new instance of ReplicationServerInfo wrapping the passed 510 public static ReplicationServerInfo newInstance( 513 ReplicationServerInfo rsInfo = newInstance(msg); 519 * Create a new instance of ReplicationServerInfo wrappin 553 private ReplicationServerInfo(ReplServerStartMsg replServerStartMsg) method in class:ReplicationBroker.ReplicationServerInfo 575 private ReplicationServerInfo(ReplServerStartDSMsg replServerStartDSMsg) method in class:ReplicationBroker.ReplicationServerInfo 708 public ReplicationServerInfo(RSInfo rsInfo, List<Integer> connectedDSs) method in class:ReplicationBroker.ReplicationServerInfo [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 181 private volatile Map<Integer, ReplicationServerInfo> replicationServerInfos 354 * Sets the locally configured flag for the passed ReplicationServerInfo 359 ReplicationServerInfo replicationServerInfo) 361 // Determine if the passed ReplicationServerInfo has a URL that is present 366 // The ReplicationServerInfo has been generated from a server with 480 public static class ReplicationServerInfo class in class:ReplicationBroker 502 * Create a new instance of ReplicationServerInfo wrapping the passed 510 public static ReplicationServerInfo newInstance( 513 ReplicationServerInfo rsInfo = newInstance(msg); 519 * Create a new instance of ReplicationServerInfo wrappin 553 private ReplicationServerInfo(ReplServerStartMsg replServerStartMsg) method in class:ReplicationBroker.ReplicationServerInfo 575 private ReplicationServerInfo(ReplServerStartDSMsg replServerStartDSMsg) method in class:ReplicationBroker.ReplicationServerInfo 708 public ReplicationServerInfo(RSInfo rsInfo, List<Integer> connectedDSs) method in class:ReplicationBroker.ReplicationServerInfo [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 181 private volatile Map<Integer, ReplicationServerInfo> replicationServerInfos 354 * Sets the locally configured flag for the passed ReplicationServerInfo 359 ReplicationServerInfo replicationServerInfo) 361 // Determine if the passed ReplicationServerInfo has a URL that is present 366 // The ReplicationServerInfo has been generated from a server with 480 public static class ReplicationServerInfo class in class:ReplicationBroker 502 * Create a new instance of ReplicationServerInfo wrapping the passed 510 public static ReplicationServerInfo newInstance( 513 ReplicationServerInfo rsInfo = newInstance(msg); 519 * Create a new instance of ReplicationServerInfo wrappin 553 private ReplicationServerInfo(ReplServerStartMsg replServerStartMsg) method in class:ReplicationBroker.ReplicationServerInfo 575 private ReplicationServerInfo(ReplServerStartDSMsg replServerStartDSMsg) method in class:ReplicationBroker.ReplicationServerInfo 708 public ReplicationServerInfo(RSInfo rsInfo, List<Integer> connectedDSs) method in class:ReplicationBroker.ReplicationServerInfo [all...] |