| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | QueuesTest.java | 74 ? Queues.drain(q, buffer, maxElements, timeout, unit) in drain()
75 : Queues.drainUninterruptibly(q, buffer, maxElements, timeout, unit); in drain()
109 assertEquals(0, Queues.drain(q, ImmutableList.of(), 1, 10, TimeUnit.MILLISECONDS)); in testDrainTimesOut()
163 int elements = Queues.drain(q, buf, -1, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testNegativeMaxElements()
169 Queues.drain(q, buf, 1, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testNegativeMaxElements()
181 Queues.drain(q, ImmutableList.of(), 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testDrain_throws()
204 Queues.drainUninterruptibly(q, buf, 100, Long.MAX_VALUE, TimeUnit.NANOSECONDS); in testDrainUninterruptibly_doesNotThrow()
213 Queues.newLinkedBlockingDeque(0); in testNewLinkedBlockingDequeCapacity()
218 assertEquals(1, Queues.newLinkedBlockingDeque(1).remainingCapacity()); in testNewLinkedBlockingDequeCapacity()
219 assertEquals(11, Queues.newLinkedBlockingDeque(11).remainingCapacity()); in testNewLinkedBlockingDequeCapacity()
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ListenerCallQueue.java | 22 import com.google.common.collect.Queues;
62 @GuardedBy("this") private final Queue<Callback<L>> waitQueue = Queues.newArrayDeque();
|
| D | MoreExecutors.java | 27 import com.google.common.collect.Queues;
679 BlockingQueue<Future<T>> futureQueue = Queues.newLinkedBlockingQueue(); in invokeAnyImpl()
|
| D | Futures.java | 35 import com.google.common.collect.Queues;
1180 Queues.newConcurrentLinkedQueue();
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | SerializingExecutorTest.java | 21 import com.google.common.collect.Queues;
43 Queue<Runnable> tasks = Queues.newArrayDeque();
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | Queues.java | 41 public final class Queues { class
42 private Queues() {} in Queues() method in Queues
|
| /external/deqp/external/vulkancts/modules/vulkan/synchronization/ |
| D | vktSynchronizationInternallySynchronizedObjectsTests.cpp | 79 } Queues; typedef in vkt::synchronization::__anone698e8e60111::MultiQueues
85 Queues temp; in addQueueFamilyIndex()
96 map<deUint32,Queues>::iterator it = m_queues.begin(); in getQueueFamilyIndex()
106 Queues & getQueues (const int index) in getQueues()
108 map<deUint32,Queues>::iterator it = m_queues.begin(); in getQueues()
117 Queues& queue = m_queues[getQueueFamilyIndex(queueFamilyIndexNdx)]; in getFreeQueue()
156 map<deUint32,Queues> m_queues;
|
| D | vktSynchronizationBasicSemaphoreTests.cpp | 117 struct Queues in basicMultiQueueCase() struct
133 Queues queues[COUNT] = in basicMultiQueueCase()
|
| /external/antlr/antlr-3.4/runtime/ActionScript/project/src/org/antlr/runtime/tree/ |
| D | RewriteRuleNodeStream.as | 4 /** Queues up nodes matched on left side of -> in a tree parser. This is
|
| /external/ltp/testcases/open_posix_testsuite/Documentation/ |
| D | COVERAGE.mqueues | 1 Coverage-Area: Message Queues (MSG)
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| D | StreamService.java | 28 import com.google.common.collect.Queues;
90 private final BlockingQueue<StreamItem> outputQueue = Queues.newLinkedBlockingQueue();
|
| D | ExperimentingCaliperRun.java | 31 import com.google.common.collect.Queues;
285 final ConcurrentLinkedQueue<SettableFuture<T>> delegates = Queues.newConcurrentLinkedQueue(); in inCompletionOrder()
|
| /external/ltp/testcases/open_posix_testsuite/ |
| D | BUILD | 34 Message Queues
106 Message Queues
|
| D | QUICK-START | 17 (Signals, Semaphores, Threads, Timers or Message Queues).
|
| D | NEWS | 19 …NPTL enabled) and linux-2.6.5-mm6 kernel.It is noted that "POSIX Message Queues" has been integrat…
|
| /external/iproute2/examples/diffserv/ |
| D | regression-testing | 13 to the correct Virtual Queues.
|
| /external/libnl/doc/ |
| D | route.txt | 615 ==== RX/TX Queues
|
| /external/libmicrohttpd/doc/ |
| D | libmicrohttpd.texi | 2142 Queues a response to request basic authentication from the client.
2180 Queues a response to request authentication from the client,
|
| D | libmicrohttpd.info | 1876 Queues a response to request basic authentication from the client.
1923 Queues a response to request authentication from the client, return
|
| /external/owasp/sanitizer/lib/guava-libraries/ |
| D | guava.jar | META-INF/
META-INF/MANIFEST.MF
com/
com/google/
com/ ... |
| /external/owasp/sanitizer/distrib/lib/ |
| D | guava.jar | META-INF/
META-INF/MANIFEST.MF
com/
com/google/
com/ ... |
| /external/guice/lib/ |
| D | guava-16.0.1.jar | META-INF/MANIFEST.MF
META-INF/
META-INF/maven/
META- ... |
| /external/v8/src/inspector/build/closure-compiler/ |
| D | closure-compiler.jar | META-INF/MANIFEST.MF
META-INF/
com/
com/google/
com/ ... |
| /external/dagger2/lib/ |
| D | google-java-format-0.1-20151017.042846-2.jar | META-INF/
META-INF/MANIFEST.MF
com/
com/google/
com/ ... |
| /external/robolectric/v3/runtime/ |
| D | android-all-4.4_r1-robolectric-1.jar | META-INF/
META-INF/MANIFEST.MF
com/
com/google/
com/ ... |