| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | mod.rs | 100 manager.start(uid, task_id); in ut_manager_task_state_and_reason()
110 manager.pause(uid, task_id); in ut_manager_task_state_and_reason()
120 manager.resume(uid, task_id); in ut_manager_task_state_and_reason()
130 manager.pause(uid, task_id); in ut_manager_task_state_and_reason()
140 manager.resume(uid, task_id); in ut_manager_task_state_and_reason()
150 manager.stop(uid, task_id); in ut_manager_task_state_and_reason()
160 manager.start(uid, task_id); in ut_manager_task_state_and_reason()
299 manager.start(uid, task_id); in ut_manager_reschedule()
305 manager.stop(uid, task_id); in ut_manager_reschedule()
311 manager.start(uid, task_id); in ut_manager_reschedule()
[all …]
|
| H A D | database.rs | 148 task_id in contains_task()
163 task_id in query_task_token_id()
176 let task_id = task.task_id(); in insert_task() localVariable
212 let task_id = task.task_id(); in insert_task() localVariable
311 task_id, in update_task()
322 task_id in update_task_state()
509 task_id: task_id, in get_task_qos_info()
574 let task_id = config.common_data.task_id; in get_task() localVariable
665 task_id in ut_database_base()
682 task_id in ut_database_contains_task()
[all …]
|
| H A D | query.rs | 45 QueryEvent::Show(task_id, uid, tx) => { in handle_query_event()
46 let info = self.show(uid, task_id); in handle_query_event()
101 .find(|task| task.task_id() == task_id) in query()
199 let task_id = TaskIdGenerator::generate(); in ut_search_user() localVariable
203 task_id, in ut_search_user()
249 assert_eq!(res, vec![task_id as u32]); in ut_search_user()
259 assert_eq!(res, vec![task_id as u32]); in ut_search_user()
269 assert_eq!(res, vec![task_id as u32]); in ut_search_user()
281 task_id, in ut_search_system()
307 assert_eq!(res, vec![task_id as u32]); in ut_search_system()
[all …]
|
| H A D | task_manager.rs | 185 ServiceEvent::Start(uid, task_id, tx) => { in handle_service_event()
188 ServiceEvent::Stop(uid, task_id, tx) => { in handle_service_event()
189 let _ = tx.send(self.stop(uid, task_id)); in handle_service_event()
191 ServiceEvent::Pause(uid, task_id, tx) => { in handle_service_event()
194 ServiceEvent::Resume(uid, task_id, tx) => { in handle_service_event()
197 ServiceEvent::Remove(uid, task_id, tx) => { in handle_service_event()
203 ServiceEvent::DumpOne(task_id, tx) => { in handle_service_event()
237 TaskEvent::Completed(task_id, uid, mode) => { in handle_task_event()
257 TaskEvent::Running(task_id, uid, mode) => { in handle_task_event()
278 TaskEvent::Offline(task_id, uid, mode) => { in handle_task_event()
[all …]
|
| H A D | notifier.rs | 25 notify_data.task_id, in complete()
36 notify_data.task_id, in fail()
65 let task_id = notify_data.task_id; in remove() localVariable
74 task_id: u32, in publish_state_change_event()
222 manager.start(uid, task_id); in ut_notify_progress()
229 assert_eq!(tid, task_id); in ut_notify_progress()
241 assert_eq!(data.task_id, task_id); in ut_notify_progress()
278 manager.start(uid, task_id); in ut_notify_pause_resume()
279 manager.pause(uid, task_id); in ut_notify_pause_resume()
367 manager.start(uid, task_id); in ut_notify_completed()
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/ |
| H A D | mod.rs | 123 .get_task_info(task_id) in start_inner()
134 .get_task_info(task_id) in start_inner()
151 .get_task_qos_info(task_id) in start_inner()
176 .get_task_info(task_id) in remove_task()
221 task_id: u32, in task_cancel()
238 task_id, in task_cancel()
270 task_id, in task_cancel()
392 .get_task_config(task_id) in check_config_satisfy()
398 task_id, in check_config_satisfy()
443 .get_task_info(task_id) in change_status()
[all …]
|
| H A D | sql.rs | 23 task_id, in start_task()
37 task_id, in pause_task()
49 task_id, in stop_task()
61 task_id, in remove_task()
93 task_id, in ut_start_pause_start()
103 task_id, in ut_start_pause_start()
116 task_id, in ut_start_pause_start()
130 task_id, in ut_start_pause_start()
154 tasks.push(task_id); in ut_pause()
164 for task_id in tasks.iter() { in ut_pause()
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/qos/ |
| H A D | apps.rs | 48 task_id: task.task_id, in insert_task()
67 app.remove(task_id) in remove_task()
113 .find(|(_, task)| task.task_id == task_id) in remove()
133 task_id: u32, field
144 pub(crate) fn task_id(&self) -> u32 { in task_id() method
145 self.task_id in task_id()
205 task_id: info.task_id, in reload_tasks_of_app_from_database()
241 task_id, in new()
255 assert_eq!(app.tasks[0].task_id, 1); in ut_app_insert()
260 assert_eq!(app.tasks[0].task_id, 1); in ut_app_insert()
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
| H A D | mod.rs | 74 .get(&(uid, task_id)) in get_task()
85 .get(&(uid, task_id)) in try_restart()
96 let task_id = task.task_id(); in try_restart() localVariable
98 (uid, task_id), in try_restart()
124 task_id, in dump_tasks()
160 let task_id = qos_direction.task_id(); in reschedule_inner() localVariable
179 task_id, in reschedule_inner()
192 task_id, in reschedule_inner()
214 running_task.task_id(), in reschedule_inner()
225 let task_id = task.task_id(); in reschedule_inner() localVariable
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/events/ |
| H A D | mod.rs | 181 Self::Pause(uid, task_id, _) => f in fmt()
184 .field("task_id", task_id) in fmt()
186 Self::Start(uid, task_id, _) => f in fmt()
189 .field("task_id", task_id) in fmt()
191 Self::Stop(uid, task_id, _) => f in fmt()
194 .field("task_id", task_id) in fmt()
196 Self::Remove(uid, task_id, _) => f in fmt()
199 .field("task_id", task_id) in fmt()
201 Self::Resume(uid, task_id, _) => f in fmt()
204 .field("task_id", task_id) in fmt()
[all …]
|
| H A D | dump.rs | 18 pub(crate) fn query_one_task(&self, task_id: u32) -> Option<DumpOneInfo> { in query_one_task()
21 .find(|task| task.task_id() == task_id) in query_one_task()
25 task_id: task.conf.common_data.task_id, in query_one_task()
41 task_id: task.conf.common_data.task_id, in query_all_task()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/state/ |
| H A D | sql.rs | 324 fn query_state_and_reason(task_id: u32) -> (u8, u8) { in query_state_and_reason()
338 let task_id = TaskIdGenerator::generate(); in network() localVariable
347 let (state, reason) = query_state_and_reason(task_id); in network()
488 let task_id = TaskIdGenerator::generate(); in ut_network_unsupported() localVariable
505 let task_id = TaskIdGenerator::generate(); in ut_network_online() localVariable
553 let task_id = TaskIdGenerator::generate(); in ut_app_state_unavailable() localVariable
644 let task_id = TaskIdGenerator::generate(); in ut_app_state_available() localVariable
662 let task_id = TaskIdGenerator::generate(); in ut_account_unavailable() localVariable
706 let task_id = TaskIdGenerator::generate(); in ut_account_available() localVariable
731 let task_id = TaskIdGenerator::generate(); in ut_multi_reason_available() localVariable
[all …]
|
| /ohos5.0/base/request/request/services/src/service/command/ |
| H A D | subscribe.rs | 23 let task_id: String = data.read()?; in subscribe() localVariable
24 info!("Service subscribe tid {}", task_id); in subscribe()
26 let Ok(task_id) = task_id.parse::<u32>() else { in subscribe()
33 if !self.check_task_uid(task_id, uid) { in subscribe()
41 let (event, rx) = TaskManagerEvent::subscribe(task_id, token_id); in subscribe()
46 task_id in subscribe()
55 task_id in subscribe()
63 error!("End Service subscribe, tid: {}, failed: {:?}", task_id, ret); in subscribe()
68 let ret = self.client_manager.subscribe(task_id, pid, uid, token_id); in subscribe()
71 debug!("End Service subscribe ok: tid: {}", task_id); in subscribe()
[all …]
|
| H A D | get_task.rs | 23 let task_id: String = data.read()?; in get_task() localVariable
24 info!("Service getTask tid {}", task_id); in get_task()
26 let Ok(task_id) = task_id.parse::<u32>() else { in get_task()
29 task_id in get_task()
37 if !self.check_task_uid(task_id, uid) { in get_task()
43 let Some(config) = query::get_task(task_id, token) else { in get_task()
46 task_id in get_task()
55 let ret = self.client_manager.subscribe(task_id, pid, uid, token_id); in get_task()
57 error!("End Service subscribe, tid: {}, failed: {:?}", task_id, ret); in get_task()
|
| H A D | resume.rs | 30 let task_id: String = data.read()?; in resume() localVariable
31 info!("Service resume tid {}", task_id); in resume()
33 let Ok(task_id) = task_id.parse::<u32>() else { in resume()
36 task_id in resume()
44 if !self.check_task_uid(task_id, uid) { in resume()
49 let (event, rx) = TaskManagerEvent::resume(uid, task_id); in resume()
58 task_id in resume()
67 task_id, ret as i32 in resume()
|
| H A D | pause.rs | 32 let task_id: String = data.read()?; in pause() localVariable
33 info!("Service pause tid {}", task_id); in pause()
34 let Ok(task_id) = task_id.parse::<u32>() else { in pause()
37 task_id in pause()
44 if !self.check_task_uid(task_id, uid) { in pause()
49 let (event, rx) = TaskManagerEvent::pause(uid, task_id); in pause()
58 task_id in pause()
67 task_id, ret as u32 in pause()
|
| H A D | remove.rs | 32 let task_id: String = data.read()?; in remove() localVariable
33 info!("Service remove tid {}", task_id); in remove()
35 let Ok(task_id) = task_id.parse::<u32>() else { in remove()
38 task_id in remove()
46 if !self.check_task_uid(task_id, uid) { in remove()
51 let (event, rx) = TaskManagerEvent::remove(uid, task_id); in remove()
60 task_id in remove()
69 task_id, ret as i32 in remove()
|
| H A D | stop.rs | 23 let task_id: String = data.read()?; in stop() localVariable
24 info!("Service stop tid {}", task_id); in stop()
26 let Ok(task_id) = task_id.parse::<u32>() else { in stop()
33 if !self.check_task_uid(task_id, uid) { in stop()
38 let (event, rx) = TaskManagerEvent::stop(uid, task_id); in stop()
47 task_id in stop()
54 error!("End Service stop, tid: {}, failed: {}", task_id, ret as i32); in stop()
|
| H A D | start.rs | 30 let task_id: String = data.read()?; in start() localVariable
31 info!("Service start tid {}", task_id); in start()
33 let Ok(task_id) = task_id.parse::<u32>() else { in start()
41 if !self.check_task_uid(task_id, uid) { in start()
46 let (event, rx) = TaskManagerEvent::start(uid, task_id); in start()
55 task_id in start()
64 task_id, ret as i32 in start()
|
| H A D | touch.rs | 22 let task_id: String = data.read()?; in touch() localVariable
23 info!("Service touch tid {}", task_id); in touch()
25 let Ok(task_id) = task_id.parse::<u32>() else { in touch()
34 if !self.check_task_uid(task_id, uid) { in touch()
38 let info = self.task_manager.lock().unwrap().touch(uid, task_id, token); in touch()
49 task_id in touch()
|
| H A D | show.rs | 28 let task_id: String = data.read()?; in show() localVariable
29 info!("Service show tid {}", task_id); in show()
31 let Ok(task_id) = task_id.parse::<u32>() else { in show()
38 if !self.check_task_uid(task_id, uid) { in show()
43 let info = self.task_manager.lock().unwrap().show(uid, task_id); in show()
53 task_id in show()
|
| H A D | query.rs | 42 let task_id: String = data.read()?; in query() localVariable
43 info!("Service query tid {}", task_id); in query()
45 let Ok(task_id) = task_id.parse::<u32>() else { in query()
48 task_id in query()
54 let info = self.task_manager.lock().unwrap().query(task_id, action); in query()
64 task_id in query()
|
| H A D | unsubscribe.rs | 22 let task_id: String = data.read()?; in unsubscribe() localVariable
23 info!("Service unsubscribe tid {}", task_id); in unsubscribe()
25 let Ok(task_id) = task_id.parse::<u32>() else { in unsubscribe()
32 if !self.check_task_uid(task_id, uid) { in unsubscribe()
37 if self.client_manager.unsubscribe(task_id) == ErrorCode::ErrOk { in unsubscribe()
|
| /ohos5.0/base/request/request/test/rustest/src/ |
| H A D | lib.rs | 117 pub fn pause(&self, task_id: u32) { in pause()
118 self.pause_version(1u32, task_id); in pause()
138 pub fn query(&self, task_id: u32) { in query()
164 pub fn remove(&self, task_id: u32) { in remove()
185 pub fn resume(&self, task_id: u32) { in resume()
197 pub fn start(&self, task_id: u32) { in start()
209 pub fn stop(&self, task_id: u32) { in stop()
221 pub fn show(&self, task_id: u32) { in show()
351 .remove(&task_id) in pop_task_info()
446 task_id, in deserialize()
[all …]
|
| /ohos5.0/base/request/request/services/tests/ |
| H A D | search.rs | 35 let task_id = agent.construct(config); in sdv_search_user() localVariable
38 assert!(v.contains(&task_id)); in sdv_search_user()
40 assert!(!v.contains(&task_id)); in sdv_search_user()
48 assert!(v.contains(&task_id)); in sdv_search_user()
56 assert!(!v.contains(&task_id)); in sdv_search_user()
64 assert!(!v.contains(&task_id)); in sdv_search_user()
73 assert!(!v.contains(&task_id)); in sdv_search_user()
|