| /external/OpenCL-CTS/test_conformance/basic/ |
| D | procs.h | 25 extern int test_hostptr(cl_device_id deviceID, cl_context context, cl_command_queue queue, int…
26 extern int test_fpmath_float(cl_device_id deviceID, cl_context context, cl_command_queue queue…
27 …fpmath_float2(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
28 …fpmath_float4(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
29 extern int test_intmath_int(cl_device_id deviceID, cl_context context, cl_command_queue queue,…
30 extern int test_intmath_int2(cl_device_id deviceID, cl_context context, cl_command_queue queue…
31 extern int test_intmath_int4(cl_device_id deviceID, cl_context context, cl_command_queue queue…
32 extern int test_intmath_long(cl_device_id deviceID, cl_context context, cl_command_queue queue…
33 …intmath_long2(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
34 …intmath_long4(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements);
[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/mesa3d/src/util/ |
| D | u_queue.c | 47 util_queue_kill_threads(struct util_queue *queue, unsigned keep_num_threads,
82 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list() argument
87 list_add(&queue->head, &queue_list); in add_to_atexit_list()
92 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list() argument
98 if (iter == queue) { in remove_from_atexit_list()
246 struct util_queue *queue; member
253 struct util_queue *queue = ((struct thread_input*)input)->queue; in util_queue_thread_func() local
258 if (queue->flags & UTIL_QUEUE_INIT_SET_FULL_THREAD_AFFINITY) { in util_queue_thread_func()
269 if (queue->flags & UTIL_QUEUE_INIT_USE_MINIMUM_PRIORITY) { in util_queue_thread_func()
275 if (strlen(queue->name) > 0) { in util_queue_thread_func()
[all …]
|
| /external/rust/crates/tokio-util/tests/ |
| D | time_delay_queue.rs | 10 ($queue:ident) => {
11 $queue.enter(|cx, mut queue| queue.poll_expired(cx))
28 let mut queue = task::spawn(DelayQueue::new()); in single_immediate_delay() localVariable
29 let _key = queue.insert_at("foo", Instant::now()); in single_immediate_delay()
34 assert_ready_some!(poll!(queue)); in single_immediate_delay()
36 let entry = assert_ready!(poll!(queue)); in single_immediate_delay()
44 let mut queue = task::spawn(DelayQueue::new()); in multi_immediate_delays() localVariable
46 let _k = queue.insert_at("1", Instant::now()); in multi_immediate_delays()
47 let _k = queue.insert_at("2", Instant::now()); in multi_immediate_delays()
48 let _k = queue.insert_at("3", Instant::now()); in multi_immediate_delays()
[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/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 | 33 extern int test_popcount(cl_device_id device, cl_context context, cl_command_queue queue, int num_e…
34 extern int test_integer_clz(cl_device_id deviceID, cl_context context, cl_command_queue queue, int …
35 extern int test_integer_ctz(cl_device_id deviceID, cl_context context, cl_command_queue queue, int …
36 extern int test_integer_hadd(cl_device_id deviceID, cl_context context, cl_command_queue queue, int…
37 extern int test_integer_rhadd(cl_device_id deviceID, cl_context context, cl_command_queue queue, in…
38 extern int test_integer_mul_hi(cl_device_id deviceID, cl_context context, cl_command_queue queue, i…
39 extern int test_integer_rotate(cl_device_id deviceID, cl_context context, cl_command_queue queue, i…
40 extern int test_integer_clamp(cl_device_id deviceID, cl_context context, cl_command_queue queue, in…
41 extern int test_integer_mad_sat(cl_device_id deviceID, cl_context context, cl_command_queue queue, …
42 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_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/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/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/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/squashfs-tools/squashfs-tools/ |
| D | caches-queues-lists.c | 39 struct queue *queue_init(int size) in queue_init()
41 struct queue *queue = malloc(sizeof(struct queue)); in queue_init() local
43 if(queue == NULL) in queue_init()
50 queue->data = malloc(sizeof(void *) * (size + 1)); in queue_init()
51 if(queue->data == NULL) in queue_init()
54 queue->size = size + 1; in queue_init()
55 queue->readp = queue->writep = 0; in queue_init()
56 pthread_mutex_init(&queue->mutex, NULL); in queue_init()
57 pthread_cond_init(&queue->empty, NULL); in queue_init()
58 pthread_cond_init(&queue->full, NULL); in queue_init()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | swap_queue_unittest.cc | 25 // Queue item verification function for the vector test.
30 // Queue item verifier for the vector test.
47 SwapQueue<std::vector<int>> queue(2, i); in TEST() local
49 EXPECT_TRUE(queue.Insert(&i)); in TEST()
51 EXPECT_TRUE(queue.Insert(&i)); in TEST()
53 EXPECT_TRUE(queue.Remove(&i)); in TEST()
55 EXPECT_TRUE(queue.Remove(&i)); in TEST()
60 SwapQueue<int> queue(2); in TEST() local
62 // Fill the queue. in TEST()
64 EXPECT_TRUE(queue.Insert(&i)); in TEST()
[all …]
|
| /external/virglrenderer/src/venus/ |
| D | vkr_queue.c | 79 vkr_queue_get_signaled_syncs(struct vkr_queue *queue, in vkr_queue_get_signaled_syncs() argument
83 struct vkr_device *dev = queue->device; in vkr_queue_get_signaled_syncs()
92 mtx_lock(&queue->mutex); in vkr_queue_get_signaled_syncs()
94 LIST_FOR_EACH_ENTRY_SAFE (sync, tmp, &queue->signaled_syncs, head) { in vkr_queue_get_signaled_syncs()
95 if (sync->head.next == &queue->signaled_syncs || in vkr_queue_get_signaled_syncs()
101 list_inithead(&queue->signaled_syncs); in vkr_queue_get_signaled_syncs()
103 *queue_empty = LIST_IS_EMPTY(&queue->pending_syncs); in vkr_queue_get_signaled_syncs()
105 mtx_unlock(&queue->mutex); in vkr_queue_get_signaled_syncs()
107 LIST_FOR_EACH_ENTRY_SAFE (sync, tmp, &queue->pending_syncs, head) { in vkr_queue_get_signaled_syncs()
114 bool is_last_sync = sync->head.next == &queue->pending_syncs; in vkr_queue_get_signaled_syncs()
[all …]
|
| /external/python/cpython3/Doc/library/ |
| D | queue.rst | 1 :mod:`queue` --- A synchronized queue class
4 .. module:: queue
5 :synopsis: A synchronized queue class.
7 **Source code:** :source:`Lib/queue.py`
11 The :mod:`queue` module implements multi-producer, multi-consumer queues.
13 exchanged safely between multiple threads. The :class:`Queue` class in this
16 The module implements three types of queue, which differ only in the order in
18 queue, the first tasks added are the first retrieved. In a
19 :abbr:`LIFO (last-in, first-out)` queue, the most recently added entry is
20 the first retrieved (operating like a stack). With a priority queue,
[all …]
|
| D | asyncio-queue.rst | 14 :mod:`queue` module. Although asyncio queues are not thread-safe,
18 use :func:`asyncio.wait_for` function to do queue operations with a
23 Queue chapter
26 .. class:: Queue(maxsize=0)
28 A first in, first out (FIFO) queue.
30 If *maxsize* is less than or equal to zero, the queue size is
32 ``await put()`` blocks when the queue reaches *maxsize*
35 Unlike the standard library threading :mod:`queue`, the size of
36 the queue is always known and can be returned by calling the
47 Number of items allowed in the queue.
[all …]
|
| /external/libnl/lib/netfilter/ |
| D | queue_obj.c | 8 * @defgroup queue Queue
15 #include <netlink/netfilter/queue.h>
27 struct nfnl_queue *queue = (struct nfnl_queue *) a; in nfnl_queue_dump() local
32 if (queue->ce_mask & QUEUE_ATTR_GROUP) in nfnl_queue_dump()
33 nl_dump(p, "group=%u ", queue->queue_group); in nfnl_queue_dump()
35 if (queue->ce_mask & QUEUE_ATTR_MAXLEN) in nfnl_queue_dump()
36 nl_dump(p, "maxlen=%u ", queue->queue_maxlen); in nfnl_queue_dump()
38 if (queue->ce_mask & QUEUE_ATTR_COPY_MODE) in nfnl_queue_dump()
40 nfnl_queue_copy_mode2str(queue->queue_copy_mode, in nfnl_queue_dump()
43 if (queue->ce_mask & QUEUE_ATTR_COPY_RANGE) in nfnl_queue_dump()
[all …]
|
| /external/mesa3d/src/gallium/drivers/llvmpipe/ |
| D | lp_scene_queue.c | 30 * Scene queue. We'll use two queues. One contains "full" scenes which
47 * A queue of scenes
57 * to index the array, we use them modulo the queue size. This scheme
58 * works because the queue size is a power of two.
66 /** Allocate a new scene queue */
70 /* Circular queue behavior depends on size being a power of two. */ in lp_scene_queue_create()
74 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); in lp_scene_queue_create() local
76 if (!queue) in lp_scene_queue_create()
79 (void) mtx_init(&queue->mutex, mtx_plain); in lp_scene_queue_create()
80 cnd_init(&queue->change); in lp_scene_queue_create()
[all …]
|