| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | operator.rs | 58 _uploaded: u64, in poll_progress()
59 _total: Option<u64>, in poll_progress()
65 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
84 uploaded: u64, in poll_progress()
85 total: Option<u64>, in poll_progress()
117 uploaded: u64, in poll_progress()
118 _total: Option<u64>, in poll_progress()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| H A D | operator.rs | 56 _uploaded: u64, in poll_progress()
57 _total: Option<u64>, in poll_progress()
63 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
82 uploaded: u64, in poll_progress()
83 total: Option<u64>, in poll_progress()
115 uploaded: u64, in poll_progress()
116 _total: Option<u64>, in poll_progress()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/state/ |
| H A D | recorder.rs | 41 top_uid: Option<u64>, in init()
42 foreground_account: u64, in init()
43 active_accounts: HashSet<u64>, in init()
79 foreground_account: u64, in update_accounts()
80 active_accounts: HashSet<u64>, in update_accounts()
|
| /ohos5.0/base/hiviewdfx/hitrace/interfaces/rust/innerkits/hitrace_meter/src/ |
| H A D | lib.rs | 20 pub fn start_trace(label: u64, value: &str) { in start_trace()
29 pub fn finish_trace(label: u64) { in finish_trace()
37 pub fn start_trace_async(label: u64, value: &str, task_id: i32) { in start_trace_async()
46 pub fn finish_trace_async(label: u64, value: &str, task_id: i32) { in finish_trace_async()
55 pub fn count_trace(label: u64, name: &str, count: i64) { in count_trace()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/metrics/ |
| H A D | runtime.rs | 236 pub fn global_queue_total_task_count(&self) -> u64 { in global_queue_total_task_count()
290 pub fn worker_total_task_count(&self, index: usize) -> Option<u64> { in worker_total_task_count()
348 pub fn steal_times(&self) -> Option<u64> { in steal_times()
373 pub fn worker_get_task_from_global_count(&self, index: usize) -> Option<u64> { in worker_get_task_from_global_count()
404 pub fn worker_push_task_to_global_count(&self, index: usize) -> Option<u64> { in worker_push_task_to_global_count()
434 pub fn fd_registered_count(&self) -> u64 { in fd_registered_count()
454 pub fn io_driver_ready_count(&self) -> u64 { in io_driver_ready_count()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | frame.rs | 108 pub fn new(ty: u64, len: u64, payload: Payload) -> Self { in new()
112 pub fn frame_type(&self) -> &u64 { in frame_type()
116 pub fn frame_len(&self) -> &u64 { in frame_len()
173 pub fn get_max_fied_section_size(&self) -> &Option<u64> { in get_max_fied_section_size()
183 pub fn get_qpack_block_stream(&self) -> &Option<u64> { in get_qpack_block_stream()
192 pub fn get_h3_datagram(&self) -> &Option<u64> { in get_h3_datagram()
215 pub fn get_push_id(&self) -> &u64 { in get_push_id()
241 pub fn new(push_id: u64, header: Vec<u8>) -> Self { in new()
248 pub fn get_push_id(&self) -> u64 { in get_push_id()
264 pub fn get_id(&self) -> &u64 { in get_id()
[all …]
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/ |
| H A D | operator.rs | 75 _downloaded: u64, in poll_progress()
76 _total: Option<u64>, in poll_progress()
93 fn progress<'a>(&'a mut self, downloaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
120 downloaded: u64, in poll_progress()
121 total: Option<u64>, in poll_progress()
180 downloaded: u64, in poll_progress()
181 _total: Option<u64>, in poll_progress()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 40 _downloaded: u64, in poll_progress()
41 _total: Option<u64>, in poll_progress()
64 fn progress<'a>(&'a mut self, downloaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
91 downloaded: u64, in poll_progress()
92 total: Option<u64>, in poll_progress()
152 downloaded: u64, in poll_progress()
153 _total: Option<u64>, in poll_progress()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | async_seek.rs | 42 ) -> Poll<io::Result<u64>>; in poll_seek()
53 ) -> Poll<io::Result<u64>> { in poll_seek()
63 ) -> Poll<io::Result<u64>> { in poll_seek()
73 ) -> Poll<io::Result<u64>> { in poll_seek()
|
| /ohos5.0/base/request/request/services/src/service/client/ |
| H A D | manager.rs | 131 fn handle_open_channel(&mut self, pid: u64, tx: Sender<Result<i32, ErrorCode>>) { in handle_open_channel()
152 pid: u64, in handle_subscribe()
153 _uid: u64, in handle_subscribe()
154 _token_id: u64, in handle_subscribe()
190 fn handle_process_terminated(&mut self, pid: u64, tx: Sender<ErrorCode>) { in handle_process_terminated()
|
| /ohos5.0/base/update/updater/services/rust/hash_signed_data/src/ |
| H A D | lib.rs | 155 -> *const ImgHashData<u64> in LoadImgHashDataNew()
228 pub unsafe extern fn CheckDataHashNew(img_hash_data: *const ImgHashData<u64>, in CheckDataHashNew()
229 img_name: *const c_char, start: u64, end: u64, hash_value: *const u8, len: usize) -> bool in CheckDataHashNew()
256 pub unsafe extern fn ReleaseImgHashDataNew(hash_data: *const ImgHashData<u64>) in ReleaseImgHashDataNew()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/ |
| H A D | mod.rs | 90 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task()
112 pub(crate) fn start_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> { in start_task()
116 pub(crate) fn resume_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> { in resume_task()
120 fn start_inner(&mut self, uid: u64, task_id: u32, is_resume: bool) -> Result<(), ErrorCode> { in start_inner()
158 pub(crate) fn pause_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> { in pause_task()
172 pub(crate) fn remove_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> { in remove_task()
187 pub(crate) fn stop_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> { in stop_task()
197 pub(crate) fn task_completed(&mut self, uid: u64, task_id: u32) { in task_completed()
220 uid: u64, in task_cancel()
223 task_count: &mut HashMap<u64, (usize, usize)>, in task_cancel()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | wheel.rs | 71 pub(crate) fn expiration(&self) -> u64 { in expiration()
76 pub(crate) fn set_expiration(&mut self, expiration: u64) { in set_expiration()
90 pub(crate) fn duration(&self) -> u64 { in duration()
94 pub(crate) fn set_duration(&mut self, duration: u64) { in set_duration()
182 pub(crate) fn elapsed(&self) -> u64 { in elapsed()
187 pub(crate) fn set_elapsed(&mut self, elapsed: u64) { in set_elapsed()
193 pub(crate) fn find_level(expiration: u64, elapsed: u64) -> usize { in find_level()
220 pub(crate) fn insert(&mut self, mut clock_entry: NonNull<Clock>) -> Result<u64, Error> { in insert()
387 fn calculate_deadline(slot: usize, level: usize, now: u64) -> u64 { in calculate_deadline()
424 fn slot_range(level: usize) -> u64 { in slot_range()
|
| /ohos5.0/base/request/request/services/src/task/ |
| H A D | files.rs | 138 fn open_file_readwrite(uid: u64, bundle_name: &str, path: &str) -> io::Result<File> { in open_file_readwrite()
148 fn open_file_readonly(uid: u64, bundle_name: &str, path: &str) -> io::Result<File> { in open_file_readonly()
157 pub(crate) fn convert_path(uid: u64, bundle_name: &str, path: &str) -> String { in convert_path()
179 fn check_app_clone_bundle_name(uid: u64, bundle_name: &str) -> String { in check_app_clone_bundle_name()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
| H A D | mod.rs | 72 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task()
78 pub(crate) fn task_finish(&mut self, uid: u64, task_id: u32) { in task_finish()
82 pub(crate) fn try_restart(&mut self, uid: u64, task_id: u32) -> bool { in try_restart()
134 pub(crate) fn reschedule(&mut self, qos: QosChanges, qos_remove_queue: &mut Vec<(u64, u32)>) { in reschedule()
147 qos_remove_queue: &mut Vec<(u64, u32)>, in reschedule_inner()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/qos/ |
| H A D | apps.rs | 33 pub(crate) fn sort(&mut self, top_uid: Option<u64>, top_user: u64) { in sort()
45 pub(crate) fn insert_task(&mut self, uid: u64, task: TaskQosInfo) { in insert_task()
64 pub(crate) fn remove_task(&mut self, uid: u64, task_id: u32) -> bool { in remove_task()
96 fn from_raw(uid: u64, tasks: Vec<Task>) -> Self { in from_raw()
140 pub(crate) fn uid(&self) -> u64 { in uid()
221 fn get_app_infos(&self) -> Vec<u64> { in get_app_infos()
|
| H A D | direction.rs | 35 pub(crate) fn uid(&self) -> u64 { in uid()
47 pub(crate) fn new(uid: u64, task_id: u32, direction: QosLevel) -> Self { in new()
|
| /ohos5.0/base/request/request/services/src/manage/events/ |
| H A D | pause.rs | 18 pub(crate) fn pause(&mut self, uid: u64, task_id: u32) -> ErrorCode { in pause()
|
| H A D | resume.rs | 18 pub(crate) fn resume(&mut self, uid: u64, task_id: u32) -> ErrorCode { in resume()
|
| H A D | start.rs | 18 pub(crate) fn start(&mut self, uid: u64, task_id: u32) -> ErrorCode { in start()
|
| H A D | remove.rs | 20 pub(crate) fn remove(&mut self, uid: u64, task_id: u32) -> ErrorCode { in remove()
|
| H A D | stop.rs | 20 pub(crate) fn stop(&mut self, uid: u64, task_id: u32) -> ErrorCode { in stop()
|
| /ohos5.0/base/request/request/services/src/service/run_count/ |
| H A D | manager.rs | 52 pub(crate) fn subscribe_run_count(&self, pid: u64, obj: RemoteObj) -> ErrorCode { in subscribe_run_count()
115 fn subscribe_run_count(&mut self, pid: u64, obj: RemoteObj, tx: Sender<ErrorCode>) { in subscribe_run_count()
124 fn unsubscribe_run_count(&mut self, subscribe_pid: u64, tx: Sender<ErrorCode>) { in unsubscribe_run_count()
|
| /ohos5.0/base/hiviewdfx/hitrace/interfaces/rust/innerkits/hitracechain/src/ |
| H A D | lib.rs | 148 pub fn set_chain_id(&mut self, chain_id: u64) { in set_chain_id()
156 pub fn get_chain_id(&self) -> u64 { in get_chain_id()
164 pub fn set_span_id(&mut self, span_id: u64) { in set_span_id()
172 pub fn get_span_id(&self)-> u64 { in get_span_id()
180 pub fn set_parent_span_id(&mut self, parent_span_id: u64) { in set_parent_span_id()
188 pub fn get_parent_span_id(&self) -> u64 { in get_parent_span_id()
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | task_manager.rs | 371 pub(crate) fn notify_foreground_app_change(&self, uid: u64) { in notify_foreground_app_change()
375 pub(crate) fn notify_app_background(&self, uid: u64) { in notify_app_background()
379 pub(crate) fn trigger_background_timeout(&self, uid: u64) { in trigger_background_timeout()
383 pub(crate) fn notify_special_process_terminate(&self, uid: u64) { in notify_special_process_terminate()
387 pub(crate) fn show(&self, uid: u64, task_id: u32) -> Option<TaskInfo> { in show()
401 pub(crate) fn touch(&self, uid: u64, task_id: u32, token: String) -> Option<TaskInfo> { in touch()
|