| /base/request/request/services/src/task/ |
| D | request_task.rs | 47 pub(crate) struct RequestTask { struct
48 pub(crate) conf: TaskConfig,
49 pub(crate) client: ylong_runtime::sync::Mutex<Client>,
50 pub(crate) files: Files,
74 impl RequestTask { argument
127 impl RequestTask { implementation
135 ) -> RequestTask { in new()
201 ) -> Result<RequestTask, ErrorCode> { in new_by_info()
337 task: Arc<RequestTask>, in build_download_request()
|
| D | upload.rs | 44 pub(crate) fn new(task: Arc<RequestTask>, index: usize) -> Self { in new()
159 task: Arc<RequestTask>, in build_stream_request()
194 task: Arc<RequestTask>, in build_multipart_request()
238 task: Arc<RequestTask>, in build_batch_multipart_request()
286 task: &Arc<RequestTask>, in build_request_common()
305 impl RequestTask { impl
396 pub(crate) async fn upload(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in upload()
425 task: Arc<RequestTask>, in upload_inner()
485 task: Arc<RequestTask>, in upload_one_file()
491 F: Fn(Arc<RequestTask>, usize, Arc<AtomicBool>) -> Option<Request>, in upload_one_file()
[all …]
|
| D | download.rs | 60 task: Arc<RequestTask>, in build_downloader()
74 pub(crate) async fn download(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in download()
106 impl RequestTask { impl
122 task: Arc<RequestTask>, in download_inner()
|
| D | operator.rs | 37 pub(crate) fn new(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) -> Self { in new()
|
| /base/request/request/common/netstack_rs/src/ |
| D | task.rs | 31 pub struct RequestTask { struct
36 unsafe impl Send for RequestTask {} argument
37 unsafe impl Sync for RequestTask {} implementation
49 impl RequestTask { implementation
|
| D | request.rs | 100 pub fn build(mut self) -> Option<RequestTask> { in build()
124 fn on_data_receive(&mut self, data: &[u8], task: RequestTask) {} in on_data_receive()
|
| /base/request/request/common/netstack_rs/tests/ut/ |
| D | ut_task.rs | 89 fn on_data_receive(&mut self, data: &[u8], _task: RequestTask) { in on_data_receive()
357 fn on_data_receive(&mut self, data: &[u8], _task: RequestTask) { in ut_request_task_reset_range()
437 fn on_data_receive(&mut self, data: &[u8], _task: RequestTask) { in ut_request_task_reset_not_range()
|
| D | ut_request.rs | 52 fn on_data_receive(&mut self, data: &[u8], _task: RequestTask) { in on_data_receive()
|
| /base/request/request/services/src/manage/scheduler/queue/ |
| D | mod.rs | 74 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task()
80 pub(crate) fn get_task_clone(&self, uid: u64, task_id: u32) -> Option<Arc<RequestTask>> { in get_task_clone()
|
| D | running_task.rs | 40 pub(crate) fn new(task: Arc<RequestTask>, tx: TaskManagerTx, keeper: SAKeeper) -> Self { in new()
|
| /base/request/request/services/tests/ut/task/ |
| D | ut_upload.rs | 32 fn build_task(config: TaskConfig) -> Arc<RequestTask> { in build_task()
|
| D | ut_download.rs | 36 fn build_task(config: TaskConfig) -> Arc<RequestTask> { in build_task()
|
| /base/request/request/frameworks/native/cache_download/src/download/ |
| D | netstack.rs | 56 fn on_data_receive(&mut self, data: &[u8], mut task: RequestTask) { in on_data_receive()
|
| /base/request/request/services/src/service/notification_bar/ |
| D | task_handle.rs | 64 impl NotificationCheck for RequestTask { implementation
|
| D | publish.rs | 125 pub(crate) fn publish_progress_notification(&self, task: &RequestTask) { in publish_progress_notification()
|
| /base/request/request/services/src/manage/scheduler/ |
| D | mod.rs | 101 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 | 626 ) -> Result<Arc<RequestTask>, ErrorCode> { in get_task()
|