| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_open/speculative/ |
| 6-1.c | 32 mqd_t queue; local
36 queue = mq_open(qname, O_CREAT | O_RDWR | O_WRONLY,
38 if (queue != (mqd_t) - 1) {
41 mq_close(queue);
|
| /external/skia/src/gpu/mtl/ |
| GrMtlTrampoline.h | 24 static sk_sp<GrGpu> MakeGpu(GrContext*, const GrContextOptions&, void* device, void* queue);
|
| GrMtlTrampoline.mm | 15 void* queue) {
19 (__bridge_transfer id<MTLCommandQueue>)queue);
|
| /external/skqp/src/gpu/mtl/ |
| GrMtlTrampoline.h | 24 static sk_sp<GrGpu> MakeGpu(GrContext*, const GrContextOptions&, void* device, void* queue);
|
| GrMtlTrampoline.mm | 15 void* queue) {
19 (__bridge_transfer id<MTLCommandQueue>)queue);
|
| /external/webrtc/webrtc/base/ |
| socketserver.h | 30 // called to allow the socket server to use the thread's message queue for
32 virtual void SetMessageQueue(MessageQueue* queue) {}
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/containers/container.adaptors/priority.queue/priqueue.cons/ |
| default_noexcept.pass.cpp | 12 // <queue>
21 #include <queue>
|
| dtor_noexcept.pass.cpp | 10 // <queue>
16 #include <queue>
|
| move_assign_noexcept.pass.cpp | 10 // <queue>
20 #include <queue>
|
| move_noexcept.pass.cpp | 12 // <queue>
20 #include <queue>
|
| /external/libnl/lib/netfilter/ |
| queue.c | 2 * lib/netfilter/queue.c Netfilter Queue
14 * @defgroup queue Queue
25 #include <netlink/netfilter/queue.h>
50 * @name Queue Commands
111 static int nfnl_queue_build_request(const struct nfnl_queue *queue,
116 if (!nfnl_queue_test_group(queue))
120 0, nfnl_queue_get_group(queue));
124 if (nfnl_queue_test_maxlen(queue) &
[all...] |
| /art/runtime/gc/ |
| reference_queue_test.cc | 34 Mutex lock("Reference queue lock");
35 ReferenceQueue queue(&lock);
36 ASSERT_TRUE(queue.IsEmpty());
37 ASSERT_EQ(queue.GetLength(), 0U);
46 queue.EnqueueReference(ref1.Get());
47 ASSERT_TRUE(!queue.IsEmpty());
48 ASSERT_EQ(queue.GetLength(), 1U);
49 queue.EnqueueReference(ref2.Get());
50 ASSERT_TRUE(!queue.IsEmpty());
51 ASSERT_EQ(queue.GetLength(), 2U)
[all...] |
| /external/libcxx/test/std/containers/container.adaptors/queue/queue.cons/ |
| ctor_default.pass.cpp | 10 // <queue>
12 // queue();
14 #include <queue>
21 std::queue<int, std::vector<int, limited_allocator<int, 10> > > q;
|
| ctor_rcontainer.pass.cpp | 12 // <queue>
14 // explicit queue(container_type&& c);
16 #include <queue>
35 std::queue<MoveOnly> q(make<std::deque<MoveOnly> >(5));
|
| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| message_queue.h | 8 #include <queue>
17 // A queue for Message objects.
28 // Removes the next message from the queue, copying its data and transferring
37 std::queue<Message*> queue_;
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_open/ |
| 11-1.c | 11 * a currently existing message queue, then the current call has no effect.
34 mqd_t queue, queue2; local
38 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
39 if (queue == (mqd_t) - 1) {
45 if (mq_send(queue, msgptr, strlen(msgptr), 1) != 0) {
48 mq_close(queue);
60 mq_close(queue);
68 mq_close(queue);
74 mq_close(queue);
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/impl/ |
| select_reactor.hpp | 25 void select_reactor::add_timer_queue(timer_queue<Time_Traits>& queue)
27 do_add_timer_queue(queue);
30 // Remove a timer queue from the reactor.
32 void select_reactor::remove_timer_queue(timer_queue<Time_Traits>& queue)
34 do_remove_timer_queue(queue);
38 void select_reactor::schedule_timer(timer_queue<Time_Traits>& queue,
50 bool earliest = queue.enqueue_timer(time, timer, op);
57 std::size_t select_reactor::cancel_timer(timer_queue<Time_Traits>& queue,
63 std::size_t n = queue.cancel_timer(timer, ops, max_cancelled);
|
| /external/v8/src/libplatform/ |
| worker-thread.cc | 8 #include "src/libplatform/task-queue.h"
13 WorkerThread::WorkerThread(TaskQueue* queue)
14 : Thread(Options("V8 WorkerThread")), queue_(queue) {
|
| worker-thread.h | 8 #include <queue>
23 explicit WorkerThread(TaskQueue* queue);
|
| /external/webrtc/webrtc/modules/audio_processing/transient/ |
| moving_moments.h | 14 #include <queue>
41 // A queue holding the |length_| latest input values.
42 std::queue<float> queue_;
43 // Sum of the values of the queue.
45 // Sum of the squares of the values of the queue.
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/containers/container.adaptors/queue/queue.cons/ |
| ctor_default.pass.cpp | 10 // <queue>
12 // queue();
14 #include <queue>
21 std::queue<int, std::vector<int, limited_allocator<int, 10> > > q;
|
| ctor_rcontainer.pass.cpp | 12 // <queue>
14 // explicit queue(container_type&& c);
16 #include <queue>
35 std::queue<MoveOnly> q(make<std::deque<MoveOnly> >(5));
|
| /system/chre/platform/linux/include/chre/target_platform/ |
| platform_log_base.h | 23 #include <queue>
42 //! A mutex to guard the shared queue and exit condition of this class.
49 //! A queue of incoming log messages.
50 std::queue<std::unique_ptr<char>> mLogQueue;
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_send/ |
| 3-1.c | 10 * Test that mq_send() inserts messages into the message queue according
12 * Test by inserting multiple messages into the queue not in priority order.
50 mqd_t queue; local
59 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
60 if (queue == (mqd_t) - 1) {
65 if (mq_send(queue, msgptr3, strlen(msgptr3), PRI3) != 0) {
70 if (mq_send(queue, msgptr1, strlen(msgptr1), PRI1) != 0) {
75 if (mq_send(queue, msgptr4, strlen(msgptr4), PRI4) != 0) {
80 if (mq_send(queue, msgptr2, strlen(msgptr2), PRI2) != 0) {
85 if (mq_send(queue, msgptr5, strlen(msgptr5), PRI5) != 0)
[all...] |
| 3-2.c | 10 * Test that mq_send() inserts messages into the message queue according
52 mqd_t queue; local
61 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
62 if (queue == (mqd_t) - 1) {
67 if (mq_send(queue, msgptr3, strlen(msgptr3), PRI3) != 0) {
73 if (mq_send(queue, msgptr1, strlen(msgptr1), PRI1) != 0) {
79 if (mq_send(queue, msgptr4, strlen(msgptr4), PRI4) != 0) {
85 if (mq_send(queue, msgptr2, strlen(msgptr2), PRI2) != 0) {
91 if (mq_send(queue, msgptr5, strlen(msgptr5), PRI5) != 0) {
97 if (mq_receive(queue, msgrcd, BUFFER, &pri) == -1)
[all...] |
