| /system/bt/osi/test/ |
| leaky_bonded_queue_test.cc | 54 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(3); local
55 EXPECT_EQ(queue->Capacity(), static_cast<size_t>(3));
56 EXPECT_EQ(queue->Length(), static_cast<size_t>(0));
57 queue->Enqueue(item1);
58 EXPECT_EQ(queue->Length(), static_cast<size_t>(1));
59 queue->Enqueue(item2);
60 EXPECT_EQ(queue->Length(), static_cast<size_t>(2));
61 queue->Enqueue(item3);
62 EXPECT_EQ(queue->Length(), static_cast<size_t>(3));
64 queue->Enqueue(item4)
90 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
124 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
164 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
193 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
218 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
227 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(1); local
237 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ListenerCallQueueTest.java | 43 ListenerCallQueue<Object> queue = local
47 queue.add(incrementingCallback(counter, 1));
48 queue.add(incrementingCallback(counter, 2));
49 queue.add(incrementingCallback(counter, 3));
50 queue.add(incrementingCallback(counter, 4));
52 queue.execute();
58 ListenerCallQueue<Object> queue = local
62 queue.add(incrementingCallback(counter, 1));
63 queue.add(THROWING_CALLBACK);
64 queue.add(incrementingCallback(counter, 2))
78 ListenerCallQueue<Object> queue = local
100 ListenerCallQueue<Object> queue = local
[all...] |
| /external/mesa3d/src/gallium/drivers/llvmpipe/ |
| lp_scene_queue.c | 30 * Scene queue. We'll use two queues. One contains "full" scenes which
49 * A queue of scenes
58 /** Allocate a new scene queue */
62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); local
63 if (!queue)
66 queue->ring = util_ringbuffer_create( MAX_SCENE_QUEUE *
68 if (queue->ring == NULL)
71 return queue;
74 FREE(queue);
79 /** Delete a scene queue */
[all...] |
| /external/mesa3d/src/vulkan/wsi/ |
| wsi_common_queue.h | 38 wsi_queue_init(struct wsi_queue *queue, int length)
46 ret = u_vector_init(&queue->vector, sizeof(uint32_t),
60 ret = pthread_cond_init(&queue->cond, &condattr);
64 ret = pthread_mutex_init(&queue->mutex, NULL);
72 pthread_cond_destroy(&queue->cond);
76 u_vector_finish(&queue->vector);
82 wsi_queue_destroy(struct wsi_queue *queue)
84 u_vector_finish(&queue->vector);
85 pthread_mutex_destroy(&queue->mutex);
86 pthread_cond_destroy(&queue->cond)
[all...] |
| /external/libcxx/test/std/containers/container.adaptors/queue/queue.defn/ |
| back.pass.cpp | 10 // <queue>
14 #include <queue>
19 std::queue<int> q;
|
| empty.pass.cpp | 10 // <queue>
14 #include <queue>
19 std::queue<int> q;
|
| front.pass.cpp | 10 // <queue>
14 #include <queue>
19 std::queue<int> q;
|
| assign_copy.pass.cpp | 10 // <queue>
12 // queue& operator=(const queue& q);
14 #include <queue>
29 std::queue<int> q(make<std::deque<int> >(5));
30 std::queue<int> q2;
|
| back_const.pass.cpp | 10 // <queue>
14 #include <queue>
19 std::queue<int> q;
24 const std::queue<int>& cqr = q;
|
| front_const.pass.cpp | 10 // <queue>
14 #include <queue>
19 std::queue<int> q;
24 const std::queue<int>& cqr = q;
|
| /external/libcxx/test/std/containers/container.adaptors/queue/queue.special/ |
| swap_noexcept.pass.cpp | 10 // <queue>
12 // void swap(queue& c)
19 #include <queue>
28 typedef std::queue<MoveOnly> C;
|
| /external/webrtc/webrtc/modules/video_coding/codecs/test/ |
| predictive_packet_manipulator.h | 14 #include <queue>
31 // FIFO queue so they will be returned in the same order they were added.
40 std::queue<double> random_results_;
|
| /libcore/ojluni/src/main/java/java/lang/ref/ |
| Reference.java | 65 final ReferenceQueue<? super T> queue; field in class:Reference
71 * before it has been removed from its queue, the queueNext field points
72 * to the next reference on the queue. The last reference on a queue
74 * reference queue, the queueNext field points to the
79 * internal to 'queue'.
125 /* -- Queue operations -- */
130 * not registered with a queue when it was created, then this method will
138 // after this reference object has been removed from its queue
141 return queue != null && queue.isEnqueued(this)
[all...] |
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/containers/container.adaptors/queue/queue.defn/ |
| back.pass.cpp | 10 // <queue>
14 #include <queue>
19 std::queue<int> q;
|
| empty.pass.cpp | 10 // <queue>
14 #include <queue>
19 std::queue<int> q;
|
| front.pass.cpp | 10 // <queue>
14 #include <queue>
19 std::queue<int> q;
|
| assign_copy.pass.cpp | 10 // <queue>
12 // queue& operator=(const queue& q);
14 #include <queue>
29 std::queue<int> q(make<std::deque<int> >(5));
30 std::queue<int> q2;
|
| back_const.pass.cpp | 10 // <queue>
14 #include <queue>
19 std::queue<int> q;
24 const std::queue<int>& cqr = q;
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/containers/container.adaptors/queue/queue.special/ |
| swap_noexcept.pass.cpp | 10 // <queue>
12 // void swap(queue& c)
19 #include <queue>
28 typedef std::queue<MoveOnly> C;
|
| /external/libcxx/test/std/containers/container.adaptors/priority.queue/ |
| types.fail.cpp | 10 // <queue>
27 #include <queue>
|
| /external/webrtc/webrtc/common_audio/ |
| swap_queue_unittest.cc | 24 // Queue item verification function for the vector test.
29 // Queue item verifier for the vector test.
46 SwapQueue<std::vector<int>> queue(2, i);
48 EXPECT_TRUE(queue.Insert(&i));
50 EXPECT_TRUE(queue.Insert(&i));
52 EXPECT_TRUE(queue.Remove(&i));
54 EXPECT_TRUE(queue.Remove(&i));
59 SwapQueue<int> queue(2);
61 // Fill the queue.
63 EXPECT_TRUE(queue.Insert(&i))
[all...] |
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/containers/container.adaptors/priority.queue/ |
| types.fail.cpp | 10 // <queue>
27 #include <queue>
|
| /external/libchrome/base/synchronization/ |
| condition_variable_unittest.cc | 259 WorkQueue queue(kThreadCount); // Start the threads.
266 base::AutoLock auto_lock(*queue.lock());
267 while (!queue.EveryIdWasAllocated())
268 queue.all_threads_have_ids()->Wait();
273 queue.SpinUntilAllThreadsAreWaiting();
277 base::AutoLock auto_lock(*queue.lock());
278 EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments());
279 EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks());
280 EXPECT_EQ(0, queue.task_count());
281 EXPECT_EQ(0, queue.GetMaxCompletionsByWorkerThread())
[all...] |
| /external/libcxx/test/std/containers/container.adaptors/queue/queue.cons/ |
| ctor_copy.pass.cpp | 10 // <queue>
12 // queue(const queue&) = default;
14 #include <queue>
29 std::queue<int> q(make<std::deque<int> >(5));
30 std::queue<int> q2 = q;
|
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/test/std/containers/container.adaptors/queue/queue.cons/ |
| ctor_copy.pass.cpp | 10 // <queue>
12 // queue(const queue&) = default;
14 #include <queue>
29 std::queue<int> q(make<std::deque<int> >(5));
30 std::queue<int> q2 = q;
|
