Home
last modified time | relevance | path

Searched full:queue (Results 1 – 25 of 19524) sorted by relevance

12345678910>>...781

/aosp_15_r20/packages/modules/Bluetooth/system/osi/test/
Dfixed_queue_test.cc37 // Function for performing dequeue operations from the queue when is ready
38 static void fixed_queue_ready(fixed_queue_t* queue, void* /* context */) { in fixed_queue_ready() argument
39 void* msg = fixed_queue_try_dequeue(queue); in fixed_queue_ready()
53 fixed_queue_t* queue; in TEST_F() local
55 // Test a corner case: queue of size 0 in TEST_F()
56 queue = fixed_queue_new(0); in TEST_F()
57 EXPECT_TRUE(queue != NULL); in TEST_F()
58 fixed_queue_free(queue, NULL); in TEST_F()
60 // Test a corner case: queue of size 1 in TEST_F()
61 queue = fixed_queue_new(1); in TEST_F()
[all …]
/aosp_15_r20/external/pigweed/pw_containers/
H A Dinline_queue_test.cc35 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 …]
/aosp_15_r20/external/rust/android-crates-io/crates/tokio-util/tests/
Dtime_delay_queue.rs11 ($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 …]
/aosp_15_r20/external/mesa3d/src/util/
H A Du_queue.c48 util_queue_kill_threads(struct util_queue *queue, unsigned keep_num_threads,
86 add_to_atexit_list(struct util_queue *queue) in add_to_atexit_list() argument
91 list_add(&queue->head, &queue_list); in add_to_atexit_list()
96 remove_from_atexit_list(struct util_queue *queue) in remove_from_atexit_list() argument
102 if (iter == queue) { in remove_from_atexit_list()
230 struct util_queue *queue; member
237 struct util_queue *queue = ((struct thread_input*)input)->queue; in util_queue_thread_func() local
242 if (queue->flags & UTIL_QUEUE_INIT_SET_FULL_THREAD_AFFINITY) { in util_queue_thread_func()
255 if (queue->flags & UTIL_QUEUE_INIT_USE_MINIMUM_PRIORITY) { in util_queue_thread_func()
261 if (strlen(queue->name) > 0) { in util_queue_thread_func()
[all …]
/aosp_15_r20/external/OpenCL-CTS/test_conformance/basic/
H A Dprocs.h24 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 …]
/aosp_15_r20/packages/modules/Bluetooth/system/osi/src/
Dfixed_queue.cc76 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free() argument
77 if (!queue) { in fixed_queue_free()
81 fixed_queue_unregister_dequeue(queue); in fixed_queue_free()
84 for (const list_node_t* node = list_begin(queue->list); node != list_end(queue->list); in fixed_queue_free()
90 list_free(queue->list); in fixed_queue_free()
91 semaphore_free(queue->enqueue_sem); in fixed_queue_free()
92 semaphore_free(queue->dequeue_sem); in fixed_queue_free()
93 delete queue->mutex; in fixed_queue_free()
94 osi_free(queue); in fixed_queue_free()
97 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush() argument
[all …]
/aosp_15_r20/external/webrtc/modules/pacing/
H A Dprioritized_packet_queue_unittest.cc43 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 …]
/aosp_15_r20/external/python/google-api-python-client/docs/dyn/
Dcloudtasks_v2beta3.projects.locations.queues.html87 …queue. Queues created with this method allow tasks to live for a maximum of 31 days. After a task …
90 …queue. This command will delete the queue even if it has tasks in it. Note: If you delete a queue,…
93 <p class="firstline">Gets a queue.</p>
96 <p class="firstline">Gets the access control policy for a Queue. Returns an empty policy if the res…
105 …queue. This method creates the queue if it does not exist and updates the queue if it does exist. …
108 …queue. If a queue is paused then the system will stop dispatching tasks until the queue is resumed…
111 <p class="firstline">Purges a queue by deleting all of its tasks. All tasks created before this met…
114 …rstline">Resume a queue. This method resumes a queue after it has been PAUSED or DISABLED. The sta…
117 …ets the access control policy for a Queue. Replaces any existing policy. Note: The Cloud Console d…
120 <p class="firstline">Returns permissions that a caller has on a Queue. If the resource does not exi…
[all …]
Dcloudtasks_v2beta2.projects.locations.queues.html87 …queue. Queues created with this method allow tasks to live for a maximum of 31 days. After a task …
90 …queue. This command will delete the queue even if it has tasks in it. Note: If you delete a queue,…
93 <p class="firstline">Gets a queue.</p>
96 <p class="firstline">Gets the access control policy for a Queue. Returns an empty policy if the res…
105 …queue. This method creates the queue if it does not exist and updates the queue if it does exist. …
108 …queue. If a queue is paused then the system will stop dispatching tasks until the queue is resumed…
111 <p class="firstline">Purges a queue by deleting all of its tasks. All tasks created before this met…
114 …rstline">Resume a queue. This method resumes a queue after it has been PAUSED or DISABLED. The sta…
117 …ets the access control policy for a Queue. Replaces any existing policy. Note: The Cloud Console d…
120 <p class="firstline">Returns permissions that a caller has on a Queue. If the resource does not exi…
[all …]
/aosp_15_r20/external/mesa3d/src/vulkan/runtime/
H A Dvk_queue.c48 vk_queue_start_submit_thread(struct vk_queue *queue);
51 vk_queue_init(struct vk_queue *queue, struct vk_device *device, in vk_queue_init() argument
58 memset(queue, 0, sizeof(*queue)); in vk_queue_init()
59 vk_object_base_init(device, &queue->base, VK_OBJECT_TYPE_QUEUE); in vk_queue_init()
61 list_addtail(&queue->link, &device->queues); in vk_queue_init()
63 queue->flags = pCreateInfo->flags; in vk_queue_init()
64 queue->queue_family_index = pCreateInfo->queueFamilyIndex; in vk_queue_init()
67 queue->index_in_family = index_in_family; in vk_queue_init()
69 queue->submit.mode = device->submit_mode; in vk_queue_init()
70 if (queue->submit.mode == VK_QUEUE_SUBMIT_MODE_THREADED_ON_DEMAND) in vk_queue_init()
[all …]
/aosp_15_r20/external/OpenCL-CTS/test_conformance/api/
H A Dprocs.h23 …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 …]
/aosp_15_r20/external/OpenCL-CTS/test_conformance/integer_ops/
H A Dprocs.h32 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 …]
/aosp_15_r20/external/OpenCL-CTS/test_conformance/buffers/
H A Dprocs.h34 …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 …]
/aosp_15_r20/external/mesa3d/src/amd/vulkan/
H A Dradv_queue.c223 radv_queue_submit_empty(struct radv_queue *queue, struct vk_queue_submit *submission) in radv_queue_submit_empty() argument
225 struct radv_device *device = radv_queue_device(queue); in radv_queue_submit_empty()
226 struct radeon_winsys_ctx *ctx = queue->hw_ctx; in radv_queue_submit_empty()
228 .ip_type = radv_queue_ring(queue), in radv_queue_submit_empty()
229 .queue_index = queue->vk.index_in_family, in radv_queue_submit_empty()
921 radv_update_preamble_cs(struct radv_queue_state *queue, struct radv_device *device, in radv_update_preamble_cs() argument
926 struct radeon_winsys_bo *scratch_bo = queue->scratch_bo; in radv_update_preamble_cs()
927 struct radeon_winsys_bo *descriptor_bo = queue->descriptor_bo; in radv_update_preamble_cs()
928 struct radeon_winsys_bo *compute_scratch_bo = queue->compute_scratch_bo; in radv_update_preamble_cs()
929 struct radeon_winsys_bo *esgs_ring_bo = queue->esgs_ring_bo; in radv_update_preamble_cs()
[all …]
/aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/collect/
H A DEvictingQueueTest.java47 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
48 assertEquals(0, queue.size()); in testCreateWithZeroSize()
50 assertTrue(queue.add("hi")); in testCreateWithZeroSize()
51 assertEquals(0, queue.size()); in testCreateWithZeroSize()
53 assertTrue(queue.offer("hi")); in testCreateWithZeroSize()
54 assertEquals(0, queue.size()); in testCreateWithZeroSize()
56 assertFalse(queue.remove("hi")); in testCreateWithZeroSize()
57 assertEquals(0, queue.size()); in testCreateWithZeroSize()
60 queue.element(); in testCreateWithZeroSize()
65 assertNull(queue.peek()); in testCreateWithZeroSize()
[all …]
/aosp_15_r20/external/guava/guava-tests/test/com/google/common/collect/
H A DEvictingQueueTest.java47 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local
48 assertEquals(0, queue.size()); in testCreateWithZeroSize()
50 assertTrue(queue.add("hi")); in testCreateWithZeroSize()
51 assertEquals(0, queue.size()); in testCreateWithZeroSize()
53 assertTrue(queue.offer("hi")); in testCreateWithZeroSize()
54 assertEquals(0, queue.size()); in testCreateWithZeroSize()
56 assertFalse(queue.remove("hi")); in testCreateWithZeroSize()
57 assertEquals(0, queue.size()); in testCreateWithZeroSize()
60 queue.element(); in testCreateWithZeroSize()
65 assertNull(queue.peek()); in testCreateWithZeroSize()
[all …]
/aosp_15_r20/external/webrtc/net/dcsctp/tx/
H A Dretransmission_queue_test.cc83 std::vector<TSN> GetTSNsForFastRetransmit(RetransmissionQueue& queue) { in GetTSNsForFastRetransmit() argument
85 for (const auto& elem : queue.GetChunksForFastRetransmit(10000)) { in GetTSNsForFastRetransmit()
91 std::vector<TSN> GetSentPacketTSNs(RetransmissionQueue& queue) { in GetSentPacketTSNs() argument
93 for (const auto& elem : queue.GetChunksToSend(now_, 10000)) { in GetSentPacketTSNs()
108 RetransmissionQueue& queue) { in CreateQueueByHandover() argument
109 EXPECT_EQ(queue.GetHandoverReadiness(), HandoverReadinessStatus()); in CreateQueueByHandover()
111 queue.AddHandoverState(state); in CreateQueueByHandover()
135 RetransmissionQueue queue = CreateQueue(); in TEST_F() local
136 EXPECT_THAT(queue.GetChunkStatesForTesting(), in TEST_F()
141 RetransmissionQueue queue = CreateQueue(); in TEST_F() local
[all …]
/aosp_15_r20/frameworks/base/services/core/java/com/android/server/am/
H A DBroadcastQueueModernImpl.java120 * Each process now has its own broadcast queue represented by a
121 * {@link BroadcastProcessQueue} instance. Each queue has a concept of being
129 * <li>{@link #updateRunnableList} promotes a per-process queue to be runnable
131 * <li>{@link #updateRunningList} promotes a runnable queue to be running and
198 * Single queue which is "running" but is awaiting a cold start to be
398 * relation to the given queue.
402 * "runnable" queue to be "running."
405 private void updateRunnableList(@NonNull BroadcastProcessQueue queue) { in updateRunnableList() argument
406 if (getRunningIndexOf(queue) >= 0) { in updateRunnableList()
415 queue.updateDeferredStates(mBroadcastConsumerDeferApply, mBroadcastConsumerDeferClear); in updateRunnableList()
[all …]
/aosp_15_r20/external/sdv/vsomeip/third_party/boost/numeric/ublas/include/boost/numeric/ublas/opencl/
Delementwise.hpp26 O op, compute::command_queue& queue) in element_wise() argument
30 a.device() == queue.get_device()); in element_wise()
38 queue); in element_wise()
39 queue.finish(); in element_wise()
47 compute::command_queue &queue) in element_wise() argument
49 ublas::matrix<T, L1, opencl::storage> adev(a, queue); in element_wise()
50 ublas::matrix<T, L2, opencl::storage> bdev(b, queue); in element_wise()
51 ublas::matrix<T, L3, opencl::storage> rdev(a.size1(), b.size2(), queue.get_context()); in element_wise()
52 element_wise(adev, bdev, rdev, op, queue); in element_wise()
53 rdev.to_host(result, queue); in element_wise()
[all …]
/aosp_15_r20/external/google-cloud-java/java-tasks/proto-google-cloud-tasks-v2/src/main/java/com/google/cloud/tasks/v2/
H A DQueue.java17 // source: google/cloud/tasks/v2/queue.proto
25 * A queue is a container of related tasks. Queues are configured to manage
27 * retry options, queue types, and others.
30 * Protobuf type {@code google.cloud.tasks.v2.Queue}
32 public final class Queue extends com.google.protobuf.GeneratedMessageV3 class
34 // @@protoc_insertion_point(message_implements:google.cloud.tasks.v2.Queue)
37 // Use Queue.newBuilder() to construct.
38 private Queue(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in Queue() method in Queue
42 private Queue() { in Queue() method in Queue
50 return new Queue(); in newInstance()
[all …]
/aosp_15_r20/external/mesa3d/src/nouveau/vulkan/
H A Dnvk_upload_queue.c63 struct nvk_upload_queue *queue) in nvk_upload_queue_init() argument
68 memset(queue, 0, sizeof(*queue)); in nvk_upload_queue_init()
70 simple_mtx_init(&queue->mutex, mtx_plain); in nvk_upload_queue_init()
73 NVKMD_ENGINE_COPY, &queue->ctx); in nvk_upload_queue_init()
81 0, &queue->sync); in nvk_upload_queue_init()
85 list_inithead(&queue->recycle); in nvk_upload_queue_init()
90 nvkmd_ctx_destroy(queue->ctx); in nvk_upload_queue_init()
92 simple_mtx_destroy(&queue->mutex); in nvk_upload_queue_init()
99 struct nvk_upload_queue *queue) in nvk_upload_queue_finish() argument
101 list_for_each_entry_safe(struct nvk_upload_mem, mem, &queue->recycle, link) in nvk_upload_queue_finish()
[all …]
/aosp_15_r20/packages/modules/Bluetooth/system/common/
Dleaky_bonded_queue_unittest.cc54 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(3); in TEST() local
55 EXPECT_EQ(queue->Capacity(), static_cast<size_t>(3)); in TEST()
56 EXPECT_EQ(queue->Length(), static_cast<size_t>(0)); in TEST()
57 queue->Enqueue(item1); in TEST()
58 EXPECT_EQ(queue->Length(), static_cast<size_t>(1)); in TEST()
59 queue->Enqueue(item2); in TEST()
60 EXPECT_EQ(queue->Length(), static_cast<size_t>(2)); in TEST()
61 queue->Enqueue(item3); in TEST()
62 EXPECT_EQ(queue->Length(), static_cast<size_t>(3)); in TEST()
64 queue->Enqueue(item4); in TEST()
[all …]
/aosp_15_r20/external/cronet/base/task/sequence_manager/
H A Dsequence_manager_impl_unittest.cc612 auto queue = CreateTaskQueue(); in TEST_P() local
614 queue->task_runner()->PostTask( in TEST_P()
616 EXPECT_EQ(queue->task_runner(), in TEST_P()
707 auto queue = CreateTaskQueue(); in TEST_P() local
710 queue->task_runner()->PostTask(FROM_HERE, BindOnce(&TestTask, 1, &run_order)); in TEST_P()
711 queue->task_runner()->PostTask(FROM_HERE, BindOnce(&TestTask, 2, &run_order)); in TEST_P()
712 queue->task_runner()->PostTask(FROM_HERE, BindOnce(&TestTask, 3, &run_order)); in TEST_P()
740 auto queue = CreateTaskQueue(); in TEST_P() local
743 queue->task_runner()->PostNonNestableTask(FROM_HERE, in TEST_P()
751 auto queue = CreateTaskQueue(); in TEST_P() local
[all …]
/aosp_15_r20/packages/modules/Bluetooth/system/test/mock/
Dmock_osi_fixed_queue.h42 // Params: fixed_queue_t* queue
46 std::function<size_t(fixed_queue_t* queue)> body{
47 [this](fixed_queue_t* /* queue */) { return return_value; }};
48 size_t operator()(fixed_queue_t* queue) { return body(queue); } in operator()
53 // Params: fixed_queue_t* queue
57 std::function<void*(fixed_queue_t* queue)> body{
58 [this](fixed_queue_t* /* queue */) { return return_value; }};
59 void* operator()(fixed_queue_t* queue) { return body(queue); } in operator()
64 // Params: fixed_queue_t* queue, void* data
67 std::function<void(fixed_queue_t* queue, void* data)> body{
[all …]
/aosp_15_r20/external/zstd/contrib/pzstd/utils/test/
H A DWorkQueueTest.cpp23 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 …]

12345678910>>...781