Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 357) sorted by relevance

12345678910>>...15

/hardware/google/gfxstream/guest/mesa/src/util/
Du_queue.c47 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()
245 struct util_queue *queue; member
252 struct util_queue *queue = ((struct thread_input*)input)->queue; in util_queue_thread_func() local
257 if (queue->flags & UTIL_QUEUE_INIT_SET_FULL_THREAD_AFFINITY) { in util_queue_thread_func()
270 if (queue->flags & UTIL_QUEUE_INIT_USE_MINIMUM_PRIORITY) { in util_queue_thread_func()
276 if (strlen(queue->name) > 0) { in util_queue_thread_func()
[all …]
Du_vector.h49 int u_vector_init_pow2(struct u_vector *queue,
53 void *u_vector_add(struct u_vector *queue);
54 void *u_vector_remove(struct u_vector *queue);
57 u_vector_init(struct u_vector *queue, in u_vector_init() argument
63 return u_vector_init_pow2(queue, initial_element_count, element_size); in u_vector_init()
67 u_vector_length(struct u_vector *queue) in u_vector_length() argument
69 return (queue->head - queue->tail) / queue->element_size; in u_vector_length()
88 u_vector_finish(struct u_vector *queue) in u_vector_finish() argument
90 free(queue->data); in u_vector_finish()
99 #define u_vector_foreach(elem, queue) \ argument
[all …]
Du_queue.h226 bool util_queue_init(struct util_queue *queue,
232 void util_queue_destroy(struct util_queue *queue);
235 void util_queue_add_job(struct util_queue *queue,
241 void util_queue_drop_job(struct util_queue *queue,
244 void util_queue_finish(struct util_queue *queue);
251 util_queue_adjust_num_threads(struct util_queue *queue, unsigned num_threads,
254 int64_t util_queue_get_thread_time_nano(struct util_queue *queue,
259 util_queue_is_initialized(struct util_queue *queue) in util_queue_is_initialized() argument
261 return queue->threads != NULL; in util_queue_is_initialized()
270 struct util_queue *queue; member
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-test/src/
Dmm_qcamera_queue.c34 int mm_camera_queue_init(mm_camera_queue_t *queue, in mm_camera_queue_init() argument
38 if ( NULL == queue ) { in mm_camera_queue_init()
42 pthread_mutex_init(&queue->m_lock, NULL); in mm_camera_queue_init()
43 cam_list_init(&queue->m_head.list); in mm_camera_queue_init()
44 queue->m_size = 0; in mm_camera_queue_init()
45 queue->m_dataFn = data_rel_fn; in mm_camera_queue_init()
46 queue->m_userData = user_data; in mm_camera_queue_init()
51 int mm_qcamera_queue_release(mm_camera_queue_t *queue) in mm_qcamera_queue_release() argument
53 if ( NULL == queue ) { in mm_qcamera_queue_release()
57 mm_qcamera_queue_flush(queue); in mm_qcamera_queue_release()
[all …]
/hardware/libhardware/modules/sensors/tests/
DSensorEventQueue_test.cpp16 bool checkWritableBufferSize(SensorEventQueue* queue, int requested, int expected) { in checkWritableBufferSize() argument
18 int actual = queue->getWritableRegion(requested, &buffer); in checkWritableBufferSize()
26 bool checkSize(SensorEventQueue* queue, int expected) { in checkSize() argument
27 int actual = queue->getSize(); in checkSize()
45 SensorEventQueue* queue = new SensorEventQueue(10); in testSimpleWriteSizeCounts() local
46 if (!checkSize(queue, 0)) return false; in testSimpleWriteSizeCounts()
47 if (!checkWritableBufferSize(queue, 11, 10)) return false; in testSimpleWriteSizeCounts()
48 if (!checkWritableBufferSize(queue, 10, 10)) return false; in testSimpleWriteSizeCounts()
49 if (!checkWritableBufferSize(queue, 9, 9)) return false; in testSimpleWriteSizeCounts()
51 queue->markAsWritten(7); in testSimpleWriteSizeCounts()
[all …]
/hardware/samsung/nfc/halimpl/osi/
Dosi_memory.cc103 if (osi_info.queue[index].state == OSI_FREE) { in OSI_queue_allocate()
105 free_que = (tOSI_QUEUE_HANDLER)&osi_info.queue[index]; in OSI_queue_allocate()
107 if (osi_info.queue[index].name == NULL) continue; in OSI_queue_allocate()
109 if (strcmp((char const*)osi_info.queue[index].name, in OSI_queue_allocate()
123 memset(free_que->queue, 0, OSI_QUEUE_SIZE); in OSI_queue_allocate()
134 int OSI_queue_put(tOSI_QUEUE_HANDLER queue, void* p_data) { in OSI_queue_put() argument
139 if (!queue || queue->state != OSI_ALLOCATED) { in OSI_queue_put()
144 if (queue->head == queue->tail) { in OSI_queue_put()
147 queue->queue[queue->head++] = p_data; in OSI_queue_put()
148 if (queue->head >= OSI_QUEUE_SIZE) queue->head = 0; in OSI_queue_put()
[all …]
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/src/
Dmm_jpeg_queue.c37 int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue) in mm_jpeg_queue_init() argument
39 pthread_mutex_init(&queue->lock, NULL); in mm_jpeg_queue_init()
40 cam_list_init(&queue->head.list); in mm_jpeg_queue_init()
41 queue->size = 0; in mm_jpeg_queue_init()
45 int32_t mm_jpeg_queue_enq(mm_jpeg_queue_t* queue, mm_jpeg_q_data_t data) in mm_jpeg_queue_enq() argument
57 pthread_mutex_lock(&queue->lock); in mm_jpeg_queue_enq()
58 cam_list_add_tail_node(&node->list, &queue->head.list); in mm_jpeg_queue_enq()
59 queue->size++; in mm_jpeg_queue_enq()
60 pthread_mutex_unlock(&queue->lock); in mm_jpeg_queue_enq()
66 int32_t mm_jpeg_queue_enq_head(mm_jpeg_queue_t* queue, mm_jpeg_q_data_t data) in mm_jpeg_queue_enq_head() argument
[all …]
/hardware/google/gfxstream/guest/mesa/src/vulkan/runtime/
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 …]
Dvk_queue.h71 VkResult (*driver_submit)(struct vk_queue *queue,
171 vk_queue_init(struct vk_queue *queue, struct vk_device *device,
176 vk_queue_finish(struct vk_queue *queue);
179 vk_queue_is_empty(struct vk_queue *queue) in vk_queue_is_empty() argument
181 return list_is_empty(&queue->submit.submits); in vk_queue_is_empty()
191 VkResult vk_queue_enable_submit_thread(struct vk_queue *queue);
193 VkResult vk_queue_flush(struct vk_queue *queue, uint32_t *submit_count_out);
195 VkResult vk_queue_wait_before_present(struct vk_queue *queue,
199 _vk_queue_set_lost(struct vk_queue *queue,
203 #define vk_queue_set_lost(queue, ...) \ argument
[all …]
Dvk_debug_utils.c278 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueBeginDebugUtilsLabelEXT()
283 if (!queue->region_begin) in vk_common_QueueBeginDebugUtilsLabelEXT()
284 (void)util_dynarray_pop(&queue->labels, VkDebugUtilsLabelEXT); in vk_common_QueueBeginDebugUtilsLabelEXT()
286 vk_common_append_debug_label(queue->base.device, in vk_common_QueueBeginDebugUtilsLabelEXT()
287 &queue->labels, in vk_common_QueueBeginDebugUtilsLabelEXT()
289 queue->region_begin = true; in vk_common_QueueBeginDebugUtilsLabelEXT()
295 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueEndDebugUtilsLabelEXT()
300 if (!queue->region_begin) in vk_common_QueueEndDebugUtilsLabelEXT()
301 vk_common_pop_debug_label(queue->base.device, &queue->labels); in vk_common_QueueEndDebugUtilsLabelEXT()
303 vk_common_pop_debug_label(queue->base.device, &queue->labels); in vk_common_QueueEndDebugUtilsLabelEXT()
[all …]
Dvk_android.c309 vk_anb_semaphore_init_once(struct vk_queue *queue, struct vk_device *device) in vk_anb_semaphore_init_once() argument
311 if (queue->anb_semaphore != VK_NULL_HANDLE) in vk_anb_semaphore_init_once()
324 &queue->anb_semaphore); in vk_anb_semaphore_init_once()
334 VK_FROM_HANDLE(vk_queue, queue, _queue); in vk_common_QueueSignalReleaseImageANDROID()
335 struct vk_device *device = queue->base.device; in vk_common_QueueSignalReleaseImageANDROID()
342 result = vk_anb_semaphore_init_once(queue, device); in vk_common_QueueSignalReleaseImageANDROID()
352 .pSignalSemaphores = &queue->anb_semaphore, in vk_common_QueueSignalReleaseImageANDROID()
362 .semaphore = queue->anb_semaphore, in vk_common_QueueSignalReleaseImageANDROID()
/hardware/qcom/camera/msm8998/QCamera2/stack/common/
Dcam_queue.h47 static inline int32_t cam_queue_init(cam_queue_t *queue) in cam_queue_init() argument
49 pthread_mutex_init(&queue->lock, NULL); in cam_queue_init()
50 cam_list_init(&queue->head.list); in cam_queue_init()
51 queue->size = 0; in cam_queue_init()
55 static inline int32_t cam_queue_enq(cam_queue_t *queue, void *data) in cam_queue_enq() argument
66 pthread_mutex_lock(&queue->lock); in cam_queue_enq()
67 cam_list_add_tail_node(&node->list, &queue->head.list); in cam_queue_enq()
68 queue->size++; in cam_queue_enq()
69 pthread_mutex_unlock(&queue->lock); in cam_queue_enq()
74 static inline void *cam_queue_deq(cam_queue_t *queue) in cam_queue_deq() argument
[all …]
/hardware/google/gfxstream/guest/mesa/src/vulkan/wsi/
Dwsi_common_queue.h38 wsi_queue_init(struct wsi_queue *queue, int length) in wsi_queue_init() argument
45 ret = u_vector_init(&queue->vector, length, sizeof(uint32_t)); in wsi_queue_init()
58 ret = pthread_cond_init(&queue->cond, &condattr); in wsi_queue_init()
62 ret = pthread_mutex_init(&queue->mutex, NULL); in wsi_queue_init()
70 pthread_cond_destroy(&queue->cond); in wsi_queue_init()
74 u_vector_finish(&queue->vector); in wsi_queue_init()
80 wsi_queue_destroy(struct wsi_queue *queue) in wsi_queue_destroy() argument
82 u_vector_finish(&queue->vector); in wsi_queue_destroy()
83 pthread_mutex_destroy(&queue->mutex); in wsi_queue_destroy()
84 pthread_cond_destroy(&queue->cond); in wsi_queue_destroy()
[all …]
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-interface/src/
Dmm_camera_channel.c89 mm_channel_queue_t * queue, cam_stream_type_t cam_type);
125 int32_t mm_channel_superbuf_queue_init(mm_channel_queue_t * queue);
126 int32_t mm_channel_superbuf_queue_deinit(mm_channel_queue_t * queue);
128 mm_channel_queue_t * queue,
131 mm_channel_queue_t * queue, mm_channel_t *ch_obj);
133 mm_channel_queue_t *queue);
135 mm_channel_queue_t *queue);
140 mm_channel_queue_t * queue);
156 mm_channel_queue_t * queue, uint32_t frame_idx);
1482 mm_frame_sync_queue_t *queue = NULL; in mm_channel_reg_frame_sync() local
[all …]
Dmm_camera_muxer.c1856 mm_frame_sync_queue_t *queue, uint8_t matched_only) in mm_camera_muxer_frame_sync_dequeue() argument
1863 pthread_mutex_lock(&queue->que.lock); in mm_camera_muxer_frame_sync_dequeue()
1864 head = &queue->que.head.list; in mm_camera_muxer_frame_sync_dequeue()
1877 queue->que.size--; in mm_camera_muxer_frame_sync_dequeue()
1881 queue->match_cnt--; in mm_camera_muxer_frame_sync_dequeue()
1885 pthread_mutex_unlock(&queue->que.lock); in mm_camera_muxer_frame_sync_dequeue()
1904 mm_frame_sync_queue_t *queue, mm_camera_super_buf_t *buffer, in mm_camera_muxer_do_frame_sync() argument
1919 for (buf_s_idx = 0; buf_s_idx < queue->num_objs; buf_s_idx++) { in mm_camera_muxer_do_frame_sync()
1920 if ((buffer->ch_id == queue->bundled_objs[buf_s_idx]) || in mm_camera_muxer_do_frame_sync()
1921 (buffer->bufs[0]->stream_id == queue->bundled_objs[buf_s_idx])) { in mm_camera_muxer_do_frame_sync()
[all …]
/hardware/google/aemu/host-common/
DGoldfishSyncCommandQueue.cpp60 GoldfishSyncCommandQueue* queue = sCommandQueue(); in hostSignal() local
68 queue->queueDeviceOperation(sync_data); in hostSignal()
73 GoldfishSyncCommandQueue* queue = sCommandQueue(); in save() local
74 stream->putBe32(queue->numPending()); in save()
75 queue->forEachPendingOperation([stream](const GoldfishSyncWakeInfo& wakeInfo) { in save()
85 GoldfishSyncCommandQueue* queue = sCommandQueue(); in load() local
86 queue->removeAllPendingOperations( in load()
96 queue->queueDeviceOperation(cmd); in load()
/hardware/google/gfxstream/codegen/vulkan/vulkan-docs-next/chapters/commonvalidity/
Dimage_memory_barrier_common.adoc9 <<synchronization-queue-transfers, queue family ownership transfer>> or
17 <<synchronization-queue-transfers, queue family ownership transfer>> or
26 <<synchronization-queue-transfers, queue family ownership transfer>> or
35 <<synchronization-queue-transfers, queue family ownership transfer>> or
44 <<synchronization-queue-transfers, queue family ownership transfer>> or
52 <<synchronization-queue-transfers, queue family ownership transfer>> or
60 <<synchronization-queue-transfers, queue family ownership transfer>> or
67 <<synchronization-queue-transfers, queue family ownership transfer>> or
75 <<synchronization-queue-transfers, queue family ownership transfer>> or
84 <<synchronization-queue-transfers, queue family ownership transfer>> or
[all …]
/hardware/google/gfxstream/host/vulkan/
Dvulkan_gfxstream.h58 typedef void (VKAPI_PTR *PFN_vkQueueHostSyncGOOGLE)(VkQueue queue, uint32_t needHostSync, uint32_t …
59 typedef void (VKAPI_PTR *PFN_vkQueueSubmitAsyncGOOGLE)(VkQueue queue, uint32_t submitCount, const V…
60 typedef void (VKAPI_PTR *PFN_vkQueueWaitIdleAsyncGOOGLE)(VkQueue queue);
61 typedef void (VKAPI_PTR *PFN_vkQueueBindSparseAsyncGOOGLE)(VkQueue queue, uint32_t bindInfoCount, c…
64 typedef void (VKAPI_PTR *PFN_vkQueueFlushCommandsGOOGLE)(VkQueue queue, VkCommandBuffer commandBuff…
65 typedef void (VKAPI_PTR *PFN_vkQueueCommitDescriptorSetUpdatesGOOGLE)(VkQueue queue, uint32_t descr…
67 typedef void (VKAPI_PTR *PFN_vkQueueSignalReleaseImageANDROIDAsyncGOOGLE)(VkQueue queue, uint32_t w…
68 typedef void (VKAPI_PTR *PFN_vkQueueFlushCommandsFromAuxMemoryGOOGLE)(VkQueue queue, VkCommandBuffe…
71 typedef void (VKAPI_PTR *PFN_vkQueueSubmitAsync2GOOGLE)(VkQueue queue, uint32_t submitCount, const …
136 VkQueue queue,
[all …]
/hardware/google/gfxstream/guest/vulkan_enc/
Dvulkan_gfxstream.h58 typedef void (VKAPI_PTR *PFN_vkQueueHostSyncGOOGLE)(VkQueue queue, uint32_t needHostSync, uint32_t …
59 typedef void (VKAPI_PTR *PFN_vkQueueSubmitAsyncGOOGLE)(VkQueue queue, uint32_t submitCount, const V…
60 typedef void (VKAPI_PTR *PFN_vkQueueWaitIdleAsyncGOOGLE)(VkQueue queue);
61 typedef void (VKAPI_PTR *PFN_vkQueueBindSparseAsyncGOOGLE)(VkQueue queue, uint32_t bindInfoCount, c…
64 typedef void (VKAPI_PTR *PFN_vkQueueFlushCommandsGOOGLE)(VkQueue queue, VkCommandBuffer commandBuff…
65 typedef void (VKAPI_PTR *PFN_vkQueueCommitDescriptorSetUpdatesGOOGLE)(VkQueue queue, uint32_t descr…
67 typedef void (VKAPI_PTR *PFN_vkQueueSignalReleaseImageANDROIDAsyncGOOGLE)(VkQueue queue, uint32_t w…
68 typedef void (VKAPI_PTR *PFN_vkQueueFlushCommandsFromAuxMemoryGOOGLE)(VkQueue queue, VkCommandBuffe…
71 typedef void (VKAPI_PTR *PFN_vkQueueSubmitAsync2GOOGLE)(VkQueue queue, uint32_t submitCount, const …
136 VkQueue queue,
[all …]
/hardware/google/gfxstream/codegen/vulkan/vulkan-docs-next/appendices/
DVK_KHR_global_priority.adoc18 In Vulkan, users can specify device-scope queue priorities.
21 This device extension allows applications to query the global queue
22 priorities supported by a queue family, and then set a priority when
24 The default queue priority is ename:VK_QUEUE_GLOBAL_PRIORITY_MEDIUM_EXT.
36 The global priority level of a queue shall take precedence over the
37 per-process queue priority
47 The driver implementation may fail the queue allocation request if resources
57 specific global queue priority in this extension?
62 this query and the actual queue creation call.
64 2) If more than 1 queue using global priority is requested, is there a good
[all …]
DVK_EXT_global_priority_query.adoc18 This device extension allows applications to query the global queue
19 priorities supported by a queue family.
33 specific global queue priority in this extension?
38 this query and the actual queue creation call.
40 2) If more than 1 queue using global priority is requested, is there a good
41 way to know which queue is failing the device creation?
49 that particular queue configuration requested.
/hardware/interfaces/media/bufferpool/aidl/default/
DBufferStatus.cpp59 auto queue = std::make_unique<BufferStatusQueue>(kNumElementsInQueue); in open() local
60 if (!queue || queue->isValid() == false) { in open()
63 *fmqDescPtr = queue->dupeDesc(); in open()
65 std::make_pair(id, std::move(queue))); in open()
101 auto queue = std::make_unique<BufferStatusQueue>(fmqDesc); in BufferStatusChannel() local
102 if (!queue || queue->isValid() == false) { in BufferStatusChannel()
107 mBufferStatusQueue = std::move(queue); in BufferStatusChannel()
215 std::unique_ptr<BufferInvalidationQueue> queue = in BufferInvalidationListener() local
217 if (!queue || queue->isValid() == false) { in BufferInvalidationListener()
222 mBufferInvalidationQueue = std::move(queue); in BufferInvalidationListener()
/hardware/interfaces/automotive/vehicle/aidl/impl/utils/common/test/
DVehicleUtilsTest.cpp684 ConcurrentQueue<int> queue; in TEST() local
686 queue.push(1); in TEST()
687 queue.push(2); in TEST()
688 auto result = queue.flush(); in TEST()
694 ConcurrentQueue<int> queue; in TEST() local
698 std::thread t1([&queue]() { in TEST()
700 queue.push(0); in TEST()
703 std::thread t2([&queue]() { in TEST()
705 queue.push(1); in TEST()
708 std::thread t3([&queue, &results, &stop]() { in TEST()
[all …]
/hardware/qcom/camera/msm8998/QCamera2/stack/mm-jpeg-interface/inc/
Dmm_jpeg.h482 extern int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue);
483 extern int32_t mm_jpeg_queue_enq(mm_jpeg_queue_t* queue,
485 extern int32_t mm_jpeg_queue_enq_head(mm_jpeg_queue_t* queue,
487 extern mm_jpeg_q_data_t mm_jpeg_queue_deq(mm_jpeg_queue_t* queue);
488 extern int32_t mm_jpeg_queue_deinit(mm_jpeg_queue_t* queue);
489 extern int32_t mm_jpeg_queue_flush(mm_jpeg_queue_t* queue);
490 extern uint32_t mm_jpeg_queue_get_size(mm_jpeg_queue_t* queue);
491 extern mm_jpeg_q_data_t mm_jpeg_queue_peek(mm_jpeg_queue_t* queue);
511 mm_jpeg_queue_t* queue, uint32_t client_hdl);
513 mm_jpeg_queue_t* queue, uint32_t job_id);
[all …]
/hardware/qcom/camera/msm8998/QCamera2/HAL3/
DQCamera3HdrPlusListenerThread.h108 std::queue<uint32_t> mNextCaptureReadyIds;
109 std::queue<PendingResult> mResults;
112 std::queue<std::pair<uint32_t, int64_t>> mShutters;
113 std::queue<PendingPostview> mPostviews;
117 std::queue<CallbackType> mPendingCallbacks;

12345678910>>...15