/base/request/request/services/src/service/ |
H A D | interface.rs | 17 pub const CONSTRUCT: u32 = 0; 19 pub const PAUSE: u32 = 1; 21 pub const QUERY: u32 = 2; 23 pub const QUERY_MIME_TYPE: u32 = 3; 25 pub const REMOVE: u32 = 4; 27 pub const RESUME: u32 = 5; 29 pub const START: u32 = 6; 31 pub const STOP: u32 = 7; 33 pub const SHOW: u32 = 8; 35 pub const TOUCH: u32 [all...] |
H A D | notification_bar.rs | 81 pub(crate) fn force_cancel_progress_notification(task_id: u32) { 138 task_id: u32, 168 fn pause_task(&self, task_id: u32) -> bool { in pause_task() 172 fn resume_task(&self, task_id: u32) -> bool { in resume_task() 176 fn stop_task(&self, task_id: u32) -> bool { in stop_task() 180 fn event_inner<F>(&self, task_id: u32, f: F) -> bool in event_inner() 182 F: Fn(u64, u32) -> (TaskManagerEvent, Recv<ErrorCode>), in event_inner() 193 error!("notification_bar {} failed: {}", task_id, ret as u32); in event_inner() 205 fn query_task_background(&self, task_id: u32) -> bool { in query_task_background() 222 fn pause_task(&self, task_id: u32) [all...] |
H A D | stub.rs | 56 pub(crate) fn check_task_uid(&self, task_id: u32, uid: u64) -> bool { 63 fn on_remote_request(&self, code: u32, data: &mut MsgParcel, reply: &mut MsgParcel) -> i32 { in on_remote_request() 115 reply.write(&(tf.common_data.action as u32))?; 116 reply.write(&(tf.common_data.mode as u32))?; 117 reply.write(&(tf.common_data.reason as u32))?; 131 reply.write(&(tf.form_items.len() as u32))?; 137 reply.write(&(tf.file_specs.len() as u32))?; 145 reply.write(&(tf.progress.common_data.state as u32))?; 147 reply.write(&(index as u32))?; 152 reply.write(&(tf.progress.extras.len() as u32)) [all...] |
/base/msdp/device_status/rust/ipc/service/src/ |
H A D | identity.rs | 47 const PARAMBITS: u32 = 12;
48 const PARAMMASK: u32 = (1u32 << PARAMBITS) - 1u32;
49 const INTENTIONSHIFT: u32 = PARAMBITS;
50 const INTENTIONBITS: u32 = 8;
51 const INTENTIONMASK: u32 = (1u32 << INTENTIONBITS) - 1u32;
52 const ACTIONSHIFT: u32 [all...] |
H A D | lib.rs | 60 fn add_watch(&self, intention: Intention, id: u32, data: &BorrowedMsgParcel<'_>, reply: &mut BorrowedMsgParcel<'_>) -> FusionResult<()>; in add_watch() 62 fn remove_watch(&self, intention: Intention, id: u32, data: &BorrowedMsgParcel<'_>, reply: &mut BorrowedMsgParcel<'_>) -> FusionResult<()>; in remove_watch() 65 fn set_param(&self, intention: Intention, id: u32, data: &BorrowedMsgParcel<'_>, reply: &mut BorrowedMsgParcel<'_>) -> FusionResult<()>; in set_param() 68 fn get_param(&self, intention: Intention, id: u32, data: &BorrowedMsgParcel<'_>, reply: &mut BorrowedMsgParcel<'_>) -> FusionResult<()>; in get_param() 72 fn control(&self, intention: Intention, id: u32, data: &BorrowedMsgParcel<'_>, reply: &mut BorrowedMsgParcel<'_>) -> FusionResult<()>; in control() 75 fn on_remote_request(stub: &dyn IDeviceStatus, code: u32, data: &BorrowedMsgParcel<'_>, in on_remote_request() 149 fn send_request(&self, action: CommonAction, intention: Intention, id: u32, in send_request() 183 self.send_request(CommonAction::Enable, intention, 0u32, data, reply) 189 self.send_request(CommonAction::Disable, intention, 0u32, data, reply) 195 self.send_request(CommonAction::Start, intention, 0u32, dat in start() [all...] |
/base/security/asset/services/plugin/src/ |
H A D | asset_plugin.rs | 114 fn get_db_name(attributes: &ExtDbMap, is_ce: bool) -> std::result::Result<String, u32> { in get_db_name() 115 let owner = attributes.get_bytes_attr(&column::OWNER).map_err(|e| e.code as u32)?; in get_db_name() 116 let owner_type = attributes.get_enum_attr::<OwnerType>(&column::OWNER_TYPE).map_err(|e| e.code as u32)?; in get_db_name() 118 construct_splited_db_name(owner_type, owner, is_ce).map_err(|e| e.code as u32) in get_db_name() 124 fn init(&mut self, user_id: i32) -> std::result::Result<(), u32> { in init() 125 create_user_de_dir(user_id).map_err(|e| e.code as u32)?; in init() 131 fn add(&mut self, attributes: &ExtDbMap) -> std::result::Result<i32, u32> { in add() 133 let mut db = Database::build_with_file_name(self.user_id, &db_name, false).map_err(|e| e.code as u32)?; in add() 134 db.insert_datas(attributes).map_err(|e| e.code as u32) in add() 138 fn ce_add(&mut self, attributes: &ExtDbMap) -> std::result::Result<i32, u32> { in ce_add() [all...] |
/base/security/asset/test/unittest/module_test/src/ |
H A D | asset_system_api_test.cpp | 89 { .tag = SEC_ASSET_TAG_ACCESSIBILITY, .value.u32 = SEC_ASSET_ACCESSIBILITY_DEVICE_UNLOCKED }, in HWTEST_F() 90 { .tag = SEC_ASSET_TAG_USER_ID, .value.u32 = SPECIFIC_USER_ID }, in HWTEST_F() 92 { .tag = SEC_ASSET_TAG_AUTH_TYPE, .value.u32 = SEC_ASSET_AUTH_TYPE_NONE }, in HWTEST_F() 93 { .tag = SEC_ASSET_TAG_SYNC_TYPE, .value.u32 = SEC_ASSET_SYNC_TYPE_NEVER }, in HWTEST_F() 94 { .tag = SEC_ASSET_TAG_CONFLICT_RESOLUTION, .value.u32 = SEC_ASSET_CONFLICT_OVERWRITE }, in HWTEST_F() 130 { .tag = SEC_ASSET_TAG_USER_ID, .value.u32 = SPECIFIC_USER_ID }, in HWTEST_F() 131 { .tag = SEC_ASSET_TAG_ACCESSIBILITY, .value.u32 = SEC_ASSET_ACCESSIBILITY_DEVICE_UNLOCKED }, in HWTEST_F() 138 { .tag = SEC_ASSET_TAG_USER_ID, .value.u32 = SPECIFIC_USER_ID }, in HWTEST_F() 139 { .tag = SEC_ASSET_TAG_RETURN_TYPE, .value.u32 = SEC_ASSET_RETURN_ALL } in HWTEST_F() 160 { .tag = SEC_ASSET_TAG_ACCESSIBILITY, .value.u32 in HWTEST_F() [all...] |
/base/security/asset/services/common/src/ |
H A D | process_info.rs | 27 app_id_len: u32, 33 uid: u32, 38 user_id: u32, 39 owner_type: u32, 42 process_name_len: u32, 49 fn init(user_id: u32, uid: u32, process_name: &mut Vec<u8>, app_id: &mut Vec<u8>) -> Self { in init() 54 process_name_len: process_name.len() as u32, in init() 55 hap_info: HapInfoFfi { app_id: app_id.as_mut_ptr(), app_id_len: app_id.len() as u32, app_index: 0 }, in init() 62 fn GetCallingProcessInfo(userId: u32, ui [all...] |
/base/security/code_signature/services/key_enable/src/ |
H A D | cert_path_utils.rs | 58 fn from_str(s: &str) -> Result<u32, ()> { in from_str() 60 "Platform" => Ok(ReleaseCertPathType::Platform as u32), in from_str() 61 "Authed" => Ok(ReleaseCertPathType::Authed as u32), in from_str() 62 "Developer" => Ok(ReleaseCertPathType::Developer as u32), in from_str() 63 "Block" => Ok(ReleaseCertPathType::Block as u32), in from_str() 64 "Restricted" => Ok(ReleaseCertPathType::Restricted as u32), in from_str() 86 fn from_str(s: &str) -> Result<u32, ()> { in from_str() 88 "Platform" => Ok(DebugCertPathType::Platform as u32), in from_str() 89 "Authed" => Ok(DebugCertPathType::Authed as u32), in from_str() 90 "Developer" => Ok(DebugCertPathType::Developer as u32), in from_str() [all...] |
/base/request/request/test/rustest/src/ |
H A D | lib.rs | 49 pub const CHANNEL_MAGIC_NUM: u32 = 0x43434646; 52 static MESSAGES: OnceCell<Arc<Mutex<HashMap<u32, Vec<MessageInfo>>>>> = OnceCell::new(); 61 messages: Arc<Mutex<HashMap<u32, Vec<MessageInfo>>>>, 85 .send((length as u32).to_le_bytes().as_slice()) in new() 104 pub fn construct(&self, config: TaskConfig) -> u32 { in construct() 114 reply.read::<i32>().unwrap() as u32 in construct() 117 pub fn pause(&self, task_id: u32) { in pause() 118 self.pause_version(1u32, task_id); in pause() 121 pub fn pause_v10(&self, task_id: u32) { in pause_v10() 122 self.pause_version(2u32, task_i in pause_v10() [all...] |
/base/security/asset/services/crypto_manager/src/ |
H A D | crypto.rs | 28 fn InitKey(keyId: *const KeyId, valid_time: u32, challenge: *mut OutBlob, handle: *mut OutBlob) -> i32; in InitKey() 50 valid_time: u32, 56 pub fn build(key: SecretKey, calling_info: CallingInfo, valid_time: u32) -> Result<Self> { in build() 69 let key_alias = HksBlob { size: self.key.alias().len() as u32, data: self.key.alias().as_ptr() }; in init_key() 70 let mut challenge = OutBlob { size: self.challenge.len() as u32, data: self.challenge.as_mut_ptr() }; in init_key() 71 let mut handle = OutBlob { size: self.handle.len() as u32, data: self.handle.as_mut_ptr() }; in init_key() 84 _ => Err(transfer_error_code(ErrCode::try_from(ret as u32)?)), in init_key() 94 let aad = HksBlob { size: aad.len() as u32, data: aad.as_ptr() }; in exec_crypt() 95 let auth_token = HksBlob { size: auth_token.len() as u32, data: auth_token.as_ptr() }; in exec_crypt() 96 let handle = HksBlob { size: self.handle.len() as u32, dat in exec_crypt() [all...] |
/base/security/asset/frameworks/ipc/src/ |
H A D | lib.rs | 29 pub const IPC_SUCCESS: u32 = 0; 31 const MAX_MAP_CAPACITY: u32 = 64; 32 const MAX_VEC_CAPACITY: u32 = 0x10000; 56 if map.len() as u32 > MAX_MAP_CAPACITY { in serialize_map() 59 parcel.write(&(map.len() as u32)).map_err(ipc_err_handle)?; in serialize_map() 69 parcel.write(&(tag as u32)).map_err(ipc_err_handle)?; in serialize_map() 72 Value::Number(n) => parcel.write::<u32>(n).map_err(ipc_err_handle)?, in serialize_map() 81 let len = parcel.read::<u32>().map_err(ipc_err_handle)?; in deserialize_map() 87 let tag = parcel.read::<u32>().map_err(ipc_err_handle)?; in deserialize_map() 95 let v = parcel.read::<u32>() in deserialize_map() [all...] |
/base/msdp/device_status/rust/subsystem/device_profile/sys/src/ |
H A D | device_profile.rs | 45 #[repr(u32)] 53 impl From<ProfileEvent> for u32 { 54 fn from(value: ProfileEvent) -> u32 { in from() 63 impl TryFrom<u32> for ProfileEvent { 66 fn try_from(value: u32) -> Result<Self, Self::Error> { in try_from() 68 _ if u32::from(ProfileEvent::Unknown) == value => { Ok(ProfileEvent::Unknown) }, in try_from() 69 _ if u32::from(ProfileEvent::SyncCompleted) == value => { Ok(ProfileEvent::SyncCompleted) }, in try_from() 70 _ if u32::from(ProfileEvent::ProfileChanged) == value => { Ok(ProfileEvent::ProfileChanged) }, in try_from() 249 profile_event: info.profile_event as u32, in subscribe_profile_events() 304 let mut profileevents = Vec::<u32> in unsubscribe_profile_events() [all...] |
/base/security/asset/frameworks/utils/src/ |
H A D | hasher.rs | 18 const LOWER_BYTES_MASK: u32 = 0xff; 24 const SHA256_H: [u32; 8] = 27 const SHA256_K: [u32; 64] = [ 38 fn expand_chunk(plain_chunk: [u8; BYTES_PER_CHUNK]) -> [u32; BYTES_PER_CHUNK] { in expand_chunk() 42 *item = ((plain_chunk[offset] as u32) << 24) 43 | ((plain_chunk[offset + 1] as u32) << 16) 44 | ((plain_chunk[offset + 2] as u32) << 8) 45 | (plain_chunk[offset + 3] as u32); 61 fn compress_chunk(expanded_chunk: [u32; 64]) -> [u32; [all...] |
/base/security/asset/interfaces/inner_kits/c/src/ |
H A D | lib.rs | 24 const MAX_MAP_CAPACITY: u32 = 64; 27 fn AssetMalloc(size: u32) -> *mut c_void; in AssetMalloc() 30 fn into_map(attributes: *const AssetAttr, attr_cnt: u32) -> Option<AssetMap> { in into_map() 72 pub extern "C" fn add_asset(attributes: *const AssetAttr, attr_cnt: u32) -> i32 { in add_asset() 92 pub extern "C" fn remove_asset(query: *const AssetAttr, query_cnt: u32) -> i32 { in remove_asset() 114 query_cnt: u32, in update_asset() 116 update_cnt: u32, in update_asset() 146 pub unsafe extern "C" fn pre_query_asset(query: *const AssetAttr, query_cnt: u32, challenge: *mut AssetBlob) -> i32 { 182 pub unsafe extern "C" fn query_asset(query: *const AssetAttr, query_cnt: u32, result_set: *mut AssetResultSet) -> i32 { 214 pub extern "C" fn post_query_asset(handle: *const AssetAttr, handle_cnt: u32) [all...] |
/base/security/asset/frameworks/definition/src/ |
H A D | extension.rs | 28 const DATA_TYPE_MASK: u32 = 0xF << 28; 32 let mask = (*self as u32) & DATA_TYPE_MASK; in data_type() 34 _ if DataType::Bool as u32 == mask => DataType::Bool, in data_type() 35 _ if DataType::Number as u32 == mask => DataType::Number, in data_type() 36 _ if DataType::Bytes as u32 == mask => DataType::Bytes, in data_type() 44 Value::Number(self as u32) in into_value() 82 impl Conversion for u32 { 108 fn get_enum_attr<T: TryFrom<u32, Error = AssetError>>(&self, key: &K) -> Result<T> { in get_enum_attr() 116 fn get_num_attr(&self, key: &K) -> Result<u32> { in get_num_attr()
|
H A D | macros.rs | 40 impl std::convert::TryFrom<u32> for $name { 43 fn try_from(v: u32) -> std::result::Result<Self, Self::Error> { in try_from() 45 $(x if x == $name::$vname as u32 => Ok($name::$vname),)* in try_from() 48 "[FATAL]Type[{}] try from u32[{}] failed.", stringify!($name), v) in try_from() 88 impl std::convert::TryFrom<u32> for $name { 91 fn try_from(v: u32) -> std::result::Result<Self, Self::Error> { in try_from() 93 $(x if x == $name::$vname as u32 => Ok($name::$vname),)* in try_from() 96 "[FATAL]Type[{}] try from u32[{}] failed.", stringify!($name), v) in try_from() 118 $crate::Value::Number(self as u32) in into_value() 161 /// Impl from trait for u32 [all...] |
/base/request/request/services/src/service/command/ |
H A D | construct.rs | 41 let action: u32 = data.read()?; 44 let version: u32 = data.read()?; 47 let mode: u32 = data.read()?; 50 let bundle_type: u32 = data.read()?; 54 let network: u32 = data.read()?; 67 let index: u32 = data.read()?; 77 let priority: u32 = data.read()?; 101 let certs_path_size: u32 = data.read()?; 102 if certs_path_size > data.readable() as u32 { 113 let form_size: u32 [all...] |
/base/hiviewdfx/hicollie/interfaces/rust/src/ |
H A D | lib.rs | 26 timeout: u32, in SetTimerRust() 29 flag: u32, in SetTimerRust() 42 timeout: u32, in set_timer() 45 flag: u32, in set_timer()
|
/base/request/request/services/src/service/client/ |
H A D | mod.rs | 30 const REQUEST_MAGIC_NUM: u32 = 0x43434646; 32 const POSITION_OF_LENGTH: u32 = 10; 37 Subscribe(u32, u64, u64, u64, Sender<ErrorCode>), 38 Unsubscribe(u32, Sender<ErrorCode>), 39 TaskFinished(u32), 41 SendResponse(u32, String, u32, String, Headers), 68 pub(crate) fn subscribe(&self, tid: u32, pid: u64, uid: u64, token_id: u64) -> ErrorCode { 84 pub(crate) fn unsubscribe(&self, tid: u32) -> ErrorCode { 100 pub(crate) fn notify_task_finished(&self, tid: u32) { [all...] |
/base/msdp/device_status/rust/data/sys/src/ |
H A D | plugin_manager.rs | 45 fn add_watch(&self, context: &CallingContext, id: u32, data: &BorrowedMsgParcel, reply: &mut BorrowedMsgParcel) -> FusionResult<()>; in add_watch() 47 fn remove_watch(&self, context: &CallingContext, id: u32, data: &BorrowedMsgParcel, reply: &mut BorrowedMsgParcel) -> FusionResult<()>; in remove_watch() 49 fn set_param(&self, context: &CallingContext, id: u32, data: &BorrowedMsgParcel, reply: &mut BorrowedMsgParcel) -> FusionResult<()>; in set_param() 51 fn get_param(&self, context: &CallingContext, id: u32, data: &BorrowedMsgParcel, reply: &mut BorrowedMsgParcel) -> FusionResult<()>; in get_param() 54 fn control(&self, context: &CallingContext, id: u32, data: &BorrowedMsgParcel, reply: &mut BorrowedMsgParcel) -> FusionResult<()>; in control()
|
/base/msdp/device_status/rust/utils/src/ |
H A D | macros.rs | 31 #[repr(u32)] 39 impl TryFrom<u32> for $name { 41 fn try_from(code: u32) -> std::result::Result<Self, Self::Error> { in try_from() 44 _ if code == Self::$item as u32 => { in try_from() 60 (Self::$item as u32).serialize(parcel) in serialize() 69 match u32::deserialize(parcel) { in deserialize()
|
/base/security/asset/test/unittest/common/src/ |
H A D | asset_test_common.cpp | 43 { .tag = SEC_ASSET_TAG_USER_ID, .value.u32 = SPECIFIC_USER_ID } in RemoveByAliasSdk() 59 .value.u32 = ASSET_RETURN_ALL in QueryByAliasNdk() 71 { .tag = SEC_ASSET_TAG_RETURN_TYPE, .value.u32 = SEC_ASSET_RETURN_ALL }, in QueryByAliasSdk() 72 { .tag = SEC_ASSET_TAG_USER_ID, .value.u32 = SPECIFIC_USER_ID } in QueryByAliasSdk() 114 if (attrs[i].value.u32 != res->value.u32) { in CheckMatchAttrResultSdk() 115 printf("tag is %x, %u vs %u", attrs[i].tag, attrs[i].value.u32, res->value.u32); in CheckMatchAttrResultSdk()
|
/base/request/request/services/src/manage/events/ |
H A D | mod.rs | 48 pub(crate) fn construct(config: TaskConfig) -> (Self, Recv<Result<u32, ErrorCode>>) { 49 let (tx, rx) = channel::<Result<u32, ErrorCode>>(); 59 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>) { 104 pub(crate) fn dump_one(task_id: u32) -> (Self, Recv<Option<DumpOneInfo>>) { 116 pub(crate) fn subscribe(task_id: u32, token_id: u64) -> (Self, Recv<ErrorCode>) { 127 Query(u32, Actio [all...] |
/base/msdp/device_status/rust/modules/scheduler/sys/src/ |
H A D | scheduler.rs | 34 pub const LIBC_EPOLLIN: u32 = libc::EPOLLIN as u32; 35 const LIBC_EPOLLONESHOT: u32 = libc::EPOLLONESHOT as u32; 37 pub const LIBC_EPOLLERR: u32 = libc::EPOLLERR as u32; 39 pub const LIBC_EPOLLHUP: u32 = libc::EPOLLHUP as u32; 40 const LIBC_EPOLLALL: u32 = LIBC_EPOLLIN | LIBC_EPOLLERR | LIBC_EPOLLHUP; 41 const LIBC_EPOLLNONE: u32 [all...] |