| /frameworks/base/libs/hwui/tests/unit/ |
| ThreadBaseTests.cpp | 39 static WorkQueue& queue() { function
40 return thread().queue();
45 queue().post([&ran]() { ran = true; });
57 queue().postDelayed(100_us, [&]() { ranAtPromise.set_value(clock::now()); });
67 auto result = queue().runSync([&otherTid]() -> auto {
80 auto otherTid = queue().async([]() -> auto { return gettid(); });
81 auto otherPid = queue().async([]() -> auto { return getpid(); });
82 auto result = queue().async([]() -> auto { return 42; });
132 queue().runSync([c = std::move(counter)](){});
141 return queue().runSync([t = test]()->int { return t->getStrongCount(); })
[all...] |
| /packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/ |
| SimpleSampleBuffer.java | 92 for (SampleQueue queue : mPlayingSampleQueues) {
93 if (queue == null) {
96 Long lastQueuedSamplePositionUs = queue.getLastQueuedPositionUs();
114 SampleQueue queue = mPlayingSampleQueues[track]; local
115 SoftPreconditions.checkNotNull(queue);
116 int result = queue == null ? SampleSource.NOTHING_READ : queue.dequeueSample(sampleHolder);
155 for (SampleQueue queue : mPlayingSampleQueues) {
156 if (queue == null) {
159 if (queue.getLastQueuedPositionUs() == nul
[all...] |
| /frameworks/base/native/android/ |
| sensor.cpp | 58 if (queue == nullptr) { \
59 ERROR_INVALID_PARAMETER("queue cannot be NULL"); \
113 sp<SensorEventQueue> queue = local
115 if (queue != 0) {
116 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data);
117 queue->looper = looper;
118 queue->incStrong(manager);
120 return static_cast<ASensorEventQueue*>(queue.get());
123 int ASensorManager_destroyEventQueue(ASensorManager* manager, ASensorEventQueue* queue) {
127 sp<SensorEventQueue> q = static_cast<SensorEventQueue*>(queue);
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/ |
| PriorityQueueTest.java | 198 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
199 assertNotNull(queue);
200 assertEquals(0, queue.size());
201 assertNull(queue.comparator());
208 PriorityQueue<Object> queue = new PriorityQueue<Object>(100); local
209 assertNotNull(queue);
210 assertEquals(0, queue.size());
211 assertNull(queue.comparator());
218 PriorityQueue<Object> queue = new PriorityQueue<Object>(100, local
220 assertNotNull(queue);
318 PriorityQueue<String> queue = new PriorityQueue<String>(4, local
342 PriorityQueue<Integer> queue = new PriorityQueue<Integer>(c); local
393 PriorityQueue<Integer> queue = new PriorityQueue<Integer>(treeSet); local
416 PriorityQueue<String> queue = new PriorityQueue<String>(10, local
434 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
447 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
487 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
510 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
550 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
563 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
602 PriorityQueue<String> queue = new PriorityQueue<String>(10, local
653 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
663 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
[all...] |
| /external/strace/ |
| unwind.c | 97 static void queue_print(struct queue_t *queue);
124 tcp->queue = xmalloc(sizeof(*tcp->queue));
125 tcp->queue->head = NULL;
126 tcp->queue->tail = NULL;
132 queue_print(tcp->queue);
133 free(tcp->queue);
134 tcp->queue = NULL;
490 * queue manipulators
493 queue_put(struct queue_t *queue,
[all...] |
| /external/libcxx/test/std/containers/container.adaptors/priority.queue/priqueue.cons/ |
| ctor_comp.pass.cpp | 10 // <queue>
14 #include <queue>
|
| ctor_default.pass.cpp | 10 // <queue>
14 #include <queue>
|
| ctor_iter_iter.pass.cpp | 10 // <queue>
15 #include <queue>
|
| ctor_iter_iter_comp.pass.cpp | 10 // <queue>
15 #include <queue>
|
| ctor_iter_iter_comp_cont.pass.cpp | 10 // <queue>
16 #include <queue>
|
| ctor_iter_iter_comp_rcont.pass.cpp | 12 // <queue>
18 #include <queue>
|
| /external/libcxx/test/std/containers/container.adaptors/priority.queue/priqueue.members/ |
| emplace.pass.cpp | 12 // <queue>
18 #include <queue>
|
| push.pass.cpp | 10 // <queue>
16 #include <queue>
|
| push_rvalue.pass.cpp | 12 // <queue>
18 #include <queue>
|
| swap.pass.cpp | 10 // <queue>
16 #include <queue>
|
| top.pass.cpp | 10 // <queue>
16 #include <queue>
|
| /external/libcxx/test/std/containers/container.adaptors/priority.queue/priqueue.special/ |
| swap.pass.cpp | 10 // <queue>
18 #include <queue>
|
| /external/libcxx/test/std/containers/container.adaptors/queue/queue.defn/ |
| emplace.pass.cpp | 12 // <queue>
19 #include <queue>
27 template <typename Queue>
29 typedef typename Queue::container_type Container;
31 typedef decltype(std::declval<Queue>().emplace(std::declval<value_type &>())) queue_return_type;
43 test_return_type<std::queue<int> > ();
44 test_return_type<std::queue<int, std::list<int> > > ();
47 std::queue<Emplaceable> q;
|
| /external/libevent/ |
| defer-internal.h | 36 #include <sys/queue.h>
|
| /external/tensorflow/tensorflow/python/framework/ |
| file_system_test.py | 42 queue = data_flow_ops.FIFOQueue(99, [dtypes.string], shapes=())
43 queue.enqueue_many([["test://foo"]]).run()
44 queue.close().run()
45 key, value = sess.run(reader.read(queue))
|
| /external/webrtc/webrtc/base/objc/ |
| RTCDispatcher.m | 30 dispatch_queue_t queue = [self dispatchQueueForType:dispatchType];
31 dispatch_async(queue, block);
|
| /frameworks/base/core/java/android/hardware/camera2/legacy/ |
| RequestHandlerThread.java | 28 * Ensure that the MessageQueue's idle handler gets run by poking the message queue;
29 * normally if the message queue is already idle, the idle handler won't get invoked.
99 MessageQueue queue = handler.getLooper().getQueue(); local
100 if (queue.isIdle()) {
104 queue.addIdleHandler(mIdleHandler);
107 if (queue.isIdle()) {
|
| /hardware/interfaces/camera/device/3.2/ |
| ICameraDeviceSession.hal | 253 * Retrieves the queue used along with processCaptureRequest. If
254 * client decides to use fast message queue to pass request metadata,
256 * - Call getCaptureRequestMetadataQueue to retrieve the fast message queue;
259 * fast message queue; leave settings field of CaptureRequest empty.
261 * @return queue the queue that client writes request metadata to.
263 getCaptureRequestMetadataQueue() generates (fmq_sync<uint8_t> queue);
268 * Retrieves the queue used along with
272 * - Call getCaptureRequestMetadataQueue to retrieve the fast message queue;
276 * queue;
[all...] |
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/containers/container.adaptors/priority.queue/priqueue.cons/ |
| ctor_comp.pass.cpp | 10 // <queue>
14 #include <queue>
|
| ctor_default.pass.cpp | 10 // <queue>
14 #include <queue>
|
