| /base/notification/eventhandler/frameworks/eventhandler/src/ |
| D | event_queue_ffrt.cpp | 56 inline ffrt_queue_t* TransferQueuePtr(std::shared_ptr<ffrt::queue> queue) in TransferQueuePtr()
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
[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(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()
|
| D | sandbox_manager.c | 78 void AddSandboxMountNode(SandboxMountNode *node, SandboxSection *queue) in AddSandboxMountNode()
307 SandboxSection *GetSandboxSection(const SandboxQueue *queue, const char *name) in GetSandboxSection()
317 void AddSandboxSection(SandboxSection *node, SandboxQueue *queue) in AddSandboxSection()
335 static void SandboxQueueClear(SandboxQueue *queue) in SandboxQueueClear()
423 static inline void InitSandboxQueue(SandboxQueue *queue, uint32_t type) in InitSandboxQueue()
|
| /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/notification/eventhandler/frameworks/eventhandler/test/unittest/ |
| D | lib_event_handler_event_queue_test.cpp | 105 static void GetEventAndCompare(uint32_t eventId, EventQueue &queue) in GetEventAndCompare()
130 EventQueueBase queue; in DelayTest() local
163 EventQueueBase queue; in InsertPriorityTest() local
205 static void BreakQueueTest(EventQueue &queue, uint32_t eventId) in BreakQueueTest()
225 static void InsertAndGet(EventQueue &queue, InnerEvent::Pointer &event) in InsertAndGet()
243 static void InsertPriorityEvent(EventQueue &queue, size_t length) in InsertPriorityEvent()
272 static void InsertAllPriorityEvent(EventQueue &queue) in InsertAllPriorityEvent()
387 EventQueueBase queue; variable
411 EventQueueBase queue; variable
435 EventQueueBase queue; variable
[all …]
|
| D | lib_event_handler_event_test.cpp | 465 EventQueueBase queue; variable
|
| /base/security/device_security_level/baselib/utils/src/ |
| 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()
|
| /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/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/powermgr/power_manager/test/apitest/inner_api/ffrt/src/ |
| 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
|
| /base/inputmethod/imf/frameworks/js/napi/inputmethodclient/ |
| D | async_call.cpp | 92 napi_value AsyncCall::Post(napi_env env, Context::ExecAction exec, std::shared_ptr<TaskQueue> queue… in Post()
160 auto queue = context->queue; in OnExecuteSeq() local
|
| D | async_call.h | 135 std::shared_ptr<TaskQueue> queue = nullptr; member
|
| /base/update/sys_installer/services/module_update/service/src/ |
| D | module_update_consumer.cpp | 32 ModuleUpdateConsumer::ModuleUpdateConsumer(ModuleUpdateQueue &queue, in ModuleUpdateConsumer()
|
| D | module_update_producer.cpp | 37 ModuleUpdateProducer::ModuleUpdateProducer(ModuleUpdateQueue &queue, in ModuleUpdateProducer()
|
| D | module_update_main.cpp | 637 ModuleUpdateQueue queue; in Start() local
|
| /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/notification/common_event_service/frameworks/core/src/ |
| D | common_event_listener.cpp | 161 void *queue = nullptr; in Stop() 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()
|
| D | messenger_device_socket_manager.c | 47 WorkQueue *queue; member
117 WorkQueue *queue = instance->queue; in OnSocketMessageReceived() local
452 bool InitDeviceSocketManager(WorkQueue *queue, const MessengerConfig *config) in InitDeviceSocketManager()
|
| /base/security/code_signature/interfaces/innerkits/jit_code_sign/src/ |
| D | jit_code_signer_base.cpp | 29 inline static Instr GetOneInstrForQueue(std::queue<Byte> &queue) in GetOneInstrForQueue()
|
| /base/notification/eventhandler/frameworks/eventhandler/include/ |
| D | event_queue_base.h | 234 std::list<InnerEvent::Pointer> queue; member
|
| /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/update/update_app/common/src/main/ets/manager/ |
| D | UpdateManager.ts | 498 private queue: Array<Message>; property in MessageQueue
|
| /base/request/request/services/src/manage/scheduler/queue/ |
| D | mod.rs | 154 let queue = if action == Action::Download { in reschedule_inner() localVariable
|