| /ohos5.0/drivers/hdf_core/adapter/khdf/linux/osal/src/ |
| H A D | osal_workqueue.c | 32 int32_t HdfWorkQueueInit(HdfWorkQueue *queue, char *name) in HdfWorkQueueInit()
145 void HdfWorkQueueDestroy(HdfWorkQueue *queue) in HdfWorkQueueDestroy()
158 bool HdfAddWork(HdfWorkQueue *queue, HdfWork *work) in HdfAddWork()
169 bool HdfAddDelayedWork(HdfWorkQueue *queue, HdfWork *work, uint32_t ms) in HdfAddDelayedWork()
|
| /ohos5.0/drivers/hdf_core/framework/test/unittest/model/network/wifi/unittest/message/ |
| H A D | hdf_queue_test.c | 31 PriorityQueue *queue = CreatePriorityQueue(TEST_QUEUE_SIZE, NO_PRIORITY); in MessageQueueTest001() local
80 PriorityQueue *queue = NULL; in MessageQueueTest002() local
137 PriorityQueue *queue = NULL; in MessageQueueTest003() local
|
| /ohos5.0/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()
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/linux/model/network/wifi/platform/src/ |
| H A D | hdf_wlan_queue.c | 59 void DestroyQueue(HdfWlanQueue *queue) in DestroyQueue()
74 void *PopQueue(HdfWlanQueue *queue) in PopQueue()
101 int32_t PushQueue(HdfWlanQueue *queue, void *context) in PushQueue()
|
| /ohos5.0/foundation/ai/ai_engine/services/common/platform/queuepool/ |
| H A D | queue_pool.inl | 57 std::shared_ptr <Queue<TYPE>> queue = nullptr; local
82 void QueuePool<TYPE>::Push(std::shared_ptr<Queue<TYPE>> &queue) {
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/ |
| H A D | timer.h | 160 ITaskQueue::Ptr queue; in META_BEGIN_NAMESPACE() member
173 …TaskQueue::Token SingleShotTimer(const TimeSpan& interval, Func func, const ITaskQueue::Ptr& queue) in SingleShotTimer()
|
| H A D | event_handler.h | 147 auto queue = GetTaskQueueRegistry().GetTaskQueue(queueId); in META_BEGIN_NAMESPACE() local
|
| H A D | task_queue.h | 40 auto AddFutureTaskOrRunDirectly(const ITaskQueue::Ptr& queue, Func func) in AddFutureTaskOrRunDirectly()
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/include/ |
| H A 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()
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/linux/model/camera/src/ |
| H A D | camera_buffer_manager_adapter.c | 85 void MemoryAdapterQueueImpInit(struct BufferQueue *queue) in MemoryAdapterQueueImpInit()
95 void MemoryAdapterDriverMutexLock(struct BufferQueue *queue) in MemoryAdapterDriverMutexLock()
105 void MemoryAdapterDriverMutexUnLock(struct BufferQueue *queue) in MemoryAdapterDriverMutexUnLock()
|
| /ohos5.0/foundation/bundlemanager/app_domain_verify/test/unittest/mock/include/mock_ffrt/ |
| H A D | ffrt.h | 22 queue(std::string name){}; in queue() function
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/linux/model/camera/include/ |
| H A D | sg_dma.h | 21 struct BufferQueue *queue = buffer->bufferQueue; in DmaSgPlaneDesc() local
|
| H A D | contig_dma.h | 20 struct BufferQueue *queue = buffer->bufferQueue; in ContigDmaGetAddr() local
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | future.cpp | 57 IFuture::Ptr Future::Then(const IFutureContinuation::Ptr& func, const ITaskQueue::Ptr& queue) in Then()
155 void Future::SetQueueInfo(const ITaskQueue::Ptr& queue, ITaskQueue::Token token) in SetQueueInfo()
193 void Promise::SetQueueInfo(const ITaskQueue::Ptr& queue, ITaskQueue::Token token) in SetQueueInfo()
|
| H A D | future.h | 54 ITaskQueue::WeakPtr queue; member
118 void SetQueueInfo(const ITaskQueue::Ptr& queue, ITaskQueue::Token token) in SetQueueInfo()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/wifi_direct_cpp/event/ |
| H A D | wifi_direct_event_dispatcher.cpp | 21 WifiDirectEventDispatcher::WifiDirectEventDispatcher(WifiDirectEventQueue *queue) in WifiDirectEventDispatcher()
|
| H A D | wifi_direct_event_sender.h | 23 explicit WifiDirectEventSender(WifiDirectEventQueue *queue) : queue_(queue) {} in WifiDirectEventSender()
|
| /ohos5.0/foundation/multimedia/av_codec/test/unittest/filter_test/ |
| H A D | audio_sink_filter_unit_test.h | 45 void OnLinkedResult(const sptr<AVBufferQueueProducer>& queue, std::shared_ptr<Meta>& meta) in OnLinkedResult()
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/internal/ |
| H A D | breadth_first_iteration.h | 43 BASE_NS::vector<IIterable::ConstPtr> queue; in META_BEGIN_NAMESPACE() local
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/ble/src/ |
| H A D | softbus_conn_ble_send_queue.c | 37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBleQueue() local
58 static void DestroyBleQueue(ConnectionQueue *queue) in DestroyBleQueue()
|
| /ohos5.0/foundation/communication/dsoftbus/core/connection/br/src/ |
| H A D | softbus_conn_br_send_queue.c | 37 ConnectionQueue *queue = (ConnectionQueue *)SoftBusCalloc(sizeof(ConnectionQueue)); in CreateBrQueue() local
58 static void DestroyBrQueue(ConnectionQueue *queue) in DestroyBrQueue()
|
| /ohos5.0/base/powermgr/power_manager/test/apitest/inner_api/ffrt/src/ |
| H A D | ffrt_utils_test.cpp | 75 FFRTQueue queue("test_power_ffrt_queue"); variable
100 FFRTQueue queue("test_power_ffrt_queue"); variable
122 FFRTQueue queue("test_power_ffrt_queue"); variable
|
| /ohos5.0/foundation/ai/intelligent_voice_framework/services/intell_voice_engine/server/wakeup/ |
| H A D | wakeup_source_process.cpp | 43 auto queue = std::make_unique<Uint8ArrayBufferQueue>(); in Init() local
97 for (auto &queue : bufferQueue_) { in Release() local
|
| /ohos5.0/drivers/hdf_core/framework/support/platform/include/can/ |
| H A D | can_mail.h | 21 struct PlatformQueue *queue; member
|
| /ohos5.0/foundation/graphic/graphic_surface/surface/test/unittest/ |
| H A D | consumer_surface_test.cpp | 139 sptr<BufferQueue> queue = new BufferQueue("test", false); variable
155 sptr<BufferQueue> queue = new BufferQueue("test", false); variable
832 sptr<BufferQueue> queue = new BufferQueue("test", false); variable
894 sptr<BufferQueue> queue = new BufferQueue("test", false); variable
914 sptr<BufferQueue> queue = new BufferQueue("test"); variable
933 sptr<BufferQueue> queue = new BufferQueue("test"); variable
952 sptr<BufferQueue> queue = new BufferQueue("test"); variable
971 sptr<BufferQueue> queue = new BufferQueue("test"); variable
1004 sptr<BufferQueue> queue = new BufferQueue("test", false); variable
1049 sptr<BufferQueue> queue = new BufferQueue("test", false); variable
[all …]
|