Searched defs:RequestTask (Results 1 – 10 of 10) sorted by relevance
| /base/request/request/services/src/task/ |
| D | request_task.rs | 46 pub(crate) struct RequestTask { struct
68 impl RequestTask { argument
129 impl RequestTask { implementation
136 ) -> RequestTask { in new()
196 ) -> Result<RequestTask, ErrorCode> { in new_by_info()
|
| D | upload.rs | 41 pub(crate) fn new(task: Arc<RequestTask>, index: usize) -> Self { in new()
152 task: Arc<RequestTask>, in build_stream_request()
187 task: Arc<RequestTask>, in build_multipart_request()
231 task: Arc<RequestTask>, in build_batch_multipart_request()
279 task: &Arc<RequestTask>, in build_request_common()
298 impl RequestTask { impl
386 pub(crate) async fn upload(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in upload()
415 task: Arc<RequestTask>, in upload_inner()
472 task: Arc<RequestTask>, in upload_one_file()
478 F: Fn(Arc<RequestTask>, usize, Arc<AtomicBool>) -> Option<Request>, in upload_one_file()
[all …]
|
| D | download.rs | 58 task: Arc<RequestTask>, in build_downloader()
72 pub(crate) async fn download(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in download()
97 impl RequestTask { impl
112 task: Arc<RequestTask>, in download_inner()
291 fn build_task(config: TaskConfig) -> Arc<RequestTask> { in build_task()
|
| D | operator.rs | 43 pub(crate) fn new(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) -> Self { in new()
|
| /base/request/request/services/src/manage/scheduler/queue/ |
| D | running_task.rs | 37 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self { in new()
|
| D | mod.rs | 72 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task()
|
| /base/request/request/services/src/service/notification_bar/ |
| D | task_handle.rs | 62 impl NotificationCheck for RequestTask { implementation
|
| D | publish.rs | 109 pub(crate) fn publish_progress_notification(&self, task: &RequestTask) { in publish_progress_notification()
|
| /base/request/request/services/src/manage/scheduler/ |
| D | mod.rs | 91 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task()
|
| /base/request/request/services/src/manage/ |
| D | database.rs | 559 ) -> Result<Arc<RequestTask>, ErrorCode> { in get_task()
|