Searched refs:scheduler (Results 1 - 16 of 16) sorted by relevance
| /base/msdp/device_status/rust/modules/scheduler/sys/src/ |
| H A D | lib.rs | 18 //! Current implementation of task scheduler allow posted tasks to run concurrently,
21 //! On creation of scheduler, an epoll instance is also created and event loop is
24 //! and is waited on for events. When events occured on its fd, scheduler will
31 mod scheduler; modules
35 pub use scheduler::IEpollHandler;
36 pub use scheduler::{
49 use scheduler::Scheduler;
57 /// Front-end of scheduler, providing interface for posting asynchronous task
61 scheduler: Arc<Scheduler>,
69 let scheduler in new()
[all...] |
| /base/request/request/services/src/manage/ |
| H A D | task_manager.rs | 38 use crate::manage::scheduler::state::Handler;
39 use crate::manage::scheduler::Scheduler;
61 pub(crate) scheduler: Scheduler,
104 // queue in `scheduler.QoS`, but there is no task rescheduling or
112 // be removed because the scheduler will also be rearranged in the
129 scheduler: Scheduler::init(
165 self.scheduler.on_rss_change(level);
169 TaskManagerEvent::Reschedule => self.scheduler.reschedule(),
179 AccountEvent::Changed => self.scheduler.on_state_change(Handler::update_account, ()),
219 self.scheduler in handle_state_event()
[all...] |
| H A D | mod.rs | 27 pub(crate) mod scheduler;
175 manager.scheduler.reschedule(); in ut_manager_task_state_and_reason()
309 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
315 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
323 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
329 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
335 manager.scheduler.resort_scheduled = false; in ut_manager_reschedule()
|
| H A D | notifier.rs | 150 manager.scheduler.reschedule(); in ut_notify_progress()
295 manager.scheduler.task_completed(uid, task_id); in ut_notify_completed()
333 manager.scheduler.task_failed(uid, task_id, Reason::IoError); in ut_notify_failed()
372 manager.scheduler.task_completed(uid, task_id); in ut_notify_pause_resume_completed()
410 manager.scheduler.task_failed(uid, task_id, Reason::IoError); in ut_notify_pause_resume_failed()
|
| H A D | query.rs | 62 if let Some(task) = self.scheduler.get_task(uid, task_id) {
76 if let Some(task) = self.scheduler.get_task(uid, task_id) {
99 .scheduler
|
| /base/request/request/services/src/manage/events/ |
| H A D | dump.rs | 19 self.scheduler
36 .scheduler
|
| H A D | resume.rs | 20 match self.scheduler.resume_task(uid, task_id) {
|
| H A D | pause.rs | 20 match self.scheduler.pause_task(uid, task_id) {
|
| H A D | start.rs | 21 match self.scheduler.start_task(uid, task_id) {
|
| H A D | stop.rs | 40 match self.scheduler.stop_task(uid, task_id) {
|
| H A D | remove.rs | 40 match self.scheduler.remove_task(uid, task_id) {
|
| /base/request/request/services/src/manage/scheduler/queue/ |
| H A D | running_task.rs | 20 use crate::manage::scheduler::queue::keeper::SAKeeper;
|
| H A D | mod.rs | 32 use crate::manage::scheduler::qos::{QosChanges, QosDirection};
33 use crate::manage::scheduler::queue::running_task::RunningTask;
|
| /base/request/request/services/src/manage/scheduler/state/ |
| H A D | recorder.rs | 17 use crate::manage::scheduler::qos::RssCapacity;
|
| /base/notification/common_event_service/services/test/unittest/ |
| H A D | ability_manager_helper_test.cpp | 135 int AttachAbilityThread(const sptr<IAbilityScheduler> &scheduler, const sptr<IRemoteObject> &token) override
|
| H A D | common_event_subscribe_unit_test.cpp | 195 int AttachAbilityThread(const sptr<IAbilityScheduler> &scheduler, const sptr<IRemoteObject> &token) override
|
Completed in 14 milliseconds