Home
last modified time | relevance | path

Searched refs:u64 (Results 1 - 25 of 71) sorted by relevance

123

/base/request/request/services/src/manage/scheduler/state/
H A Drecorder.rs20 pub(super) top_uid: Option<u64>,
21 pub(super) top_user: u64,
23 pub(super) active_accounts: HashSet<u64>,
41 top_uid: Option<u64>,
42 foreground_account: u64,
43 active_accounts: HashSet<u64>,
79 foreground_account: u64,
80 active_accounts: HashSet<u64>,
93 pub(crate) fn update_top_uid(&mut self, uid: u64) -> Option<SqlList> {
108 pub(crate) fn update_background_timeout(&self, uid: u64)
[all...]
H A Dupdater.rs33 pub(super) fn query_active_accounts(&self) -> (u64, HashSet<u64>) {
35 let foreground_account = FOREGROUND_ACCOUNT.load(Ordering::SeqCst) as u64;
39 active_accounts.insert(*account as u64);
H A Dmod.rs34 background_timeout: HashMap<u64, JoinHandle<()>>,
69 Some(top_uid as u64)
90 pub(crate) fn update_top_uid(&mut self, top_uid: u64) -> Option<SqlList> {
103 pub(crate) fn update_background(&mut self, uid: u64) -> Option<SqlList> {
119 pub(crate) fn update_background_timeout(&mut self, uid: u64) -> Option<SqlList> {
123 pub(crate) fn app_uninstall(&mut self, uid: u64) -> Option<SqlList> {
129 pub(crate) fn top_uid(&self) -> Option<u64> {
133 pub(crate) fn top_user(&self) -> u64 {
/base/security/asset/services/core_service/src/
H A Dtrace_scope.rs25 label: u64,
29 const HITRACE_TAG_SECURITY: u64 = 1u64 << 7;
/base/hiviewdfx/hitrace/interfaces/rust/innerkits/hitrace_meter/src/
H A Dlib.rs20 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()
/base/request/request/services/src/task/
H A Doperator.rs30 const SPEED_LIMIT_INTERVAL: u64 = 1000;
31 const FRONT_NOTIFY_INTERVAL: u64 = 1000;
36 pub(crate) last_time: u64,
37 pub(crate) last_size: u64,
38 pub(crate) more_sleep_time: u64,
76 .total_processed as u64;
/base/request/request/services/src/manage/events/
H A Dmod.rs59 pub(crate) fn pause(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) {
67 pub(crate) fn start(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) {
75 pub(crate) fn stop(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) {
83 pub(crate) fn remove(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) {
91 pub(crate) fn resume(uid: u64, task_id: u32) -> (Self, Recv<ErrorCode>) {
116 pub(crate) fn subscribe(task_id: u32, token_id: u64) -> (Self, Recv<ErrorCode>) {
128 Show(u32, u64, Sender<Option<TaskInfo>>),
129 Touch(u32, u64, String, Sender<Option<TaskInfo>>),
134 Pause(u64, u32, Sender<ErrorCode>),
135 Start(u64, u3
[all...]
/base/request/request/services/src/manage/scheduler/qos/
H A Ddirection.rs29 uid: u64,
35 pub(crate) fn uid(&self) -> u64 {
47 pub(crate) fn new(uid: u64, task_id: u32, direction: QosLevel) -> Self {
H A Drss.rs93 assert_eq!(QosLevel::High as u64, 0u64); in ut_rss_capacity()
94 assert_eq!(QosLevel::Middle as u64, 800u64); in ut_rss_capacity()
95 assert_eq!(QosLevel::Low as u64, 400u64); in ut_rss_capacity()
H A Dapps.rs33 pub(crate) fn sort(&mut self, top_uid: Option<u64>, top_user: u64) {
45 pub(crate) fn insert_task(&mut self, uid: u64, task: TaskQosInfo) {
64 pub(crate) fn remove_task(&mut self, uid: u64, task_id: u32) -> bool {
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()
132 uid: u64,
140 pub(crate) fn uid(&self) -> u64 {
199 fn reload_tasks_of_app_from_database(uid: u64)
[all...]
/base/hiviewdfx/hitrace/test/unittest/rust/hitracechain/src/
H A Dmain.rs47 trace_id.set_chain_id(1024u64); in hitracechain_rust_unit_test_003()
48 assert!(trace_id.get_chain_id() == 1024u64); in hitracechain_rust_unit_test_003()
49 trace_id.set_span_id(1025u64); in hitracechain_rust_unit_test_003()
50 assert!(trace_id.get_span_id() == 1025u64); in hitracechain_rust_unit_test_003()
51 trace_id.set_parent_span_id(1026u64); in hitracechain_rust_unit_test_003()
52 assert!(trace_id.get_parent_span_id() == 1026u64); in hitracechain_rust_unit_test_003()
/base/request/request/services/src/
H A Dtrace.rs22 const HITRACE_TAG_MISC: u64 = 1u64 << 41;
/base/msdp/device_status/rust/data/sys/src/ipc/
H A Ddefault.rs39 calling_uid: u64,
40 calling_pid: u64,
41 calling_token_id: u64,
/base/hiviewdfx/hitrace/interfaces/rust/innerkits/hitracechain/src/
H A Dlib.rs100 trace_details: [u64;2],
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()
/base/request/request/services/src/manage/
H A Dapp_state.rs60 .notify_foreground_app_change(uid as u64) in app_state_change_callback()
67 .notify_app_background(uid as u64) in app_state_change_callback()
83 .notify_process_terminate(pid as u64) in process_state_change_callback()
104 uid as u64, in on_receive_event()
/base/request/request/services/src/service/run_count/
H A Dmanager.rs52 pub(crate) fn subscribe_run_count(&self, pid: u64, obj: RemoteObj) -> ErrorCode {
59 pub(crate) fn unsubscribe_run_count(&self, pid: u64) -> ErrorCode {
75 remotes: HashMap<u64, Client>,
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()
H A Dmod.rs29 Subscribe(u64, RemoteObj, Sender<ErrorCode>),
30 Unsubscribe(u64, Sender<ErrorCode>),
/base/request/request/services/src/manage/scheduler/queue/
H A Dmod.rs44 download_queue: HashMap<(u64, u32), Arc<RequestTask>>,
45 upload_queue: HashMap<(u64, u32), Arc<RequestTask>>,
46 running_tasks: HashMap<(u64, u32), Option<AbortHandle>>,
76 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> {
82 pub(crate) fn task_finish(&mut self, uid: u64, task_id: u32) {
86 pub(crate) fn try_restart(&mut self, uid: u64, task_id: u32) -> bool {
121 pub(crate) fn reschedule(&mut self, qos: QosChanges, qos_remove_queue: &mut Vec<(u64, u32)>) {
134 qos_remove_queue: &mut Vec<(u64, u32)>,
152 task.speed_limit(qos_direction.direction() as u64);
190 task.speed_limit(qos_direction.direction() as u64);
[all...]
/base/request/request/services/src/service/client/
H A Dmanager.rs54 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()
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()
H A Dmod.rs36 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> {
68 pub(crate) fn subscribe(&self, tid: u32, pid: u64, uid: u64, token_id: u64) -> ErrorCode {
105 pub(crate) fn notify_process_terminate(&self, pid: u64)
[all...]
/base/request/request/services/src/utils/
H A Dmod.rs63 pub(crate) fn get_current_timestamp() -> u64 {
65 Ok(n) => n.as_millis() as u64,
134 fn GetCallingBundle(token_id: u64) -> String; in GetCallingBundle()
135 fn IsSystemAPI(token_id: u64) -> bool; in IsSystemAPI()
136 fn CheckPermission(token_id: u64, permission: &str) -> bool; in CheckPermission()
/base/security/asset/services/crypto_manager/src/
H A Dcrypto_manager.rs84 pub fn max_crypto_expire_duration(&mut self) -> u64 { in max_crypto_expire_duration()
88 max_time = max(crypto.valid_time() as u64 - crypto.start_time().elapsed().as_secs(), max_time) in max_crypto_expire_duration()
94 self.cryptos.retain(|crypto| crypto.start_time().elapsed().as_secs() <= crypto.valid_time() as u64); in remove_expired_crypto()
/base/request/request/pre_download/native/src/download/
H A Dtask.rs62 fn on_progress(&mut self, dl_total: u64, dl_now: u64, ul_total: u64, ul_now: u64) {} in on_progress()
/base/update/updater/services/rust/hash_signed_data/src/
H A Dlib.rs155 -> *const ImgHashData<u64>
228 pub unsafe extern fn CheckDataHashNew(img_hash_data: *const ImgHashData<u64>,
229 img_name: *const c_char, start: u64, end: u64, hash_value: *const u8, len: usize) -> bool
256 pub unsafe extern fn ReleaseImgHashDataNew(hash_data: *const ImgHashData<u64>)
262 unsafe { drop(Box::from_raw(hash_data as *mut ImgHashData<u64>)); }
/base/request/request/services/src/manage/scheduler/
H A Dmod.rs44 const MILLISECONDS_IN_ONE_MONTH: u64 = 30 * 24 * 60 * 60 * 1000;
101 pub(crate) fn get_task(&self, uid: u64, task_id: u32) -> Option<&Arc<RequestTask>> {
119 pub(crate) fn start_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> {
123 pub(crate) fn resume_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> {
127 fn start_inner(&mut self, uid: u64, task_id: u32, is_resume: bool) -> Result<(), ErrorCode> { in start_inner()
165 pub(crate) fn pause_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> {
179 pub(crate) fn remove_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> {
194 pub(crate) fn stop_task(&mut self, uid: u64, task_id: u32) -> Result<(), ErrorCode> {
204 pub(crate) fn task_completed(&mut self, uid: u64, task_id: u32) {
228 uid: u64,
[all...]

Completed in 7 milliseconds

123