/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 348 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 D | InitOnLineTest.java | 418 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 D | LDAPReplicationDomain.java | 345 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 D | LDAPReplicationDomain.java | 369 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 D | GenerationIdTest.java | 355 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 D | InitOnLineTest.java | 400 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 D | SynchronizationMsgTest.java | 842 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 D | AssuredReplicationServerTest.java | 482 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 D | SynchronizationMsgTest.java | 842 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 D | AssuredReplicationServerTest.java | 482 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 D | SynchronizationMsgTest.java | 842 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 D | AssuredReplicationServerTest.java | 480 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 D | SynchronizationMsgTest.java | 664 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 D | ReplicationDomainTest.java | 388 if (remoteDS.getDsId() != domain.getServerId())
|
H A D | ComputeBestServerTest.java | 130 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 D | SynchronizationMsgTest.java | 664 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 D | ReplicationDomainTest.java | 388 if (remoteDS.getDsId() != domain.getServerId())
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/ |
H A D | SynchronizationMsgTest.java | 661 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 D | ReplicationDomainTest.java | 383 if (remoteDS.getDsId() != domain.getServerId())
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServer.java | 294 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 D | ReplicationTestCase.java | 272 + 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 D | ReplicationServerLoadBalancingTest.java | 462 int curRsId = repServer.getServerId(); 514 int curRsId = repServer.getServerId();
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ReplicationTestCase.java | 265 + 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 D | ReplicationServer.java | 295 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 D | ReplicationTestCase.java | 272 + rb.getServerId() + " to RS " + rb.getRsGroupId() 291 fail("checkConnection: DS " + rb.getServerId() + " is not connected to "
|