Searched refs:getServerId (Results 251 - 275 of 335) sorted by relevance

<<11121314

/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java348 debugInfo("Connecting DS1 to replicate to RS" + getRSNumber(rs) + "(" + rs.getServerId() + ")");
411 debugInfo("Disconnect DS1 from RS" + getRSNumber(rs) + "(" + rs.getServerId() + ")");
447 debugInfo("disconnectFromReplServer: " + rs.getServerId(), e);
H A DInitOnLineTest.java418 final int serverId = broker.getServerId();
1014 log(testCase + " " + server2.getServerId() + " wait target " + Thread.currentThread());
1042 log(testCase + " " + server.getServerId() + " receives " + msgrcv);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java345 super("Replica DS(" + getServerId()
391 super("Replica DS(" + getServerId()
499 state = new PersistentServerState(getBaseDN(), getServerId(),
1542 getBaseDNString(), Integer.toString(getServerId()));
3206 getGenerator().adjust(state.getMaxCSN(getServerId()));
4098 CSN replServerMaxCSN = rsState.getCSN(getServerId());
4108 CSN ourMaxCSN = state.getMaxCSN(getServerId());
4178 CSN endCSN = new CSN(missingChangesDelta, 0xffffffff, getServerId());
4278 final Integer serverId = fromCSN.getServerId();
4446 if (source >= -1 && source != getServerId())
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java369 super("Replica DS(" + getServerId() + ") state checkpointer for domain \"" + getBaseDN() + "\"");
413 super("Replica DS(" + getServerId() + ") missing change publisher for domain \"" + getBaseDN() + "\"");
516 state = new PersistentServerState(getBaseDN(), getServerId(),
1522 LocalizableMessage msg = NOTE_ERR_FRACTIONAL_FORBIDDEN_FULL_UPDATE_FRACTIONAL.get(getBaseDN(), getServerId());
3130 getGenerator().adjust(state.getMaxCSN(getServerId()));
3981 CSN replServerMaxCSN = rsState.getCSN(getServerId());
3991 CSN ourMaxCSN = state.getMaxCSN(getServerId());
4060 CSN endCSN = new CSN(missingChangesDelta, 0xffffffff, getServerId());
4164 final Integer serverId = fromCSN.getServerId();
4325 if (source >= -1 && source != getServerId())
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DGenerationIdTest.java355 debugInfo("Connecting DS1 to replicate to RS" + getRSNumber(rs) + "(" + rs.getServerId() + ")");
420 debugInfo("Disconnect DS1 from RS" + getRSNumber(rs) + "(" + rs.getServerId() + ")");
462 debugInfo("disconnectFromReplServer: " + rs.getServerId(), e);
H A DInitOnLineTest.java400 final int serverId = broker.getServerId();
1012 log(testCase + " " + server2.getServerId() + " wait target " + Thread.currentThread());
1040 log(testCase + " " + server.getServerId() + " receives " + msgrcv);
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java842 assertEquals(msg.getServerId(), newMsg.getServerId());
886 assertEquals(msg.getServerId(), newMsg.getServerId());
932 assertEquals(msg.getServerId(), newMsg.getServerId());
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DAssuredReplicationServerTest.java482 gen = new CSNGenerator(config.getServerId(), 0L);
530 getServerId() + " for update with CSN " + updateMsg.getCSN());
549 debugInfo("Fake DS " + getServerId() + " received update assured flag is wrong: " + updateMsg);
554 debugInfo("Fake DS " + getServerId() + " received update assured mode is wrong: " + updateMsg);
559 debugInfo("Fake DS " + getServerId() + " received update assured sd level is wrong: " + updateMsg);
565 debugInfo("Fake DS " + getServerId() + " received update assured parameters are ok: " + updateMsg);
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java842 assertEquals(msg.getServerId(), newMsg.getServerId());
886 assertEquals(msg.getServerId(), newMsg.getServerId());
932 assertEquals(msg.getServerId(), newMsg.getServerId());
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DAssuredReplicationServerTest.java482 gen = new CSNGenerator(config.getServerId(), 0L);
530 getServerId() + " for update with CSN " + updateMsg.getCSN());
549 debugInfo("Fake DS " + getServerId() + " received update assured flag is wrong: " + updateMsg);
554 debugInfo("Fake DS " + getServerId() + " received update assured mode is wrong: " + updateMsg);
559 debugInfo("Fake DS " + getServerId() + " received update assured sd level is wrong: " + updateMsg);
565 debugInfo("Fake DS " + getServerId() + " received update assured parameters are ok: " + updateMsg);
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java842 assertEquals(msg.getServerId(), newMsg.getServerId());
886 assertEquals(msg.getServerId(), newMsg.getServerId());
932 assertEquals(msg.getServerId(), newMsg.getServerId());
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DAssuredReplicationServerTest.java480 gen = new CSNGenerator(config.getServerId(), 0L);
528 getServerId() + " for update with CSN " + updateMsg.getCSN());
547 debugInfo("Fake DS " + getServerId() + " received update assured flag is wrong: " + updateMsg);
552 debugInfo("Fake DS " + getServerId() + " received update assured mode is wrong: " + updateMsg);
557 debugInfo("Fake DS " + getServerId() + " received update assured sd level is wrong: " + updateMsg);
563 debugInfo("Fake DS " + getServerId() + " received update assured parameters are ok: " + updateMsg);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java664 assertEquals(msg.getServerId(), newMsg.getServerId());
708 assertEquals(msg.getServerId(), newMsg.getServerId());
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationDomainTest.java388 if (remoteDS.getDsId() != domain.getServerId())
H A DComputeBestServerTest.java130 results.put(rsInfo.getServerId(), rsInfo);
1316 rsInfos.put(info.getServerId(), info);
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java664 assertEquals(msg.getServerId(), newMsg.getServerId());
708 assertEquals(msg.getServerId(), newMsg.getServerId());
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationDomainTest.java388 if (remoteDS.getDsId() != domain.getServerId())
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java661 assertEquals(msg.getServerId(), newMsg.getServerId());
705 assertEquals(msg.getServerId(), newMsg.getServerId());
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DReplicationDomainTest.java383 if (remoteDS.getDsId() != domain.getServerId())
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DReplicationServer.java294 getServerId(),
1225 public int getServerId() method in class:ReplicationServer
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java272 + rb.getServerId() + " to RS " + rb.getRsGroupId()
291 fail("checkConnection: DS " + rb.getServerId() + " is not connected to "
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DReplicationServerLoadBalancingTest.java462 int curRsId = repServer.getServerId();
514 int curRsId = repServer.getServerId();
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java265 + rb.getServerId() + " to RS " + rb.getRsGroupId()
275 "checkConnection: DS " + rb.getServerId() + " is not connected to "
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationServer.java295 getServerId(),
1204 public int getServerId() method in class:ReplicationServer
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java272 + rb.getServerId() + " to RS " + rb.getRsGroupId()
291 fail("checkConnection: DS " + rb.getServerId() + " is not connected to "

Completed in 195 milliseconds

<<11121314