| /ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
| H A D | running_task.rs | 25 use crate::task::request_task::RequestTask;
29 task: Arc<RequestTask>,
36 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self { in new() argument
58 type Target = Arc<RequestTask>;
|
| H A D | mod.rs | 39 use crate::task::request_task::RequestTask;
43 download_queue: HashMap<(u64, u32), Arc<RequestTask>>,
44 upload_queue: HashMap<(u64, u32), Arc<RequestTask>>,
72 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task() argument
107 pub(crate) fn tasks(&self) -> impl Iterator<Item = &Arc<RequestTask>> { in tasks()
|
| /ohos5.0/base/request/request/services/src/task/ |
| H A D | upload.rs | 30 use crate::task::request_task::RequestTask;
35 pub(crate) task: Arc<RequestTask>,
141 task: Arc<RequestTask>, in build_stream_request() argument
176 task: Arc<RequestTask>, in build_multipart_request() argument
220 task: &Arc<RequestTask>, in build_request_common() argument
239 impl RequestTask { implementation
304 task: Arc<RequestTask>, in upload_inner() argument
356 task: Arc<RequestTask>, in upload_one_file() argument
454 use crate::task::request_task::{check_config, RequestTask};
460 fn build_task(config: TaskConfig) -> Arc<RequestTask> { in build_task() argument
[all …]
|
| H A D | download.rs | 29 use crate::task::request_task::RequestTask;
58 task: Arc<RequestTask>, in build_downloader() argument
72 pub(crate) async fn download(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in download() argument
97 impl RequestTask { impl
113 task: Arc<RequestTask>, in download_inner() argument
238 fn check_file_exist(task: &Arc<RequestTask>) -> Result<(), TaskError> { in check_file_exist()
287 use crate::task::request_task::{check_config, RequestTask, TaskError};
292 fn build_task(config: TaskConfig) -> Arc<RequestTask> { in build_task() argument
303 let task = Arc::new(RequestTask::new( in build_task()
|
| H A D | operator.rs | 27 use crate::task::request_task::RequestTask;
36 pub(crate) task: Arc<RequestTask>,
44 pub(crate) fn new(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) -> Self { in new() argument
|
| H A D | request_task.rs | 46 pub(crate) struct RequestTask { struct
67 impl RequestTask { impl
128 impl RequestTask { implementation
135 ) -> RequestTask { in new() argument
166 RequestTask { in new()
194 ) -> Result<RequestTask, ErrorCode> { in new_by_info() argument
228 Ok(RequestTask { in new_by_info()
272 each_file_status: RequestTask::get_each_file_status_by_code( in update_progress_in_database()
|
| /ohos5.0/base/request/request/services/src/manage/events/ |
| H A D | construct.rs | 23 use crate::task::request_task::{check_config, RequestTask};
70 let task = RequestTask::new( in create()
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | database.rs | 36 use crate::task::request_task::RequestTask;
40 user_file_tasks: Mutex<HashMap<u32, Arc<RequestTask>>>,
175 pub(crate) fn insert_task(&self, task: RequestTask) -> bool { in insert_task()
208 pub(crate) fn insert_task(&self, task: RequestTask) -> bool { in insert_task()
563 ) -> Result<Arc<RequestTask>, ErrorCode> { in get_task() argument
588 match RequestTask::new_by_info( in get_task()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/ |
| H A D | mod.rs | 36 use crate::task::request_task::RequestTask;
90 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task() argument
94 pub(crate) fn tasks(&self) -> impl Iterator<Item = &Arc<RequestTask>> { in tasks()
|