| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | frame.rs | 36 ty: u64,
37 len: u64,
78 h3_datagram: Option<u64>,
79 raw: Option<Vec<(u64, u64)>>,
84 push_id: u64,
89 push_id: u64,
95 id: u64,
99 push_id: u64,
103 raw_type: u64,
104 len: u64,
[all …]
|
| H A D | octets.rs | 97 pub fn into_u64(&mut self) -> Result<u64> { in into_u64() argument
105 let res: u64 = u64::from_be_bytes(bytes); in into_u64()
108 let res: u64 = u64::from_le_bytes(bytes); in into_u64()
115 pub fn get_varint(&mut self) -> Result<u64> { in get_varint() argument
125 1 => u64::from(self.into_u8()?), in get_varint()
127 2 => u64::from(self.into_u16()? & 0x3fff), in get_varint()
129 4 => u64::from(self.into_u32()? & 0x3fffffff), in get_varint()
232 pub fn write_u64(&mut self, value: u64) -> Result<usize> { in write_u64()
246 pub fn write_varint(&mut self, value: u64) -> Result<usize> { in write_varint()
250 pub fn write_varint_with_len(&mut self, value: u64, len: usize) -> Result<usize> { in write_varint_with_len() argument
[all …]
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/ |
| H A D | skeleton.rs | 32 fn GetCallingPid() -> u64; in GetCallingPid()
34 fn GetCallingRealPid() -> u64; in GetCallingRealPid()
36 fn GetCallingUid() -> u64; in GetCallingUid()
40 fn GetCallingFullTokenID() -> u64; in GetCallingFullTokenID()
44 fn GetFirstFullTokenID() -> u64; in GetFirstFullTokenID()
46 fn GetSelfTokenID() -> u64; in GetSelfTokenID()
86 pub fn calling_pid() -> u64 { in calling_pid()
91 pub fn calling_real_pid() -> u64 { in calling_real_pid()
96 pub fn calling_uid() -> u64 { in calling_uid()
116 pub fn first_full_token_id() -> u64 { in first_full_token_id()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | wheel.rs | 37 expiration: u64,
43 duration: u64,
90 pub(crate) fn duration(&self) -> u64 { in duration() argument
144 deadline: u64,
150 elapsed: u64,
193 pub(crate) fn find_level(expiration: u64, elapsed: u64) -> usize { in find_level() argument
310 occupied: u64,
387 fn calculate_deadline(slot: usize, level: usize, now: u64) -> u64 { in calculate_deadline() argument
411 let slot = (zeros as u64 + now_slot) % SLOTS_NUM as u64; in next_occupied_slot()
424 fn slot_range(level: usize) -> u64 { in slot_range() argument
[all …]
|
| /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() argument
59 _total: Option<u64>, in poll_progress() argument
65 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress() argument
84 uploaded: u64, in poll_progress() argument
85 total: Option<u64>, in poll_progress() argument
94 uploaded: u64,
95 total: Option<u64>,
117 uploaded: u64, in poll_progress() argument
118 _total: Option<u64>, in poll_progress() argument
|
| H A D | multipart.rs | 100 pub fn total_bytes(&self) -> Option<u64> { in total_bytes() argument
106 size += 2 + self.boundary.len() as u64 + 2; in total_bytes()
113 size += 9 + name.len() as u64; in total_bytes()
118 size += 13 + name.len() as u64; in total_bytes()
126 size += 16 + mime.len() as u64; in total_bytes()
133 size += 2 + self.boundary.len() as u64 + 4; in total_bytes()
250 length: Option<u64>,
333 pub fn length(mut self, length: Option<u64>) -> Self { in length()
351 self.length = Some(body.len() as u64); in body()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| H A D | operator.rs | 56 _uploaded: u64, in poll_progress() argument
57 _total: Option<u64>, in poll_progress() argument
63 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress() argument
82 uploaded: u64, in poll_progress() argument
83 total: Option<u64>, in poll_progress() argument
92 uploaded: u64,
93 total: Option<u64>,
115 uploaded: u64, in poll_progress() argument
116 _total: Option<u64>, in poll_progress() argument
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/state/ |
| H A D | recorder.rs | 20 pub(super) top_uid: Option<u64>,
21 pub(super) top_user: u64,
23 pub(super) active_accounts: HashSet<u64>,
41 top_uid: Option<u64>, in init() argument
42 foreground_account: u64, in init() argument
43 active_accounts: HashSet<u64>, in init() argument
79 foreground_account: u64, in update_accounts() argument
80 active_accounts: HashSet<u64>, in update_accounts() argument
93 pub(crate) fn update_top_uid(&mut self, uid: u64) -> Option<SqlList> { in update_top_uid()
108 pub(crate) fn update_background_timeout(&self, uid: u64) -> Option<SqlList> { in update_background_timeout()
|
| H A D | mod.rs | 33 background_timeout: HashMap<u64, JoinHandle<()>>,
67 Some(top_uid as u64) in init()
88 pub(crate) fn update_top_uid(&mut self, top_uid: u64) -> Option<SqlList> { in update_top_uid()
101 pub(crate) fn update_background(&mut self, uid: u64) -> Option<SqlList> { in update_background()
117 pub(crate) fn update_background_timeout(&mut self, uid: u64) -> Option<SqlList> { in update_background_timeout()
121 pub(crate) fn special_process_terminate(&mut self, uid: u64) -> Option<SqlList> { in special_process_terminate()
128 pub(crate) fn top_uid(&self) -> Option<u64> { in top_uid() argument
132 pub(crate) fn top_user(&self) -> u64 { in top_user() argument
|
| /ohos5.0/base/request/request/services/src/manage/events/ |
| H A D | mod.rs | 134 Pause(u64, u32, Sender<ErrorCode>),
135 Start(u64, u32, Sender<ErrorCode>),
136 Stop(u64, u32, Sender<ErrorCode>),
145 Completed(u32, u64, Mode),
146 Failed(u32, u64, Reason, Mode),
147 Offline(u32, u64, Mode),
148 Running(u32, u64, Mode),
155 ForegroundApp(u64),
156 Background(u64),
157 BackgroundTimeout(u64),
[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() argument
76 _total: Option<u64>, in poll_progress() argument
93 fn progress<'a>(&'a mut self, downloaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress() argument
120 downloaded: u64, in poll_progress() argument
121 total: Option<u64>, in poll_progress() argument
148 downloaded: u64,
149 total: Option<u64>,
180 downloaded: u64, in poll_progress() argument
181 _total: Option<u64>, in poll_progress() argument
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 40 _downloaded: u64, in poll_progress() argument
41 _total: Option<u64>, in poll_progress() argument
64 fn progress<'a>(&'a mut self, downloaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress() argument
91 downloaded: u64, in poll_progress() argument
92 total: Option<u64>, in poll_progress() argument
117 downloaded: u64,
118 total: Option<u64>,
152 downloaded: u64, in poll_progress() argument
153 _total: Option<u64>, in poll_progress() argument
|
| /ohos5.0/base/request/request/services/src/service/client/ |
| H A D | mod.rs | 36 OpenChannel(u64, Sender<Result<i32, ErrorCode>>),
37 Subscribe(u32, u64, u64, u64, Sender<ErrorCode>),
40 Terminate(u64, Sender<ErrorCode>),
52 pub(crate) fn open_channel(&self, pid: u64) -> Result<i32, ErrorCode> { in open_channel()
68 pub(crate) fn subscribe(&self, tid: u32, pid: u64, uid: u64, token_id: u64) -> ErrorCode { in subscribe() argument
105 pub(crate) fn notify_process_terminate(&self, pid: u64) -> ErrorCode { in notify_process_terminate()
141 pub(crate) pid: u64,
149 pub(crate) fn constructor(pid: u64) -> Option<(UnboundedSender<ClientEvent>, i32)> { in constructor()
303 message.extend_from_slice(&(notify_data.progress.processed[index] as u64).to_le_bytes()); in handle_send_notify_data()
306 &(notify_data.progress.common_data.total_processed as u64).to_le_bytes(), in handle_send_notify_data()
|
| H A D | manager.rs | 54 clients: HashMap<u64, (UnboundedSender<ClientEvent>, i32)>,
55 pid_map: HashMap<u32, u64>,
131 fn handle_open_channel(&mut self, pid: u64, tx: Sender<Result<i32, ErrorCode>>) { in handle_open_channel() argument
152 pid: u64, in handle_subscribe() argument
153 _uid: u64, in handle_subscribe() argument
154 _token_id: u64, in handle_subscribe() argument
190 fn handle_process_terminated(&mut self, pid: u64, tx: Sender<ErrorCode>) { in handle_process_terminated() argument
|
| /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() argument
29 pub fn finish_trace(label: u64) { in finish_trace() argument
37 pub fn start_trace_async(label: u64, value: &str, task_id: i32) { in start_trace_async() argument
46 pub fn finish_trace_async(label: u64, value: &str, task_id: i32) { in finish_trace_async() argument
55 pub fn count_trace(label: u64, name: &str, count: i64) { in count_trace() argument
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/queue/ |
| H A D | mod.rs | 43 download_queue: HashMap<(u64, u32), Arc<RequestTask>>,
44 upload_queue: HashMap<(u64, u32), Arc<RequestTask>>,
45 running_tasks: HashMap<(u64, u32), Option<AbortHandle>>,
72 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> { in get_task() argument
78 pub(crate) fn task_finish(&mut self, uid: u64, task_id: u32) { in task_finish() argument
82 pub(crate) fn try_restart(&mut self, uid: u64, task_id: u32) -> bool { in try_restart() argument
134 pub(crate) fn reschedule(&mut self, qos: QosChanges, qos_remove_queue: &mut Vec<(u64, u32)>) { in reschedule() argument
147 qos_remove_queue: &mut Vec<(u64, u32)>, in reschedule_inner() argument
165 task.speed_limit(qos_direction.direction() as u64); in reschedule_inner()
202 task.speed_limit(qos_direction.direction() as u64); 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() argument
45 pub(crate) fn insert_task(&mut self, uid: u64, task: TaskQosInfo) { in insert_task() argument
64 pub(crate) fn remove_task(&mut self, uid: u64, task_id: u32) -> bool { in remove_task() argument
84 pub(crate) uid: u64,
89 fn new(uid: u64) -> Self { in new()
96 fn from_raw(uid: u64, tasks: Vec<Task>) -> Self { in from_raw() argument
132 uid: u64,
140 pub(crate) fn uid(&self) -> u64 { in uid() argument
199 fn reload_tasks_of_app_from_database(uid: u64) -> Vec<Task> { in reload_tasks_of_app_from_database()
213 fn reload_app_list_from_database() -> HashSet<u64> { in reload_app_list_from_database()
[all …]
|
| /ohos5.0/base/hiviewdfx/hitrace/interfaces/rust/innerkits/hitracechain/src/ |
| H A D | lib.rs | 100 trace_details: [u64;2],
148 pub fn set_chain_id(&mut self, chain_id: u64) { in set_chain_id() argument
156 pub fn get_chain_id(&self) -> u64 { in get_chain_id() argument
164 pub fn set_span_id(&mut self, span_id: u64) { in set_span_id() argument
172 pub fn get_span_id(&self)-> u64 { in get_span_id() argument
180 pub fn set_parent_span_id(&mut self, parent_span_id: u64) { in set_parent_span_id() argument
188 pub fn get_parent_span_id(&self) -> u64 { in get_parent_span_id() argument
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/ |
| H A D | config.rs | 56 pub fn from_secs(secs: u64) -> Self { in from_secs()
75 min: (u64, Duration),
76 max: u64,
110 pub fn min_speed(mut self, min: u64, duration: u64) -> Self { in min_speed() argument
130 pub fn max_speed(mut self, max: u64) -> Self { in max_speed()
147 max: u64::MAX, in none()
|
| /ohos5.0/base/request/request/services/src/task/ |
| H A D | operator.rs | 30 const SPEED_LIMIT_INTERVAL: u64 = 1000;
31 const FRONT_NOTIFY_INTERVAL: u64 = 1000;
32 const BACKGROUND_NOTIFY_INTERVAL: u64 = 3000;
37 pub(crate) last_time: u64,
38 pub(crate) last_size: u64,
39 pub(crate) more_sleep_time: u64,
86 .total_processed as u64; in poll_progress_common()
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/tests/ |
| H A D | skeleton.rs | 121 fn GetCallingFullTokenID() -> u64; in GetCallingFullTokenID()
122 fn GetCallingPid() -> u64; in GetCallingPid()
123 fn GetCallingRealPid() -> u64; in GetCallingRealPid()
125 fn GetCallingUid() -> u64; in GetCallingUid()
126 fn GetFirstFullTokenID() -> u64; in GetFirstFullTokenID()
128 fn SelfTokenID() -> u64; in SelfTokenID()
|
| H A D | parcel_remote.rs | 82 reply.write(&data.read::<u64>().unwrap()); in parcel_remote_primitive()
83 reply.write(&data.read::<u64>().unwrap()); in parcel_remote_primitive()
104 reply.write(&data.read::<Vec<u64>>().unwrap()); in parcel_remote_vec()
152 msg.write(&u64::MAX).unwrap(); in read_and_write()
153 msg.write(&u64::MIN).unwrap(); in read_and_write()
173 msg.write(&vec![u64::MIN; 3]).unwrap(); in read_and_write_vec()
178 msg.write(&vec![u64::MAX; 3]).unwrap(); in read_and_write_vec()
242 assert_eq!(u64::MAX, reply.read().unwrap()); in assert_read_and_write()
243 assert_eq!(u64::MIN, reply.read().unwrap()); in assert_read_and_write()
263 assert_eq!(reply.read::<Vec<u64>>().unwrap(), vec![u64::MIN; 3]); in assert_read_and_write_vec()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/task_helpers/ |
| H A D | mod.rs | 30 pub const FIBBO_ANS: u64 = 1346268;
80 pub fn work() -> u64 { in work()
84 pub fn recur_fibbo(a: u64) -> u64 { in recur_fibbo() argument
91 pub fn fibbo(upper: usize) -> u64 { in fibbo() argument
94 ret += black_box(recur_fibbo(j as u64)); in fibbo()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | simple.rs | 100 pub fn total_bytes(&self) -> Option<u64> { in total_bytes() argument
106 size += 2 + self.boundary.len() as u64 + 2; in total_bytes()
113 size += 9 + name.len() as u64; in total_bytes()
118 size += 13 + name.len() as u64; in total_bytes()
126 size += 16 + mime.len() as u64; in total_bytes()
133 size += 2 + self.boundary.len() as u64 + 4; in total_bytes()
280 length: Option<u64>,
381 self.length = Some(body.len() as u64); in body()
550 fn xor_shift() -> u64 { in xor_shift()
561 fn seed() -> u64 { in xor_shift()
[all …]
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | task_manager.rs | 44 const CLEAR_INTERVAL: u64 = 30 * 60;
45 const LOG_INTERVAL: u64 = 5 * 60;
46 const RESTORE_ALL_TASKS_INTERVAL: u64 = 10;
65 pub(crate) task_count: HashMap<u64, (usize, usize)>,
297 fn check_subscriber(&self, task_id: u32, token_id: u64) -> ErrorCode { in check_subscriber()
371 pub(crate) fn notify_foreground_app_change(&self, uid: u64) { in notify_foreground_app_change() argument
375 pub(crate) fn notify_app_background(&self, uid: u64) { in notify_app_background() argument
379 pub(crate) fn trigger_background_timeout(&self, uid: u64) { in trigger_background_timeout() argument
383 pub(crate) fn notify_special_process_terminate(&self, uid: u64) { in notify_special_process_terminate() argument
387 pub(crate) fn show(&self, uid: u64, task_id: u32) -> Option<TaskInfo> { in show() argument
[all …]
|