| /external/OpenCL-CTS/test_conformance/basic/ |
| D | procs.h | 24 extern int test_hostptr(cl_device_id deviceID, cl_context context, cl_command_queue queue, int…
26 cl_command_queue queue, int num_elements);
27 extern int test_intmath_int(cl_device_id deviceID, cl_context context, cl_command_queue queue,…
28 extern int test_intmath_int2(cl_device_id deviceID, cl_context context, cl_command_queue queue…
29 extern int test_intmath_int4(cl_device_id deviceID, cl_context context, cl_command_queue queue…
30 extern int test_intmath_long(cl_device_id deviceID, cl_context context, cl_command_queue queue…
31 …intmath_long2(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
32 …intmath_long4(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
33 extern int test_hiloeo(cl_device_id deviceID, cl_context context, cl_command_queue queue, int …
34 extern int test_if(cl_device_id deviceID, cl_context context, cl_command_queue queue, int nu…
[all …]
|
| /external/antlr/runtime/ObjC/Framework/test/runtime/misc/ |
| D | FastQueueTest.m | 18 FastQueue *queue = [[FastQueue newFastQueue] retain];
19 STAssertNotNil(queue, @"Queue was not created and was nil");
20 [queue release];
25 FastQueue *queue = [[FastQueue newFastQueue] retain];
26 STAssertNotNil(queue, @"Queue was not created and was nil");
27 [queue addObject:@"My String"];
28 …STAssertTrue([[queue objectAtIndex:0] isKindOfClass:[NSString class]], @"First object is not a NSS…
29 STAssertEquals([queue objectAtIndex:0], @"My String", @"Object at index zero is invalid");
30 STAssertTrue([queue size] == 1, @"Queue is the wrong size: %d", [queue size]);
31 [queue release];
[all …]
|
| /external/pigweed/pw_containers/ |
| D | inline_queue_test.cc | 35 InlineQueue<int, 3> queue; in TEST() local
36 EXPECT_TRUE(queue.empty()); in TEST()
37 EXPECT_EQ(queue.size(), 0u); in TEST()
38 EXPECT_EQ(queue.max_size(), 3u); in TEST()
43 InlineQueue<int>& queue(sized_queue); in TEST() local
44 EXPECT_TRUE(queue.empty()); in TEST()
45 EXPECT_EQ(queue.size(), 0u); in TEST()
46 EXPECT_EQ(queue.max_size(), 3u); in TEST()
50 InlineQueue<CopyOnly, 4> queue(4, CopyOnly(123)); in TEST() local
51 InlineQueue<CopyOnly, 4> copied(queue); in TEST()
[all …]
|
| D | inline_var_len_entry_queue.c | 23 static uint32_t BufferSize(const uint32_t* queue) { return queue[0]; } in BufferSize() argument
24 static uint32_t Capacity(const uint32_t* queue) { in Capacity() argument
25 return BufferSize(queue) - 1; in Capacity()
29 #define HEAD(queue) queue[1] argument
30 #define TAIL(queue) queue[2] argument
33 static uint8_t* WritableData(uint32_t* queue) { return (uint8_t*)&queue[3]; } in WritableData() argument
34 static const uint8_t* Data(const uint32_t* queue) { in Data() argument
35 return (const uint8_t*)&queue[3]; in Data()
38 static uint32_t WrapIndex(pw_InlineVarLenEntryQueue_ConstHandle queue, in WrapIndex() argument
40 if (offset >= BufferSize(queue)) { in WrapIndex()
[all …]
|
| /external/mesa3d/src/util/ |
| D | u_queue.c | 47 util_queue_kill_threads(struct util_queue *queue, unsigned keep_num_threads,
85 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list() argument
90 list_add(&queue->head, &queue_list); in add_to_atexit_list()
95 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list() argument
101 if (iter == queue) { in remove_from_atexit_list()
249 struct util_queue *queue; member
256 struct util_queue *queue = ((struct thread_input*)input)->queue; in util_queue_thread_func() local
261 if (queue->flags & UTIL_QUEUE_INIT_SET_FULL_THREAD_AFFINITY) { in util_queue_thread_func()
274 if (queue->flags & UTIL_QUEUE_INIT_USE_MINIMUM_PRIORITY) { in util_queue_thread_func()
280 if (strlen(queue->name) > 0) { in util_queue_thread_func()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/collect/ |
| D | EvictingQueueTest.java | 45 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
46 assertEquals(0, queue.size()); in testCreateWithZeroSize()
48 assertTrue(queue.add("hi")); in testCreateWithZeroSize()
49 assertEquals(0, queue.size()); in testCreateWithZeroSize()
51 assertTrue(queue.offer("hi")); in testCreateWithZeroSize()
52 assertEquals(0, queue.size()); in testCreateWithZeroSize()
54 assertFalse(queue.remove("hi")); in testCreateWithZeroSize()
55 assertEquals(0, queue.size()); in testCreateWithZeroSize()
58 queue.element(); in testCreateWithZeroSize()
63 assertNull(queue.peek()); in testCreateWithZeroSize()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | EvictingQueueTest.java | 45 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
46 assertEquals(0, queue.size()); in testCreateWithZeroSize()
48 assertTrue(queue.add("hi")); in testCreateWithZeroSize()
49 assertEquals(0, queue.size()); in testCreateWithZeroSize()
51 assertTrue(queue.offer("hi")); in testCreateWithZeroSize()
52 assertEquals(0, queue.size()); in testCreateWithZeroSize()
54 assertFalse(queue.remove("hi")); in testCreateWithZeroSize()
55 assertEquals(0, queue.size()); in testCreateWithZeroSize()
58 queue.element(); in testCreateWithZeroSize()
63 assertNull(queue.peek()); in testCreateWithZeroSize()
[all …]
|
| /external/rust/crates/tokio-util/tests/ |
| D | time_delay_queue.rs | 11 ($queue:ident) => {
12 $queue.enter(|cx, mut queue| queue.poll_expired(cx))
29 let mut queue = task::spawn(DelayQueue::new()); in single_immediate_delay() localVariable
30 let _key = queue.insert_at("foo", Instant::now()); in single_immediate_delay()
35 assert_ready_some!(poll!(queue)); in single_immediate_delay()
37 let entry = assert_ready!(poll!(queue)); in single_immediate_delay()
45 let mut queue = task::spawn(DelayQueue::new()); in multi_immediate_delays() localVariable
47 let _k = queue.insert_at("1", Instant::now()); in multi_immediate_delays()
48 let _k = queue.insert_at("2", Instant::now()); in multi_immediate_delays()
49 let _k = queue.insert_at("3", Instant::now()); in multi_immediate_delays()
[all …]
|
| /external/OpenCL-CTS/test_conformance/buffers/ |
| D | procs.h | 34 …fer_read_int( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
35 …er_read_uint( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
36 …er_read_long( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
37 …r_read_ulong( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
38 …r_read_short( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
39 …_read_ushort( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
40 …r_read_float( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
41 …er_read_half( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
42 …er_read_char( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
43 …r_read_uchar( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
[all …]
|
| /external/OpenCL-CTS/test_conformance/integer_ops/ |
| D | procs.h | 32 extern int test_popcount(cl_device_id device, cl_context context, cl_command_queue queue, int num_e…
33 extern int test_integer_clz(cl_device_id deviceID, cl_context context, cl_command_queue queue, int …
34 extern int test_integer_ctz(cl_device_id deviceID, cl_context context, cl_command_queue queue, int …
35 extern int test_integer_hadd(cl_device_id deviceID, cl_context context, cl_command_queue queue, int…
36 extern int test_integer_rhadd(cl_device_id deviceID, cl_context context, cl_command_queue queue, in…
37 extern int test_integer_mul_hi(cl_device_id deviceID, cl_context context, cl_command_queue queue, i…
38 extern int test_integer_rotate(cl_device_id deviceID, cl_context context, cl_command_queue queue, i…
39 extern int test_integer_clamp(cl_device_id deviceID, cl_context context, cl_command_queue queue, in…
40 extern int test_integer_mad_sat(cl_device_id deviceID, cl_context context, cl_command_queue queue, …
41 extern int test_integer_mad_hi(cl_device_id deviceID, cl_context context, cl_command_queue queue, i…
[all …]
|
| /external/OpenCL-CTS/test_conformance/api/ |
| D | procs.h | 23 …single_kernel(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
24 …d_two_kernels(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
25 …ernels_in_one(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
26 …nels_manually(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
27 …kernel_names( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
28 …ls_in_program(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
29 …_enqueue_task(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
30 …setup_cleanup(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
32 extern int test_bool_type(cl_device_id deviceID, cl_context context, cl_command_queue queue,…
33 …rm_extensions(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
[all …]
|
| /external/webrtc/modules/pacing/ |
| D | prioritized_packet_queue_unittest.cc | 43 PrioritizedPacketQueue queue(now); in TEST() local
46 queue.Push(now, CreatePacket(RtpPacketMediaType::kPadding, /*seq=*/1)); in TEST()
47 queue.Push(now, CreatePacket(RtpPacketMediaType::kVideo, /*seq=*/2)); in TEST()
48 queue.Push(now, CreatePacket(RtpPacketMediaType::kForwardErrorCorrection, in TEST()
50 queue.Push(now, CreatePacket(RtpPacketMediaType::kRetransmission, /*seq=*/4)); in TEST()
51 queue.Push(now, CreatePacket(RtpPacketMediaType::kAudio, /*seq=*/5)); in TEST()
54 EXPECT_EQ(queue.Pop()->SequenceNumber(), 5); in TEST()
55 EXPECT_EQ(queue.Pop()->SequenceNumber(), 4); in TEST()
57 EXPECT_EQ(queue.Pop()->SequenceNumber(), 2); in TEST()
58 EXPECT_EQ(queue.Pop()->SequenceNumber(), 3); in TEST()
[all …]
|
| /external/zstd/contrib/pzstd/utils/test/ |
| D | WorkQueueTest.cpp | 23 WorkQueue<int>* queue; member
29 while (queue->pop(result)) { in operator ()()
38 WorkQueue<int> queue; in TEST() local
41 queue.push(5); in TEST()
42 EXPECT_TRUE(queue.pop(result)); in TEST()
45 queue.push(1); in TEST()
46 queue.push(2); in TEST()
47 EXPECT_TRUE(queue.pop(result)); in TEST()
49 EXPECT_TRUE(queue.pop(result)); in TEST()
52 queue.push(1); in TEST()
[all …]
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/common/src/test/java/com/google/android/exoplayer2/util/ |
| D | TimedValueQueueTest.java | 29 private TimedValueQueue<String> queue; field in TimedValueQueueTest
33 queue = new TimedValueQueue<>(); in setUp()
38 queue = new TimedValueQueue<>(1); in bufferCapacityIncreasesAutomatically()
40 queue.add(i, "" + i); in bufferCapacityIncreasesAutomatically()
42 assertThat(queue.pollFirst()).isEqualTo("" + (i / 2)); in bufferCapacityIncreasesAutomatically()
45 assertThat(queue.size()).isEqualTo(10); in bufferCapacityIncreasesAutomatically()
50 queue.add(1, "b"); in timeDiscontinuityClearsValues()
51 queue.add(2, "c"); in timeDiscontinuityClearsValues()
52 queue.add(0, "a"); in timeDiscontinuityClearsValues()
53 assertThat(queue.size()).isEqualTo(1); in timeDiscontinuityClearsValues()
[all …]
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/common/src/test/java/com/google/android/exoplayer2/util/ |
| D | TimedValueQueueTest.java | 29 private TimedValueQueue<String> queue; field in TimedValueQueueTest
33 queue = new TimedValueQueue<>(); in setUp()
38 queue = new TimedValueQueue<>(1); in bufferCapacityIncreasesAutomatically()
40 queue.add(i, "" + i); in bufferCapacityIncreasesAutomatically()
42 assertThat(queue.pollFirst()).isEqualTo("" + (i / 2)); in bufferCapacityIncreasesAutomatically()
45 assertThat(queue.size()).isEqualTo(10); in bufferCapacityIncreasesAutomatically()
50 queue.add(1, "b"); in timeDiscontinuityClearsValues()
51 queue.add(2, "c"); in timeDiscontinuityClearsValues()
52 queue.add(0, "a"); in timeDiscontinuityClearsValues()
53 assertThat(queue.size()).isEqualTo(1); in timeDiscontinuityClearsValues()
[all …]
|
| /external/mesa3d/src/nouveau/vulkan/ |
| D | nvk_upload_queue.c | 67 struct nvk_upload_queue *queue) in nvk_upload_queue_init() argument
71 memset(queue, 0, sizeof(*queue)); in nvk_upload_queue_init()
73 simple_mtx_init(&queue->mutex, mtx_plain); in nvk_upload_queue_init()
76 &queue->drm.ws_ctx); in nvk_upload_queue_init()
85 err = drmSyncobjCreate(dev->ws_dev->fd, 0, &queue->drm.syncobj); in nvk_upload_queue_init()
91 list_inithead(&queue->bos); in nvk_upload_queue_init()
96 simple_mtx_destroy(&queue->mutex); in nvk_upload_queue_init()
98 nouveau_ws_context_destroy(queue->drm.ws_ctx); in nvk_upload_queue_init()
105 struct nvk_upload_queue *queue) in nvk_upload_queue_finish() argument
107 list_for_each_entry_safe(struct nvk_upload_bo, bo, &queue->bos, link) in nvk_upload_queue_finish()
[all …]
|
| /external/OpenCL-CTS/test_conformance/compiler/ |
| D | procs.h | 42 cl_command_queue queue, int num_elements);
45 cl_command_queue queue,
49 cl_command_queue queue,
53 cl_command_queue queue,
57 cl_command_queue queue,
60 cl_device_id deviceID, cl_context context, cl_command_queue queue,
64 cl_command_queue queue,
67 cl_command_queue queue, int num_elements);
70 cl_command_queue queue,
73 cl_command_queue queue, int num_elements);
[all …]
|
| /external/sdv/vsomeip/third_party/boost/thread/include/boost/thread/concurrent_queues/ |
| D | queue_adaptor.hpp | 28 template <typename Queue>
30 public boost::queue_base<typename Queue::value_type, typename Queue::size_type>
32 Queue queue; member in boost::concurrent::detail::queue_adaptor_copyable_only
34 typedef typename Queue::value_type value_type;
35 typedef typename Queue::size_type size_type;
41 bool empty() const { return queue.empty(); } in empty()
42 bool full() const { return queue.full(); } in full()
43 size_type size() const { return queue.size(); } in size()
44 bool closed() const { return queue.closed(); } in closed()
47 void close() { queue.close(); } in close()
[all …]
|
| D | deque_adaptor.hpp | 28 template <typename Queue>
30 public boost::deque_base<typename Queue::value_type, typename Queue::size_type>
32 Queue queue; member in boost::concurrent::detail::deque_adaptor_copyable_only
34 typedef typename Queue::value_type value_type;
35 typedef typename Queue::size_type size_type;
41 bool empty() const { return queue.empty(); } in empty()
42 bool full() const { return queue.full(); } in full()
43 size_type size() const { return queue.size(); } in size()
44 bool closed() const { return queue.closed(); } in closed()
47 void close() { queue.close(); } in close()
[all …]
|
| D | deque_views.hpp | 26 template <typename Queue>
29 Queue* queue; member in boost::concurrent::deque_back_view
31 typedef typename Queue::value_type value_type;
32 typedef typename Queue::size_type size_type;
35 deque_back_view(Queue& q) BOOST_NOEXCEPT : queue(&q) {} in deque_back_view()
38 bool empty() const { return queue->empty(); } in empty()
39 bool full() const { return queue->full(); } in full()
40 size_type size() const { return queue->size(); } in size()
41 bool closed() const { return queue->closed(); } in closed()
44 void close() { queue->close(); } in close()
[all …]
|
| /external/webrtc/test/pc/e2e/analyzer/video/ |
| D | multi_reader_queue_test.cc | 20 MultiReaderQueue<int> queue = MultiReaderQueue<int>(/*readers_count=*/10); in TEST() local
21 EXPECT_EQ(queue.size(), 0lu); in TEST()
23 EXPECT_TRUE(queue.IsEmpty(/*reader=*/i)); in TEST()
24 EXPECT_EQ(queue.size(/*reader=*/i), 0lu); in TEST()
25 EXPECT_FALSE(queue.PopFront(/*reader=*/i).has_value()); in TEST()
26 EXPECT_FALSE(queue.Front(/*reader=*/i).has_value()); in TEST()
31 MultiReaderQueue<int> queue = MultiReaderQueue<int>(/*readers_count=*/10); in TEST() local
32 queue.PushBack(1); in TEST()
33 queue.PushBack(2); in TEST()
34 queue.PushBack(3); in TEST()
[all …]
|
| /external/OpenCL-CTS/test_conformance/pipes/ |
| D | procs.h | 30 …eadwrite_int( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
31 …adwrite_uint( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
32 …adwrite_long( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
33 …dwrite_ulong( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
34 …dwrite_short( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
35 …write_ushort( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
36 …dwrite_float( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
37 …adwrite_half( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
38 …adwrite_char( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
39 …dwrite_uchar( cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements …
[all …]
|
| /external/perfetto/src/base/ |
| D | circular_queue_unittest.cc | 28 CircularQueue<int> queue(/*initial_capacity=*/1); in TEST() local
29 ASSERT_EQ(queue.size(), 0u); in TEST()
30 queue.emplace_back(101); in TEST()
31 ASSERT_EQ(queue.size(), 1u); in TEST()
32 queue.emplace_back(102); in TEST()
33 queue.emplace_back(103); in TEST()
34 queue.emplace_back(104); in TEST()
35 ASSERT_EQ(queue.size(), 4u); in TEST()
37 auto it = queue.begin(); in TEST()
42 ASSERT_EQ(it, queue.end()); in TEST()
[all …]
|
| /external/python/cpython2/Doc/library/ |
| D | queue.rst | 1 :mod:`Queue` --- A synchronized queue class
4 .. module:: Queue
5 :synopsis: A synchronized queue class.
8 The :mod:`Queue` module has been renamed to :mod:`queue` in Python 3. The
12 **Source code:** :source:`Lib/Queue.py`
16 The :mod:`Queue` module implements multi-producer, multi-consumer queues.
18 exchanged safely between multiple threads. The :class:`~Queue.Queue` class in this
23 The module implements three types of queue, which differ only in the order in
24 which the entries are retrieved. In a FIFO queue, the first tasks added are
25 the first retrieved. In a LIFO queue, the most recently added entry is
[all …]
|
| /external/OpenCL-CTS/test_conformance/extensions/cl_khr_command_buffer/ |
| D | procs.h | 23 cl_command_queue queue, int num_elements);
25 cl_command_queue queue, int num_elements);
27 cl_command_queue queue, int num_elements);
29 cl_command_queue queue, int num_elements);
31 cl_command_queue queue, int num_elements);
33 cl_command_queue queue, int num_elements);
35 cl_command_queue queue, int num_elements);
37 cl_command_queue queue, int num_elements);
39 cl_command_queue queue, int num_elements);
41 cl_command_queue queue, int num_elements);
[all …]
|