/ohos5.0/base/request/request/services/src/manage/ |
H A D | mod.rs | 92 let task_id = manager.create(config).unwrap(); in ut_manager_task_state_and_reason() localVariable 211 let task_id = manager.create(config.clone()).unwrap(); in ut_manager_state_change_error() localVariable 226 let task_id = manager.create(config.clone()).unwrap(); in ut_manager_state_change_error() localVariable 237 let task_id = manager.create(config.clone()).unwrap(); in ut_manager_state_change_error() localVariable 250 let task_id = manager.create(config.clone()).unwrap(); in ut_manager_state_change_error() localVariable 265 let task_id = manager.create(config.clone()).unwrap(); in ut_manager_state_change_error() localVariable 297 let task_id = manager.create(config.clone()).unwrap(); in ut_manager_reschedule() localVariable
|
H A D | notifier.rs | 65 let task_id = notify_data.task_id; in remove() localVariable 221 let task_id = manager.create(config).unwrap(); in ut_notify_progress() localVariable 277 let task_id = manager.create(config).unwrap(); in ut_notify_pause_resume() localVariable 329 let task_id = manager.create(config).unwrap(); in ut_notify_remove() localVariable 366 let task_id = manager.create(config).unwrap(); in ut_notify_completed() localVariable 404 let task_id = manager.create(config).unwrap(); in ut_notify_failed() localVariable 442 let task_id = manager.create(config).unwrap(); in ut_notify_pause_resume_completed() localVariable 480 let task_id = manager.create(config).unwrap(); in ut_notify_pause_resume_failed() localVariable
|
H A D | database.rs | 176 let task_id = task.task_id(); in insert_task() localVariable 212 let task_id = task.task_id(); in insert_task() localVariable 574 let task_id = config.common_data.task_id; in get_task() localVariable 661 let task_id = TaskIdGenerator::generate(); in ut_database_base() localVariable 678 let task_id = TaskIdGenerator::generate(); in ut_database_contains_task() localVariable 694 let task_id = TaskIdGenerator::generate(); in ut_database_query_task_token_id() localVariable 710 let task_id = TaskIdGenerator::generate(); in ut_database_app_task_qos_info() localVariable
|
/ohos5.0/base/request/request/services/src/manage/scheduler/state/ |
H A D | sql.rs | 338 let task_id = TaskIdGenerator::generate(); in network() localVariable 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 822 let task_id = TaskIdGenerator::generate(); in ut_multi_reason_unailable() localVariable
|
/ohos5.0/base/request/request/services/src/manage/scheduler/ |
H A D | sql.rs | 89 let task_id: u32 = rand::random(); in ut_start_pause_start() localVariable 153 let task_id: u32 = rand::random(); in ut_pause() localVariable 194 let task_id: u32 = rand::random(); in ut_stop() localVariable
|
/ohos5.0/base/request/request/services/src/manage/scheduler/qos/ |
H A D | direction.rs | 30 task_id: u32, field 39 pub(crate) fn task_id(&self) -> u32 { in task_id() method
|
/ohos5.0/base/request/request/services/src/utils/ |
H A D | task_id_generator.rs | 27 let task_id = match SystemTime::now().duration_since(UNIX_EPOCH) { in generate() localVariable
|
/ohos5.0/base/request/request/services/src/service/command/ |
H A D | unsubscribe.rs | 22 let task_id: String = data.read()?; in unsubscribe() localVariable
|
H A D | resume.rs | 30 let task_id: String = data.read()?; in resume() localVariable
|
H A D | show.rs | 28 let task_id: String = data.read()?; in show() localVariable
|
H A D | start.rs | 30 let task_id: String = data.read()?; in start() localVariable
|
H A D | stop.rs | 23 let task_id: String = data.read()?; in stop() localVariable
|
H A D | pause.rs | 32 let task_id: String = data.read()?; in pause() localVariable
|
H A D | query.rs | 42 let task_id: String = data.read()?; in query() localVariable
|
H A D | query_mime_type.rs | 33 let task_id: String = data.read()?; in query_mime_type() localVariable
|
H A D | remove.rs | 32 let task_id: String = data.read()?; in remove() localVariable
|
H A D | touch.rs | 22 let task_id: String = data.read()?; in touch() localVariable
|
H A D | subscribe.rs | 23 let task_id: String = data.read()?; in subscribe() localVariable
|
H A D | get_task.rs | 23 let task_id: String = data.read()?; in get_task() localVariable
|
H A D | dump.rs | 45 let task_id = args[1].parse::<u32>(); in dump() localVariable
|
/ohos5.0/base/request/request/services/tests/ |
H A D | resume.rs | 34 let task_id = agent.construct(config); in sdv_start_resume() localVariable
|
H A D | start.rs | 34 let task_id = agent.construct(config); in sdv_start_basic() localVariable
|
H A D | search.rs | 35 let task_id = agent.construct(config); in sdv_search_user() localVariable
|
/ohos5.0/base/request/request/services/src/manage/events/ |
H A D | construct.rs | 31 let task_id = TaskIdGenerator::generate(); in create() localVariable
|
/ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
H A D | mod.rs | 96 let task_id = task.task_id(); in try_restart() localVariable 160 let task_id = qos_direction.task_id(); in reschedule_inner() localVariable 225 let task_id = task.task_id(); in reschedule_inner() localVariable
|