| /foundation/arkui/ace_engine/frameworks/bridge/arkts_frontend/koala_projects/incremental/runtime/test/common/ |
| D | MarkableQueue.test.ts | 30 const queue = markableQueue() constant
38 const queue = markableQueue() constant
51 const queue = markableQueue() constant
71 const queue = markableQueue(true) constant
79 const queue = markableQueue(true) constant
92 const queue = markableQueue(true) constant
|
| /foundation/arkui/ace_engine/frameworks/bridge/arkts_frontend/koala_mirror/incremental/runtime/test/common/ |
| D | MarkableQueue.test.ts | 30 const queue = markableQueue() constant
38 const queue = markableQueue() constant
51 const queue = markableQueue() constant
71 const queue = markableQueue(true) constant
79 const queue = markableQueue(true) constant
92 const queue = markableQueue(true) constant
|
| /foundation/arkui/ace_engine/frameworks/bridge/arkts_frontend/koala_projects/incremental/runtime/test-arkts/common/ |
| D | MarkableQueue.test.ts | 31 const queue = markableQueue() constant
39 const queue = markableQueue() constant
52 const queue = markableQueue() constant
72 const queue = markableQueue(true) constant
80 const queue = markableQueue(true) constant
93 const queue = markableQueue(true) constant
|
| /foundation/arkui/ace_engine/frameworks/bridge/arkts_frontend/koala_mirror/incremental/runtime/test-arkts/common/ |
| D | MarkableQueue.test.ts | 31 const queue = markableQueue() constant
39 const queue = markableQueue() constant
52 const queue = markableQueue() constant
72 const queue = markableQueue(true) constant
80 const queue = markableQueue(true) constant
93 const queue = markableQueue(true) constant
|
| /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/ability/form_fwk/test/unittest/form_proxy_test/ |
| D | form_record_report_test.cpp | 97 std::queue<FormRecordReportInfo> queue; variable
116 std::queue<FormRecordReportInfo> queue; variable
135 std::queue<FormRecordReportInfo> queue; variable
154 std::queue<FormRecordReportInfo> queue; variable
173 std::queue<FormRecordReportInfo> queue; variable
192 std::queue<FormRecordReportInfo> queue; variable
211 std::queue<FormRecordReportInfo> queue; variable
230 std::queue<FormRecordReportInfo> queue; variable
|
| /foundation/ability/form_fwk/test/unittest/form_record_report_test/ |
| D | form_record_report_test.cpp | 97 std::queue<FormRecordReportInfo> queue; variable
116 std::queue<FormRecordReportInfo> queue; variable
135 std::queue<FormRecordReportInfo> queue; variable
154 std::queue<FormRecordReportInfo> queue; variable
173 std::queue<FormRecordReportInfo> queue; variable
192 std::queue<FormRecordReportInfo> queue; variable
211 std::queue<FormRecordReportInfo> queue; variable
230 std::queue<FormRecordReportInfo> queue; variable
|
| /foundation/resourceschedule/ffrt/src/queue/ |
| D | queue_api.cpp | 40 inline QueueTask* ffrt_queue_submit_base(ffrt_queue_t queue, ffrt_function_header_t* f, bool withHa… in ffrt_queue_submit_base()
193 void ffrt_queue_destroy(ffrt_queue_t queue) in ffrt_queue_destroy()
201 void ffrt_queue_submit(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) in ffrt_queue_submit()
209 void ffrt_queue_submit_f(ffrt_queue_t queue, ffrt_function_t func, void* arg, const ffrt_task_attr_… in ffrt_queue_submit_f()
216 void ffrt_queue_submit_head(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* … in ffrt_queue_submit_head()
224 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()
233 ffrt_task_handle_t ffrt_queue_submit_h_f(ffrt_queue_t queue, ffrt_function_t func, void* arg, in ffrt_queue_submit_h_f()
241 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()
258 uint64_t ffrt_queue_get_task_cnt(ffrt_queue_t queue) in ffrt_queue_get_task_cnt()
277 void ffrt_queue_cancel_all(ffrt_queue_t queue) in ffrt_queue_cancel_all()
[all …]
|
| /foundation/communication/dsoftbus/core/connection/common/src/ |
| D | softbus_conn_fair_priority_queue.c | 44 LockFreeQueue *queue[CONN_PRIORITY_BUTT]; member
60 static void DestroyPriorityQueue(struct PriorityQueue *queue) in DestroyPriorityQueue()
71 static LockFreeQueue *GetQueue(struct PriorityQueue *queue, ConnPriority priority, bool createIfEmp… in GetQueue()
86 static int32_t Enqueue(struct PriorityQueue *queue, struct ConnQueueItem *item) in Enqueue()
96 static int32_t Dequeue(struct PriorityQueue *queue, ConnPriority least, struct ConnQueueItem **out) in Dequeue()
125 ConnFairPriorityQueue *queue = SoftBusCalloc(sizeof(ConnFairPriorityQueue)); in ConnCreateQueue() local
163 void ConnDestroyQueue(ConnFairPriorityQueue *queue) in ConnDestroyQueue()
181 static struct PriorityQueue *GetOrCreatePriorityQueue(ConnFairPriorityQueue *queue, int32_t id) in GetOrCreatePriorityQueue()
214 int32_t ConnEnqueue(ConnFairPriorityQueue *queue, struct ConnQueueItem *item, int32_t timeoutMs) in ConnEnqueue()
262 static int32_t DequeueInner(ConnFairPriorityQueue *queue, ConnPriority least, struct ConnQueueItem … in DequeueInner()
[all …]
|
| /foundation/ability/form_fwk/test/unittest/fms_form_serial_queue_test/ |
| D | fms_form_serial_queue_test.cpp | 60 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
78 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
98 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
118 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
142 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
|
| /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/distributeddatamgr/pasteboard/framework/test/mock/ |
| D | ffrt_utils_mock.cpp | 25 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask> &tasks, FFRTQueue &queue) in SubmitQueueTasks()
31 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, FFRTQueue &queue) in SubmitDelayTask()
39 …ndle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue) in SubmitDelayTask()
54 int FFRTUtils::CancelTask(FFRTHandle &handle, FFRTQueue &queue) in CancelTask()
61 int FFRTUtils::CancelTask(FFRTHandle &handle, std::shared_ptr<FFRTQueue> &queue) in CancelTask()
|
| /foundation/ability/form_fwk/test/unittest/fms_form_provider_queue_test/ |
| D | fms_form_provider_queue_test.cpp | 60 std::shared_ptr<FormProviderQueue> queue = std::make_shared<FormProviderQueue>(); variable
76 std::shared_ptr<FormProviderQueue> queue = std::make_shared<FormProviderQueue>(); variable
94 std::shared_ptr<FormProviderQueue> queue = std::make_shared<FormProviderQueue>(); variable
|
| /foundation/ability/form_fwk/test/unittest/fms_form_render_queue_test/ |
| D | fms_form_render_queue_test.cpp | 60 std::shared_ptr<FormRenderQueue> queue = std::make_shared<FormRenderQueue>(); variable
76 std::shared_ptr<FormRenderQueue> queue = std::make_shared<FormRenderQueue>(); variable
94 std::shared_ptr<FormRenderQueue> queue = std::make_shared<FormRenderQueue>(); variable
|
| /foundation/ability/form_fwk/test/unittest/fms_form_host_queue_test/ |
| D | fms_form_host_queue_test.cpp | 60 std::shared_ptr<FormHostQueue> queue = std::make_shared<FormHostQueue>(); variable
76 std::shared_ptr<FormHostQueue> queue = std::make_shared<FormHostQueue>(); variable
94 std::shared_ptr<FormHostQueue> queue = std::make_shared<FormHostQueue>(); variable
|
| /foundation/ability/form_fwk/test/unittest/fms_form_mgr_service_queue_test/ |
| D | fms_form_mgr_service_queue_test.cpp | 60 std::shared_ptr<FormMgrQueue> queue = std::make_shared<FormMgrQueue>(); variable
76 std::shared_ptr<FormMgrQueue> queue = std::make_shared<FormMgrQueue>(); variable
94 std::shared_ptr<FormMgrQueue> queue = std::make_shared<FormMgrQueue>(); variable
|
| /foundation/ability/form_fwk/services/src/data_center/form_record/ |
| D | form_record_report.cpp | 47 std::queue<FormRecordReportInfo> queue; in SetFormRecordRecordInfo() local
58 auto &queue = formRecordReportMap_[formId]; in IncreaseUpdateTimes() local
107 auto &queue = entry.second; in HandleFormRefreshCount() local
145 auto &queue = entry.second; in AddNewDayReportInfo() local
|
| /foundation/ability/form_fwk/test/unittest/fms_form_status_mgr_center_test/ |
| D | fms_form_status_queue_test.cpp | 59 std::shared_ptr<FormStatusQueue> queue = std::make_shared<FormStatusQueue>(); variable
79 std::shared_ptr<FormStatusQueue> queue = std::make_shared<FormStatusQueue>(); variable
102 std::shared_ptr<FormStatusQueue> queue = std::make_shared<FormStatusQueue>(); variable
|
| D | fms_form_event_timeout_queue_test.cpp | 59 std::shared_ptr<FormEventTimeoutQueue> queue = std::make_shared<FormEventTimeoutQueue>(); variable
79 std::shared_ptr<FormEventTimeoutQueue> queue = std::make_shared<FormEventTimeoutQueue>(); variable
102 std::shared_ptr<FormEventTimeoutQueue> queue = std::make_shared<FormEventTimeoutQueue>(); variable
|
| /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
|