| /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
|
| /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...] |
| /test/xts/acts/kernel_lite/ipc_posix/message_queue/ |
| H A D | IpcMqExceptionTest.cpp | 37 mqd_t queue, queueOther;
in HWTEST_F() local
59 mqd_t queue;
in HWTEST_F() local
126 mqd_t queue; HWTEST_F() local
152 mqd_t queue; HWTEST_F() local
174 mqd_t queue[MAX_MQ_NUMBER + 1]; HWTEST_F() local
216 mqd_t queue; HWTEST_F() local
251 mqd_t queue; HWTEST_F() local
276 mqd_t queue; HWTEST_F() local
319 mqd_t queue; HWTEST_F() local
343 mqd_t queue; HWTEST_F() local
375 mqd_t queue; HWTEST_F() local
427 mqd_t queue; HWTEST_F() local
452 mqd_t queue; HWTEST_F() local
502 mqd_t queue; HWTEST_F() local
550 mqd_t queue; HWTEST_F() local
577 mqd_t queue; HWTEST_F() local
608 mqd_t queue; HWTEST_F() local
657 mqd_t queue; HWTEST_F() local
708 mqd_t queue; HWTEST_F() local
738 mqd_t queue; HWTEST_F() local
811 mqd_t queue; HWTEST_F() local
842 mqd_t queue; HWTEST_F() local
[all...] |
| H A D | IpcMqTest.cpp | 36 mqd_t queue;
in HWTEST_F() local
70 mqd_t queue;
in HWTEST_F() local
110 mqd_t queue; HWTEST_F() local
177 mqd_t queue; HWTEST_F() local
236 mqd_t queue; HWTEST_F() local
302 mqd_t queue; HWTEST_F() local
358 mqd_t queue; PthreadCom() local
381 mqd_t queue; HWTEST_F() local
413 mqd_t queue; PthreadTimedCom() local
443 mqd_t queue; HWTEST_F() local
481 mqd_t queue; PthreadAllCom() local
510 mqd_t queue; HWTEST_F() local
547 mqd_t queue; HWTEST_F() local
633 mqd_t queue; HWTEST_F() local
666 mqd_t queue; HWTEST_F() local
[all...] |
| /test/xts/hats/hdf/bluetooth/a2dp/ |
| H A D | a2dp_services_test.cpp | 78 std::shared_ptr<SharedMemQueue<uint8_t>> queue = nullptr; in HWTEST_F() local
|
| /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
|
| /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...] |
| /test/testfwk/xdevice/src/xdevice/_core/context/ |
| H A D | impl.py | 19 import queue namespace
|
| /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
|
| /test/testfwk/xdevice/src/xdevice/_core/ |
| H A D | logger.py | 24 import queue namespace
|