Searched refs:maxNbConcurrentOperations (Results 1 - 9 of 9) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/core/
H A DBoundedWorkQueueStrategy.java49 private final int maxNbConcurrentOperations; field in class:BoundedWorkQueueStrategy
54 * @param maxNbConcurrentOperations
58 public BoundedWorkQueueStrategy(Integer maxNbConcurrentOperations) argument
60 if (maxNbConcurrentOperations != null)
62 this.maxNbConcurrentOperations = maxNbConcurrentOperations;
69 this.maxNbConcurrentOperations =
85 if (maxNbConcurrentOperations == 0)
92 else if (nbRunningOperations.getAndIncrement() > maxNbConcurrentOperations
/forgerock/opendj2/src/server/org/opends/server/core/
H A DBoundedWorkQueueStrategy.java48 private final int maxNbConcurrentOperations; field in class:BoundedWorkQueueStrategy
53 * @param maxNbConcurrentOperations
57 public BoundedWorkQueueStrategy(Integer maxNbConcurrentOperations) argument
59 if (maxNbConcurrentOperations != null)
61 this.maxNbConcurrentOperations = maxNbConcurrentOperations;
66 this.maxNbConcurrentOperations =
94 if (maxNbConcurrentOperations == 0)
101 else if (nbRunningOperations.getAndIncrement() > maxNbConcurrentOperations
/forgerock/opendj2.6.2/src/server/org/opends/server/core/
H A DBoundedWorkQueueStrategy.java49 private final int maxNbConcurrentOperations; field in class:BoundedWorkQueueStrategy
54 * @param maxNbConcurrentOperations
58 public BoundedWorkQueueStrategy(Integer maxNbConcurrentOperations) argument
60 if (maxNbConcurrentOperations != null)
62 this.maxNbConcurrentOperations = maxNbConcurrentOperations;
69 this.maxNbConcurrentOperations =
85 if (maxNbConcurrentOperations == 0)
92 else if (nbRunningOperations.getAndIncrement() > maxNbConcurrentOperations
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/
H A DBoundedWorkQueueStrategy.java49 private final int maxNbConcurrentOperations; field in class:BoundedWorkQueueStrategy
54 * @param maxNbConcurrentOperations
58 public BoundedWorkQueueStrategy(Integer maxNbConcurrentOperations) argument
60 if (maxNbConcurrentOperations != null)
62 this.maxNbConcurrentOperations = maxNbConcurrentOperations;
69 this.maxNbConcurrentOperations =
85 if (maxNbConcurrentOperations == 0)
92 else if (nbRunningOperations.getAndIncrement() > maxNbConcurrentOperations
/forgerock/opendj2-hg/src/server/org/opends/server/core/
H A DBoundedWorkQueueStrategy.java48 private final int maxNbConcurrentOperations; field in class:BoundedWorkQueueStrategy
53 * @param maxNbConcurrentOperations
57 public BoundedWorkQueueStrategy(Integer maxNbConcurrentOperations) argument
59 if (maxNbConcurrentOperations != null)
61 this.maxNbConcurrentOperations = maxNbConcurrentOperations;
66 this.maxNbConcurrentOperations =
94 if (maxNbConcurrentOperations == 0)
101 else if (nbRunningOperations.getAndIncrement() > maxNbConcurrentOperations
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/core/
H A DBoundedWorkQueueStrategy.java48 private final int maxNbConcurrentOperations; field in class:BoundedWorkQueueStrategy
53 * @param maxNbConcurrentOperations
57 public BoundedWorkQueueStrategy(Integer maxNbConcurrentOperations) argument
59 if (maxNbConcurrentOperations != null)
61 this.maxNbConcurrentOperations = maxNbConcurrentOperations;
66 this.maxNbConcurrentOperations =
94 if (maxNbConcurrentOperations == 0)
101 else if (nbRunningOperations.getAndIncrement() > maxNbConcurrentOperations
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/core/
H A DBoundedWorkQueueStrategyTest.java57 private BoundedWorkQueueStrategyForTest(Integer maxNbConcurrentOperations, argument
60 super(maxNbConcurrentOperations);
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/core/
H A DBoundedWorkQueueStrategyTest.java57 private BoundedWorkQueueStrategyForTest(Integer maxNbConcurrentOperations, argument
60 super(maxNbConcurrentOperations);
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/core/
H A DBoundedWorkQueueStrategyTest.java57 private BoundedWorkQueueStrategyForTest(Integer maxNbConcurrentOperations, argument
60 super(maxNbConcurrentOperations);

Completed in 69 milliseconds