| /base/telephony/core_service/test/mock/ffrt/inner_api/c/ |
| D | queue_ext.h | 41 inline FFRT_C_API bool ffrt_queue_has_task(ffrt_queue_t queue, const char *name) in ffrt_queue_has_task()
46 inline FFRT_C_API void ffrt_queue_cancel_all(ffrt_queue_t queue) in ffrt_queue_cancel_all()
49 inline FFRT_C_API void ffrt_queue_cancel_and_wait(ffrt_queue_t queue) in ffrt_queue_cancel_and_wait()
52 inline FFRT_C_API int ffrt_queue_cancel_by_name(ffrt_queue_t queue, const char *name) in ffrt_queue_cancel_by_name()
57 inline FFRT_C_API bool ffrt_queue_is_idle(ffrt_queue_t queue) in ffrt_queue_is_idle()
62 inline FFRT_C_API int ffrt_queue_dump(ffrt_queue_t queue, const char *tag, char *buf, uint32_t len,… in ffrt_queue_dump()
67 inline FFRT_C_API int ffrt_queue_size_dump(ffrt_queue_t queue, ffrt_inner_queue_priority_t priority) in ffrt_queue_size_dump()
72 inline FFRT_C_API void ffrt_queue_set_eventhandler(ffrt_queue_t queue, void *eventhandler) in ffrt_queue_set_eventhandler()
80 inline FFRT_C_API int ffrt_concurrent_queue_wait_all(ffrt_queue_t queue) in ffrt_concurrent_queue_wait_all()
|
| /base/startup/appspawn/modules/sandbox/ |
| 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(const SandboxQueue *queue, const char *permis… in GetPermissionNodeInQueue()
132 const SandboxPermissionNode *GetPermissionNodeInQueueByIndex(const SandboxQueue *queue, int32_t ind… in GetPermissionNodeInQueueByIndex()
144 int32_t GetPermissionIndexInQueue(const SandboxQueue *queue, const char *permission) in GetPermissionIndexInQueue()
|
| /base/notification/eventhandler/frameworks/eventhandler/src/ |
| D | event_queue_ffrt.cpp | 59 inline ffrt_queue_t* TransferQueuePtr(std::shared_ptr<ffrt::queue> queue) in TransferQueuePtr()
115 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in RemoveOrphanByHandlerId() local
138 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in RemoveAll() local
162 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove() local
186 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove() local
211 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove() local
235 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Remove() local
258 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in HasInnerEvent() local
280 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in HasInnerEvent() local
300 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); in Dump() local
[all …]
|
| D | event_queue.cpp | 198 auto queue = runner->GetEventQueue(); in PostTaskForVsync() local
250 auto queue = EventRunner::Current()->GetEventQueue(); in HandleFileDescriptorEvent() local
|
| /base/notification/eventhandler/frameworks/eventhandler/test/unittest/ |
| D | lib_event_handler_event_queue_test.cpp | 108 static void GetEventAndCompare(uint32_t eventId, EventQueue &queue) in GetEventAndCompare()
133 EventQueueBase queue; in DelayTest() local
164 EventQueueBase queue; in InsertPriorityTest() local
206 static void BreakQueueTest(EventQueue &queue, uint32_t eventId) in BreakQueueTest()
226 static void InsertAndGet(EventQueue &queue, InnerEvent::Pointer &event) in InsertAndGet()
244 static void InsertPriorityEvent(EventQueue &queue, size_t length) in InsertPriorityEvent()
273 static void InsertAllPriorityEvent(EventQueue &queue) in InsertAllPriorityEvent()
413 EventQueueBase queue; variable
437 EventQueueBase queue; variable
461 EventQueueBase queue; variable
[all …]
|
| /base/notification/eventhandler/test/systemtest/ems_event_queue_system_test/ |
| 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
|
| /base/telephony/core_service/test/mock/ffrt/kits/c/ |
| D | queue.h | 85 inline FFRT_C_API void ffrt_queue_destroy(ffrt_queue_t queue) in ffrt_queue_destroy()
88 inline FFRT_C_API void ffrt_queue_submit(ffrt_queue_t queue, ffrt_function_header_t *f, const ffrt_… in ffrt_queue_submit()
92 ffrt_queue_t queue, ffrt_function_header_t *f, const ffrt_task_attr_t *attr) in ffrt_queue_submit_h()
98 ffrt_queue_t queue, ffrt_function_t func, void *arg, const ffrt_task_attr_t *attr) in ffrt_queue_submit_f()
102 ffrt_queue_t queue, ffrt_function_t func, void *arg, const ffrt_task_attr_t *attr) in ffrt_queue_submit_h_f()
125 inline FFRT_C_API uint64_t ffrt_queue_get_task_cnt(ffrt_queue_t queue) in ffrt_queue_get_task_cnt()
131 ffrt_queue_t queue, ffrt_function_header_t *f, const ffrt_task_attr_t *attr) in ffrt_queue_submit_head()
135 ffrt_queue_t queue, ffrt_function_header_t *f, const ffrt_task_attr_t *attr) in ffrt_queue_submit_head_h()
|
| D | loop.h | 23 inline FFRT_C_API ffrt_loop_t ffrt_loop_create(ffrt_queue_t queue) in ffrt_loop_create()
|
| /base/security/device_security_level/baselib/utils/src/ |
| D | utils_work_queue.c | 51 WorkQueue *queue = (WorkQueue *)data; in WorkQueueThread() local
107 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); in CreateWorkQueue() local
146 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); in CreateWorkQueue() local
203 uint32_t DestroyWorkQueue(WorkQueue *queue) in DestroyWorkQueue()
227 uint32_t QueueWork(WorkQueue *queue, WorkProcess process, uint8_t *data, uint32_t length) in QueueWork()
|
| /base/powermgr/power_manager/utils/ffrt/src/ |
| 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()
|
| /base/powermgr/power_manager/test/apitest/inner_api/ffrt/src/ |
| D | ffrt_utils_test.cpp | 81 FFRTQueue queue("test_power_ffrt_queue"); variable
108 FFRTQueue queue("test_power_ffrt_queue"); variable
132 FFRTQueue queue("test_power_ffrt_queue"); variable
192 FFRTQueue queue("test_power_ffrt_queue_test008"); variable
|
| /base/powermgr/display_manager/brightness_manager/include/ |
| D | brightness_ffrt.h | 25 inline void FFRT_CANCEL(PowerMgr::FFRTHandle& handle, std::shared_ptr<PowerMgr::FFRTQueue>& queue) in FFRT_CANCEL()
|
| /base/notification/eventhandler/interfaces/inner_api/ |
| D | event_handler.h | 1097 auto queue = runner->GetEventQueue(); in SetVsyncLazyMode() local
1112 auto queue = runner->GetEventQueue(); in SetVsyncPolicy() local
1127 auto queue = eventRunner_->GetEventQueue(); in RequestVsyncNotification() local
|
| /base/update/sys_installer/services/module_update/service/src/ |
| D | module_update_consumer.cpp | 31 ModuleUpdateConsumer::ModuleUpdateConsumer(ModuleUpdateQueue &queue, in ModuleUpdateConsumer()
|
| D | module_update_producer.cpp | 37 ModuleUpdateProducer::ModuleUpdateProducer(ModuleUpdateQueue &queue, in ModuleUpdateProducer()
|
| /base/security/device_security_level/baselib/msglib/src/lite/ |
| D | messenger_device_status_manager.c | 37 WorkQueue *queue; member
87 WorkQueue *queue = instance->queue; in ProcessDeviceStatusReceiver() local
172 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat… in InitDeviceStatusManager()
|
| D | messenger_device_session_manager.c | 46 WorkQueue *queue; member
108 WorkQueue *queue = instance->queue; in OnSessionMessageReceived() local
311 bool InitDeviceSessionManager(WorkQueue *queue, const MessengerConfig *config) in InitDeviceSessionManager()
|
| /base/startup/appspawn/modules/sandbox/modern/ |
| D | sandbox_manager.c | 88 void AddSandboxMountNode(SandboxMountNode *node, SandboxSection *queue) in AddSandboxMountNode()
317 SandboxSection *GetSandboxSection(const SandboxQueue *queue, const char *name) in GetSandboxSection()
327 void AddSandboxSection(SandboxSection *node, SandboxQueue *queue) in AddSandboxSection()
345 static void SandboxQueueClear(SandboxQueue *queue) in SandboxQueueClear()
433 static inline void InitSandboxQueue(SandboxQueue *queue, uint32_t type) in InitSandboxQueue()
|
| /base/inputmethod/imf/frameworks/js/napi/inputmethodclient/ |
| D | async_call.cpp | 90 napi_value AsyncCall::Post(napi_env env, Context::ExecAction exec, std::shared_ptr<TaskQueue> queue… in Post()
158 auto queue = context->queue; in OnExecuteSeq() local
|
| /base/security/device_security_level/baselib/msglib/src/standard/ |
| D | messenger_device_status_manager.cpp | 48 void Reset(const std::string &pkgName, WorkQueue *queue, StateReceiver deviceStatusReceiver) in Reset()
144 auto queue = DeviceStatusControlBlock::GetInstance().GetQueue(); in ProcessDeviceStatusReceiver() local
275 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat… in InitDeviceStatusManager()
|
| /base/notification/common_event_service/frameworks/core/src/ |
| D | common_event_listener.cpp | 163 void *queue = nullptr; in Stop() local
|
| /base/startup/appspawn/test/moduletest/threadpool/ |
| D | thread_manager.c | 152 static TaskNode *GetTask(ThreadManager *mgr, ListNode *queue, uint32_t taskId) in GetTask()
177 static TaskNode *PopTask(ThreadManager *mgr, ListNode *queue) in PopTask()
191 static void PushTask(ThreadManager *mgr, TaskNode *task, ListNode *queue) in PushTask()
|
| /base/notification/eventhandler/frameworks/eventhandler/include/ |
| D | event_queue_base.h | 308 std::list<InnerEvent::Pointer> queue; member
|
| /base/update/update_app/common/src/main/ets/manager/ |
| D | UpdateManager.ts | 498 private queue: Array<Message>; property in MessageQueue
|
| /base/security/code_signature/interfaces/inner_api/jit_code_sign/src/ |
| D | jit_code_signer.cpp | 46 inline static Instr GetOneInstrForQueue(std::queue<Byte> &queue) in GetOneInstrForQueue()
|