Searched refs:rsState (Results 1 - 21 of 21) sorted by relevance

/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DDummyReplicationDomain.java60 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DDummyReplicationDomain.java60 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DDummyReplicationDomain.java74 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java990 ServerState rsState = new ServerState();
991 rsState.update(new CSN(1, 1, 1));
992 rsState.update(new CSN(1, 1, 45678));
1011 msg.setReplServerDbState(rsState);
1019 assertEquals(rsState, msg.getReplServerDbState());
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java990 ServerState rsState = new ServerState();
991 rsState.update(new CSN(1, 1, 1));
992 rsState.update(new CSN(1, 1, 45678));
1011 msg.setReplServerDbState(rsState);
1019 assertEquals(rsState, msg.getReplServerDbState());
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java987 ServerState rsState = new ServerState();
988 rsState.update(new CSN(1, 1, 1));
989 rsState.update(new CSN(1, 1, 45678));
1008 msg.setReplServerDbState(rsState);
1016 assertEquals(rsState, msg.getReplServerDbState());
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1139 * @param rsState The server state of the RS
1145 ServerState rsState, int degradedStatusThreshold, long dsGenId)
1166 int nChanges = ServerState.diffChanges(rsState, state);
1763 ServerState rsState = replicationServerInfo.getServerState();
1764 ChangeNumber rsChangeNumber = rsState.getMaxChangeNumber(localServerId);
1144 computeInitialServerStatus(long rsGenId, ServerState rsState, int degradedStatusThreshold, long dsGenId) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1139 * @param rsState The server state of the RS
1145 ServerState rsState, int degradedStatusThreshold, long dsGenId)
1166 int nChanges = ServerState.diffChanges(rsState, state);
1763 ServerState rsState = replicationServerInfo.getServerState();
1764 ChangeNumber rsChangeNumber = rsState.getMaxChangeNumber(localServerId);
1144 computeInitialServerStatus(long rsGenId, ServerState rsState, int degradedStatusThreshold, long dsGenId) argument
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1223 ServerState rsState = new ServerState();
1226 rsState.update(rscn1);
1227 rsState.update(rscn2);
1250 msg.setReplServerDbState(rsState);
1258 assertEquals(rsState, msg.getReplServerDbState());
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1223 ServerState rsState = new ServerState();
1226 rsState.update(rscn1);
1227 rsState.update(rscn2);
1250 msg.setReplServerDbState(rsState);
1258 assertEquals(rsState, msg.getReplServerDbState());
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java1223 ServerState rsState = new ServerState();
1226 rsState.update(rscn1);
1227 rsState.update(rscn2);
1250 msg.setReplServerDbState(rsState);
1258 assertEquals(rsState, msg.getReplServerDbState());
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1007 * @param rsState The server state of the RS
1013 ServerState rsState, int degradedStatusThreshold, long dsGenId)
1037 int nChanges = ServerState.diffChanges(rsState, state);
1012 computeInitialServerStatus(long rsGenId, ServerState rsState, int degradedStatusThreshold, long dsGenId) argument
H A DReplicationDomain.java437 * @param rsState The ServerState of the ReplicationServer
440 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
453 generator.adjust(rsState);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1138 * @param rsState The server state of the RS
1144 ServerState rsState, int degradedStatusThreshold, long dsGenId)
1165 int nChanges = ServerState.diffChanges(rsState, state);
1143 computeInitialServerStatus(long rsGenId, ServerState rsState, int degradedStatusThreshold, long dsGenId) argument
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1007 * @param rsState The server state of the RS
1013 ServerState rsState, int degradedStatusThreshold, long dsGenId)
1037 int nChanges = ServerState.diffChanges(rsState, state);
1012 computeInitialServerStatus(long rsGenId, ServerState rsState, int degradedStatusThreshold, long dsGenId) argument
H A DReplicationDomain.java437 * @param rsState The ServerState of the ReplicationServer
440 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
453 generator.adjust(rsState);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java992 * @param rsState The server state of the RS
998 ServerState rsState, int degradedStatusThreshold, long dsGenId)
1022 int nChanges = ServerState.diffChanges(rsState, state);
997 computeInitialServerStatus(long rsGenId, ServerState rsState, int degradedStatusThreshold, long dsGenId) argument
H A DReplicationDomain.java416 * @param rsState The ServerState of the ReplicationServer
419 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
431 generator.adjust(rsState);
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java4073 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
4079 super.sessionInitiated(initStatus, rsState);
4098 CSN replServerMaxCSN = rsState.getCSN(getServerId());
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java4073 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
4079 super.sessionInitiated(initStatus, rsState);
4098 CSN replServerMaxCSN = rsState.getCSN(getServerId());
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DLDAPReplicationDomain.java3956 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
3962 super.sessionInitiated(initStatus, rsState);
3981 CSN replServerMaxCSN = rsState.getCSN(getServerId());

Completed in 174 milliseconds