| /foundation/ai/ai_engine/test/common/queuepool/ |
| D | queuepool_test.cpp | 70 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); variable
102 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); variable
120 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); variable
156 std::shared_ptr<Queue<int>> queue; variable
179 std::shared_ptr<Queue<int>> queue; variable
197 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); variable
215 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); variable
236 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); variable
257 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); variable
274 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); variable
[all …]
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/ |
| D | queue.c | 38 Queue *queue = (Queue *)calloc(1, (sizeof(Queue))); in QueueCreate() local
71 void QueueDelete(Queue *queue, NodeDataFreeCb cb) in QueueDelete()
92 void QueueEnqueue(Queue *queue, void *data) in QueueEnqueue()
105 bool QueueTryEnqueue(Queue *queue, void *data) in QueueTryEnqueue()
123 void *QueueDequeue(Queue *queue) in QueueDequeue()
141 void *QueueTryDequeue(Queue *queue) in QueueTryDequeue()
162 int32_t QueueGetEnqueueFd(const Queue *queue) in QueueGetEnqueueFd()
168 int32_t QueueGetDequeueFd(const Queue *queue) in QueueGetDequeueFd()
174 void QueueFlush(Queue* queue, NodeDataFreeCb cb) in QueueFlush()
186 bool QueueIsEmpty(Queue* queue) in QueueIsEmpty()
[all …]
|
| /foundation/arkui/ace_engine_lite/frameworks/src/core/stylemgr/test/unittest/common/ |
| D | link_queue_test.cpp | 34 LinkQueue queue; variable
52 LinkQueue queue; variable
70 LinkQueue queue; variable
88 LinkQueue queue; variable
131 LinkQueue queue; variable
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| 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()
51 BOOL LFQUE_IsEmpty(LockFreeQueue *queue) in LFQUE_IsEmpty()
56 int LFQUE_Push(LockFreeQueue *queue, const void *element, uint8 pri) in LFQUE_Push()
88 int LFQUE_Pop(LockFreeQueue *queue, void *element, uint8 *pri) in LFQUE_Pop()
|
| 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; in QUEUE_Put() local
67 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; in QUEUE_Pop() local
82 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; in QUEUE_Destroy() local
|
| /foundation/resourceschedule/ffrt/src/queue/ |
| D | queue_api.cpp | 36 inline QueueTask* ffrt_queue_submit_base(ffrt_queue_t queue, ffrt_function_header_t* f, bool withHa… in ffrt_queue_submit_base()
157 void ffrt_queue_destroy(ffrt_queue_t queue) in ffrt_queue_destroy()
165 void ffrt_queue_submit(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) in ffrt_queue_submit()
173 void ffrt_queue_submit_head(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* … in ffrt_queue_submit_head()
181 ffrt_task_handle_t ffrt_queue_submit_h(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_ta… in ffrt_queue_submit_h()
190 ffrt_task_handle_t ffrt_queue_submit_head_h(ffrt_queue_t queue, ffrt_function_header_t* f, const ff… in ffrt_queue_submit_head_h()
207 uint64_t ffrt_queue_get_task_cnt(ffrt_queue_t queue) in ffrt_queue_get_task_cnt()
226 void ffrt_queue_cancel_all(ffrt_queue_t queue) in ffrt_queue_cancel_all()
234 void ffrt_queue_cancel_and_wait(ffrt_queue_t queue) in ffrt_queue_cancel_and_wait()
242 int ffrt_queue_cancel_by_name(ffrt_queue_t queue, const char* name) in ffrt_queue_cancel_by_name()
[all …]
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| D | btm_thread.c | 36 Queue *queue; member
84 Queue *queue; member
106 static void RunAllTaskInQueue(Queue *queue) in RunAllTaskInQueue()
123 static void FreeProcessingQueue(void *queue) in FreeProcessingQueue()
139 BtmProcessingQueue *queue = NULL; in FindProcessingQueueById() local
191 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_CreateProcessingQueue() local
210 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_DeleteProcessingQueue() local
234 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_RunTaskInProcessingQueue() local
|
| /foundation/communication/dsoftbus/tests/core/common/queue/ |
| D | queue_test.cpp | 54 LockFreeQueue queue; variable
86 LockFreeQueue queue; variable
102 LockFreeQueue *queue = CreateQueue(INVALID_NUM); variable
118 LockFreeQueue *queue = CreateQueue(IS_POWER_OF_2_NUM); variable
|
| /foundation/ability/form_fwk/test/unittest/fms_form_serial_queue_test/ |
| D | fms_form_serial_queue_test.cpp | 59 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
76 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
96 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/ |
| D | ffrt_utils.cpp | 26 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask> &tasks, FFRTQueue &queue) in SubmitQueueTasks()
36 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, FFRTQueue &queue) in SubmitDelayTask()
44 …ndle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue) in SubmitDelayTask()
59 int FFRTUtils::CancelTask(FFRTHandle &handle, FFRTQueue &queue) in CancelTask()
64 int FFRTUtils::CancelTask(FFRTHandle &handle, std::shared_ptr<FFRTQueue> &queue) in CancelTask()
|
| /foundation/communication/dsoftbus/core/common/queue/ |
| D | softbus_queue.c | 32 int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum) in QueueInit()
77 int32_t QueueCountGet(const LockFreeQueue* queue, uint32_t* count) in QueueCountGet()
105 LockFreeQueue *queue = (LockFreeQueue *)SoftBusCalloc(queueSize); in CreateQueue() local
|
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| D | engine_worker.cpp | 28 EngineWorker::EngineWorker(Queue<Task> &queue) : queue_(queue) in EngineWorker()
32 static void ClearQueue(Queue<Task> &queue) in ClearQueue()
|
| /foundation/ai/ai_engine/services/common/platform/queuepool/ |
| D | queue_pool.inl | 57 std::shared_ptr <Queue<TYPE>> queue = nullptr; local
82 void QueuePool<TYPE>::Push(std::shared_ptr<Queue<TYPE>> &queue) {
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| D | napi_rdb_statistics_observer.cpp | 22 napi_env env, napi_value callback, std::shared_ptr<AppDataMgrJsKit::UvQueue> queue) in NapiStatisticsObserver()
48 auto queue = queue_; in OnStatistic() local
|
| /foundation/communication/dsoftbus/core/common/include/ |
| D | softbus_queue.h | 71 static inline int32_t QueueIsEmpty(LockFreeQueue* queue) in QueueIsEmpty()
92 static inline int32_t QueueSingleProducerEnqueue(LockFreeQueue *queue, const void *node) in QueueSingleProducerEnqueue()
141 static inline int32_t QueueMultiProducerEnqueue(LockFreeQueue* queue, const void* node) in QueueMultiProducerEnqueue()
205 static inline int32_t QueueSingleConsumerDequeue(LockFreeQueue* queue, void** node) in QueueSingleConsumerDequeue()
258 static inline int32_t QueueMultiConsumerDequeue(LockFreeQueue *queue, void **node) in QueueMultiConsumerDequeue()
|
| /foundation/graphic/graphic_3d/lume/LumeMeta/src/ |
| D | future.h | 55 ITaskQueue::WeakPtr queue; member
98 void SetQueueInfo(const ITaskQueue::Ptr& queue, ITaskQueue::Token token) in SetQueueInfo()
|
| D | future.cpp | 57 IFuture::Ptr Future::Then(const IFutureContinuation::Ptr& func, const ITaskQueue::Ptr& queue) in Then()
155 void Future::SetQueueInfo(const ITaskQueue::Ptr& queue, ITaskQueue::Token token) in SetQueueInfo()
193 void Promise::SetQueueInfo(const ITaskQueue::Ptr& queue, ITaskQueue::Token token) in SetQueueInfo()
|
| /foundation/graphic/graphic_3d/lume/LumeMeta/include/meta/api/ |
| D | timer.h | 160 ITaskQueue::Ptr queue; in META_BEGIN_NAMESPACE() member
173 …TaskQueue::Token SingleShotTimer(const TimeSpan& interval, Func func, const ITaskQueue::Ptr& queue) in SingleShotTimer()
|
| D | event_handler.h | 149 auto queue = GetTaskQueueRegistry().GetTaskQueue(queueId); in META_BEGIN_NAMESPACE() local
|
| D | task_queue.h | 37 auto AddFutureTaskOrRunDirectly(const ITaskQueue::Ptr& queue, Func&& func) in AddFutureTaskOrRunDirectly()
|
| /foundation/window/window_manager/window_scene/session_manager/include/ |
| D | ffrt_queue_helper.h | 22 class queue; variable
|
| /foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/event/ |
| D | wifi_direct_event_sender.h | 23 explicit WifiDirectEventSender(WifiDirectEventQueue *queue) : queue_(queue) {} in WifiDirectEventSender()
|
| D | wifi_direct_event_dispatcher.cpp | 19 WifiDirectEventDispatcher::WifiDirectEventDispatcher(WifiDirectEventQueue *queue) in WifiDirectEventDispatcher()
|
| /foundation/communication/dsoftbus/core/connection/br/src/ |
| D | softbus_conn_br_send_queue.c | 37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBrQueue() local
58 static void DestroyBrQueue(ConnectionQueue *queue) in DestroyBrQueue()
|
| /foundation/communication/dsoftbus/core/connection/ble/src/ |
| D | softbus_conn_ble_send_queue.c | 37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBleQueue() local
58 static void DestroyBleQueue(ConnectionQueue *queue) in DestroyBleQueue()
|