/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | DbHandler.java | 105 private String baseDn; field in class:DbHandler 127 * @param baseDn the baseDn for which this DB was created. 135 int id, String baseDn, ReplicationServer replicationServer, 141 this.baseDn = baseDn; 149 db = new ReplicationDB(id, baseDn, replicationServer, dbenv); 155 + ") for domain \"" + baseDn + "\""); 529 attributes.add(Attributes.create("domain-name", baseDn)); 559 .getReplicationServerDomain(baseDn, fals 134 DbHandler( int id, String baseDn, ReplicationServer replicationServer, ReplicationDbEnv dbenv, int queueSize) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 84 private final String baseDn; field in class:ReplicationServerDomain 286 * Creates a new ReplicationServerDomain associated to the DN baseDn. 288 * @param baseDn The baseDn associated to the ReplicationServerDomain. 293 String baseDn, ReplicationServer replicationServer) 295 this.baseDn = baseDn; 299 + ") assured timer for domain \"" + baseDn + "\"", true); 371 assuredMode.toString(), baseDn, update.toString()); 391 dbHandler = replicationServer.newDbHandler(id, baseDn); 292 ReplicationServerDomain( String baseDn, ReplicationServer replicationServer) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | DependencyTest.java | 96 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 138 openReplicationSession(baseDn, brokerId, 1000, replServerPort, 1000, 172 new DomainFakeCfg(baseDn, serverId, replServers); 242 MultimasterReplication.deleteDomain(baseDn); 257 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 294 new DomainFakeCfg(baseDn, serverId, replServers); 302 openReplicationSession(baseDn, brokerId, 1000, replServerPort, 1000, 364 MultimasterReplication.deleteDomain(baseDn); 412 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 441 openReplicationSession(baseDn, brokerI [all...] |
H A D | ReplicationTestCase.java | 175 * Retrieves the domain associated to the baseDn, and the value of the generationId 180 * @param baseDn The baseDn for which we want the generationId 183 static protected long getGenerationId(DN baseDn) argument 190 LDAPReplicationDomain replDomain = LDAPReplicationDomain.retrievesReplicationDomain(baseDn); 203 final DN baseDn, int serverId, int window_size, 207 return openReplicationSession(baseDn, serverId, window_size, 208 port, timeout, emptyOldChanges, getGenerationId(baseDn), null); 216 final DN baseDn, int serverId, int window_size, 221 return openReplicationSession(baseDn, serverI 202 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges) argument 215 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges, long generationId) argument 229 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges, long generationId, ReplicationDomain replicationDomain) argument 302 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, ServerState state) argument 315 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, ServerState state, long generationId) argument 338 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, int maxSendQueue, int maxRcvQueue, boolean emptyOldChanges) argument 587 getMonitorAttrValue(DN baseDn, String attr) argument 702 updateMonitorCount(DN baseDn, String attr) argument [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | DependencyTest.java | 96 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 138 openReplicationSession(baseDn, brokerId, 1000, replServerPort, 1000, 172 new DomainFakeCfg(baseDn, serverId, replServers); 242 MultimasterReplication.deleteDomain(baseDn); 257 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 294 new DomainFakeCfg(baseDn, serverId, replServers); 302 openReplicationSession(baseDn, brokerId, 1000, replServerPort, 1000, 364 MultimasterReplication.deleteDomain(baseDn); 412 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 441 openReplicationSession(baseDn, brokerI [all...] |
H A D | ReplicationTestCase.java | 175 * Retrieves the domain associated to the baseDn, and the value of the generationId 180 * @param baseDn The baseDn for which we want the generationId 183 static protected long getGenerationId(DN baseDn) argument 190 LDAPReplicationDomain replDomain = LDAPReplicationDomain.retrievesReplicationDomain(baseDn); 203 final DN baseDn, int serverId, int window_size, 207 return openReplicationSession(baseDn, serverId, window_size, 208 port, timeout, emptyOldChanges, getGenerationId(baseDn), null); 216 final DN baseDn, int serverId, int window_size, 221 return openReplicationSession(baseDn, serverI 202 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges) argument 215 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges, long generationId) argument 229 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges, long generationId, ReplicationDomain replicationDomain) argument 302 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, ServerState state) argument 315 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, ServerState state, long generationId) argument 338 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, int maxSendQueue, int maxRcvQueue, boolean emptyOldChanges) argument 587 getMonitorAttrValue(DN baseDn, String attr) argument 702 updateMonitorCount(DN baseDn, String attr) argument [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | DependencyTest.java | 96 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 138 openReplicationSession(baseDn, brokerId, 1000, replServerPort, 1000, 172 new DomainFakeCfg(baseDn, serverId, replServers); 242 MultimasterReplication.deleteDomain(baseDn); 257 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 294 new DomainFakeCfg(baseDn, serverId, replServers); 302 openReplicationSession(baseDn, brokerId, 1000, replServerPort, 1000, 364 MultimasterReplication.deleteDomain(baseDn); 412 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 441 openReplicationSession(baseDn, brokerI [all...] |
H A D | ReplicationTestCase.java | 175 * Retrieves the domain associated to the baseDn, and the value of the generationId 180 * @param baseDn The baseDn for which we want the generationId 183 static protected long getGenerationId(DN baseDn) argument 190 LDAPReplicationDomain replDomain = LDAPReplicationDomain.retrievesReplicationDomain(baseDn); 203 final DN baseDn, int serverId, int window_size, 207 return openReplicationSession(baseDn, serverId, window_size, 208 port, timeout, emptyOldChanges, getGenerationId(baseDn), null); 216 final DN baseDn, int serverId, int window_size, 221 return openReplicationSession(baseDn, serverI 202 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges) argument 215 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges, long generationId) argument 229 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, boolean emptyOldChanges, long generationId, ReplicationDomain replicationDomain) argument 302 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, ServerState state) argument 315 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, ServerState state, long generationId) argument 338 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, int maxSendQueue, int maxRcvQueue, boolean emptyOldChanges) argument 587 getMonitorAttrValue(DN baseDn, String attr) argument 702 updateMonitorCount(DN baseDn, String attr) argument [all...] |
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/services/ldap/event/ |
H A D | Request.java | 71 Request(int id, String reqID, SSOToken requester, String baseDn, int scope, argument 78 _baseDn = baseDn;
|
/forgerock/openam/openam-core/src/main/java/com/iplanet/services/ldap/event/ |
H A D | Request.java | 71 Request(int id, String reqID, SSOToken requester, String baseDn, int scope, argument 78 _baseDn = baseDn;
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | MonitorTest.java | 88 private DN baseDn; field in class:MonitorTest 124 baseDn = DN.decode(baseDnStr); 136 "dn: " + baseDn + "\n" 141 "dn: ou=People," + baseDn + "\n" 146 "dn: cn=Fiona Jensen,ou=people," + baseDn + "\n" 157 "dn: cn=Robert Langman,ou=people," + baseDn + "\n" 237 replDomain = LDAPReplicationDomain.retrievesReplicationDomain(baseDn); 382 broker2 = openReplicationSession(baseDn, 394 broker3 = openReplicationSession(baseDn, 406 broker4 = openReplicationSession(baseDn, [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | MonitorTest.java | 88 private DN baseDn; field in class:MonitorTest 124 baseDn = DN.decode(baseDnStr); 136 "dn: " + baseDn + "\n" 141 "dn: ou=People," + baseDn + "\n" 146 "dn: cn=Fiona Jensen,ou=people," + baseDn + "\n" 157 "dn: cn=Robert Langman,ou=people," + baseDn + "\n" 237 replDomain = LDAPReplicationDomain.retrievesReplicationDomain(baseDn); 382 broker2 = openReplicationSession(baseDn, 394 broker3 = openReplicationSession(baseDn, 406 broker4 = openReplicationSession(baseDn, [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | MonitorTest.java | 88 private DN baseDn; field in class:MonitorTest 124 baseDn = DN.decode(baseDnStr); 136 "dn: " + baseDn + "\n" 141 "dn: ou=People," + baseDn + "\n" 146 "dn: cn=Fiona Jensen,ou=people," + baseDn + "\n" 157 "dn: cn=Robert Langman,ou=people," + baseDn + "\n" 237 replDomain = LDAPReplicationDomain.retrievesReplicationDomain(baseDn); 382 broker2 = openReplicationSession(baseDn, 394 broker3 = openReplicationSession(baseDn, 406 broker4 = openReplicationSession(baseDn, [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerFailoverTest.java | 171 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 172 rd1 = createReplicationDomain(baseDn, DS1_ID); 240 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 241 rd1 = createReplicationDomain(baseDn, DS1_ID); 243 rd2 = createReplicationDomain(baseDn, DS2_ID); 452 private LDAPReplicationDomain createReplicationDomain(DN baseDn, int serverId) argument 463 new DomainFakeCfg(baseDn, serverId, replServers);
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | GroupIdHandshakeTest.java | 304 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 306 new DomainFakeCfg(baseDn, serverId, replServers, groupId); 483 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 484 DomainFakeCfg domainConfWithNewGid = new DomainFakeCfg(baseDn, DS1_ID, replServers, 1); 486 domainConfWithNewGid = new DomainFakeCfg(baseDn, DS2_ID, replServers, 1); 523 domainConfWithNewGid = new DomainFakeCfg(baseDn, DS1_ID, replServers, 3); 525 domainConfWithNewGid = new DomainFakeCfg(baseDn, DS2_ID, replServers, 3);
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerFailoverTest.java | 171 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 172 rd1 = createReplicationDomain(baseDn, DS1_ID); 240 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 241 rd1 = createReplicationDomain(baseDn, DS1_ID); 243 rd2 = createReplicationDomain(baseDn, DS2_ID); 452 private LDAPReplicationDomain createReplicationDomain(DN baseDn, int serverId) argument 463 new DomainFakeCfg(baseDn, serverId, replServers);
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | GroupIdHandshakeTest.java | 304 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 306 new DomainFakeCfg(baseDn, serverId, replServers, groupId); 483 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 484 DomainFakeCfg domainConfWithNewGid = new DomainFakeCfg(baseDn, DS1_ID, replServers, 1); 486 domainConfWithNewGid = new DomainFakeCfg(baseDn, DS2_ID, replServers, 1); 523 domainConfWithNewGid = new DomainFakeCfg(baseDn, DS1_ID, replServers, 3); 525 domainConfWithNewGid = new DomainFakeCfg(baseDn, DS2_ID, replServers, 3);
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerFailoverTest.java | 171 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 172 rd1 = createReplicationDomain(baseDn, DS1_ID); 240 DN baseDn = DN.decode(TEST_ROOT_DN_STRING); 241 rd1 = createReplicationDomain(baseDn, DS1_ID); 243 rd2 = createReplicationDomain(baseDn, DS2_ID); 452 private LDAPReplicationDomain createReplicationDomain(DN baseDn, int serverId) argument 463 new DomainFakeCfg(baseDn, serverId, replServers);
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | GroupIdHandshakeTest.java | 308 DN baseDn = DN.valueOf(TEST_ROOT_DN_STRING); 310 new DomainFakeCfg(baseDn, serverId, replServers, groupId); 487 DN baseDn = DN.valueOf(TEST_ROOT_DN_STRING); 488 DomainFakeCfg domainConfWithNewGid = new DomainFakeCfg(baseDn, DS1_ID, replServers, 1); 490 domainConfWithNewGid = new DomainFakeCfg(baseDn, DS2_ID, replServers, 1); 526 domainConfWithNewGid = new DomainFakeCfg(baseDn, DS1_ID, replServers, 3); 528 domainConfWithNewGid = new DomainFakeCfg(baseDn, DS2_ID, replServers, 3);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 100 private final String baseDn; field in class:ReplicationBroker 213 * @param baseDn The base DN that should be used by this broker 229 ServerState state, String baseDn, int serverID2, int window, 235 this.baseDn = baseDn; 488 private String baseDn = null; field in class:ReplicationBroker.ReplicationServerInfo 560 this.baseDn = replServerStartMsg.getBaseDn(); 582 this.baseDn = replServerStartDSMsg.getBaseDn(); 648 * @return the baseDn 652 return baseDn; 228 ReplicationBroker(ReplicationDomain replicationDomain, ServerState state, String baseDn, int serverID2, int window, long generationId, long heartbeatInterval, ReplSessionSecurity replSessionSecurity, byte groupId, long changeTimeHeartbeatInterval) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 100 private final String baseDn; field in class:ReplicationBroker 213 * @param baseDn The base DN that should be used by this broker 229 ServerState state, String baseDn, int serverID2, int window, 235 this.baseDn = baseDn; 488 private String baseDn = null; field in class:ReplicationBroker.ReplicationServerInfo 560 this.baseDn = replServerStartMsg.getBaseDn(); 582 this.baseDn = replServerStartDSMsg.getBaseDn(); 648 * @return the baseDn 652 return baseDn; 228 ReplicationBroker(ReplicationDomain replicationDomain, ServerState state, String baseDn, int serverID2, int window, long generationId, long heartbeatInterval, ReplSessionSecurity replSessionSecurity, byte groupId, long changeTimeHeartbeatInterval) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
H A D | LDAPReplicationDomain.java | 207 private final DN baseDn; field in class:LDAPReplicationDomain 368 + ") state checkpointer for domain \"" + baseDn.toString() 419 + baseDn.toString() + "\""); 459 baseDn.toNormalizedString()); 472 baseDn.toNormalizedString()); 502 this.baseDn = configuration.getBaseDN(); 521 fractionalConfig = new FractionalConfig(baseDn); 536 if (baseDn.compareTo(DirectoryServer.getSchemaDN()) == 0) 545 Backend backend = retrievesBackend(baseDn); 549 baseDn 4058 retrievesBackend(DN baseDn) argument 4223 retrievesReplicationDomain(DN baseDn) argument 4781 searchForChangedEntries( DN baseDn, ChangeNumber fromChangeNumber, ChangeNumber lastChangeNumber, InternalSearchListener resultListener) argument 4832 searchForChangedEntries( DN baseDn, ChangeNumber fromChangeNumber, InternalSearchListener resultListener) argument 5202 private DN baseDn = null; field in class:LDAPReplicationDomain.FractionalConfig 5208 FractionalConfig(DN baseDn) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
H A D | LDAPReplicationDomain.java | 210 private final DN baseDn; field in class:LDAPReplicationDomain 371 + ") state checkpointer for domain \"" + baseDn.toString() 428 + baseDn.toString() + "\""); 468 baseDn.toNormalizedString()); 481 baseDn.toNormalizedString()); 522 this.baseDn = configuration.getBaseDN(); 541 fractionalConfig = new FractionalConfig(baseDn); 556 if (baseDn.compareTo(DirectoryServer.getSchemaDN()) == 0) 565 Backend backend = retrievesBackend(baseDn); 569 baseDn 4079 retrievesBackend(DN baseDn) argument 4246 retrievesReplicationDomain(DN baseDn) argument 4861 searchForChangedEntries( DN baseDn, ChangeNumber fromChangeNumber, ChangeNumber lastChangeNumber, InternalSearchListener resultListener) argument 4912 searchForChangedEntries( DN baseDn, ChangeNumber fromChangeNumber, InternalSearchListener resultListener) argument 5297 private DN baseDn = null; field in class:LDAPReplicationDomain.FractionalConfig 5303 FractionalConfig(DN baseDn) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
H A D | LDAPReplicationDomain.java | 207 private final DN baseDn; field in class:LDAPReplicationDomain 368 + ") state checkpointer for domain \"" + baseDn.toString() 419 + baseDn.toString() + "\""); 459 baseDn.toNormalizedString()); 472 baseDn.toNormalizedString()); 502 this.baseDn = configuration.getBaseDN(); 521 fractionalConfig = new FractionalConfig(baseDn); 536 if (baseDn.compareTo(DirectoryServer.getSchemaDN()) == 0) 545 Backend backend = retrievesBackend(baseDn); 549 baseDn 4058 retrievesBackend(DN baseDn) argument 4223 retrievesReplicationDomain(DN baseDn) argument 4781 searchForChangedEntries( DN baseDn, ChangeNumber fromChangeNumber, ChangeNumber lastChangeNumber, InternalSearchListener resultListener) argument 4832 searchForChangedEntries( DN baseDn, ChangeNumber fromChangeNumber, InternalSearchListener resultListener) argument 5202 private DN baseDn = null; field in class:LDAPReplicationDomain.FractionalConfig 5208 FractionalConfig(DN baseDn) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 94 private final String baseDn; field in class:ReplicationBroker 210 * @param baseDn The base DN that should be used by this broker 228 ServerState state, String baseDn, int serverID2, int window, 234 this.baseDn = baseDn; 488 private String baseDn = null; field in class:ReplicationBroker.ReplicationServerInfo 560 this.baseDn = replServerStartMsg.getBaseDn(); 582 this.baseDn = replServerStartDSMsg.getBaseDn(); 648 * @return the baseDn 652 return baseDn; 227 ReplicationBroker(ReplicationDomain replicationDomain, ServerState state, String baseDn, int serverID2, int window, long generationId, long heartbeatInterval, ReplSessionSecurity replSessionSecurity, byte groupId, long changeTimeHeartbeatInterval, InetAddress sourceAddress) argument [all...] |