Searched refs:serverState (Results 51 - 75 of 81) sorted by relevance

1234

/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DByteArrayBuilder.java298 * @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 DChangeNumberIndexerTest.java574 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 DChangeNumberIndexerTest.java574 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 DReplicationBroker.java490 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 DReplicationBroker.java490 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 DReplicationBroker.java490 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 DReplicationBroker.java390 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 DReplicationBroker.java390 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 DReplicationBroker.java381 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 DChangeNumberIndexerTest.java574 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 DAssuredReplicationServerTest.java278 * @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 DAssuredReplicationServerTest.java278 * @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 DAssuredReplicationServerTest.java274 * @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 DAssuredReplicationServerTest.java413 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 DAssuredReplicationPluginTest.java295 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 DAssuredReplicationServerTest.java413 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 DAssuredReplicationPluginTest.java295 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 DAssuredReplicationServerTest.java413 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 DAssuredReplicationPluginTest.java290 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 DAssuredReplicationPluginTest.java268 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 DAssuredReplicationPluginTest.java268 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 DAssuredReplicationPluginTest.java268 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 DReplicationServerDomain.java1844 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 DReplicationServerDomain.java1932 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 DReplicationServerDomain.java1844 ServerState serverState = new ServerState();
1847 serverState.update(db.getLastChange());
1849 return serverState;
3341 * - from a serverState start point

Completed in 108 milliseconds

1234