/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | DummyReplicationDomain.java | 60 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | DummyReplicationDomain.java | 60 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | DummyReplicationDomain.java | 74 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | SynchronizationMsgTest.java | 990 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 D | SynchronizationMsgTest.java | 990 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 D | SynchronizationMsgTest.java | 987 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 D | ReplicationBroker.java | 1139 * @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 D | ReplicationBroker.java | 1139 * @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 D | SynchronizationMsgTest.java | 1223 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 D | SynchronizationMsgTest.java | 1223 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 D | SynchronizationMsgTest.java | 1223 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 D | ReplicationBroker.java | 1007 * @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 D | ReplicationDomain.java | 437 * @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 D | ReplicationBroker.java | 1138 * @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 D | ReplicationBroker.java | 1007 * @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 D | ReplicationDomain.java | 437 * @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 D | ReplicationBroker.java | 992 * @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 D | ReplicationDomain.java | 416 * @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 D | LDAPReplicationDomain.java | 4073 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 D | LDAPReplicationDomain.java | 4073 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 D | LDAPReplicationDomain.java | 3956 public void sessionInitiated(ServerStatus initStatus, ServerState rsState) argument 3962 super.sessionInitiated(initStatus, rsState); 3981 CSN replServerMaxCSN = rsState.getCSN(getServerId());
|