/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | ByteArrayBuilder.java | 298 * @param serverState 303 public ByteArrayBuilder appendServerStateMustComeLast(ServerState serverState) argument 305 final Map<Integer, CSN> serverIdToCSN = serverState.getServerIdToCSNMap();
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ChangeNumberIndexerTest.java | 574 ServerState serverState = domainNewestCSNs.get(baseDN); 575 if (serverState == null) 577 serverState = new ServerState(); 578 domainNewestCSNs.put(baseDN, serverState); 580 return serverState;
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ChangeNumberIndexerTest.java | 574 ServerState serverState = domainNewestCSNs.get(baseDN); 575 if (serverState == null) 577 serverState = new ServerState(); 578 domainNewestCSNs.put(baseDN, serverState); 580 return serverState;
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 490 private ServerState serverState = null; field in class:ReplicationBroker.ReplicationServerInfo 562 this.serverState = replServerStartMsg.getServerState(); 584 this.serverState = replServerStartDSMsg.getServerState(); 598 return serverState; 717 this.serverState = new ServerState(); 746 * @param serverState The ServerState to use for the update 748 public void update(ServerState serverState) argument 750 if (this.serverState != null) 752 this.serverState.update(serverState); [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 490 private ServerState serverState = null; field in class:ReplicationBroker.ReplicationServerInfo 562 this.serverState = replServerStartMsg.getServerState(); 584 this.serverState = replServerStartDSMsg.getServerState(); 598 return serverState; 717 this.serverState = new ServerState(); 746 * @param serverState The ServerState to use for the update 748 public void update(ServerState serverState) argument 750 if (this.serverState != null) 752 this.serverState.update(serverState); [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 490 private ServerState serverState = null; field in class:ReplicationBroker.ReplicationServerInfo 562 this.serverState = replServerStartMsg.getServerState(); 584 this.serverState = replServerStartDSMsg.getServerState(); 598 return serverState; 717 this.serverState = new ServerState(); 746 * @param serverState The ServerState to use for the update 748 public void update(ServerState serverState) argument 750 if (this.serverState != null) 752 this.serverState.update(serverState); [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 390 private final ServerState serverState; field in class:ReplicationBroker.ReplicationServerInfo 461 this.serverState = ss != null ? ss : new ServerState(); 481 this.serverState = ss != null ? ss : new ServerState(); 508 this.serverState = new ServerState(); 517 return serverState; 653 * @param serverState The ServerState to use for the update 655 private void update(ServerState serverState) argument 657 this.serverState.update(serverState); 1595 * When the selected replication servers have no change (empty serverState) [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 390 private final ServerState serverState; field in class:ReplicationBroker.ReplicationServerInfo 461 this.serverState = ss != null ? ss : new ServerState(); 481 this.serverState = ss != null ? ss : new ServerState(); 508 this.serverState = new ServerState(); 517 return serverState; 653 * @param serverState The ServerState to use for the update 655 private void update(ServerState serverState) argument 657 this.serverState.update(serverState); 1595 * When the selected replication servers have no change (empty serverState) [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 381 private final ServerState serverState; field in class:ReplicationBroker.ReplicationServerInfo 452 this.serverState = ss != null ? ss : new ServerState(); 472 this.serverState = ss != null ? ss : new ServerState(); 499 this.serverState = new ServerState(); 508 return serverState; 644 * @param serverState The ServerState to use for the update 646 private void update(ServerState serverState) argument 648 this.serverState.update(serverState); 1571 * When the selected replication servers have no change (empty serverState) [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/ |
H A D | ChangeNumberIndexerTest.java | 574 ServerState serverState = domainNewestCSNs.get(baseDN); 575 if (serverState == null) 577 serverState = new ServerState(); 578 domainNewestCSNs.put(baseDN, serverState); 580 return serverState;
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 278 * @param serverState 291 long assuredTimeout, int scenario, ServerState serverState, 297 serverState, startListen); 302 ServerState serverState, boolean startListen) throws Exception 305 new FakeReplicationDomain(config, generationId, scenario, serverState); 365 AssuredMode assuredMode, int safeDataLevel, ServerState serverState, 376 fakeReplicationServer.connect(serverState); 476 long generationId, int scenario, ServerState serverState) 479 super(config, generationId, serverState); 803 public void connect(ServerState serverState) throw argument 288 createFakeReplicationDomain( int serverId, int groupId, int rsId, long generationId, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState, boolean startListen) argument 300 createFakeReplicationDomain( ReplicationDomainCfg config, int rsId, long generationId, int scenario, ServerState serverState, boolean startListen) argument 363 createFakeReplicationServer(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, ServerState serverState, int scenario) argument 475 FakeReplicationDomain(ReplicationDomainCfg config, long generationId, int scenario, ServerState serverState) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 278 * @param serverState 291 long assuredTimeout, int scenario, ServerState serverState, 297 serverState, startListen); 302 ServerState serverState, boolean startListen) throws Exception 305 new FakeReplicationDomain(config, generationId, scenario, serverState); 365 AssuredMode assuredMode, int safeDataLevel, ServerState serverState, 376 fakeReplicationServer.connect(serverState); 476 long generationId, int scenario, ServerState serverState) 479 super(config, generationId, serverState); 803 public void connect(ServerState serverState) throw argument 288 createFakeReplicationDomain( int serverId, int groupId, int rsId, long generationId, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState, boolean startListen) argument 300 createFakeReplicationDomain( ReplicationDomainCfg config, int rsId, long generationId, int scenario, ServerState serverState, boolean startListen) argument 363 createFakeReplicationServer(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, ServerState serverState, int scenario) argument 475 FakeReplicationDomain(ReplicationDomainCfg config, long generationId, int scenario, ServerState serverState) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 274 * @param serverState 287 long assuredTimeout, int scenario, ServerState serverState, 293 serverState, startListen); 298 ServerState serverState, boolean startListen) throws Exception 301 new FakeReplicationDomain(config, generationId, scenario, serverState); 363 AssuredMode assuredMode, int safeDataLevel, ServerState serverState, 374 fakeReplicationServer.connect(serverState); 474 long generationId, int scenario, ServerState serverState) 477 super(config, generationId, serverState); 803 public void connect(ServerState serverState) throw argument 284 createFakeReplicationDomain( int serverId, int groupId, int rsId, long generationId, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState, boolean startListen) argument 296 createFakeReplicationDomain( ReplicationDomainCfg config, int rsId, long generationId, int scenario, ServerState serverState, boolean startListen) argument 361 createFakeReplicationServer(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, ServerState serverState, int scenario) argument 473 FakeReplicationDomain(ReplicationDomainCfg config, long generationId, int scenario, ServerState serverState) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 413 int scenario, ServerState serverState) 417 assuredMode, safeDataLevel, assuredTimeout, scenario, serverState, true, 100); 464 * @param serverState 480 int scenario, ServerState serverState, boolean startListen, int window) 489 scenario, serverState); 516 AssuredMode assuredMode, int safeDataLevel, ServerState serverState, 527 fakeReplicationServer.connect(serverState); 640 ServerState serverState) throws ConfigException 642 super(serviceID, serverID, serverState); 902 public void connect(ServerState serverState) throw argument 410 createFakeReplicationDomain(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState) argument 477 createFakeReplicationDomain(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState, boolean startListen, int window) argument 514 createFakeReplicationServer(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, ServerState serverState, int scenario) argument 630 FakeReplicationDomain( String serviceID, int serverID, long generationId, byte groupId, boolean assured, AssuredMode assuredMode, byte safeDataLevel, long assuredTimeout, int scenario, ServerState serverState) argument [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 295 private ServerState serverState; field in class:AssuredReplicationPluginTest.FakeReplicationServer 464 serverState = serverStartMsg.getServerState(); 472 serverURL, baseDN, windowSize, serverState, generationId, sslEncryption,
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 413 int scenario, ServerState serverState) 417 assuredMode, safeDataLevel, assuredTimeout, scenario, serverState, true, 100); 464 * @param serverState 480 int scenario, ServerState serverState, boolean startListen, int window) 489 scenario, serverState); 516 AssuredMode assuredMode, int safeDataLevel, ServerState serverState, 527 fakeReplicationServer.connect(serverState); 640 ServerState serverState) throws ConfigException 642 super(serviceID, serverID, serverState); 902 public void connect(ServerState serverState) throw argument 410 createFakeReplicationDomain(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState) argument 477 createFakeReplicationDomain(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState, boolean startListen, int window) argument 514 createFakeReplicationServer(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, ServerState serverState, int scenario) argument 630 FakeReplicationDomain( String serviceID, int serverID, long generationId, byte groupId, boolean assured, AssuredMode assuredMode, byte safeDataLevel, long assuredTimeout, int scenario, ServerState serverState) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 295 private ServerState serverState; field in class:AssuredReplicationPluginTest.FakeReplicationServer 464 serverState = serverStartMsg.getServerState(); 472 serverURL, baseDN, windowSize, serverState, generationId, sslEncryption,
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 413 int scenario, ServerState serverState) 417 assuredMode, safeDataLevel, assuredTimeout, scenario, serverState, true, 100); 464 * @param serverState 480 int scenario, ServerState serverState, boolean startListen, int window) 489 scenario, serverState); 516 AssuredMode assuredMode, int safeDataLevel, ServerState serverState, 527 fakeReplicationServer.connect(serverState); 640 ServerState serverState) throws ConfigException 642 super(serviceID, serverID, serverState); 902 public void connect(ServerState serverState) throw argument 410 createFakeReplicationDomain(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState) argument 477 createFakeReplicationDomain(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, long assuredTimeout, int scenario, ServerState serverState, boolean startListen, int window) argument 514 createFakeReplicationServer(int serverId, int groupId, int rsId, long generationId, boolean assured, AssuredMode assuredMode, int safeDataLevel, ServerState serverState, int scenario) argument 630 FakeReplicationDomain( String serviceID, int serverID, long generationId, byte groupId, boolean assured, AssuredMode assuredMode, byte safeDataLevel, long assuredTimeout, int scenario, ServerState serverState) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 290 private ServerState serverState; field in class:AssuredReplicationPluginTest.FakeReplicationServer 436 serverState = serverStartMsg.getServerState(); 444 serverURL, baseDN, windowSize, serverState, generationId, sslEncryption,
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 268 private ServerState serverState = null; field in class:AssuredReplicationPluginTest.FakeReplicationServer 437 serverState = serverStartMsg.getServerState(); 445 serverURL, baseDn, windowSize, serverState,
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 268 private ServerState serverState = null; field in class:AssuredReplicationPluginTest.FakeReplicationServer 437 serverState = serverStartMsg.getServerState(); 445 serverURL, baseDn, windowSize, serverState,
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 268 private ServerState serverState = null; field in class:AssuredReplicationPluginTest.FakeReplicationServer 437 serverState = serverStartMsg.getServerState(); 445 serverURL, baseDn, windowSize, serverState,
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 1844 ServerState serverState = new ServerState(); 1847 serverState.update(db.getLastChange()); 1849 return serverState; 3341 * - from a serverState start point
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 1932 ServerState serverState = new ServerState(); 1935 serverState.update(db.getLastChange()); 1937 return serverState; 3284 * - from a serverState start point
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 1844 ServerState serverState = new ServerState(); 1847 serverState.update(db.getLastChange()); 1849 return serverState; 3341 * - from a serverState start point
|