| /ohos5.0/foundation/ai/ai_engine/test/common/queuepool/ |
| H A 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 …]
|
| /ohos5.0/drivers/hdf_core/framework/utils/src/ |
| H A D | hdf_task_queue.c | 18 static int32_t HdfCreateThread(struct HdfTaskQueue *queue) in HdfCreateThread()
33 struct HdfTaskQueue *queue = NULL; in HdfTaskQueueCreate() local
77 static void HdfQueueStopThread(struct HdfTaskQueue *queue) in HdfQueueStopThread()
94 void HdfTaskQueueDestroy(struct HdfTaskQueue *queue) in HdfTaskQueueDestroy()
103 static void HdfQueueStartThread(struct HdfTaskQueue *queue) in HdfQueueStartThread()
119 void HdfTaskEnqueue(struct HdfTaskQueue *queue, struct HdfTaskType *task) in HdfTaskEnqueue()
152 static struct HdfTaskType *HdfTaskDequeue(struct HdfTaskQueue *queue) in HdfTaskDequeue()
168 struct HdfTaskQueue *queue = (struct HdfTaskQueue *)data; in HdfThreadTasker() local
|
| H A D | osal_msg_queue.c | 13 void OsalMessageQueueInit(struct HdfMessageQueue *queue) in OsalMessageQueueInit()
22 void OsalMessageQueueDestroy(struct HdfMessageQueue *queue) in OsalMessageQueueDestroy()
32 struct HdfMessageQueue *queue, struct HdfMessage *message, long delayed) in HdfMessageQueueEnqueue()
57 struct HdfMessage* HdfMessageQueueNext(struct HdfMessageQueue *queue) in HdfMessageQueueNext()
79 void HdfMessageQueueFlush(struct HdfMessageQueue *queue) in HdfMessageQueueFlush()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/platform/src/ |
| H A 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 …]
|
| /ohos5.0/drivers/hdf_core/framework/model/camera/buffer_manager/src/ |
| H A D | camera_buffer_manager.c | 21 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferDone() local
49 int32_t BufferQueueFindPlaneByOffset(struct BufferQueue *queue, in BufferQueueFindPlaneByOffset()
76 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferGetPlaneVaddr() local
89 int32_t BufferQueueInit(struct BufferQueue *queue) in BufferQueueInit()
126 int32_t BufferQueueRequest(struct BufferQueue *queue, struct UserCameraReq *userRequest) in BufferQueueRequest()
177 int32_t BufferQueueQueryBuffer(struct BufferQueue *queue, struct UserCameraBuffer *userBuffer) in BufferQueueQueryBuffer()
238 static int32_t WaitForDoneBuffer(struct BufferQueue *queue, uint32_t blocking) in WaitForDoneBuffer()
270 static int32_t GetDoneBuffer(struct BufferQueue *queue, in GetDoneBuffer()
328 int32_t BufferQueueStreamOn(struct BufferQueue *queue) in BufferQueueStreamOn()
347 int32_t BufferQueueStreamOff(struct BufferQueue *queue) in BufferQueueStreamOff()
[all …]
|
| H A D | buffer_queue.c | 20 void BufferQueueStop(struct BufferQueue *queue) in BufferQueueStop()
51 static int32_t BufferQueueCheckMmapOps(struct BufferQueue *queue) in BufferQueueCheckMmapOps()
60 static int32_t BufferQueueCheckUserPtrOps(struct BufferQueue *queue) in BufferQueueCheckUserPtrOps()
69 static int32_t BufferQueueCheckDmaBufOps(struct BufferQueue *queue) in BufferQueueCheckDmaBufOps()
79 int32_t BufferQueueCheckMemOps(struct BufferQueue *queue, enum CameraMemType memType) in BufferQueueCheckMemOps()
100 static int32_t BufferQueueFree(struct BufferQueue *queue, uint32_t count) in BufferQueueFree()
132 int32_t BufferQueueReleaseBuffers(struct BufferQueue *queue, struct UserCameraReq *userRequest) in BufferQueueReleaseBuffers()
156 static int32_t BufferQueueAllocBuffers(struct BufferQueue *queue, uint32_t memType, in BufferQueueAllocBuffers()
201 int32_t BufferQueueRequestBuffers(struct BufferQueue *queue, struct UserCameraReq *userRequest, in BufferQueueRequestBuffers()
236 int32_t BufferQueueStart(struct BufferQueue *queue) in BufferQueueStart()
[all …]
|
| H A D | camera_buffer.c | 21 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferSyncForUser() local
40 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferFreeMmapPlanes() local
53 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferFreeUserPtrPlanes() local
67 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferFreeDmaPlane() local
95 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferFree() local
107 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferAllocMmapPlane() local
133 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferAllocMmapPlanes() local
157 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferSetupOffsets() local
233 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferEnqueue() local
245 struct BufferQueue *queue = buffer->bufferQueue; in CameraBufferQueueBuffer() local
[all …]
|
| /ohos5.0/drivers/hdf_core/framework/support/platform/src/fwk/ |
| H A D | platform_queue.c | 21 static void PlatformQueueDoDestroy(struct PlatformQueue *queue) in PlatformQueueDoDestroy()
29 static int32_t PlatformQueueNextMsg(struct PlatformQueue *queue, struct PlatformMsg **msg) in PlatformQueueNextMsg()
51 struct PlatformQueue *queue = (struct PlatformQueue *)data; in PlatformQueueWorker() local
78 struct PlatformQueue *queue = NULL; in PlatformQueueCreate() local
99 int32_t PlatformQueueStart(struct PlatformQueue *queue) in PlatformQueueStart()
131 void PlatformQueueDestroy(struct PlatformQueue *queue) in PlatformQueueDestroy()
150 int32_t PlatformQueueAddMsg(struct PlatformQueue *queue, struct PlatformMsg *msg) in PlatformQueueAddMsg()
173 int32_t PlatformQueueGetMsg(struct PlatformQueue *queue, struct PlatformMsg **msg, uint32_t tms) in PlatformQueueGetMsg()
|
| /ohos5.0/foundation/arkui/ace_engine_lite/frameworks/src/core/stylemgr/test/unittest/common/ |
| H A 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
|
| /ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| H A 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()
|
| H A 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
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/liteos/model/network/wifi/platform/src/ |
| H A D | hdf_wlan_queue.c | 37 HdfWlanQueue queue; member
43 HdfWlanQueueImpl *queue = (HdfWlanQueueImpl *)OsalMemCalloc(sizeof(HdfWlanQueueImpl)); in CreateQueue() local
56 void DestroyQueue(HdfWlanQueue *queue) in DestroyQueue()
69 void *PopQueue(HdfWlanQueue *queue) in PopQueue()
86 int32_t PushQueue(HdfWlanQueue *queue, void *context) in PushQueue()
|
| /ohos5.0/base/notification/eventhandler/frameworks/eventhandler/src/ |
| H A D | event_queue_ffrt.cpp | 110 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in RemoveOrphanByHandlerId() local
133 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in RemoveAll() local
157 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove() local
181 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove() local
206 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove() local
230 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove() local
253 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in HasInnerEvent() local
275 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in HasInnerEvent() local
295 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Dump() local
318 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in DumpQueueInfo() local
[all …]
|
| /ohos5.0/base/startup/appspawn/modules/sandbox/ |
| H A D | appspawn_permission.c | 52 int AddSandboxPermissionNode(const char *name, SandboxQueue *queue) in AddSandboxPermissionNode()
81 int32_t DeleteSandboxPermissions(SandboxQueue *queue) in DeleteSandboxPermissions()
100 int32_t PermissionRenumber(SandboxQueue *queue) in PermissionRenumber()
120 const SandboxPermissionNode *GetPermissionNodeInQueue(SandboxQueue *queue, const char *permission) in GetPermissionNodeInQueue()
132 const SandboxPermissionNode *GetPermissionNodeInQueueByIndex(SandboxQueue *queue, int32_t index) in GetPermissionNodeInQueueByIndex()
144 int32_t GetPermissionIndexInQueue(SandboxQueue *queue, const char *permission) in GetPermissionIndexInQueue()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/common/queue/ |
| H A D | queue_test.cpp | 54 LockFreeQueue queue; variable
86 LockFreeQueue queue; variable
102 LockFreeQueue *queue = CreateQueue(INVALID_NUM); variable
118 LockFreeQueue *queue = CreateQueue(IS_POWER_OF_2_NUM); variable
|
| /ohos5.0/base/notification/eventhandler/test/systemtest/ems_event_queue_system_test/ |
| H A D | ems_event_queue_system_test.cpp | 66 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); variable
87 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); variable
103 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); variable
115 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); variable
129 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); variable
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_thread.c | 36 Queue *queue; member
84 Queue *queue; member
106 static void RunAllTaskInQueue(Queue *queue) in RunAllTaskInQueue()
123 static void FreeProcessingQueue(void *queue) in FreeProcessingQueue()
139 BtmProcessingQueue *queue = NULL; in FindProcessingQueueById() local
191 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_CreateProcessingQueue() local
210 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_DeleteProcessingQueue() local
234 BtmProcessingQueue *queue = FindProcessingQueueById(queueId); in BTM_RunTaskInProcessingQueue() local
|
| /ohos5.0/base/notification/eventhandler/frameworks/eventhandler/test/unittest/ |
| H A D | lib_event_handler_event_queue_test.cpp | 130 EventQueueBase queue; in DelayTest() local
163 EventQueueBase queue; in InsertPriorityTest() local
387 EventQueueBase queue; variable
411 EventQueueBase queue; variable
435 EventQueueBase queue; variable
565 EventQueueBase queue; variable
592 EventQueueBase queue; variable
634 EventQueueBase queue; variable
685 EventQueueBase queue; variable
760 EventQueueBase queue; variable
[all …]
|
| /ohos5.0/foundation/ability/form_fwk/test/unittest/fms_form_serial_queue_test/ |
| H A D | fms_form_serial_queue_test.cpp | 59 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
76 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
96 std::shared_ptr<FormSerialQueue> queue = std::make_shared<FormSerialQueue>(queueName.c_str()); variable
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/queue/ |
| H A D | softbus_queue.c | 32 int32_t QueueInit(LockFreeQueue* queue, uint32_t unitNum) in QueueInit()
77 int32_t QueueCountGet(const LockFreeQueue* queue, uint32_t* count) in QueueCountGet()
105 LockFreeQueue *queue = (LockFreeQueue *)SoftBusCalloc(queueSize); in CreateQueue() local
|
| /ohos5.0/foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/ |
| H A D | ffrt_utils.cpp | 26 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask>& tasks, FFRTQueue& queue) in SubmitQueueTasks()
36 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, FFRTQueue& queue) in SubmitDelayTask()
44 …ndle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue) in SubmitDelayTask()
59 int FFRTUtils::CancelTask(FFRTHandle& handle, FFRTQueue& queue) in CancelTask()
64 int FFRTUtils::CancelTask(FFRTHandle& handle, std::shared_ptr<FFRTQueue> queue) in CancelTask()
|
| /ohos5.0/drivers/hdf_core/framework/model/network/wifi/platform/src/ |
| H A D | hdf_wlan_priority_queue.c | 66 void DestroyPriorityQueue(PriorityQueue *queue) in DestroyPriorityQueue()
92 int32_t PushPriorityQueue(PriorityQueue *queue, const uint8_t priority, void *context) in PushPriorityQueue()
118 static void *PopQueueByPri(PriorityQueueImpl *queue) in PopQueueByPri()
131 void *PopPriorityQueue(PriorityQueue *queue, uint32_t waitInMS) in PopPriorityQueue()
|
| /ohos5.0/base/security/device_security_level/baselib/utils/src/ |
| H A D | utils_work_queue.c | 51 WorkQueue *queue = (WorkQueue *)data; in WorkQueueThread() local
93 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); in CreateWorkQueue() local
132 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); in CreateWorkQueue() local
189 uint32_t DestroyWorkQueue(WorkQueue *queue) in DestroyWorkQueue()
213 uint32_t QueueWork(WorkQueue *queue, WorkProcess process, uint8_t *data, uint32_t length) in QueueWork()
|
| /ohos5.0/base/powermgr/power_manager/utils/ffrt/src/ |
| H A D | ffrt_utils.cpp | 32 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask>& tasks, FFRTQueue& queue) in SubmitQueueTasks()
42 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, FFRTQueue& queue) in SubmitDelayTask()
50 …ndle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue) in SubmitDelayTask()
65 int FFRTUtils::CancelTask(FFRTHandle& handle, FFRTQueue& queue) in CancelTask()
70 int FFRTUtils::CancelTask(FFRTHandle& handle, std::shared_ptr<FFRTQueue> queue) in CancelTask()
|
| /ohos5.0/drivers/hdf_core/adapter/khdf/liteos/osal/src/ |
| H A D | osal_workqueue.c | 44 int32_t HdfWorkQueueInit(HdfWorkQueue *queue, char *name) in HdfWorkQueueInit()
151 void HdfWorkQueueDestroy(HdfWorkQueue *queue) in HdfWorkQueueDestroy()
163 bool HdfAddWork(HdfWorkQueue *queue, HdfWork *work) in HdfAddWork()
173 bool HdfAddDelayedWork(HdfWorkQueue *queue, HdfWork *work, uint32_t ms) in HdfAddDelayedWork()
|