/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | DomainFakeCfg.java | 50 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 D | DomainFakeCfg.java | 55 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 D | FractionalReplicationTest.java | 451 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 D | DomainFakeCfg.java | 56 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 D | FractionalReplicationTest.java | 451 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 D | DomainFakeCfg.java | 55 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 D | FractionalReplicationTest.java | 451 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 D | InstallerHelper.java | 449 * @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 D | ReplicationTestCase.java | 408 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 D | ReplicationTestCase.java | 408 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 D | ReplicationTestCase.java | 396 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 D | ReplicationServer.java | 97 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 D | ReplicationServerDomain.java | 108 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 D | ReplicationServer.java | 96 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 D | ReplicationServerDomain.java | 116 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 D | ReplicationServer.java | 97 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 D | ReplicationServerDomain.java | 108 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 D | ReplicationBroker.java | 273 * @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 D | ReplicationDomain.java | 2948 * @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 D | ReplicationCliMain.java | 7836 * @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 D | ReplicationCliMain.java | 7408 * @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 D | ReplicationBroker.java | 273 * @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 D | ReplicationDomain.java | 2949 * @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 D | ReplicationCliMain.java | 7836 * @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 D | ReplicationBroker.java | 273 * @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
|