| /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/resourceschedule/ffrt/src/queue/ |
| D | queue.cpp | 26 void *queue_pophead(struct queue_s *queue) in queue_pophead()
49 int queue_pushtail(struct queue_s *queue, void *object) in queue_pushtail()
68 int queue_init(struct queue_s *queue, unsigned int capacity) in queue_init()
84 void queue_destroy(struct queue_s *queue) in queue_destroy()
96 unsigned int queue_length(struct queue_s *queue) in queue_length()
107 unsigned int queue_pushtail_batch(struct queue_s *queue, void *buf[], unsigned int buf_len) in queue_pushtail_batch()
133 unsigned int queue_pophead_batch(struct queue_s *queue, void *buf[], unsigned int buf_len) in queue_pophead_batch()
194 void queue_pophead_to_gqueue_batch(struct queue_s* queue, unsigned int pop_len, int qos, queue_push… in queue_pophead_to_gqueue_batch()
217 unsigned int queue_capacity(struct queue_s *queue) in queue_capacity()
222 unsigned int queue_prob(struct queue_s *queue) in queue_prob()
|
| D | serial_queue_api.cpp | 34 inline SerialTask* ffrt_queue_submit_base(ffrt_queue_t queue, ffrt_function_header_t* f, bool withH… in ffrt_queue_submit_base()
140 void ffrt_queue_destroy(ffrt_queue_t queue) in ffrt_queue_destroy()
148 void ffrt_queue_submit(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) in ffrt_queue_submit()
156 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()
|
| /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/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/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/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()
|
| D | sync_msg_handler.cpp | 28 SyncMsgHandler::SyncMsgHandler(Queue<Task> &queue, IPlugin *pluginAlgorithm) in SyncMsgHandler()
|
| D | engine.cpp | 30 std::shared_ptr<Queue<Task>> &queue) in Engine()
|
| /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/communication/dsoftbus/core/common/include/ |
| D | softbus_queue.h | 73 static inline int32_t QueueIsEmpty(LockFreeQueue* queue) in QueueIsEmpty()
94 static inline int32_t QueueSingleProducerEnqueue(LockFreeQueue *queue, const void *node) in QueueSingleProducerEnqueue()
143 static inline int32_t QueueMultiProducerEnqueue(LockFreeQueue* queue, const void* node) in QueueMultiProducerEnqueue()
207 static inline int32_t QueueSingleConsumerDequeue(LockFreeQueue* queue, void** node) in QueueSingleConsumerDequeue()
260 static inline int32_t QueueMultiConsumerDequeue(LockFreeQueue *queue, void **node) in QueueMultiConsumerDequeue()
|
| /foundation/communication/dsoftbus/core/connection/ble/src/ |
| D | softbus_conn_ble_send_queue.c | 36 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBleQueue() local
57 static void DestroyBleQueue(ConnectionQueue *queue) in DestroyBleQueue()
|
| /foundation/communication/dsoftbus/core/connection/br/src/ |
| D | softbus_conn_br_send_queue.c | 36 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBrQueue() local
57 static void DestroyBrQueue(ConnectionQueue *queue) in DestroyBrQueue()
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| D | cpuworker_manager.cpp | 111 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(thread)->localFifo); in PickUpTaskBatch() local
141 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(thread)->localFifo); in TryMoveLocal2Global() local
161 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(iter->first)->localFifo); in StealTaskBatch() local
|
| /foundation/communication/dsoftbus/core/connection/wifi_direct/utils/ |
| D | wifi_direct_timer_list.c | 60 struct WifiDirectWorkQueue *queue = GetWifiDirectWorkQueue(); in WorkHandler() local
88 struct WifiDirectWorkQueue *queue = GetWifiDirectWorkQueue(); in StartTimer() local
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| D | task_queue.cpp | 36 TaskQueue::ExecuteAsyncTask::ExecuteAsyncTask(TaskQueue& queue) : queue_(queue) {} in ExecuteAsyncTask()
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler/ |
| D | event_queue.h | 221 std::list<InnerEvent::Pointer> queue; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| D | task_pool_impl.cpp | 163 Task TaskPoolImpl::ReapTask(TaskQueue *&queue) in ReapTask()
187 void TaskPoolImpl::GetTask(Task &task, TaskQueue *&queue) in GetTask()
|
| /foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/common/ |
| D | uv_queue.cpp | 33 auto queue = entry->uvQueue_.lock(); in ExecUvWork() local
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| D | napi_uv_queue.cpp | 56 auto queue = static_cast<NapiUvQueue*>(work->data); in CallFunction() local
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/rdb/src/ |
| D | napi_uv_queue.cpp | 56 auto queue = static_cast<NapiUvQueue*>(work->data); in CallFunction() local
|