| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/rt.equinox.bundles/bundles/org.eclipse.equinox.log.stream/osgi/src/org/osgi/util/pushstream/ |
| H A D | PushbackPolicyOption.java | 47 return q -> q.remainingCapacity() == 0 ? value : 0; in getPolicy()
61 if (q.remainingCapacity() == 0) { in getPolicy()
79 long remainingCapacity = q.remainingCapacity();
81 return (value * used) / (used + remainingCapacity);
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/tck/ |
| H A D | ArrayBlockingQueueTest.java | 218 assertEquals(2, q.remainingCapacity()); in testEmptyFull()
223 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
233 int spare = q.remainingCapacity(); in testRemainingCapacity()
262 assertEquals(0, q.remainingCapacity()); in testAdd()
303 assertEquals(0, q.remainingCapacity()); in testAddAll_insufficientSpace()
338 assertEquals(0, q.remainingCapacity()); in testPut()
352 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
374 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
408 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
415 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
[all …]
|
| H A D | LinkedBlockingQueueTest.java | 94 assertEquals(0, q.remainingCapacity()); in populatedQueue()
178 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
188 assertEquals(i, q.remainingCapacity()); in testRemainingCapacity()
215 assertEquals(0, q.remainingCapacity()); in testAdd()
289 assertEquals(0, q.remainingCapacity()); in testPut()
303 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
325 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
359 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
366 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
597 assertEquals(SIZE, q.remainingCapacity()); in testClear()
[all …]
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/util/concurrent/tck/ |
| H A D | ArrayBlockingQueueTest.java | 218 assertEquals(2, q.remainingCapacity()); in testEmptyFull()
223 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
233 int spare = q.remainingCapacity(); in testRemainingCapacity()
262 assertEquals(0, q.remainingCapacity()); in testAdd()
303 assertEquals(0, q.remainingCapacity()); in testAddAll_insufficientSpace()
338 assertEquals(0, q.remainingCapacity()); in testPut()
352 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
374 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
408 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
415 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
[all …]
|
| H A D | LinkedBlockingQueueTest.java | 94 assertEquals(0, q.remainingCapacity()); in populatedQueue()
178 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
188 assertEquals(i, q.remainingCapacity()); in testRemainingCapacity()
215 assertEquals(0, q.remainingCapacity()); in testAdd()
289 assertEquals(0, q.remainingCapacity()); in testPut()
303 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
325 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
359 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
366 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
597 assertEquals(SIZE, q.remainingCapacity()); in testClear()
[all …]
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/tck/ |
| H A D | ArrayBlockingQueueTest.java | 218 assertEquals(2, q.remainingCapacity()); in testEmptyFull()
223 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
233 int spare = q.remainingCapacity(); in testRemainingCapacity()
262 assertEquals(0, q.remainingCapacity()); in testAdd()
303 assertEquals(0, q.remainingCapacity()); in testAddAll_insufficientSpace()
338 assertEquals(0, q.remainingCapacity()); in testPut()
352 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
374 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
408 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
415 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
[all …]
|
| H A D | LinkedBlockingQueueTest.java | 94 assertEquals(0, q.remainingCapacity()); in populatedQueue()
178 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
188 assertEquals(i, q.remainingCapacity()); in testRemainingCapacity()
215 assertEquals(0, q.remainingCapacity()); in testAdd()
289 assertEquals(0, q.remainingCapacity()); in testPut()
303 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
325 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
359 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
366 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
597 assertEquals(SIZE, q.remainingCapacity()); in testClear()
[all …]
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/util/concurrent/tck/ |
| H A D | ArrayBlockingQueueTest.java | 218 assertEquals(2, q.remainingCapacity()); in testEmptyFull()
223 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
233 int spare = q.remainingCapacity(); in testRemainingCapacity()
262 assertEquals(0, q.remainingCapacity()); in testAdd()
303 assertEquals(0, q.remainingCapacity()); in testAddAll_insufficientSpace()
338 assertEquals(0, q.remainingCapacity()); in testPut()
352 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
374 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
408 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
415 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
[all …]
|
| H A D | LinkedBlockingQueueTest.java | 94 assertEquals(0, q.remainingCapacity()); in populatedQueue()
178 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
188 assertEquals(i, q.remainingCapacity()); in testRemainingCapacity()
215 assertEquals(0, q.remainingCapacity()); in testAdd()
289 assertEquals(0, q.remainingCapacity()); in testPut()
303 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
325 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
359 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
366 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
597 assertEquals(SIZE, q.remainingCapacity()); in testClear()
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/util/concurrent/tck/ |
| H A D | ArrayBlockingQueueTest.java | 218 assertEquals(2, q.remainingCapacity()); in testEmptyFull()
223 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
233 int spare = q.remainingCapacity(); in testRemainingCapacity()
262 assertEquals(0, q.remainingCapacity()); in testAdd()
303 assertEquals(0, q.remainingCapacity()); in testAddAll_insufficientSpace()
338 assertEquals(0, q.remainingCapacity()); in testPut()
352 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
374 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
408 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
415 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
[all …]
|
| H A D | LinkedBlockingQueueTest.java | 94 assertEquals(0, q.remainingCapacity()); in populatedQueue()
178 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
188 assertEquals(i, q.remainingCapacity()); in testRemainingCapacity()
215 assertEquals(0, q.remainingCapacity()); in testAdd()
289 assertEquals(0, q.remainingCapacity()); in testPut()
303 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
325 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
359 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
366 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
594 assertEquals(SIZE, q.remainingCapacity()); in testClear()
[all …]
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/util/concurrent/tck/ |
| H A D | ArrayBlockingQueueTest.java | 218 assertEquals(2, q.remainingCapacity()); in testEmptyFull()
223 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
233 int spare = q.remainingCapacity(); in testRemainingCapacity()
262 assertEquals(0, q.remainingCapacity()); in testAdd()
303 assertEquals(0, q.remainingCapacity()); in testAddAll_insufficientSpace()
338 assertEquals(0, q.remainingCapacity()); in testPut()
352 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
374 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
408 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
415 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
[all …]
|
| H A D | LinkedBlockingQueueTest.java | 94 assertEquals(0, q.remainingCapacity()); in populatedQueue()
178 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
188 assertEquals(i, q.remainingCapacity()); in testRemainingCapacity()
215 assertEquals(0, q.remainingCapacity()); in testAdd()
289 assertEquals(0, q.remainingCapacity()); in testPut()
303 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
325 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
359 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
366 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
594 assertEquals(SIZE, q.remainingCapacity()); in testClear()
[all …]
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/util/concurrent/tck/ |
| H A D | ArrayBlockingQueueTest.java | 218 assertEquals(2, q.remainingCapacity()); in testEmptyFull()
223 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
233 int spare = q.remainingCapacity(); in testRemainingCapacity()
262 assertEquals(0, q.remainingCapacity()); in testAdd()
303 assertEquals(0, q.remainingCapacity()); in testAddAll_insufficientSpace()
338 assertEquals(0, q.remainingCapacity()); in testPut()
352 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
374 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
408 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
415 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
[all …]
|
| H A D | LinkedBlockingQueueTest.java | 94 assertEquals(0, q.remainingCapacity()); in populatedQueue()
178 assertEquals(0, q.remainingCapacity()); in testEmptyFull()
188 assertEquals(i, q.remainingCapacity()); in testRemainingCapacity()
215 assertEquals(0, q.remainingCapacity()); in testAdd()
289 assertEquals(0, q.remainingCapacity()); in testPut()
303 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
325 assertEquals(0, q.remainingCapacity()); in testBlockingPut()
359 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
366 assertEquals(0, q.remainingCapacity()); in testPutWithTake()
594 assertEquals(SIZE, q.remainingCapacity()); in testClear()
[all …]
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/util/concurrent/tck/ |
| H A D | ArrayBlockingQueueTest.java | 214 mustEqual(2, q.remainingCapacity()); in testEmptyFull()
219 mustEqual(0, q.remainingCapacity()); in testEmptyFull()
229 int spare = q.remainingCapacity(); in testRemainingCapacity()
258 mustEqual(0, q.remainingCapacity()); in testAdd()
297 mustEqual(0, q.remainingCapacity()); in testAddAll_insufficientSpace()
330 mustEqual(0, q.remainingCapacity()); in testPut()
344 mustEqual(0, q.remainingCapacity()); in testBlockingPut()
366 mustEqual(0, q.remainingCapacity()); in testBlockingPut()
400 mustEqual(0, q.remainingCapacity()); in testPutWithTake()
407 mustEqual(0, q.remainingCapacity()); in testPutWithTake()
[all …]
|
| H A D | LinkedBlockingQueueTest.java | 94 mustEqual(0, q.remainingCapacity()); in populatedQueue()
170 mustEqual(2, q.remainingCapacity()); in testEmptyFull()
175 mustEqual(0, q.remainingCapacity()); in testEmptyFull()
185 mustEqual(i, q.remainingCapacity()); in testRemainingCapacity()
212 mustEqual(0, q.remainingCapacity()); in testAdd()
280 mustEqual(0, q.remainingCapacity()); in testPut()
316 mustEqual(0, q.remainingCapacity()); in testBlockingPut()
350 mustEqual(0, q.remainingCapacity()); in testPutWithTake()
357 mustEqual(0, q.remainingCapacity()); in testPutWithTake()
585 mustEqual(SIZE, q.remainingCapacity()); in testClear()
[all …]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/http2/java.net.http/jdk/internal/net/http/hpack/ |
| H A D | CircularBufferTest.java | 127 int remainingCapacity = capacity; in queueOnce() local
131 assert remainingCapacity + size == capacity; in queueOnce()
132 int puts = random.nextInt(remainingCapacity + 1); // [0, remainingCapacity] in queueOnce()
133 remainingCapacity -= puts; in queueOnce()
142 remainingCapacity += gets; in queueOnce()
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/net/httpclient/http2/java.net.http/jdk/internal/net/http/hpack/ |
| H A D | CircularBufferTest.java | 127 int remainingCapacity = capacity; in queueOnce() local
131 assert remainingCapacity + size == capacity; in queueOnce()
132 int puts = random.nextInt(remainingCapacity + 1); // [0, remainingCapacity] in queueOnce()
133 remainingCapacity -= puts; in queueOnce()
142 remainingCapacity += gets; in queueOnce()
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/http2/java.net.http/jdk/internal/net/http/hpack/ |
| H A D | CircularBufferTest.java | 127 int remainingCapacity = capacity; in queueOnce() local
131 assert remainingCapacity + size == capacity; in queueOnce()
132 int puts = random.nextInt(remainingCapacity + 1); // [0, remainingCapacity] in queueOnce()
133 remainingCapacity -= puts; in queueOnce()
142 remainingCapacity += gets; in queueOnce()
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/net/httpclient/http2/java.net.http/jdk/internal/net/http/hpack/ |
| H A D | CircularBufferTest.java | 127 int remainingCapacity = capacity; in queueOnce() local
131 assert remainingCapacity + size == capacity; in queueOnce()
132 int puts = random.nextInt(remainingCapacity + 1); // [0, remainingCapacity] in queueOnce()
133 remainingCapacity -= puts; in queueOnce()
142 remainingCapacity += gets; in queueOnce()
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/net/httpclient/http2/java.net.http/jdk/internal/net/http/hpack/ |
| H A D | CircularBufferTest.java | 127 int remainingCapacity = capacity; in queueOnce() local
131 assert remainingCapacity + size == capacity; in queueOnce()
132 int puts = random.nextInt(remainingCapacity + 1); // [0, remainingCapacity] in queueOnce()
133 remainingCapacity -= puts; in queueOnce()
142 remainingCapacity += gets; in queueOnce()
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/net/httpclient/http2/java.net.http/jdk/internal/net/http/hpack/ |
| H A D | CircularBufferTest.java | 127 int remainingCapacity = capacity;
131 assert remainingCapacity + size == capacity; in relative_link_deref_error()
132 int puts = random.nextInt(remainingCapacity + 1); // [0, remainingCapacity] in relative_link_deref_error()
133 remainingCapacity -= puts; in relative_link_deref_error()
142 remainingCapacity += gets; in relative_link_deref_error()
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/net/httpclient/http2/java.net.http/jdk/internal/net/http/hpack/ |
| H A D | CircularBufferTest.java | 127 int remainingCapacity = capacity; in queueOnce() local
131 assert remainingCapacity + size == capacity; in queueOnce()
132 int puts = random.nextInt(remainingCapacity + 1); // [0, remainingCapacity] in queueOnce()
133 remainingCapacity -= puts; in queueOnce()
142 remainingCapacity += gets; in queueOnce()
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/net/httpclient/http2/java.net.http/jdk/internal/net/http/hpack/ |
| H A D | CircularBufferTest.java | 127 int remainingCapacity = capacity; in queueOnce() local
131 assert remainingCapacity + size == capacity; in queueOnce()
132 int puts = random.nextInt(remainingCapacity + 1); // [0, remainingCapacity] in queueOnce()
133 remainingCapacity -= puts; in queueOnce()
142 remainingCapacity += gets; in queueOnce()
|