Searched refs:ReplicationServerInfo (Results 1 - 15 of 15) sorted by relevance

/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationBrokerTest.java33 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 DComputeBestServerTest.java46 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 DReplicationBrokerTest.java33 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 DComputeBestServerTest.java46 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 DComputeBestServerTest.java101 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 DComputeBestServerTest.java101 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 DReplicationBrokerTest.java33 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 DComputeBestServerTest.java43 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 DComputeBestServerTest.java47 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 DReplicationBroker.java79 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 DReplicationBroker.java79 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 DReplicationBroker.java76 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 DReplicationBroker.java178 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 DReplicationBroker.java181 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 DReplicationBroker.java181 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...]

Completed in 44 milliseconds