| /foundation/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/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/communication/bluetooth/services/bluetooth/stack/src/btm/ |
| D | btm_thread.c | 35 Queue *queue; member
83 Queue *queue; member
105 static void RunAllTaskInQueue(Queue *queue) in RunAllTaskInQueue()
122 static void FreeProcessingQueue(void *queue) in FreeProcessingQueue()
138 BtmProcessingQueue *queue = NULL; in FindProcessingQueueById() local
190 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_CreateProcessingQueue() local
209 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_DeleteProcessingQueue() local
232 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_RunTaskInProcessingQueue() local
|
| /foundation/communication/dsoftbus/core/common/queue/ |
| D | softbus_queue.c | 30 int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum) in QueueInit()
71 int32_t QueueCountGet(const LockFreeQueue* queue, uint32_t* count) in QueueCountGet()
98 LockFreeQueue *queue = (LockFreeQueue *)SoftBusCalloc(queueSize); in CreateQueue() local
|
| /foundation/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()
|
| D | engine_manager.cpp | 211 std::shared_ptr<Queue<Task>> queue = queuePool->Pop(); in CreateEngine() local
|
| /foundation/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/connection/ble/src/ |
| D | softbus_ble_queue.c | 39 LockFreeQueue *queue[QUEUE_NUM_PER_PID]; member
61 BleQueue *queue = (BleQueue *)SoftBusCalloc(sizeof(BleQueue)); in CreateBleQueue() local
82 static void DestroyBleQueue(BleQueue *queue) in DestroyBleQueue()
151 static int GetMsg(BleQueue *queue, void **msg) in GetMsg()
|
| /foundation/communication/dsoftbus/core/common/include/ |
| D | softbus_queue.h | 74 static inline int32_t QueueIsEmpty(LockFreeQueue* queue) in QueueIsEmpty()
95 static inline int32_t QueueSingleProducerEnqueue(LockFreeQueue *queue, const void *node) in QueueSingleProducerEnqueue()
144 static inline int32_t QueueMultiProducerEnqueue(LockFreeQueue* queue, const void* node) in QueueMultiProducerEnqueue()
208 static inline int32_t QueueSingleConsumerDequeue(LockFreeQueue* queue, void** node) in QueueSingleConsumerDequeue()
261 static inline int32_t QueueMultiConsumerDequeue(LockFreeQueue *queue, void **node) in QueueMultiConsumerDequeue()
|
| /foundation/communication/dsoftbus/core/connection/br/src/ |
| D | br_connection_queue.c | 47 LockFreeQueue *queue[QUEUE_NUM_PER_PID]; member
64 BrQueue *queue = (BrQueue *)SoftBusCalloc(sizeof(BrQueue)); in CreateBrQueue() local
85 static void DestroyBrQueue(BrQueue *queue) in DestroyBrQueue()
229 static int32_t GetMsg(BrQueue *queue, void **msg, bool *isFull) in GetMsg()
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler/ |
| D | event_queue.h | 221 std::list<InnerEvent::Pointer> queue; member
|
| /foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/common/ |
| D | uv_queue.cpp | 58 auto queue = static_cast<UvQueue *>(work->data); in CallFunction() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| D | task_pool_impl.cpp | 164 Task TaskPoolImpl::ReapTask(TaskQueue *&queue) in ReapTask()
188 int TaskPoolImpl::GetTask(Task &task, TaskQueue *&queue) in GetTask()
|
| /foundation/distributeddatamgr/preferences/frameworks/native/src/ |
| D | task_pool.cpp | 178 Task TaskPool::ReapTask(TaskQueue *&queue) in ReapTask()
203 int TaskPool::GetTask(Task &task, TaskQueue *&queue) in GetTask()
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| D | napi_uv_queue.cpp | 55 auto queue = static_cast<NapiUvQueue*>(work->data); in CallFunction() local
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/rdb/src/ |
| D | napi_uv_queue.cpp | 55 auto queue = static_cast<NapiUvQueue*>(work->data); in CallFunction() local
|
| /foundation/resourceschedule/work_scheduler/services/native/src/ |
| D | work_policy_manager.cpp | 238 auto queue = uidQueueMap_.at(uid); in StopAndClearWorks() local
455 auto queue = uidQueueMap_.at(uid); in ObtainAllWorks() local
468 auto queue = uidQueueMap_.at(uid); in GetWorkStatus() local
|
| /foundation/arkui/ace_engine_lite/frameworks/src/core/stylemgr/ |
| D | condition_arbitrator.cpp | 58 LinkQueue queue; in Decide() local
417 void ConditionArbitrator::TransformExpression(const LinkQueue *queue, LinkQueue *expressionQueue) c… in TransformExpression() argument
|
| /foundation/communication/bluetooth/services/bluetooth/stack/platform/linux/ |
| D | thread_linux.c | 54 static void ReadyToRead(void *queue) in ReadyToRead()
|
| /foundation/graphic/graphic_2d/frameworks/vulkan_wrapper/src/ |
| D | driver.cpp | 285 VkQueue queue, in GetNativeFenceFdOpenHarmony()
|