| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_open/ |
| H A D | 20-1.c | 40 mqd_t queue; in main() local
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_timedsend/ |
| H A D | 4-2.c | 32 mqd_t queue; in main() local
|
| H A D | 4-1.c | 32 mqd_t queue; in main() local
|
| /third_party/libabigail/include/ |
| H A D | abg-workers.h | 67 class queue class
[all...] |
| /third_party/skia/third_party/externals/imgui/examples/example_allegro5/ |
| H A D | main.cpp | 29 ALLEGRO_EVENT_QUEUE* queue = al_create_event_queue(); in main() local
|
| /third_party/skia/experimental/graphite/src/mtl/ |
| H A D | MtlGpu.h | 28 id<MTLCommandQueue> queue() const { return fQueue.get(); } in queue() function in skgpu::mtl::final
|
| /arkcompiler/ets_frontend/ets2panda/compiler/core/ |
| H A D | compileQueue.cpp | 66 void CompileQueue::Worker(CompileQueue *queue) in Worker() argument
|
| /arkcompiler/ets_frontend/es2panda/util/ |
| H A D | workerQueue.cpp | 59 void WorkerQueue::Worker(WorkerQueue *queue) in Worker() argument
|
| /base/request/request/services/src/manage/scheduler/ |
| H A D | mod.rs | 15 mod queue; modules
|
| /device/soc/hisilicon/common/platform/wifi/hi3881v100/driver/oal/ |
| H A D | oal_queue.h | 83 static inline hi_void oal_queue_set(oal_queue_stru *queue, hi_u32 *pul_buf, hi_u8 max_elements) in oal_queue_set() argument
99 static inline hi_void oal_queue_destroy(oal_queue_stru *queue) in oal_queue_destroy() argument
121 oal_queue_enqueue(oal_queue_stru *queue, hi_void *element) oal_queue_enqueue() argument
143 oal_queue_dequeue(oal_queue_stru *queue) oal_queue_dequeue() argument
162 oal_queue_get_length(const oal_queue_stru *queue) oal_queue_get_length() argument
[all...] |
| /device/soc/hisilicon/common/platform/wifi/hi3881v100/driver/mac/common/ |
| H A D | mac_resource.h | 59 oal_queue_stru queue; member
|
| /device/soc/rockchip/common/vendor/drivers/gpu/arm/mali400/mali/linux/ |
| H A D | mali_osk_wait_queue.c | 43 void _mali_osk_wait_queue_wait_event(_mali_osk_wait_queue_t *queue, mali_bool (*condition)(void *), void *data) in _mali_osk_wait_queue_wait_event() argument
50 void _mali_osk_wait_queue_wait_event_timeout(_mali_osk_wait_queue_t *queue, mali_bool (*condition)(void *), void *data, in _mali_osk_wait_queue_wait_event_timeout() argument
58 _mali_osk_wait_queue_wake_up(_mali_osk_wait_queue_t *queue) _mali_osk_wait_queue_wake_up() argument
74 _mali_osk_wait_queue_term(_mali_osk_wait_queue_t *queue) _mali_osk_wait_queue_term() argument
[all...] |
| /device/soc/rockchip/rk3568/hardware/omx_il/osal/ |
| H A D | Rockchip_OSAL_Queue.c | 40 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; in Rockchip_OSAL_QueueCreate() local
84 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; Rockchip_OSAL_QueueTerminate() local
108 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; Rockchip_OSAL_Queue() local
130 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; Rockchip_OSAL_Dequeue() local
153 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; Rockchip_OSAL_GetElemNum() local
166 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; Rockchip_OSAL_SetElemNum() local
179 ROCKCHIP_QUEUE *queue = (ROCKCHIP_QUEUE *)queueHandle; Rockchip_OSAL_ResetQueue() local
[all...] |
| /device/soc/rockchip/common/kernel/drivers/gpu/arm/mali400/mali/linux/ |
| H A D | mali_osk_wait_queue.c | 43 void _mali_osk_wait_queue_wait_event(_mali_osk_wait_queue_t *queue, mali_bool(*condition)(void *), void *data) in _mali_osk_wait_queue_wait_event() argument
50 void _mali_osk_wait_queue_wait_event_timeout(_mali_osk_wait_queue_t *queue, mali_bool(*condition)(void *), void *data, u32 timeout) in _mali_osk_wait_queue_wait_event_timeout() argument
57 _mali_osk_wait_queue_wake_up(_mali_osk_wait_queue_t *queue) _mali_osk_wait_queue_wake_up() argument
71 _mali_osk_wait_queue_term(_mali_osk_wait_queue_t *queue) _mali_osk_wait_queue_term() argument
[all...] |
| /device/soc/rockchip/common/kernel/drivers/gpu/arm/bifrost/csf/ |
| H A D | mali_kbase_csf_scheduler.h | 525 kbase_csf_scheduler_queue_has_trace(struct kbase_queue *queue) kbase_csf_scheduler_queue_has_trace() argument
[all...] |
| /foundation/ability/form_fwk/test/unittest/fms_form_serial_queue_test/ |
| H A D | fms_form_serial_queue_test.cpp | 59 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); in HWTEST_F() local
76 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); in HWTEST_F() local
96 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); in HWTEST_F() local
|
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | engine_worker.cpp | 28 EngineWorker::EngineWorker(Queue<Task> &queue) : queue_(queue) in EngineWorker() argument
32 static void ClearQueue(Queue<Task> &queue) in ClearQueue() argument
|
| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/ |
| H A D | event_handler.h | 147 auto queue = GetTaskQueueRegistry().GetTaskQueue(queueId); Subscribe() local
[all...] |
| H A D | future.h | 95 IFuture::Ptr Then(const IFutureContinuation::Ptr& func, const BASE_NS::shared_ptr<ITaskQueue>& queue) in Then() argument
100 auto Then(Func func, const BASE_NS::shared_ptr<ITaskQueue>& queue) in Then() argument
105 auto Then(Func func, const BASE_NS::shared_ptr<ITaskQueue>& queue, int = 0) in Then() argument
120 queue)); in Then() variable
|
| H A D | deferred_callback.h | 104 auto MakeDeferred(Func func, const ITaskQueue::Ptr& queue) in MakeDeferred() argument
|
| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/property/ |
| H A D | property_event_handler.h | 44 bool Subscribe(const IProperty::ConstPtr& property, const CallableTypePtr& onInvoked, const ITaskQueue::Ptr& queue) in Subscribe() argument
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue.cpp | 32 TaskQueue::ExecuteAsyncTask::ExecuteAsyncTask(TaskQueue& queue) : queue_(queue) {} in ExecuteAsyncTask() argument
|
| /foundation/multimedia/av_codec/test/unittest/filter_test/ |
| H A D | audio_sink_filter_unit_test.h | 45 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta)
in OnLinkedResult() argument
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| H A D | lock_free_queue.c | 31 register LockFreeQueue *queue = (LockFreeQueue *)SAMGR_Malloc(sizeof(LockFreeQueue) + total);
in LFQUE_Create() local
42 BOOL LFQUE_IsFull(LockFreeQueue *queue)
in LFQUE_IsFull() argument
51 LFQUE_IsEmpty(LockFreeQueue *queue) LFQUE_IsEmpty() argument
56 LFQUE_Push(LockFreeQueue *queue, const void *element, uint8 pri) LFQUE_Push() argument
88 LFQUE_Pop(LockFreeQueue *queue, void *element, uint8 *pri) LFQUE_Pop() argument
[all...] |
| /foundation/communication/dsoftbus/tests/core/common/queue/ |
| H A D | queue_test.cpp | 54 LockFreeQueue queue; in HWTEST_F() local
86 LockFreeQueue queue; in HWTEST_F() local
102 LockFreeQueue *queue = CreateQueue(INVALID_NUM); in HWTEST_F() local
118 LockFreeQueue *queue = CreateQueue(IS_POWER_OF_2_NUM); HWTEST_F() local
[all...] |