| /aosp_15_r20/external/wayland/tests/ |
| H A D | queue-test.c | 115 struct wl_event_queue *queue; in client_test_multiple_queues() local
164 struct wl_event_queue *queue; in client_test_queue_roundtrip() local
215 struct wl_event_queue *queue; in client_test_queue_proxy_wrapper() local
265 struct wl_event_queue *queue; in client_test_queue_set_queue_race() local
355 struct wl_event_queue *queue; in client_test_queue_destroy_with_attached_proxies() local
401 struct wl_event_queue *queue; in client_test_queue_proxy_event_to_destroyed_queue() local
|
| /aosp_15_r20/external/deqp/external/vulkancts/modules/vulkan/api/ |
| H A D | vktApiCommandBuffersTests.cpp | 491 bool executeCommandBuffer(const VkDevice device, const DeviceInterface &vk, const VkQueue queue, in executeCommandBuffer()
516 const VkQueue queue = context.getUniversalQueue(); in resetPoolReuseTest() local
716 const VkQueue queue = context.getUniversalQueue(); in executePrimaryBufferTest() local
768 const VkQueue queue = context.getUniversalQueue(); in executeLargePrimaryBufferTest() local
834 const VkQueue queue = context.getUniversalQueue(); in resetBufferImplicitlyTest() local
912 const VkQueue queue = context.getUniversalQueue(); in submitAndCheck() local
1130 const VkQueue queue = context.getUniversalQueue(); in recordLargePrimaryBufferTest() local
1245 const VkQueue queue = context.getUniversalQueue(); in recordLargeSecondaryBufferTest() local
1341 const VkQueue queue = context.getUniversalQueue(); in submitPrimaryBufferTwiceTest() local
1403 const VkQueue queue = context.getUniversalQueue(); in submitSecondaryBufferTwiceTest() local
[all …]
|
| /aosp_15_r20/frameworks/base/services/core/java/com/android/server/am/ |
| H A D | BroadcastProcessQueue.java | 372 final ArrayDeque<SomeArgs> queue = getQueueForBroadcast(record); in replaceBroadcast() local
386 private BroadcastRecord replaceBroadcastInQueue(@NonNull ArrayDeque<SomeArgs> queue, in replaceBroadcastInQueue()
472 private boolean forEachMatchingBroadcastInQueue(@NonNull ArrayDeque<SomeArgs> queue, in forEachMatchingBroadcastInQueue()
858 final ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in removeNextBroadcast() local
913 private static boolean isQueueEmpty(@Nullable ArrayDeque<SomeArgs> queue) { in isQueueEmpty()
968 ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in peekNextBroadcast() local
974 ArrayDeque<SomeArgs> queue = queueForNextBroadcast(); in peekNextBroadcastRecord() local
1060 private boolean isDispatchedInQueue(@NonNull ArrayDeque<SomeArgs> queue, in isDispatchedInQueue()
1367 private void assertHealthLocked(@NonNull ArrayDeque<SomeArgs> queue) { in assertHealthLocked()
|
| /aosp_15_r20/external/mesa3d/src/util/ |
| H A D | u_vector.h | 57 u_vector_init(struct u_vector *queue, in u_vector_init()
67 u_vector_length(struct u_vector *queue) in u_vector_length()
88 u_vector_finish(struct u_vector *queue) in u_vector_finish()
99 #define u_vector_foreach(elem, queue) \ argument
|
| /aosp_15_r20/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| H A D | WriteQueueTest.java | 116 WriteQueue queue = new WriteQueue(channel); in singleWriteShouldWork() local
125 WriteQueue queue = new WriteQueue(channel); in multipleWritesShouldBeBatched() local
137 WriteQueue queue = new WriteQueue(channel); in maxWritesBeforeFlushShouldBeEnforced() local
150 final WriteQueue queue = new WriteQueue(channel); in concurrentWriteAndFlush() local
|
| /aosp_15_r20/external/mesa3d/src/gallium/drivers/svga/ |
| H A D | svga_state_tss.c | 64 struct bind_queue *queue) in emit_tex_binding_unit()
132 struct bind_queue queue; in update_tss_binding() local
223 struct bind_queue queue; in svga_reemit_tss_bindings() local
341 struct ts_queue *queue) in emit_tss_unit()
370 struct ts_queue queue; in update_tss() local
|
| /aosp_15_r20/external/mesa3d/src/intel/vulkan/xe/ |
| H A D | anv_batch_chain.c | 54 xe_exec_process_syncs(struct anv_queue *queue, in xe_exec_process_syncs()
120 xe_exec_print_debug(struct anv_queue *queue, uint32_t cmd_buffer_count, in xe_exec_print_debug()
139 struct anv_queue *queue = submit->queue; in xe_queue_exec_async() local
203 xe_companion_rcs_queue_exec_locked(struct anv_queue *queue, in xe_companion_rcs_queue_exec_locked()
252 xe_queue_exec_locked(struct anv_queue *queue, in xe_queue_exec_locked()
|
| /aosp_15_r20/external/OpenCL-CTS/test_conformance/extensions/cl_khr_command_buffer/ |
| H A D | basic_command_buffer.cpp | 27 cl_command_queue queue) in BasicCommandBufferTest()
425 cl_command_queue queue, int num_elements) in test_single_ndrange()
432 cl_command_queue queue, int num_elements) in test_interleaved_enqueue()
439 cl_command_queue queue, int num_elements) in test_mixed_commands()
446 cl_command_queue queue, int num_elements) in test_explicit_flush()
|
| H A D | command_buffer_get_command_buffer_info.cpp | 378 cl_command_queue queue, int num_elements) in test_info_queues()
386 cl_command_queue queue, int num_elements) in test_info_ref_count()
394 cl_command_queue queue, int num_elements) in test_info_state()
402 cl_command_queue queue, int num_elements) in test_info_prop_array()
410 cl_command_queue queue, int num_elements) in test_info_context()
|
| /aosp_15_r20/external/sdv/vsomeip/third_party/boost/numeric/ublas/include/boost/numeric/ublas/opencl/ |
| D | vector.hpp | 37 vector(size_type size, T value, compute::command_queue queue) in vector()
45 vector(vector<T, A> const &v, compute::command_queue &queue) in vector()
56 void from_host(ublas::vector<T, A> const &v, compute::command_queue & queue) in from_host()
77 void fill(T value, compute::command_queue & queue) in fill()
|
| /aosp_15_r20/external/mesa3d/src/asahi/vulkan/ |
| H A D | hk_queue.c | 35 queue_submit_empty(struct hk_device *dev, struct hk_queue *queue, in queue_submit_empty()
390 queue_submit(struct hk_device *dev, struct hk_queue *queue, in queue_submit()
536 struct hk_queue *queue = container_of(vk_queue, struct hk_queue, vk); in hk_queue_submit() local
550 hk_queue_init(struct hk_device *dev, struct hk_queue *queue, in hk_queue_init()
603 hk_queue_finish(struct hk_device *dev, struct hk_queue *queue) in hk_queue_finish()
|
| /aosp_15_r20/development/samples/browseable/MediaBrowserService/src/com.example.android.mediabrowserservice/utils/ |
| H A D | QueueHelper.java | 79 public static int getMusicIndexOnQueue(Iterable<MediaSession.QueueItem> queue, in getMusicIndexOnQueue()
91 public static int getMusicIndexOnQueue(Iterable<MediaSession.QueueItem> queue, in getMusicIndexOnQueue()
105 List<MediaSession.QueueItem> queue = new ArrayList<>(); in convertToQueue() local
146 public static boolean isIndexPlayable(int index, List<MediaSession.QueueItem> queue) { in isIndexPlayable()
|
| /aosp_15_r20/external/deqp/external/vulkancts/modules/vulkan/renderpass/ |
| H A D | vktDynamicRenderingTests.cpp | 542 void submitCommandsAndWait(const DeviceInterface &vk, const VkDevice device, const VkQueue queue, in submitCommandsAndWait()
908 const VkQueue queue = m_context.getUniversalQueue(); in rendering() local
1282 const VkQueue queue = m_context.getUniversalQueue(); in rendering() local
1398 const VkQueue queue = m_context.getUniversalQueue(); in rendering() local
1538 const VkQueue queue = m_context.getUniversalQueue(); in rendering() local
1683 const VkQueue queue = m_context.getUniversalQueue(); in rendering() local
1838 const VkQueue queue = m_context.getUniversalQueue(); in rendering() local
1958 const VkQueue queue = m_context.getUniversalQueue(); in rendering() local
2095 const VkQueue queue = m_context.getUniversalQueue(); in rendering() local
2258 const VkQueue queue = m_context.getUniversalQueue(); in rendering() local
[all …]
|
| /aosp_15_r20/cts/tests/tests/telephony/current/LocationAccessingApp/src/android/telephony/cts/locationaccessingapp/ |
| H A D | CtsLocationAccessService.java | 103 LinkedBlockingQueue<List<CellInfo>> queue = new LinkedBlockingQueue<>(); in listenForCellInfo() local
127 LinkedBlockingQueue<CellLocation> queue = new LinkedBlockingQueue<>(); in listenForCellLocation() local
151 LinkedBlockingQueue<ServiceState> queue = new LinkedBlockingQueue<>(); in listenForServiceState() local
179 LinkedBlockingQueue<List<CellInfo>> queue = new LinkedBlockingQueue<>(); in requestCellInfoUpdate() local
|
| /aosp_15_r20/frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/notification/headsup/ |
| H A D | AvalancheController.kt | 445 val queue = ArrayList<String>() constant
454 val queue = ArrayList<String>() constant
463 val queue = ArrayList<String>() constant
|
| /aosp_15_r20/external/libgav1/src/utils/ |
| H A D | unbounded_queue_test.cc | 49 UnboundedQueue<int> queue; in TEST() local
68 UnboundedQueue<int> queue; in TEST() local
83 UnboundedQueue<int> queue; in TEST() local
88 UnboundedQueue<Integer> queue; in TEST() local
|
| /aosp_15_r20/external/deqp/external/vulkancts/modules/vulkan/dynamic_state/ |
| H A D | vktDynamicStateDiscardTests.cpp | 300 const vk::VkQueue queue = m_context.getUniversalQueue(); in iterate() local
395 const vk::VkQueue queue = m_context.getUniversalQueue(); in verifyResults() local
458 const vk::VkQueue queue = m_context.getUniversalQueue(); in verifyResults() local
513 const vk::VkQueue queue = m_context.getUniversalQueue(); in verifyResults() local
557 const vk::VkQueue queue = m_context.getUniversalQueue(); in verifyResults() local
598 const vk::VkQueue queue = m_context.getUniversalQueue(); in verifyResults() local
641 const vk::VkQueue queue = m_context.getUniversalQueue(); in verifyResults() local
|
| /aosp_15_r20/external/mesa3d/src/intel/vulkan/i915/ |
| H A D | anv_batch_chain.c | 320 get_context_and_exec_flags(struct anv_queue *queue, in get_context_and_exec_flags()
366 struct anv_queue *queue, in setup_execbuf_for_cmd_buffers()
522 setup_empty_execbuf(struct anv_execbuf *execbuf, struct anv_queue *queue) in setup_empty_execbuf()
573 struct anv_queue *queue = submit->queue; in setup_async_execbuf() local
724 struct anv_queue *queue = submit->queue; in i915_queue_exec_async() local
756 i915_companion_rcs_queue_exec_locked(struct anv_queue *queue, in i915_companion_rcs_queue_exec_locked()
819 i915_queue_exec_locked(struct anv_queue *queue, in i915_queue_exec_locked()
|
| /aosp_15_r20/external/OpenCL-CTS/test_conformance/workgroups/ |
| H A D | test_wg_suggested_local_work_size.cpp | 128 int do_test(cl_device_id device, cl_context context, cl_command_queue queue, in do_test()
220 cl_device_id device, cl_context context, cl_command_queue queue, in do_test_work_group_suggested_local_size()
295 cl_command_queue queue, int n_elems) in test_work_group_suggested_local_size_1D()
399 cl_command_queue queue, int n_elems) in test_work_group_suggested_local_size_2D()
504 cl_command_queue queue, int n_elems) in test_work_group_suggested_local_size_3D()
|
| /aosp_15_r20/external/mesa3d/src/gallium/drivers/radeonsi/ |
| H A D | si_perfetto.cpp | 160 static void begin_event(struct si_ds_queue *queue, uint64_t ts_ns, enum si_ds_queue_stage stage_id) in begin_event()
180 static void end_event(struct si_ds_queue *queue, uint64_t ts_ns, enum si_ds_queue_stage stage_id, in end_event()
288 void si_ds_end_submit(struct si_ds_queue *queue, uint64_t start_ts) in si_ds_end_submit()
371 struct si_ds_queue *queue, in si_ds_device_init_queue()
391 void si_ds_flush_data_init(struct si_ds_flush_data *data, struct si_ds_queue *queue, in si_ds_flush_data_init()
|
| /aosp_15_r20/external/mesa3d/src/vulkan/runtime/ |
| H A D | vk_queue.h | 179 vk_queue_is_empty(struct vk_queue *queue) in vk_queue_is_empty()
203 #define vk_queue_set_lost(queue, ...) \ argument
207 vk_queue_is_lost(struct vk_queue *queue) in vk_queue_is_lost()
212 #define vk_foreach_queue(queue, device) \ argument
215 #define vk_foreach_queue_safe(queue, device) \ argument
|
| /aosp_15_r20/external/mesa3d/src/intel/vulkan/ |
| H A D | anv_batch_chain.c | 1224 struct anv_queue *queue, in anv_print_batch()
1250 anv_cmd_buffer_exec_batch_debug(struct anv_queue *queue, in anv_cmd_buffer_exec_batch_debug()
1309 anv_queue_exec_locked(struct anv_queue *queue, in anv_queue_exec_locked()
1378 anv_queue_submit_sparse_bind_locked(struct anv_queue *queue, in anv_queue_submit_sparse_bind_locked()
1475 anv_queue_submit_cmd_buffers_locked(struct anv_queue *queue, in anv_queue_submit_cmd_buffers_locked()
1564 anv_queue_free_initial_submission(struct anv_queue *queue) in anv_queue_free_initial_submission()
1582 struct anv_queue *queue = container_of(vk_queue, struct anv_queue, vk); in anv_queue_submit() local
1693 struct anv_queue *queue, in anv_async_submit_init()
1751 anv_async_submit_create(struct anv_queue *queue, in anv_async_submit_create()
|
| /aosp_15_r20/external/cronet/base/ |
| H A D | stl_util_unittest.cc | 32 std::queue<int> queue({1, 2, 3, 4, 5}); in TEST() local
41 std::queue<int> queue; in TEST() local
46 base::queue<int> queue({1, 2, 3, 4, 5}); in TEST() local
57 std::priority_queue<int> queue(values.begin(), values.end()); in TEST() local
|
| /aosp_15_r20/external/ltp/testcases/kernel/fs/read_all/ |
| H A D | read_all.c | 58 struct queue { struct
69 struct queue *q; argument
|
| /aosp_15_r20/external/cronet/net/spdy/ |
| H A D | spdy_write_queue_unittest.cc | 54 explicit RequeingBufferProducer(SpdyWriteQueue* queue) { in RequeingBufferProducer()
64 static void ConsumeCallback(SpdyWriteQueue* queue, in ConsumeCallback()
319 SpdyWriteQueue queue; in TEST_F() local
350 SpdyWriteQueue queue; in TEST_F() local
373 SpdyWriteQueue queue; in TEST_F() local
396 SpdyWriteQueue queue; in TEST_F() local
|