Searched refs:limits (Results 1 - 25 of 28) sorted by relevance

12

/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicyTest.java51 * This set of tests test the resource limits.
123 final ResourceLimitsPolicy limits = createQOSPolicy(cfg);
126 limits.addConnection(conn1);
128 assertOperationIsAllowed(limits, conn1, null, true);
131 limits.addConnection(conn2);
132 assertOperationIsAllowed(limits, conn2, null, false);
134 limits.removeConnection(conn1);
135 assertOperationIsAllowed(limits, conn2, null, true);
137 limits.removeConnection(conn2);
148 final ResourceLimitsPolicy limits
233 assertOperationIsAllowed(ResourceLimitsPolicy limits, ClientConnection conn, InternalSearchOperation operation, boolean expected) argument
239 assertOperationIsAllowed(ResourceLimitsPolicy limits, ClientConnection conn, InternalSearchOperation operation, boolean expected, String assertMsg) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicyTest.java51 * This set of tests test the resource limits.
123 final ResourceLimitsPolicy limits = createQOSPolicy(cfg);
126 limits.addConnection(conn1);
128 assertOperationIsAllowed(limits, conn1, null, true);
131 limits.addConnection(conn2);
132 assertOperationIsAllowed(limits, conn2, null, false);
134 limits.removeConnection(conn1);
135 assertOperationIsAllowed(limits, conn2, null, true);
137 limits.removeConnection(conn2);
148 final ResourceLimitsPolicy limits
233 assertOperationIsAllowed(ResourceLimitsPolicy limits, ClientConnection conn, InternalSearchOperation operation, boolean expected) argument
239 assertOperationIsAllowed(ResourceLimitsPolicy limits, ClientConnection conn, InternalSearchOperation operation, boolean expected, String assertMsg) argument
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicyTest.java48 * This set of tests test the resource limits.
126 ResourceLimitsPolicy limits =
140 limits.addConnection(conn1);
142 boolean check = limits.isAllowed(conn1, null, true, messages);
146 limits.addConnection(conn2);
147 check = limits.isAllowed(conn2, null, true, messages);
150 limits.removeConnection(conn1);
151 check = limits.isAllowed(conn2, null, true, messages);
154 limits.removeConnection(conn2);
169 ResourceLimitsPolicy limits
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicyTest.java48 * This set of tests test the resource limits.
126 ResourceLimitsPolicy limits =
140 limits.addConnection(conn1);
142 boolean check = limits.isAllowed(conn1, null, true, messages);
146 limits.addConnection(conn2);
147 check = limits.isAllowed(conn2, null, true, messages);
150 limits.removeConnection(conn1);
151 check = limits.isAllowed(conn2, null, true, messages);
154 limits.removeConnection(conn2);
169 ResourceLimitsPolicy limits
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicyTest.java48 * This set of tests test the resource limits.
126 ResourceLimitsPolicy limits =
140 limits.addConnection(conn1);
142 boolean check = limits.isAllowed(conn1, null, true, messages);
146 limits.addConnection(conn2);
147 check = limits.isAllowed(conn2, null, true, messages);
150 limits.removeConnection(conn1);
151 check = limits.isAllowed(conn2, null, true, messages);
154 limits.removeConnection(conn2);
169 ResourceLimitsPolicy limits
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DJEReplicaDB.java149 final CSNLimits limits = csnLimits;
150 final boolean updateNew = limits.newestCSN == null || limits.newestCSN.isOlderThan(updateMsg.getCSN());
151 final boolean updateOld = limits.oldestCSN == null;
155 updateOld ? updateMsg.getCSN() : limits.oldestCSN,
156 updateNew ? updateMsg.getCSN() : limits.newestCSN);
298 final CSNLimits limits = csnLimits;
299 if (limits.oldestCSN != null)
301 create(attributes, "first-change", encode(limits.oldestCSN));
303 if (limits
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DJEReplicaDB.java149 final CSNLimits limits = csnLimits;
150 final boolean updateNew = limits.newestCSN == null || limits.newestCSN.isOlderThan(updateMsg.getCSN());
151 final boolean updateOld = limits.oldestCSN == null;
155 updateOld ? updateMsg.getCSN() : limits.oldestCSN,
156 updateNew ? updateMsg.getCSN() : limits.newestCSN);
298 final CSNLimits limits = csnLimits;
299 if (limits.oldestCSN != null)
301 create(attributes, "first-change", encode(limits.oldestCSN));
303 if (limits
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDB.java173 final CSNLimits limits = csnLimits;
174 final boolean updateNew = limits.newestCSN == null || limits.newestCSN.isOlderThan(updateMsg.getCSN());
175 final boolean updateOld = limits.oldestCSN == null;
179 updateOld ? updateMsg.getCSN() : limits.oldestCSN,
180 updateNew ? updateMsg.getCSN() : limits.newestCSN);
273 final CSNLimits limits = csnLimits;
274 if (limits.oldestCSN != null)
276 create(attributes, "first-change", encode(limits.oldestCSN));
278 if (limits
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDB.java173 final CSNLimits limits = csnLimits;
174 final boolean updateNew = limits.newestCSN == null || limits.newestCSN.isOlderThan(updateMsg.getCSN());
175 final boolean updateOld = limits.oldestCSN == null;
179 updateOld ? updateMsg.getCSN() : limits.oldestCSN,
180 updateNew ? updateMsg.getCSN() : limits.newestCSN);
273 final CSNLimits limits = csnLimits;
274 if (limits.oldestCSN != null)
276 create(attributes, "first-change", encode(limits.oldestCSN));
278 if (limits
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDB.java173 final CSNLimits limits = csnLimits;
174 final boolean updateNew = limits.newestCSN == null || limits.newestCSN.isOlderThan(updateMsg.getCSN());
175 final boolean updateOld = limits.oldestCSN == null;
179 updateOld ? updateMsg.getCSN() : limits.oldestCSN,
180 updateNew ? updateMsg.getCSN() : limits.newestCSN);
272 final CSNLimits limits = csnLimits;
273 if (limits.oldestCSN != null)
275 create(attributes, "first-change", encode(limits.oldestCSN));
277 if (limits
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/common/
H A DFirstChangeNumberVirtualAttributeProvider.java90 final long[] limits = replicationServer.getECLChangeNumberLimits();
91 value = String.valueOf(limits[0]);
H A DLastChangeNumberVirtualAttributeProvider.java90 final long[] limits = replicationServer.getECLChangeNumberLimits();
91 value = String.valueOf(limits[1]);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/
H A DFirstChangeNumberVirtualAttributeProvider.java90 final long[] limits = replicationServer.getECLChangeNumberLimits();
91 value = String.valueOf(limits[0]);
H A DLastChangeNumberVirtualAttributeProvider.java90 final long[] limits = replicationServer.getECLChangeNumberLimits();
91 value = String.valueOf(limits[1]);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/
H A DFirstChangeNumberVirtualAttributeProvider.java156 int[] limits = rs.getECLDraftCNLimits(
159 first = String.valueOf(limits[0]);
H A DLastChangeNumberVirtualAttributeProvider.java156 int[] limits = rs.getECLDraftCNLimits(
159 last = String.valueOf(limits[1]);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/
H A DFirstChangeNumberVirtualAttributeProvider.java156 int[] limits = rs.getECLDraftCNLimits(
159 first = String.valueOf(limits[0]);
H A DLastChangeNumberVirtualAttributeProvider.java156 int[] limits = rs.getECLDraftCNLimits(
159 last = String.valueOf(limits[1]);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/
H A DFirstChangeNumberVirtualAttributeProvider.java156 int[] limits = rs.getECLDraftCNLimits(
159 first = String.valueOf(limits[0]);
H A DLastChangeNumberVirtualAttributeProvider.java156 int[] limits = rs.getECLDraftCNLimits(
159 last = String.valueOf(limits[1]);
/forgerock/web-agents-v4/zlib/
H A Dgzguts.h26 # include <limits.h>
H A Dzconf.h401 # include <limits.h>
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java619 int[] limits = replicationServer.getECLDraftCNLimits(
624 if (startDraftCN < limits[0])
626 crossDomainStartState = draftCNDb.getValue(limits[0]);
634 draftCNDb.generateIterator(limits[0]);
644 else if (startDraftCN<=limits[1])
1145 int[] limits = computeCLLimits(crossDomainEligibleCN);
1147 CLLimitsMsg msg = new CLLimitsMsg(limits[0], limits[1]);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java619 int[] limits = replicationServer.getECLDraftCNLimits(
624 if (startDraftCN < limits[0])
626 crossDomainStartState = draftCNDb.getValue(limits[0]);
634 draftCNDb.generateIterator(limits[0]);
644 else if (startDraftCN<=limits[1])
1145 int[] limits = computeCLLimits(crossDomainEligibleCN);
1147 CLLimitsMsg msg = new CLLimitsMsg(limits[0], limits[1]);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java619 int[] limits = replicationServer.getECLDraftCNLimits(
624 if (startDraftCN < limits[0])
626 crossDomainStartState = draftCNDb.getValue(limits[0]);
634 draftCNDb.generateIterator(limits[0]);
644 else if (startDraftCN<=limits[1])
1145 int[] limits = computeCLLimits(crossDomainEligibleCN);
1147 CLLimitsMsg msg = new CLLimitsMsg(limits[0], limits[1]);

Completed in 78 milliseconds

12