Home
last modified time | relevance | path

Searched refs:queue (Results 1 - 25 of 662) sorted by relevance

12345678910>>...27

/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/
H A Dqueue.c16 #include "platform/include/queue.h"
35 LOG_WARN("[QueueCreate]queue capacity can't be 0 or less than 0"); in QueueCreate()
38 Queue *queue = (Queue *)calloc(1, (sizeof(Queue))); in QueueCreate() local
39 if (queue != NULL) { in QueueCreate()
40 queue->capacity = capacity; in QueueCreate()
42 queue->mutex = MutexCreate(); in QueueCreate()
43 if (queue->mutex == NULL) { in QueueCreate()
46 queue->enqueueSem = SemaphoreCreate(capacity); in QueueCreate()
47 if (queue->enqueueSem == NULL) { in QueueCreate()
50 queue in QueueCreate()
71 QueueDelete(Queue *queue, NodeDataFreeCb cb) QueueDelete() argument
92 QueueEnqueue(Queue *queue, void *data) QueueEnqueue() argument
105 QueueTryEnqueue(Queue *queue, void *data) QueueTryEnqueue() argument
123 QueueDequeue(Queue *queue) QueueDequeue() argument
141 QueueTryDequeue(Queue *queue) QueueTryDequeue() argument
162 QueueGetEnqueueFd(const Queue *queue) QueueGetEnqueueFd() argument
168 QueueGetDequeueFd(const Queue *queue) QueueGetDequeueFd() argument
174 QueueFlush(Queue* queue, NodeDataFreeCb cb) QueueFlush() argument
186 QueueIsEmpty(Queue* queue) QueueIsEmpty() argument
196 QueueGetSize(Queue *queue) QueueGetSize() argument
[all...]
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/
H A Dlock_free_queue.c31 register LockFreeQueue *queue = (LockFreeQueue *)SAMGR_Malloc(sizeof(LockFreeQueue) + total); in LFQUE_Create() local
32 if (queue == NULL) { in LFQUE_Create()
35 queue->write = 0; in LFQUE_Create()
36 queue->read = 0; in LFQUE_Create()
37 queue->itemSize = size; in LFQUE_Create()
38 queue->totalSize = total; in LFQUE_Create()
39 return queue; in LFQUE_Create()
42 BOOL LFQUE_IsFull(LockFreeQueue *queue) in LFQUE_IsFull() argument
44 uint32 nextWrite = queue->write + 1; in LFQUE_IsFull()
45 if (nextWrite >= queue in LFQUE_IsFull()
51 LFQUE_IsEmpty(LockFreeQueue *queue) LFQUE_IsEmpty() argument
56 LFQUE_Push(LockFreeQueue *queue, const void *element, uint8 pri) LFQUE_Push() argument
88 LFQUE_Pop(LockFreeQueue *queue, void *element, uint8 *pri) LFQUE_Pop() argument
[all...]
H A Dqueue_adapter.c26 LockFreeQueue *queue; member
31 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)SAMGR_Malloc(sizeof(LockFreeBlockQueue)); in QUEUE_Create() local
32 if (queue == NULL) { in QUEUE_Create()
35 queue->queue = LFQUE_Create(size, count); in QUEUE_Create()
36 if (queue->queue == NULL) { in QUEUE_Create()
37 SAMGR_Free(queue); in QUEUE_Create()
40 pthread_mutex_init(&queue->wMutex, NULL); in QUEUE_Create()
41 pthread_mutex_init(&queue in QUEUE_Create()
51 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Put() local
67 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Pop() local
82 LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; QUEUE_Destroy() local
[all...]
/foundation/arkui/ace_engine_lite/frameworks/src/core/stylemgr/test/unittest/common/
H A Dlink_queue_test.cpp28 * @tc.desc: test the init queue success
34 LinkQueue queue; in HWTEST_F() local
35 queue.InitQueue(); in HWTEST_F()
37 EXPECT_TRUE(queue.GetFront() != nullptr); in HWTEST_F()
38 EXPECT_TRUE(queue.GetRear() != nullptr); in HWTEST_F()
39 EXPECT_EQ(queue.LengthQueue(), 0); in HWTEST_F()
41 queue.FreeNode(); in HWTEST_F()
52 LinkQueue queue; in HWTEST_F() local
55 queue.Enqueue("queueTest"); in HWTEST_F()
57 queue in HWTEST_F()
70 LinkQueue queue; HWTEST_F() local
88 LinkQueue queue; HWTEST_F() local
131 LinkQueue queue; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/core/common/include/
H A Dsoftbus_queue.h38 /** @brief Lock free ring queue */
41 uint32_t unitNum; /* queue node limit */
46 uint32_t size; /* queue size */
55 uint32_t size; /* queue size */
62 uintptr_t nodes[0]; /* queue nodes */
67 extern int32_t QueueCountGet(const LockFreeQueue* queue, uint32_t* count);
69 extern int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum);
73 static inline int32_t QueueIsEmpty(LockFreeQueue* queue) in QueueIsEmpty() argument
79 if (queue == NULL) { in QueueIsEmpty()
83 producerTail = queue in QueueIsEmpty()
94 QueueSingleProducerEnqueue(LockFreeQueue *queue, const void *node) QueueSingleProducerEnqueue() argument
143 QueueMultiProducerEnqueue(LockFreeQueue* queue, const void* node) QueueMultiProducerEnqueue() argument
207 QueueSingleConsumerDequeue(LockFreeQueue* queue, void** node) QueueSingleConsumerDequeue() argument
260 QueueMultiConsumerDequeue(LockFreeQueue *queue, void **node) QueueMultiConsumerDequeue() argument
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/
H A Dbtm_thread.c24 #include "platform/include/queue.h"
36 Queue *queue; member
74 block->queue = QueueCreate(size); in AllocProcessingQueue()
75 if (block->queue != NULL) { in AllocProcessingQueue()
77 block->reactorItem = ReactorRegister(reactor, QueueGetDequeueFd(block->queue), block->queue, RunTask, NULL); in AllocProcessingQueue()
84 Queue *queue; member
92 BtmTask *task = QueueTryDequeue(context->queue); in RunAllTaskInQueueTask()
98 task = QueueTryDequeue(context->queue); in RunAllTaskInQueueTask()
106 static void RunAllTaskInQueue(Queue *queue) in RunAllTaskInQueue() argument
123 FreeProcessingQueue(void *queue) FreeProcessingQueue() argument
139 BtmProcessingQueue *queue = NULL; FindProcessingQueueById() local
191 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); BTM_CreateProcessingQueue() local
210 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); BTM_DeleteProcessingQueue() local
234 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); BTM_RunTaskInProcessingQueue() local
[all...]
/foundation/ai/ai_engine/test/common/queuepool/
H A Dqueuepool_test.cpp18 #include "platform/queuepool/queue.h"
48 * @tc.desc: Get singleton of queue pool.
62 * @tc.desc: Pop a queue from queue pool.
70 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F() local
71 ASSERT_NE(queue, nullptr); in HWTEST_F()
78 * @tc.desc: Get the singleton of queue pool and test the number of busy queues.
94 * @tc.desc: Test the number of busy queues when pop a queue.
102 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); in HWTEST_F() local
103 ASSERT_NE(queue, nullpt in HWTEST_F()
120 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
156 std::shared_ptr<Queue<int>> queue; HWTEST_F() local
179 std::shared_ptr<Queue<int>> queue; HWTEST_F() local
215 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
236 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
257 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
274 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
294 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
314 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
340 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
360 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
382 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
411 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
429 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
458 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
490 std::shared_ptr<Queue<int>> queue = queuePool->Pop(); HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/core/common/queue/
H A Dsoftbus_queue.c32 int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum) in QueueInit() argument
34 if (queue == NULL) { in QueueInit()
35 COMM_LOGE(COMM_UTILS, "queue is null"); in QueueInit()
43 (void)memset_s(queue, sizeof(LockFreeQueue), 0, sizeof(LockFreeQueue)); in QueueInit()
45 queue->magic = QUEUE_HEADER_MAGIC; in QueueInit()
46 queue->producer.size = unitNum; in QueueInit()
47 queue->consumer.size = unitNum; in QueueInit()
48 queue->producer.mask = unitNum - 1; in QueueInit()
49 queue->consumer.mask = unitNum - 1; in QueueInit()
50 queue in QueueInit()
77 QueueCountGet(const LockFreeQueue* queue, uint32_t* count) QueueCountGet() argument
105 LockFreeQueue *queue = (LockFreeQueue *)SoftBusCalloc(queueSize); CreateQueue() local
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/include/
H A Dqueue.h41 * @param queue Queue's pointer.
42 * @param cb Free queue node callback.
45 void QueueDelete(Queue *queue, NodeDataFreeCb cb);
50 * @param queue Queue's pointer.
54 void QueueEnqueue(Queue *queue, void *data);
59 * @param queue Queue's pointer.
64 bool QueueTryEnqueue(Queue *queue, void *data);
68 * @param queue Queue's pointer.
72 void *QueueDequeue(Queue *queue);
77 * @param queue Queu
[all...]
/foundation/communication/dsoftbus/tests/core/common/queue/
H A Dqueue_test.cpp54 LockFreeQueue queue; in HWTEST_F() local
57 ret = QueueInit(&queue, INVALID_NUM); in HWTEST_F()
59 ret = QueueInit(&queue, NOT_POWER_OF_2_NUM); in HWTEST_F()
86 LockFreeQueue queue; in HWTEST_F() local
90 ret = QueueCountGet(&queue, nullptr); in HWTEST_F()
102 LockFreeQueue *queue = CreateQueue(INVALID_NUM); in HWTEST_F() local
103 EXPECT_EQ(queue, nullptr); in HWTEST_F()
104 queue = CreateQueue(NOT_POWER_OF_2_NUM); in HWTEST_F()
105 EXPECT_EQ(queue, nullptr); in HWTEST_F()
106 SoftBusFree(queue); in HWTEST_F()
118 LockFreeQueue *queue = CreateQueue(IS_POWER_OF_2_NUM); HWTEST_F() local
[all...]
/foundation/resourceschedule/ffrt/interfaces/inner_api/c/
H A Dqueue_ext.h20 #include "c/queue.h"
29 /* highest priority, should be distributed until the tasks in the queue are completed */
37 /* lowest priority, sorted by handle time, only distribute when there is no other level inside queue. */
42 * @brief Submits a task to a queue, for tasks with the same delay, insert the header.
44 * @param queue Indicates a queue handle.
49 FFRT_C_API void ffrt_queue_submit_head(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr);
52 * @brief Submits a task to the queue, and obtains a task handle, for tasks with the same delay, insert the header.
54 * @param queue Indicates a queue handl
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/
H A Dnapi_uv_queue.cpp56 auto queue = static_cast<NapiUvQueue*>(work->data); in CallFunction()
58 if (queue == nullptr) { in CallFunction()
61 napi_open_handle_scope(queue->env_, &scope); in CallFunction()
68 if (queue->args) { in CallFunction()
69 queue->args(queue->env_, argc, argv); in CallFunction()
73 napi_get_reference_value(queue->env_, queue->callback_, &callback); in CallFunction()
75 napi_get_global(queue->env_, &global); in CallFunction()
77 napi_status status = napi_call_function(queue in CallFunction()
[all...]
/foundation/communication/dsoftbus/core/connection/br/src/
H A Dsoftbus_conn_br_send_queue.c37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBrQueue() local
38 if (queue == NULL) { in CreateBrQueue()
41 queue->pid = pid; in CreateBrQueue()
44 queue->queue[i] = CreateQueue(GetQueueLimit(i)); in CreateBrQueue()
45 if (queue->queue[i] == NULL) { in CreateBrQueue()
49 return queue; in CreateBrQueue()
52 SoftBusFree(queue->queue[ in CreateBrQueue()
58 DestroyBrQueue(ConnectionQueue *queue) DestroyBrQueue() argument
[all...]
/foundation/communication/dsoftbus/core/connection/ble/src/
H A Dsoftbus_conn_ble_send_queue.c37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBleQueue() local
38 if (queue == NULL) { in CreateBleQueue()
41 queue->pid = pid; in CreateBleQueue()
44 queue->queue[i] = CreateQueue(GetQueueLimit(i)); in CreateBleQueue()
45 if (queue->queue[i] == NULL) { in CreateBleQueue()
49 return queue; in CreateBleQueue()
52 SoftBusFree(queue->queue[ in CreateBleQueue()
58 DestroyBleQueue(ConnectionQueue *queue) DestroyBleQueue() argument
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/rdb/src/
H A Dnapi_uv_queue.cpp56 auto queue = static_cast<NapiUvQueue*>(work->data); in CallFunction()
58 napi_open_handle_scope(queue->env_, &scope); in CallFunction()
65 if (queue->args) { in CallFunction()
66 queue->args(queue->env_, argc, argv); in CallFunction()
70 napi_get_reference_value(queue->env_, queue->callback_, &callback); in CallFunction()
72 napi_get_global(queue->env_, &global); in CallFunction()
74 napi_status status = napi_call_function(queue->env_, global, callback, argc, argv, &result); in CallFunction()
78 napi_close_handle_scope(queue in CallFunction()
[all...]
/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_api.cpp16 #include "cpp/queue.h"
36 inline QueueTask* ffrt_queue_submit_base(ffrt_queue_t queue, ffrt_function_header_t* f, bool withHandle, in ffrt_queue_submit_base() argument
39 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return nullptr, "input invalid, queue == nullptr"); in ffrt_queue_submit_base()
41 QueueHandler* handler = static_cast<QueueHandler*>(queue); in ffrt_queue_submit_base()
156 void ffrt_queue_destroy(ffrt_queue_t queue) in ffrt_queue_destroy() argument
158 FFRT_COND_DO_ERR((queue == nullptr), return, "input invalid, queue is nullptr"); in ffrt_queue_destroy()
159 QueueHandler* handler = static_cast<QueueHandler*>(queue); in ffrt_queue_destroy()
164 void ffrt_queue_submit(ffrt_queue_t queue, ffrt_function_header_ argument
172 ffrt_queue_submit_head(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) ffrt_queue_submit_head() argument
180 ffrt_queue_submit_h(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) ffrt_queue_submit_h() argument
189 ffrt_queue_submit_head_h(ffrt_queue_t queue, ffrt_function_header_t* f, const ffrt_task_attr_t* attr) ffrt_queue_submit_head_h() argument
217 ffrt_queue_cancel_all(ffrt_queue_t queue) ffrt_queue_cancel_all() argument
225 ffrt_queue_cancel_and_wait(ffrt_queue_t queue) ffrt_queue_cancel_and_wait() argument
233 ffrt_queue_cancel_by_name(ffrt_queue_t queue, const char* name) ffrt_queue_cancel_by_name() argument
242 ffrt_queue_has_task(ffrt_queue_t queue, const char* name) ffrt_queue_has_task() argument
251 ffrt_queue_is_idle(ffrt_queue_t queue) ffrt_queue_is_idle() argument
259 ffrt_queue_set_eventhandler(ffrt_queue_t queue, void* eventhandler) ffrt_queue_set_eventhandler() argument
309 ffrt_queue_dump(ffrt_queue_t queue, const char* tag, char* buf, uint32_t len, bool history_info) ffrt_queue_dump() argument
318 ffrt_queue_size_dump(ffrt_queue_t queue, ffrt_inner_queue_priority_t priority) ffrt_queue_size_dump() argument
[all...]
/foundation/multimedia/av_codec/test/unittest/video_test/vcodec_framework_test/stable_sample/common/include/
H A Dvcodec_signal.h22 #include <queue>
51 std::queue<uint32_t> inQueue_;
52 std::queue<OH_AVMemory *> inMemoryQueue_;
53 std::queue<OH_AVBuffer *> inBufferQueue_;
57 std::queue<uint32_t> outQueue_;
58 std::queue<OH_AVCodecBufferAttr> outAttrQueue_;
59 std::queue<OH_AVMemory *> outMemoryQueue_;
60 std::queue<OH_AVBuffer *> outBufferQueue_;
133 std::queue<uint32_t> tempIndex; in FlushInQueue()
135 std::queue<OH_AVMemor in FlushInQueue()
[all...]
/foundation/ability/form_fwk/test/unittest/fms_form_serial_queue_test/
H A Dfms_form_serial_queue_test.cpp58 const std::string queueName = "queue"; in HWTEST_F()
59 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); in HWTEST_F() local
63 EXPECT_EQ(true, queue->ScheduleTask(0, task)); in HWTEST_F()
76 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); in HWTEST_F() local
77 EXPECT_NE(nullptr, queue); in HWTEST_F()
83 queue->ScheduleDelayTask(std::make_pair(msg, eventId), 0, task); in HWTEST_F()
96 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); in HWTEST_F() local
97 EXPECT_NE(nullptr, queue); in HWTEST_F()
100 queue->CancelDelayTask(std::make_pair(msg, eventId)); in HWTEST_F()
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/
H A Dtimer.h49 Timer(const TimeSpan& interval, Func func, TimerType type, const ITaskQueue::Ptr& queue) in Timer() argument
51 Start(interval, BASE_NS::move(func), type, queue); in Timer()
76 * @param queue Queue to which the timer task is posted to (this dictates on what thread the func is called).
79 bool Start(const TimeSpan& interval, Func func, TimerType type, const ITaskQueue::Ptr& queue) in Start() argument
81 if (!queue) { in Start()
86 control_->queue = queue; in Start()
88 queue->AddTask(MakeCallback<ITaskQueueTask>([control = control_, type, callback = BASE_NS::move(func)] { in Start()
108 * @param queueId Uid of queue to which the timer task is posted to (this dictates on what thread the func is
124 if (control_->queue in Stop()
160 ITaskQueue::Ptr queue; global() member
173 SingleShotTimer(const TimeSpan& interval, Func func, const ITaskQueue::Ptr& queue) SingleShotTimer() argument
[all...]
H A Devent_handler.h58 const ITaskQueue::Ptr& queue = nullptr) in EventHandler()
60 Subscribe(event, func, queue); in EventHandler()
77 EventHandler(const Event<EventType>& event, Func func, const ITaskQueue::Ptr& queue = nullptr) in EventHandler()
79 Subscribe(event, BASE_NS::move(func), queue); in EventHandler()
122 * @oaram queue Optional queue where 'func' is invoked, if null, invoked directly.
127 const ITaskQueue::Ptr& queue = nullptr) in Subscribe()
129 return queue ? TypelessSubscribe(event, in Subscribe()
132 queue)) in Subscribe()
140 * @param queueId Queue id where 'func' is invoked. Fails if no such queue exist
147 auto queue = GetTaskQueueRegistry().GetTaskQueue(queueId); Subscribe() local
[all...]
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/internal/
H A Dbreadth_first_iteration.h43 BASE_NS::vector<IIterable::ConstPtr> queue; in BreadthFirstOrderIterate()
48 AddToQueue(queue, arg); in BreadthFirstOrderIterate()
56 queue.push_back(ite); in BreadthFirstOrderIterate()
57 while (!queue.empty()) { in BreadthFirstOrderIterate()
58 auto i = queue[0]; in BreadthFirstOrderIterate()
59 queue.erase(queue.begin()); in BreadthFirstOrderIterate()
/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dengine_worker.cpp28 EngineWorker::EngineWorker(Queue<Task> &queue) : queue_(queue) in EngineWorker() argument
32 static void ClearQueue(Queue<Task> &queue) in ClearQueue() argument
34 size_t size = queue.Count(); in ClearQueue()
37 int retCode = queue.PopFront(task); in ClearQueue()
60 HILOGE("[EngineWorker]Fetch task from queue failed. error code is [%d].", retCode); in OneAction()
/foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/
H A Dffrt_utils.cpp26 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask> &tasks, FFRTQueue &queue) in SubmitQueueTasks() argument
32 queue.submit(task); in SubmitQueueTasks()
36 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, FFRTQueue &queue) in SubmitDelayTask() argument
41 return queue.submit_h(task, ffrt::task_attr().delay(us.count())); in SubmitDelayTask()
44 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask &task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue) in SubmitDelayTask() argument
49 return queue->submit_h(task, ffrt::task_attr().delay(us.count())); in SubmitDelayTask()
59 int FFRTUtils::CancelTask(FFRTHandle &handle, FFRTQueue &queue) in CancelTask() argument
61 return queue.cancel(handle); in CancelTask()
64 int FFRTUtils::CancelTask(FFRTHandle &handle, std::shared_ptr<FFRTQueue> queue) in CancelTask() argument
66 return queue in CancelTask()
[all...]
/foundation/multimedia/av_codec/test/moduletest/vcodec/hdrcodec/include/
H A Dhdrcodec_sample.h26 #include <queue>
46 std::queue<uint32_t> inIdxQueue_;
47 std::queue<uint32_t> outIdxQueue_;
48 std::queue<OH_AVCodecBufferAttr> attrQueue_;
49 std::queue<OH_AVMemory *> inBufferQueue_;
50 std::queue<OH_AVMemory *> outBufferQueue_;
/foundation/multimedia/av_codec/test/nativedemo/audio_demo/
H A Davcodec_audio_aac_encoder_demo.h22 #include <queue>
39 std::queue<uint32_t> inQueue_;
40 std::queue<uint32_t> outQueue_;
41 std::queue<OH_AVMemory *> inBufferQueue_;
42 std::queue<OH_AVMemory *> outBufferQueue_;
43 std::queue<OH_AVCodecBufferAttr> attrQueue_;

Completed in 10 milliseconds

12345678910>>...27