| /base/request/request/services/src/manage/scheduler/ |
| H A D | mod.rs | 15 mod queue; modules
|
| /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>(); in HWTEST_F() local
87 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); in HWTEST_F() local
103 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); in HWTEST_F() local
115 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); HWTEST_F() local
129 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueueBase>(); HWTEST_F() local
[all...] |
| /base/update/sys_installer/services/module_update/service/src/ |
| H A D | module_update_consumer.cpp | 32 ModuleUpdateConsumer::ModuleUpdateConsumer(ModuleUpdateQueue &queue, in ModuleUpdateConsumer() argument
|
| H A D | module_update_producer.cpp | 37 ModuleUpdateProducer::ModuleUpdateProducer(ModuleUpdateQueue &queue, in ModuleUpdateProducer() argument
|
| H A D | module_update_main.cpp | 640 ModuleUpdateQueue queue; in Start() local
|
| /base/notification/common_event_service/frameworks/core/src/ |
| H A D | common_event_listener.cpp | 161 void *queue = nullptr; in Stop() local
|
| /base/security/code_signature/interfaces/innerkits/jit_code_sign/src/ |
| H A D | jit_code_signer_base.cpp | 29 inline static Instr GetOneInstrForQueue(std::queue<Byte> &queue) in GetOneInstrForQueue() argument
|
| /base/security/device_security_level/baselib/utils/src/ |
| H A D | utils_work_queue.c | 51 WorkQueue *queue = (WorkQueue *)data; in WorkQueueThread() local
107 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); CreateWorkQueue() local
146 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); CreateWorkQueue() local
203 DestroyWorkQueue(WorkQueue *queue) DestroyWorkQueue() argument
227 QueueWork(WorkQueue *queue, WorkProcess process, uint8_t *data, uint32_t length) QueueWork() argument
[all...] |
| /base/startup/appspawn/modules/sandbox/ |
| H A D | appspawn_permission.c | 52 int AddSandboxPermissionNode(const char *name, SandboxQueue *queue) in AddSandboxPermissionNode() argument
81 int32_t DeleteSandboxPermissions(SandboxQueue *queue) in DeleteSandboxPermissions() argument
100 PermissionRenumber(SandboxQueue *queue) PermissionRenumber() argument
120 GetPermissionNodeInQueue(SandboxQueue *queue, const char *permission) GetPermissionNodeInQueue() argument
132 GetPermissionNodeInQueueByIndex(SandboxQueue *queue, int32_t index) GetPermissionNodeInQueueByIndex() argument
144 GetPermissionIndexInQueue(SandboxQueue *queue, const char *permission) GetPermissionIndexInQueue() argument
[all...] |
| H A D | sandbox_manager.c | 78 void AddSandboxMountNode(SandboxMountNode *node, SandboxSection *queue) in AddSandboxMountNode() argument
307 SandboxSection *GetSandboxSection(const SandboxQueue *queue, const char *name) in GetSandboxSection() argument
317 void AddSandboxSection(SandboxSection *node, SandboxQueue *queue) in AddSandboxSection() argument
335 static void SandboxQueueClear(SandboxQueue *queue) in SandboxQueueClear() argument
423 InitSandboxQueue(SandboxQueue *queue, uint32_t type) InitSandboxQueue() argument
[all...] |
| /base/inputmethod/imf/frameworks/js/napi/inputmethodclient/ |
| H A D | async_call.cpp | 92 napi_value AsyncCall::Post(napi_env env, Context::ExecAction exec, std::shared_ptr<TaskQueue> queue, const char *func) in Post() argument
160 auto queue = context->queue; OnExecuteSeq() local
[all...] |
| H A D | async_call.h | 135 std::shared_ptr<TaskQueue> queue = nullptr; member
|
| /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() argument
42 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, FFRTQueue& queue)
in SubmitDelayTask() argument
50 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue)
in SubmitDelayTask() argument
65 int FFRTUtils::CancelTask(FFRTHandle& handle, FFRTQueue& queue)
in CancelTask() argument
70 int FFRTUtils::CancelTask(FFRTHandle& handle, std::shared_ptr<FFRTQueue> queue)
in CancelTask() argument
[all...] |
| /base/notification/eventhandler/frameworks/eventhandler/include/ |
| H A D | event_queue_base.h | 291 std::list<InnerEvent::Pointer> queue; global() member
[all...] |
| /base/notification/eventhandler/frameworks/eventhandler/test/unittest/ |
| H A D | lib_event_handler_event_test.cpp | 460 EventQueueBase queue; in HWTEST_F() local
|
| H A D | lib_event_handler_event_queue_test.cpp | 104 static void GetEventAndCompare(uint32_t eventId, EventQueue &queue) in GetEventAndCompare() argument
129 EventQueueBase queue; in DelayTest() local
162 EventQueueBase queue; InsertPriorityTest() local
204 BreakQueueTest(EventQueue &queue, uint32_t eventId) BreakQueueTest() argument
224 InsertAndGet(EventQueue &queue, InnerEvent::Pointer &event) InsertAndGet() argument
242 InsertPriorityEvent(EventQueue &queue, size_t length) InsertPriorityEvent() argument
271 InsertAllPriorityEvent(EventQueue &queue) InsertAllPriorityEvent() argument
386 EventQueueBase queue; HWTEST_F() local
410 EventQueueBase queue; HWTEST_F() local
434 EventQueueBase queue; HWTEST_F() local
564 EventQueueBase queue; HWTEST_F() local
591 EventQueueBase queue; HWTEST_F() local
633 EventQueueBase queue; HWTEST_F() local
684 EventQueueBase queue; HWTEST_F() local
759 EventQueueBase queue; HWTEST_F() local
773 EventQueueBase queue; HWTEST_F() local
786 EventQueueBase queue; HWTEST_F() local
799 EventQueueBase queue; HWTEST_F() local
811 EventQueueBase queue; HWTEST_F() local
1134 EventQueueBase queue; HWTEST_F() local
1169 EventQueueBase queue; HWTEST_F() local
1204 EventQueueBase queue; HWTEST_F() local
1241 EventQueueBase queue; HWTEST_F() local
1275 EventQueueBase queue; HWTEST_F() local
1308 EventQueueBase queue; HWTEST_F() local
1343 EventQueueBase queue; HWTEST_F() local
1818 auto queue = std::make_shared<EventQueueBase>(nullptr); HWTEST_F() local
1830 auto queue = std::make_shared<EventQueueBase>(); HWTEST_F() local
1842 auto queue = std::make_shared<EventQueueBase>(); HWTEST_F() local
1862 auto queue = std::make_shared<EventQueueBase>(); HWTEST_F() local
1875 auto queue = std::make_shared<EventQueueBase>(); HWTEST_F() local
1890 EventQueueBase queue; HWTEST_F() local
1924 EventQueueBase queue; HWTEST_F() local
1956 EventQueueFFRT queue; HWTEST_F() local
2003 EventQueueBase queue; HWTEST_F() local
2024 EventQueueBase queue; HWTEST_F() local
2044 EventQueueBase queue; HWTEST_F() local
2068 EventQueueBase queue; HWTEST_F() local
2087 ObserverTest(EventQueue &queue) ObserverTest() argument
2109 EventQueueBase queue; HWTEST_F() local
2124 EventQueueBase queue; HWTEST_F() local
2147 EventQueueBase queue; HWTEST_F() local
2168 RemoveTaskTest(EventQueue &queue) RemoveTaskTest() argument
2186 EventQueueBase queue; HWTEST_F() local
2196 CheckFileTest(EventQueue &queue) CheckFileTest() argument
2213 EventQueueBase queue; HWTEST_F() local
2223 InsertSyncEventTest(EventQueue &queue) InsertSyncEventTest() argument
2242 EventQueueBase queue; HWTEST_F() local
[all...] |
| /base/security/device_security_level/baselib/msglib/src/standard/ |
| H A D | messenger_device_status_manager.cpp | 48 void Reset(const std::string &pkgName, WorkQueue *queue, StateReceiver deviceStatusReceiver) in Reset() argument
144 auto queue = DeviceStatusControlBlock::GetInstance().GetQueue(); in ProcessDeviceStatusReceiver() local
275 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStatusReceiver) in InitDeviceStatusManager() argument
[all...] |
| H A 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() argument
[all...] |
| /base/security/device_security_level/baselib/msglib/src/lite/ |
| H A 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 deviceStatusReceiver) in InitDeviceStatusManager() argument
[all...] |
| H A 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() argument
[all...] |
| /base/notification/eventhandler/frameworks/eventhandler/src/ |
| H A D | event_queue_ffrt.cpp | 59 inline ffrt_queue_t* TransferQueuePtr(std::shared_ptr<ffrt::queue> queue) in TransferQueuePtr() argument
130 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); RemoveOrphanByHandlerId() local
153 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); RemoveAll() local
177 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); Remove() local
201 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); Remove() local
226 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); Remove() local
250 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); Remove() local
273 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); HasInnerEvent() local
295 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); HasInnerEvent() local
315 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); Dump() local
338 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); DumpQueueInfo() local
357 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); IsIdle() local
373 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); IsQueueEmpty() local
392 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); DumpCurrentQueueSize() local
429 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); CancelAndWait() local
544 ffrt_queue_t* queue = TransferQueuePtr(ffrtQueue_); SubmitEventAtFront() local
[all...] |
| /base/startup/appspawn/test/moduletest/threadpool/ |
| H A D | thread_manager.c | 152 static TaskNode *GetTask(ThreadManager *mgr, ListNode *queue, uint32_t taskId) in GetTask() argument
177 static TaskNode *PopTask(ThreadManager *mgr, ListNode *queue) in PopTask() argument
191 static void PushTask(ThreadManager *mgr, TaskNode *task, ListNode *queue) in PushTask() argument
|
| /base/security/device_security_level/test/dslm_unit_test/ |
| H A D | dslm_test.cpp | 2054 auto queue = CreateWorkQueue(2, "test"); in HWTEST_F() local
[all...] |