Searched refs:nChanges (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DStatusAnalyzer.java132 int nChanges = serverHandler.getRcvMsgQueueSize();
137 Integer.toString(serverHandler.getServerId()) + " has " + nChanges +
153 if (nChanges >= degradedStatusThreshold)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DStatusAnalyzer.java132 int nChanges = serverHandler.getRcvMsgQueueSize();
137 Integer.toString(serverHandler.getServerId()) + " has " + nChanges +
153 if (nChanges >= degradedStatusThreshold)
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java1229 public void followAndPause(int nChanges) argument
1231 debugInfo("Requested broker writer " + serverId + " to write " + nChanges + " change(s).");
1236 nChangesSentLimit = nChanges;
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java1042 public void followAndPause(int nChanges) argument
1044 debugInfo("Requested broker writer " + serverId + " to write " + nChanges + " change(s).");
1049 nChangesSentLimit = nChanges;
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java1229 public void followAndPause(int nChanges) argument
1231 debugInfo("Requested broker writer " + serverId + " to write " + nChanges + " change(s).");
1236 nChangesSentLimit = nChanges;
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java1042 public void followAndPause(int nChanges) argument
1044 debugInfo("Requested broker writer " + serverId + " to write " + nChanges + " change(s).");
1049 nChangesSentLimit = nChanges;
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java1229 public void followAndPause(int nChanges) argument
1231 debugInfo("Requested broker writer " + serverId + " to write " + nChanges + " change(s).");
1236 nChangesSentLimit = nChanges;
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DStateMachineTest.java984 public void followAndPause(int nChanges) argument
986 debugInfo("Requested broker writer " + serverId + " to write " + nChanges + " change(s).");
991 nChangesSentLimit = nChanges;
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java2567 final int nChanges = serverHandler.getRcvMsgQueueSize();
2572 + serverHandler.getServerId() + " has " + nChanges
2581 if (nChanges >= degradedStatusThreshold)
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java2567 final int nChanges = serverHandler.getRcvMsgQueueSize();
2572 + serverHandler.getServerId() + " has " + nChanges
2581 if (nChanges >= degradedStatusThreshold)
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServerDomain.java2496 final int nChanges = serverHandler.getRcvMsgQueueSize();
2501 + serverHandler.getServerId() + " has " + nChanges
2510 if (nChanges >= degradedStatusThreshold)
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1166 int nChanges = ServerState.diffChanges(rsState, state);
1172 + " computed " + Integer.toString(nChanges) + " changes late.");
1184 if (nChanges >= degradedStatusThreshold)
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1037 int nChanges = ServerState.diffChanges(rsState, state);
1040 debugInfo("computed " + nChanges + " changes late.");
1050 if (degradedStatusThreshold > 0 && nChanges >= degradedStatusThreshold)
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java3370 final int nChanges = serverHandler.getRcvMsgQueueSize();
3375 + serverHandler.getServerId() + " has " + nChanges
3384 if (nChanges >= degradedStatusThreshold)
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1165 int nChanges = ServerState.diffChanges(rsState, state);
1169 debugInfo("computed " + nChanges + " changes late.");
1181 if (nChanges >= degradedStatusThreshold)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1166 int nChanges = ServerState.diffChanges(rsState, state);
1172 + " computed " + Integer.toString(nChanges) + " changes late.");
1184 if (nChanges >= degradedStatusThreshold)
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java1037 int nChanges = ServerState.diffChanges(rsState, state);
1040 debugInfo("computed " + nChanges + " changes late.");
1050 if (degradedStatusThreshold > 0 && nChanges >= degradedStatusThreshold)
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java1022 int nChanges = ServerState.diffChanges(rsState, state);
1025 debugInfo("computed " + nChanges + " changes late.");
1035 if (degradedStatusThreshold > 0 && nChanges >= degradedStatusThreshold)

Completed in 140 milliseconds