| /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_standard/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()
|
| /foundation/distributedschedule/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/appexecfwk/standard/test/systemtest/common/ems/ems_event_queue_system_test/ |
| D | ems_event_queue_system_test.cpp | 65 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
86 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
102 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
114 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
128 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
|
| /foundation/communication/bluetooth/services/bluetooth_standard/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/communication/dsoftbus/core/connection/ble/src/ |
| D | softbus_ble_queue.c | 39 LockFreeQueue *queue[QUEUE_NUM_PER_PID]; member
60 BleQueue *queue = (BleQueue *)SoftBusCalloc(sizeof(BleQueue)); in CreateBleQueue() local
81 static void DestroyBleQueue(BleQueue *queue) in DestroyBleQueue()
138 static int GetMsg(BleQueue *queue, void **msg) in GetMsg()
|
| /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/graphic/utils/frameworks/ |
| D | queue.c | 29 int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum) in QueueInit()
70 int32_t QueueCountGet(const LockFreeQueue* queue, uint32_t* count) in QueueCountGet()
|
| /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/appexecfwk/standard/libs/libeventhandler/test/unittest/ |
| D | lib_event_handler_event_queue_test.cpp | 100 static void GetEventAndCompare(uint32_t eventId, EventQueue &queue) in GetEventAndCompare()
125 EventQueue queue; in DelayTest() local
158 EventQueue queue; in InsertPriorityTest() local
200 static void BreakQueueTest(EventQueue &queue, uint32_t eventId) in BreakQueueTest()
220 static void InsertAndGet(EventQueue &queue, InnerEvent::Pointer &event) in InsertAndGet()
238 static void InsertPriorityEvent(EventQueue &queue, size_t length) in InsertPriorityEvent()
267 static void InsertAllPriorityEvent(EventQueue &queue) in InsertAllPriorityEvent()
382 EventQueue queue; variable
406 EventQueue queue; variable
430 EventQueue queue; variable
[all …]
|
| /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/graphic/utils/interfaces/innerkits/ |
| D | queue.h | 72 static inline int32_t QueueIsEmpty(LockFreeQueue* queue) in QueueIsEmpty()
93 static inline int32_t QueueSingleProducerEnqueue(LockFreeQueue *queue, void *node) in QueueSingleProducerEnqueue()
142 static inline uint32_t QueueMultiProducerEnqueue(LockFreeQueue* queue, void* node) in QueueMultiProducerEnqueue()
206 static inline uint32_t QueueSingleConsumerDequeue(LockFreeQueue* queue, void** node) in QueueSingleConsumerDequeue()
259 static inline uint32_t QueueMultiConsumerDequeue(LockFreeQueue *queue, void **node) in QueueMultiConsumerDequeue()
|
| /foundation/appexecfwk/standard/interfaces/innerkits/libeventhandler/include/ |
| D | event_queue.h | 220 std::list<InnerEvent::Pointer> queue; member
|
| /foundation/distributeddatamgr/objectstore/frameworks/jskitsimpl/src/common/ |
| D | uv_queue.cpp | 58 auto queue = static_cast<UvQueue *>(work->data); in CallFunction() local
|
| /foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/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/appdatamgr/frameworks/innerkitsimpl/native_preferences/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/appdatamgr/frameworks/jskitsimpl/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 | 185 auto queue = uidQueueMap_.at(uid); in StopAndClearWorks() local
372 auto queue = uidQueueMap_.at(uid); in ObtainAllWorks() local
386 auto queue = uidQueueMap_.at(uid); in GetWorkStatus() local
|
| /foundation/communication/bluetooth/services/bluetooth_standard/stack/platform/linux/ |
| D | thread_linux.c | 54 static void ReadyToRead(void *queue) in ReadyToRead()
|
| /foundation/multimedia/media_standard/services/engine/gstreamer/plugins/source/common/ |
| D | gst_shmem_pool_src.cpp | 52 GstQueueArray *queue; member
|