| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/include/ |
| H A D | queue.h | 26 typedef struct Queue Queue; typedef
30 * @brief Perform instantiation of the Queue.
32 * @param capacity Queue's capacity.
33 * @return Succeed return Queue instantiation, failed return NULL.
36 Queue *QueueCreate(uint32_t capacity);
39 * @brief Delete instantiation of the Queue.
41 * @param queue Queue's pointer.
45 void QueueDelete(Queue *queue, NodeDataFreeCb cb);
48 * @brief Enqueue data into Queue
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/ |
| H A D | queue.c | 24 typedef struct Queue { struct
32 Queue *QueueCreate(uint32_t capacity) in QueueCreate()
38 Queue *queue = (Queue *)calloc(1, (sizeof(Queue))); in QueueCreate()
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 *queu
[all...] |
| /foundation/ai/ai_engine/services/common/platform/queuepool/ |
| H A D | queue.h | 27 class Queue { class
28 FORBID_COPY_AND_ASSIGN(Queue);
30 explicit Queue(size_t maxQueueSize);
32 virtual ~Queue();
|
| H A D | queue_pool.h | 36 typedef std::list<std::shared_ptr<Queue<TYPE>>> Queues;
56 std::shared_ptr<Queue<TYPE>> Pop();
63 void Push(std::shared_ptr<Queue<TYPE>> &queue);
|
| /foundation/ai/ai_engine/test/common/queuepool/ |
| H A D | queuepool_test.cpp | 70 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F()
102 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F()
120 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F()
156 std::shared_ptr<Queue<int>> queue; in HWTEST_F()
179 std::shared_ptr<Queue<int>> queue; in HWTEST_F()
197 std::shared_ptr<Queue<int>> queue = queuePool->Pop();
215 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F()
236 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F()
257 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F()
274 std::shared_ptr<Queue<in in HWTEST_F()
[all...] |
| /foundation/ai/ai_engine/services/server/server_executor/include/ |
| H A D | engine_worker.h | 33 explicit EngineWorker(Queue<Task> &queue);
56 Queue<Task> &queue_;
|
| H A D | async_msg_handler.h | 32 AsyncMsgHandler(Queue<Task> &queue, IPlugin *pluginAlgorithm);
68 Queue<Task> &queue_;
|
| H A D | sync_msg_handler.h | 33 SyncMsgHandler(Queue<Task> &queue, IPlugin *pluginAlgorithm);
72 Queue<Task> &queue_;
|
| H A D | engine.h | 37 Engine(std::shared_ptr<Plugin> &plugin, std::shared_ptr<Thread> &thread, std::shared_ptr<Queue<Task>> &queue);
90 std::shared_ptr<Queue<Task>> queue_;
|
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | engine_worker.cpp | 28 EngineWorker::EngineWorker(Queue<Task> &queue) : queue_(queue) in EngineWorker()
32 static void ClearQueue(Queue<Task> &queue) in ClearQueue()
|
| H A D | async_msg_handler.cpp | 28 AsyncMsgHandler::AsyncMsgHandler(Queue<Task> &g_queue, IPlugin *pluginAlgorithm) in AsyncMsgHandler()
|
| H A D | sync_msg_handler.cpp | 28 SyncMsgHandler::SyncMsgHandler(Queue<Task> &queue, IPlugin *pluginAlgorithm) in SyncMsgHandler()
84 HILOGE("[SyncMsgHandler]Queue overload"); in SendRequest()
|
| H A D | engine.cpp | 30 std::shared_ptr<Queue<Task>> &queue) in Engine()
|
| H A D | engine_manager.cpp | 211 std::shared_ptr<Queue<Task>> queue = queuePool->Pop(); in CreateEngine()
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_thread.c | 36 Queue *queue;
61 BtmTask *task = QueueTryDequeue((Queue *)context); in RunTask()
84 Queue *queue;
106 static void RunAllTaskInQueue(Queue *queue) in RunAllTaskInQueue()
207 Queue *taskQueue = NULL; in BTM_DeleteProcessingQueue()
|
| H A D | btm_acl.c | 154 static Queue *g_leWhiteListPendingActionQueue;
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
| H A D | thread_linux.c | 39 Queue *taskQueue;
57 TaskItem *item = (TaskItem *)QueueDequeue((Queue *)queue); in ReadyToRead()
59 LOG_ERROR("Thread: Queue Dequeue failed."); in ReadyToRead()
|
| /foundation/arkui/napi/native_engine/ |
| H A D | native_async_work.h | 58 virtual bool Queue();
|
| H A D | native_async_work.cpp | 44 const std::string TRACE_POINT_QUEUE = "napi::NativeAsyncWork::Queue";
96 bool NativeAsyncWork::Queue() in Queue() function in NativeAsyncWork
|
| H A D | native_node_api.cpp | 160 asyncWork->Queue(); in napi_queue_async_work()
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | task_queue_factory.cpp | 259 class Queue { class in __anon9628::final
385 Queue<Task> q_;
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/ |
| H A D | hci.c | 50 static Queue *g_hciTxQueue = NULL;
51 static Queue *g_hciRxQueue = NULL;
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/gavdp/ |
| H A D | a2dp_profile.h | 626 Queue *packetQueue_ = nullptr; // queue of packets to be sent
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/cmd/ |
| H A D | hci_cmd.c | 52 static Queue *g_cmdCache = NULL;
|