| /base/request/request/services/src/manage/ |
| 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
|
| D | notifier.rs | 63 let task_id = notify_data.task_id; in remove() localVariable
218 let task_id = manager.create(config).unwrap(); in ut_notify_progress() localVariable
274 let task_id = manager.create(config).unwrap(); in ut_notify_pause_resume() localVariable
326 let task_id = manager.create(config).unwrap(); in ut_notify_remove() localVariable
363 let task_id = manager.create(config).unwrap(); in ut_notify_completed() localVariable
401 let task_id = manager.create(config).unwrap(); in ut_notify_failed() localVariable
439 let task_id = manager.create(config).unwrap(); in ut_notify_pause_resume_completed() localVariable
477 let task_id = manager.create(config).unwrap(); in ut_notify_pause_resume_failed() localVariable
|
| 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
623 pub(crate) task_id: u32, field
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
|
| /base/request/request/services/src/manage/scheduler/ |
| 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
|
| /base/request/request/services/src/manage/scheduler/state/ |
| 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
|
| /base/request/request/services/src/manage/scheduler/qos/ |
| D | direction.rs | 30 task_id: u32, field
39 pub(crate) fn task_id(&self) -> u32 { in task_id() method
|
| /base/request/request/services/src/utils/ |
| D | task_id_generator.rs | 27 let task_id = match SystemTime::now().duration_since(UNIX_EPOCH) { in generate() localVariable
|
| /base/request/request/services/src/service/command/ |
| D | unsubscribe.rs | 22 let task_id: String = data.read()?; in unsubscribe() localVariable
|
| D | resume.rs | 30 let task_id: String = data.read()?; in resume() localVariable
|
| D | show.rs | 28 let task_id: String = data.read()?; in show() localVariable
|
| D | stop.rs | 23 let task_id: String = data.read()?; in stop() localVariable
|
| D | start.rs | 30 let task_id: String = data.read()?; in start() localVariable
|
| D | pause.rs | 32 let task_id: String = data.read()?; in pause() localVariable
|
| D | query.rs | 42 let task_id: String = data.read()?; in query() localVariable
|
| D | remove.rs | 32 let task_id: String = data.read()?; in remove() localVariable
|
| D | touch.rs | 22 let task_id: String = data.read()?; in touch() localVariable
|
| D | query_mime_type.rs | 33 let task_id: String = data.read()?; in query_mime_type() localVariable
|
| D | subscribe.rs | 23 let task_id: String = data.read()?; in subscribe() localVariable
|
| D | get_task.rs | 23 let task_id: String = data.read()?; in get_task() localVariable
|
| D | dump.rs | 45 let task_id = args[1].parse::<u32>(); in dump() localVariable
|
| /base/request/request/services/tests/ |
| D | start.rs | 34 let task_id = agent.construct(config); in sdv_start_basic() localVariable
|
| D | resume.rs | 34 let task_id = agent.construct(config); in sdv_start_resume() localVariable
|
| D | search.rs | 35 let task_id = agent.construct(config); in sdv_search_user() localVariable
|
| /base/request/request/services/src/manage/events/ |
| D | construct.rs | 31 let task_id = TaskIdGenerator::generate(); in create() localVariable
|
| /base/request/request/services/src/manage/scheduler/queue/ |
| 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
|