Searched defs:replicationServers (Results 26 - 50 of 54) sorted by relevance

123

/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DDomainFakeCfg.java50 private final SortedSet<String> replicationServers; field in class:DomainFakeCfg
97 this.replicationServers = replServers;
171 return replicationServers;
347 + serverId + ", replicationServers=" + replicationServers;
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DDomainFakeCfg.java55 private SortedSet<String> replicationServers; field in class:DomainFakeCfg
92 this.replicationServers = replServers;
169 this.replicationServers = new TreeSet<String>();
170 this.replicationServers.add(replServer);
261 return replicationServers;
H A DFractionalReplicationTest.java451 List<String> replicationServers = new ArrayList<String>();
452 replicationServers.add("localhost:" + replServerPort);
455 (firstBackend ? TEST_ROOT_DN_STRING : TEST2_ROOT_DN_STRING), DS2_ID, replicationServers, 100, 1000, generationId);
683 Collection<String> replicationServers,
690 startPublishService(replicationServers, window, heartbeatInterval, 500);
680 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, long generationId) argument
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DDomainFakeCfg.java56 private SortedSet<String> replicationServers; field in class:DomainFakeCfg
93 this.replicationServers = replServers;
170 this.replicationServers = new TreeSet<String>();
171 this.replicationServers.add(replServer);
262 return replicationServers;
H A DFractionalReplicationTest.java451 List<String> replicationServers = new ArrayList<String>();
452 replicationServers.add("localhost:" + replServerPort);
455 (firstBackend ? TEST_ROOT_DN_STRING : TEST2_ROOT_DN_STRING), DS2_ID, replicationServers, 100, 1000, generationId);
683 Collection<String> replicationServers,
690 startPublishService(replicationServers, window, heartbeatInterval, 500, null);
680 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, long generationId) argument
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DDomainFakeCfg.java55 private SortedSet<String> replicationServers; field in class:DomainFakeCfg
92 this.replicationServers = replServers;
169 this.replicationServers = new TreeSet<String>();
170 this.replicationServers.add(replServer);
261 return replicationServers;
H A DFractionalReplicationTest.java451 List<String> replicationServers = new ArrayList<String>();
452 replicationServers.add("localhost:" + replServerPort);
455 (firstBackend ? TEST_ROOT_DN_STRING : TEST2_ROOT_DN_STRING), DS2_ID, replicationServers, 100, 1000, generationId);
683 Collection<String> replicationServers,
690 startPublishService(replicationServers, window, heartbeatInterval, 500);
680 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, long generationId) argument
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/quicksetup/installer/
H A DInstallerHelper.java449 * @param replicationServers a Map where the key value is the base dn and
464 InitialLdapContext remoteCtx, Map<String,Set<String>> replicationServers,
571 for (Set<String> rs : replicationServers.values())
596 for (String dn : replicationServers.keySet())
631 servers = replicationServers.get(dn);
463 configureReplication( InitialLdapContext remoteCtx, Map<String,Set<String>> replicationServers, int replicationPort, boolean useSecureReplication, String serverDisplay, Set<Integer> usedReplicationServerIds, Set<Integer> usedServerIds) argument
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java408 protected void remove(ReplicationServer... replicationServers) throws Exception argument
410 remove(Arrays.asList(replicationServers));
413 protected void remove(Collection<ReplicationServer> replicationServers) argument
416 for (ReplicationServer rs : replicationServers)
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java408 protected void remove(ReplicationServer... replicationServers) throws Exception argument
410 remove(Arrays.asList(replicationServers));
413 protected void remove(Collection<ReplicationServer> replicationServers) argument
416 for (ReplicationServer rs : replicationServers)
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DReplicationTestCase.java396 protected void remove(ReplicationServer... replicationServers) throws Exception argument
398 remove(Arrays.asList(replicationServers));
401 protected void remove(Collection<ReplicationServer> replicationServers) argument
404 for (ReplicationServer rs : replicationServers)
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DReplicationServer.java97 private Collection<String> replicationServers; field in class:ReplicationServer
214 replicationServers = configuration.getReplicationServer();
215 if (replicationServers == null)
216 replicationServers = new ArrayList<String>();
406 for (String aServerURL : replicationServers)
1002 replicationServers = configuration.getReplicationServer();
1003 if (replicationServers == null)
1004 replicationServers = new ArrayList<String>();
1158 for (String rs : replicationServers)
1531 for (String server: replicationServers)
[all...]
H A DReplicationServerDomain.java108 private final Map<Integer, ReplicationServerHandler> replicationServers = field in class:ReplicationServerDomain
373 for (ReplicationServerHandler handler : replicationServers.values())
555 for (ReplicationServerHandler handler : replicationServers.values())
705 for (ReplicationServerHandler handler : replicationServers.values())
915 replicationServers.get(serverId);
949 for (ReplicationServerHandler handler : replicationServers.values())
965 for (ReplicationServerHandler serverHandler : replicationServers.values())
1042 if ( (directoryServers.size() + replicationServers.size() )== 1)
1054 if (replicationServers.containsKey(handler.getServerId()))
1181 replicationServers
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationServer.java96 private Collection<String> replicationServers; field in class:ReplicationServer
214 replicationServers = configuration.getReplicationServer();
215 if (replicationServers == null)
216 replicationServers = new ArrayList<String>();
407 for (String aServerURL : replicationServers)
1008 replicationServers = configuration.getReplicationServer();
1009 if (replicationServers == null)
1010 replicationServers = new ArrayList<String>();
1138 for (String rs : replicationServers)
1509 for (String server: replicationServers)
[all...]
H A DReplicationServerDomain.java116 private final Map<Integer, ReplicationServerHandler> replicationServers = field in class:ReplicationServerDomain
463 for (ReplicationServerHandler handler : replicationServers.values())
645 for (ReplicationServerHandler handler : replicationServers.values())
795 for (ReplicationServerHandler handler : replicationServers.values())
1005 replicationServers.get(serverId);
1039 for (ReplicationServerHandler handler : replicationServers.values())
1055 for (ReplicationServerHandler serverHandler : replicationServers.values())
1132 if ( (directoryServers.size() + replicationServers.size() )== 1)
1142 if (replicationServers.containsKey(handler.getServerId()))
1265 replicationServers
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DReplicationServer.java97 private Collection<String> replicationServers; field in class:ReplicationServer
214 replicationServers = configuration.getReplicationServer();
215 if (replicationServers == null)
216 replicationServers = new ArrayList<String>();
406 for (String aServerURL : replicationServers)
1002 replicationServers = configuration.getReplicationServer();
1003 if (replicationServers == null)
1004 replicationServers = new ArrayList<String>();
1158 for (String rs : replicationServers)
1531 for (String server: replicationServers)
[all...]
H A DReplicationServerDomain.java108 private final Map<Integer, ReplicationServerHandler> replicationServers = field in class:ReplicationServerDomain
373 for (ReplicationServerHandler handler : replicationServers.values())
555 for (ReplicationServerHandler handler : replicationServers.values())
705 for (ReplicationServerHandler handler : replicationServers.values())
915 replicationServers.get(serverId);
949 for (ReplicationServerHandler handler : replicationServers.values())
965 for (ReplicationServerHandler serverHandler : replicationServers.values())
1042 if ( (directoryServers.size() + replicationServers.size() )== 1)
1054 if (replicationServers.containsKey(handler.getServerId()))
1181 replicationServers
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java273 * @param replicationServers list of servers used
275 public void start(Collection<String> replicationServers) argument
281 this.replicationServerUrls = replicationServers;
2817 * @param replicationServers The new list of replication servers.
2826 Collection<String> replicationServers, int window, long heartbeatInterval,
2837 || replicationServers.size() != this.replicationServerUrls.size()
2838 || !replicationServers.containsAll(this.replicationServerUrls)
2846 this.replicationServerUrls = replicationServers;
2825 changeConfig( Collection<String> replicationServers, int window, long heartbeatInterval, byte groupId) argument
H A DReplicationDomain.java2948 * @param replicationServers The replication servers that should be used.
2960 Collection<String> replicationServers, int window,
2980 broker.start(replicationServers);
3075 * @param replicationServers The new list of Replication Servers that this
3083 Collection<String> replicationServers,
3093 replicationServers, windowSize, heartbeatInterval, groupId))
2959 startPublishService( Collection<String> replicationServers, int window, long heartbeatInterval, long changetimeHeartbeatInterval) argument
3082 changeConfig( Collection<String> replicationServers, int windowSize, long heartbeatInterval, byte groupId) argument
/forgerock/opendj-b2.6/src/server/org/opends/server/tools/dsreplication/
H A DReplicationCliMain.java7836 * @param replicationServers the list of replication servers to which the
7845 LinkedHashSet<String> replicationServers,
7913 replicationServer.setReplicationServer(replicationServers);
7924 replicationServer.setReplicationServer(replicationServers);
7927 else if (!areReplicationServersEqual(servers, replicationServers))
7930 mergeReplicationServers(replicationServers, servers));
7947 * @param replicationServers the list of replication servers to which the
7952 LinkedHashSet<String> replicationServers) throws OpenDsException
7970 replicationServer.setReplicationServer(replicationServers);
7973 else if (!areReplicationServersEqual(servers, replicationServers))
7843 configureAsReplicationServer(InitialLdapContext ctx, int replicationPort, boolean useSecureReplication, LinkedHashSet<String> replicationServers, Set<Integer> usedReplicationServerIds) argument
7951 updateReplicationServer(InitialLdapContext ctx, LinkedHashSet<String> replicationServers) argument
8021 configureToReplicateBaseDN(InitialLdapContext ctx, String baseDN, LinkedHashSet<String> replicationServers, Set<Integer> usedReplicationDomainIds) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/tools/dsreplication/
H A DReplicationCliMain.java7408 * @param replicationServers the list of replication servers to which the
7417 Set<String> replicationServers,
7485 replicationServer.setReplicationServer(replicationServers);
7496 replicationServer.setReplicationServer(replicationServers);
7499 else if (!areReplicationServersEqual(servers, replicationServers))
7502 mergeReplicationServers(replicationServers, servers));
7519 * @param replicationServers the list of replication servers to which the
7524 Set<String> replicationServers) throws OpenDsException
7542 replicationServer.setReplicationServer(replicationServers);
7545 else if (!areReplicationServersEqual(servers, replicationServers))
7415 configureAsReplicationServer(InitialLdapContext ctx, int replicationPort, boolean useSecureReplication, Set<String> replicationServers, Set<Integer> usedReplicationServerIds) argument
7523 updateReplicationServer(InitialLdapContext ctx, Set<String> replicationServers) argument
7593 configureToReplicateBaseDN(InitialLdapContext ctx, String baseDN, Set<String> replicationServers, Set<Integer> usedReplicationDomainIds) argument
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java273 * @param replicationServers list of servers used
275 public void start(Collection<String> replicationServers) argument
281 this.replicationServerUrls = replicationServers;
3079 * @param replicationServers The new list of replication servers.
3088 Collection<String> replicationServers, int window, long heartbeatInterval,
3099 || replicationServers.size() != this.replicationServerUrls.size()
3100 || !replicationServers.containsAll(this.replicationServerUrls)
3108 this.replicationServerUrls = replicationServers;
3087 changeConfig( Collection<String> replicationServers, int window, long heartbeatInterval, byte groupId) argument
H A DReplicationDomain.java2949 * @param replicationServers The replication servers that should be used.
2962 Collection<String> replicationServers, int window,
2984 broker.start(replicationServers);
3079 * @param replicationServers The new list of Replication Servers that this
3087 Collection<String> replicationServers,
3097 replicationServers, windowSize, heartbeatInterval, groupId))
2961 startPublishService( Collection<String> replicationServers, int window, long heartbeatInterval, long changetimeHeartbeatInterval, InetAddress sourceAddress) argument
3086 changeConfig( Collection<String> replicationServers, int windowSize, long heartbeatInterval, byte groupId) argument
/forgerock/opendj2.6.2/src/server/org/opends/server/tools/dsreplication/
H A DReplicationCliMain.java7836 * @param replicationServers the list of replication servers to which the
7845 LinkedHashSet<String> replicationServers,
7913 replicationServer.setReplicationServer(replicationServers);
7924 replicationServer.setReplicationServer(replicationServers);
7927 else if (!areReplicationServersEqual(servers, replicationServers))
7930 mergeReplicationServers(replicationServers, servers));
7947 * @param replicationServers the list of replication servers to which the
7952 LinkedHashSet<String> replicationServers) throws OpenDsException
7970 replicationServer.setReplicationServer(replicationServers);
7973 else if (!areReplicationServersEqual(servers, replicationServers))
7843 configureAsReplicationServer(InitialLdapContext ctx, int replicationPort, boolean useSecureReplication, LinkedHashSet<String> replicationServers, Set<Integer> usedReplicationServerIds) argument
7951 updateReplicationServer(InitialLdapContext ctx, LinkedHashSet<String> replicationServers) argument
8021 configureToReplicateBaseDN(InitialLdapContext ctx, String baseDN, LinkedHashSet<String> replicationServers, Set<Integer> usedReplicationDomainIds) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java273 * @param replicationServers list of servers used
275 public void start(Collection<String> replicationServers) argument
281 this.replicationServerUrls = replicationServers;
2817 * @param replicationServers The new list of replication servers.
2826 Collection<String> replicationServers, int window, long heartbeatInterval,
2837 || replicationServers.size() != this.replicationServerUrls.size()
2838 || !replicationServers.containsAll(this.replicationServerUrls)
2846 this.replicationServerUrls = replicationServers;
2825 changeConfig( Collection<String> replicationServers, int window, long heartbeatInterval, byte groupId) argument

Completed in 297 milliseconds

123