Searched refs:RequestTask (Results 1 - 12 of 12) sorted by relevance
| /base/request/request/services/src/manage/scheduler/queue/ |
| H A D | running_task.rs | 26 use crate::task::request_task::RequestTask;
30 task: Arc<RequestTask>,
37 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self {
59 type Target = Arc<RequestTask>;
|
| H A D | mod.rs | 40 use crate::task::request_task::RequestTask;
44 download_queue: HashMap<(u64, u32), Arc<RequestTask>>,
45 upload_queue: HashMap<(u64, u32), Arc<RequestTask>>,
76 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> {
111 pub(crate) fn tasks(&self) -> impl Iterator<Item = &Arc<RequestTask>> {
|
| /base/request/request/services/src/task/ |
| H A D | operator.rs | 27 use crate::task::request_task::RequestTask;
35 pub(crate) task: Arc<RequestTask>,
43 pub(crate) fn new(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) -> Self {
|
| H A D | upload.rs | 30 use crate::task::request_task::RequestTask;
35 pub(crate) task: Arc<RequestTask>,
41 pub(crate) fn new(task: Arc<RequestTask>, index: usize) -> Self {
141 task: Arc<RequestTask>, in build_stream_request()
176 task: Arc<RequestTask>, in build_multipart_request()
220 task: &Arc<RequestTask>, in build_request_common()
239 impl RequestTask { impls
275 pub(crate) async fn upload(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) {
304 task: Arc<RequestTask>,
356 task: Arc<RequestTask>,
[all...] |
| H A D | download.rs | 29 use crate::task::request_task::RequestTask;
58 task: Arc<RequestTask>,
72 pub(crate) async fn download(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) {
97 impl RequestTask { impls
113 task: Arc<RequestTask>,
238 fn check_file_exist(task: &Arc<RequestTask>) -> Result<(), TaskError> { in check_file_exist()
290 use crate::task::request_task::{check_config, RequestTask, TaskError};
295 fn build_task(config: TaskConfig) -> Arc<RequestTask> { in build_task()
306 let task = Arc::new(RequestTask::new( in build_task()
|
| H A D | request_task.rs | 45 pub(crate) struct RequestTask {
67 impl RequestTask { impls
124 impl RequestTask { impls
132 ) -> RequestTask {
146 _ => unreachable!("Action::Any in RequestTask::new never reach"),
163 RequestTask {
193 ) -> Result<RequestTask, ErrorCode> {
213 _ => unreachable!("Action::Any in RequestTask::new never reach"),
227 Ok(RequestTask {
271 each_file_status: RequestTask
[all...] |
| /base/request/request/pre_download/netstack_rs/src/ |
| H A D | task.rs | 23 /// RequestTask
24 pub struct RequestTask { structure names
28 /// RequestTask status
38 impl RequestTask { impls
|
| H A D | request.rs | 18 use crate::task::RequestTask;
82 /// Build the RequestTask.
83 pub fn build(mut self) -> RequestTask { in build()
84 let mut task = RequestTask::from_http_request(&self.inner); in build()
|
| /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(
|
| /base/request/request/pre_download/native/src/download/ |
| H A D | task.rs | 20 use netstack_rs::task::RequestTask;
83 inner: RequestTask,
|
| /base/request/request/services/src/service/ |
| H A D | notification_bar.rs | 25 use crate::task::request_task::RequestTask;
29 pub(crate) fn publish_progress_notification(task: &RequestTask) {
92 impl NotificationCheck for RequestTask {
|
| /base/request/request/services/src/manage/scheduler/ |
| H A D | mod.rs | 41 use crate::task::request_task::RequestTask;
101 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> {
105 pub(crate) fn tasks(&self) -> impl Iterator<Item = &Arc<RequestTask>> {
|
Completed in 10 milliseconds