| /foundation/ai/ai_engine/test/common/queuepool/ |
| H A D | queuepool_test.cpp | 70 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F() local
102 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F() local
120 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
156 std::shared_ptr<Queue<int>> queue; HWTEST_F() local
179 std::shared_ptr<Queue<int>> queue; HWTEST_F() local
215 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
236 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
257 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
274 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
294 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
314 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
340 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
360 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
382 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
411 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
429 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
458 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
490 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
[all...] |
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | sync_msg_handler.cpp | 28 SyncMsgHandler::SyncMsgHandler(Queue<Task> &queue, IPlugin *pluginAlgorithm) in SyncMsgHandler() argument
|
| H A D | engine.cpp | 29 Engine(std::shared_ptr<Plugin> &plugin, std::shared_ptr<Thread> &thread, std::shared_ptr<Queue<Task>> &queue) Engine() argument
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler/ |
| H A D | event_queue.h | 223 std::list<InnerEvent::Pointer> queue; global() member
[all...] |
| /foundation/multimedia/av_codec/test/unittest/decoder_filter_test/ |
| H A D | audio_decoder_filter_unit_test.h | 75 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta)
in OnLinkedResult() argument
|
| H A D | video_resize_filter_unit_test.h | 73 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta)
in OnLinkedResult() argument
|
| /foundation/multimedia/av_codec/test/unittest/filter_test/ |
| H A D | subtitle_sink_filter_unit_test.cpp | 40 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta) in OnLinkedResult() argument
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | loop_api.cpp | 25 ffrt_loop_t ffrt_loop_create(ffrt_queue_t queue) in ffrt_loop_create() argument
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| H A D | queue_adapter.c | 26 LockFreeQueue *queue;
member
31 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)SAMGR_Malloc(sizeof(LockFreeBlockQueue));
in QUEUE_Create() local
51 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Put() local
67 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Pop() local
82 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Destroy() local
[all...] |
| /foundation/communication/dsoftbus/core/common/queue/ |
| H A D | softbus_queue.c | 32 int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum) in QueueInit() argument
77 QueueCountGet(const LockFreeQueue* queue, uint32_t* count) QueueCountGet() argument
105 LockFreeQueue *queue = (LockFreeQueue *)SoftBusCalloc(queueSize); CreateQueue() local
[all...] |
| /foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/event/ |
| H A D | wifi_direct_event_template_dispatcher.h | 28 WifiDirectEventTemplateDispatcher(WifiDirectEventQueue *queue, PrevDispatcher *prev, Func &&func) in WifiDirectEventTemplateDispatcher() argument
|
| /device/soc/hisilicon/common/platform/wifi/hi3881v100/driver/frw/ |
| H A D | frw_event_sched.c | 79 frw_event_sched_queue_stru *queue = HI_NULL; in frw_event_schedule() local
214 hi_u32 oal_queue_init(oal_queue_stru *queue, hi_u8 max_events) in oal_queue_init() argument
[all...] |
| H A D | frw_event_sched.h | 107 oal_queue_stru queue; /* 队列 */ member
|
| /device/soc/rockchip/common/kernel/drivers/gpu/arm/bifrost/debug/backend/ |
| H A D | mali_kbase_debug_ktrace_csf.c | 92 kbasep_ktrace_add_csf(struct kbase_device *kbdev, enum kbase_ktrace_code code, struct kbase_queue_group *group, struct kbase_queue *queue, kbase_ktrace_flag_t flags, u64 info_val) kbasep_ktrace_add_csf() argument
159 kbasep_ktrace_add_csf_kcpu(struct kbase_device *kbdev, enum kbase_ktrace_code code, struct kbase_kcpu_command_queue *queue, u64 info_val1, u64 info_val2) kbasep_ktrace_add_csf_kcpu() argument
[all...] |
| /device/soc/rockchip/common/vendor/drivers/gpu/arm/mali400/mali/linux/ |
| H A D | mali_osk_notification.c | 97 void _mali_osk_notification_queue_term(_mali_osk_notification_queue_t *queue) in _mali_osk_notification_queue_term() argument
109 void mali_osk_notification_queue_send(_mali_osk_notification_queue_t *queue, _mali_osk_notification_t *object) in mali_osk_notification_queue_send() argument
139 _mali_osk_notification_queue_dequeue(_mali_osk_notification_queue_t *queue, _mali_osk_notification_t **result) _mali_osk_notification_queue_dequeue() argument
171 _mali_osk_notification_queue_receive(_mali_osk_notification_queue_t *queue, _mali_osk_notification_t **result) _mali_osk_notification_queue_receive() argument
[all...] |
| /device/soc/rockchip/rk3568/hardware/mpp/mpp/legacy/inc/ |
| H A D | mpp_task_impl.h | 69 MppTaskQueue queue; member
|
| /device/soc/rockchip/common/kernel/drivers/gpu/arm/mali400/mali/linux/ |
| H A D | mali_osk_notification.c | 94 void _mali_osk_notification_queue_term(_mali_osk_notification_queue_t *queue) in _mali_osk_notification_queue_term() argument
106 void _mali_osk_notification_queue_send(_mali_osk_notification_queue_t *queue, _mali_osk_notification_t *object) in _mali_osk_notification_queue_send() argument
136 _mali_osk_notification_queue_dequeue(_mali_osk_notification_queue_t *queue, _mali_osk_notification_t **result) _mali_osk_notification_queue_dequeue() argument
167 _mali_osk_notification_queue_receive(_mali_osk_notification_queue_t *queue, _mali_osk_notification_t **result) _mali_osk_notification_queue_receive() argument
[all...] |
| /foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | future.h | 54 ITaskQueue::WeakPtr queue; member
118 void SetQueueInfo(const ITaskQueue::Ptr& queue, ITaskQueue::Token token) in SetQueueInfo() argument
|
| H A D | future.cpp | 57 IFuture::Ptr Future::Then(const IFutureContinuation::Ptr& func, const ITaskQueue::Ptr& queue) in Then() argument
155 void Future::SetQueueInfo(const ITaskQueue::Ptr& queue, ITaskQueue::Token token) in SetQueueInfo() argument
193 void Promise::SetQueueInfo(const ITaskQueue::Ptr& queue, ITaskQueue::Token token) in SetQueueInfo() argument
|
| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/ |
| H A D | timer.h | 49 Timer(const TimeSpan& interval, Func func, TimerType type, const ITaskQueue::Ptr& queue) in Timer() argument
79 bool Start(const TimeSpan& interval, Func func, TimerType type, const ITaskQueue::Ptr& queue) in Start() argument
160 ITaskQueue::Ptr queue; global() member
173 SingleShotTimer(const TimeSpan& interval, Func func, const ITaskQueue::Ptr& queue) SingleShotTimer() argument
[all...] |
| /foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/include/texture_encode/ |
| H A D | image_compressor.h | 56 cl_command_queue queue = nullptr; member
|
| /foundation/communication/dsoftbus/core/connection/common/include/ |
| H A D | softbus_conn_common.h | 55 LockFreeQueue *queue[QUEUE_NUM_PER_PID]; member
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/ |
| H A D | ffrt_utils.cpp | 26 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask> &tasks, FFRTQueue &queue) in SubmitQueueTasks() argument
36 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, FFRTQueue &queue) in SubmitDelayTask() argument
44 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue) in SubmitDelayTask() argument
59 int FFRTUtils::CancelTask(FFRTHandle &handle, FFRTQueue &queue) in CancelTask() argument
64 int FFRTUtils::CancelTask(FFRTHandle &handle, std::shared_ptr<FFRTQueue> queue) in CancelTask() argument
[all...] |
| /foundation/distributeddatamgr/pasteboard/test/fuzztest/ffrtutils_fuzzer/ |
| H A D | ffrtutils_fuzzer.cpp | 91 shared_ptr<FFRTQueue> queue = make_shared<FFRTQueue>("delaytask_queue_ptr");
in FuzzUtilsSubmitDelayTask() local
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/ |
| H A D | queue.c | 38 Queue *queue = (Queue *)calloc(1, (sizeof(Queue))); in QueueCreate() local
71 QueueDelete(Queue *queue, NodeDataFreeCb cb) QueueDelete() argument
92 QueueEnqueue(Queue *queue, void *data) QueueEnqueue() argument
105 QueueTryEnqueue(Queue *queue, void *data) QueueTryEnqueue() argument
123 QueueDequeue(Queue *queue) QueueDequeue() argument
141 QueueTryDequeue(Queue *queue) QueueTryDequeue() argument
162 QueueGetEnqueueFd(const Queue *queue) QueueGetEnqueueFd() argument
168 QueueGetDequeueFd(const Queue *queue) QueueGetDequeueFd() argument
174 QueueFlush(Queue* queue, NodeDataFreeCb cb) QueueFlush() argument
186 QueueIsEmpty(Queue* queue) QueueIsEmpty() argument
196 QueueGetSize(Queue *queue) QueueGetSize() argument
[all...] |