| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationServerHandler.java | 91 setInitialServerState(inReplServerStartMsg.getServerState());
|
| H A D | ReplicationServerDomain.java | 1881 monitorMsg.setServerState(lsh.getServerId(), lsh.getServerState(), lsh
1888 monitorMsg.setServerState(rsh.getServerId(), rsh.getServerState(), rsh
2687 ServerState dsState = ds.getServerState()
|
| /forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
| H A D | ProtocolCompatibilityTest.java | 157 assertEquals(msg.getServerState().getMaxChangeNumber(1),
158 newMsg.getServerState().getMaxChangeNumber(1));
181 assertEquals(msg.getServerState().getMaxChangeNumber(1),
182 vlastMsg.getServerState().getMaxChangeNumber(1));
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
| H A D | ProtocolCompatibilityTest.java | 131 assertEquals(msg.getServerState().getCSN(1), newMsg.getServerState().getCSN(1));
154 assertEquals(msg.getServerState().getCSN(1), vlastMsg.getServerState().getCSN(1));
|
| H A D | SynchronizationMsgTest.java | 670 assertEquals(msg.getServerState().getCSN(1),
671 newMsg.getServerState().getCSN(1));
712 assertEquals(msg.getServerState().getCSN(1),
713 newMsg.getServerState().getCSN(1));
|
| /forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
| H A D | ProtocolCompatibilityTest.java | 157 assertEquals(msg.getServerState().getMaxChangeNumber(1),
158 newMsg.getServerState().getMaxChangeNumber(1));
181 assertEquals(msg.getServerState().getMaxChangeNumber(1),
182 vlastMsg.getServerState().getMaxChangeNumber(1));
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationServerHandler.java | 91 setInitialServerState(inReplServerStartMsg.getServerState());
|
| H A D | ReplicationServerDomain.java | 1784 lsh.getServerState(), lsh.getApproxFirstMissingDate(),
1792 rsh.getServerState(), rsh.getApproxFirstMissingDate(),
2658 ServerState dsState = ds.getServerState()
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationServerHandler.java | 86 setInitialServerState(inReplServerStartMsg.getServerState());
|
| H A D | ReplicationServer.java | 669 currentStartingCookie.append(domainDN).append(":").append(cookie.getServerState(domainDN)).append(";");
712 final ServerState providedState = cookie.getServerState(domainDN);
|
| H A D | ReplicationServerDomain.java | 1634 dsHandler.getServerState(), dsHandler.getApproxFirstMissingDate(),
1641 rsHandler.getServerState(), rsHandler.getApproxFirstMissingDate(),
|
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/ |
| H A D | ProtocolCompatibilityTest.java | 136 assertEquals(msg.getServerState().getCSN(1), newMsg.getServerState().getCSN(1));
159 assertEquals(msg.getServerState().getCSN(1), vlastMsg.getServerState().getCSN(1));
|
| H A D | SynchronizationMsgTest.java | 667 assertEquals(msg.getServerState().getCSN(1),
668 newMsg.getServerState().getCSN(1));
709 assertEquals(msg.getServerState().getCSN(1),
710 newMsg.getServerState().getCSN(1));
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationServer.java | 669 currentStartingCookie.append(domainDN).append(":").append(cookie.getServerState(domainDN)).append(";");
712 final ServerState providedState = cookie.getServerState(domainDN);
|
| H A D | ReplicationServerDomain.java | 1634 dsHandler.getServerState(), dsHandler.getApproxFirstMissingDate(),
1641 rsHandler.getServerState(), rsHandler.getApproxFirstMissingDate(),
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
| H A D | ReplicationServer.java | 649 currentStartingCookie.append(domainDN).append(":").append(cookie.getServerState(domainDN)).append(";");
673 final ServerState providedState = cookie.getServerState(domainDN);
|
| H A D | ReplicationServerDomain.java | 1588 dsHandler.getServerState(), dsHandler.getApproxFirstMissingDate(),
1595 rsHandler.getServerState(), rsHandler.getApproxFirstMissingDate(),
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationServerDomain.java | 1784 lsh.getServerState(), lsh.getApproxFirstMissingDate(),
1792 rsh.getServerState(), rsh.getApproxFirstMissingDate(),
2658 ServerState dsState = ds.getServerState()
|
| H A D | ECLServerHandler.java | 332 setInitialServerState(inECLStartMsg.getServerState());
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 522 getServerState().update(updateMsg.getCSN());
531 getServerState().update(updateMsg.getCSN());
2107 ServerState serverState = fakeRd1.getServerState();
2140 fakeRd1.getServerState(), REPLY_OK_RS_SCENARIO);
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 522 getServerState().update(updateMsg.getCSN());
531 getServerState().update(updateMsg.getCSN());
2107 ServerState serverState = fakeRd1.getServerState();
2140 fakeRd1.getServerState(), REPLY_OK_RS_SCENARIO);
|
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 520 getServerState().update(updateMsg.getCSN());
529 getServerState().update(updateMsg.getCSN());
2107 ServerState serverState = fakeRd1.getServerState();
2140 fakeRd1.getServerState(), REPLY_OK_RS_SCENARIO);
|
| /forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 722 getServerState().update(updateMsg.getChangeNumber());
735 getServerState().update(updateMsg.getChangeNumber());
2346 ServerState serverState = fakeRd1.getServerState();
2402 fakeRd1.getServerState(), REPLY_OK_RS_SCENARIO);
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | AssuredReplicationPluginTest.java | 464 serverState = serverStartMsg.getServerState();
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
| H A D | FileChangelogDB.java | 690 cursor.addDomain(baseDN, startState.getServerState(baseDN));
|