Home
last modified time | relevance | path

Searched refs:new (Results 1 - 25 of 195) sorted by relevance

12345678

/base/request/request/pre_download/native/src/cache/
H A Dmanage.rs35 fn new() -> Self { in new() functions
37 caches: Mutex::new(HashMap::new()), in new()
38 ram_cache_queue: Mutex::new(VecDeque::new()), in new()
39 file_cache_queue: Mutex::new(VecDeque::new()), in new()
40 handler: Mutex::new(Handler::new(DEFAULT_RAM_CACHE_SIZE)), in new()
45 static CACHE_MANAGER: LazyLock<CacheManager> = LazyLock::new(CacheManage
131 fn new(ram_cache_size: usize) -> Self { new() functions
[all...]
/base/startup/appspawn/etc/sandbox/
H A Dappdata_sandbox_fixer.py53 def _merge_list(origin, new):
54 if origin is None or new is None:
56 for data1 in new:
81 def _merge_scope_array(origin, new, keys):
82 for data1 in new:
105 def _merge_scope_flags_point(origin, new):
109 for data1 in new:
121 def _merge_scope_app(origin, new):
128 if new[0].get(k) is not None:
129 origin[0][k] = new[
[all...]
/base/security/asset/services/common/src/
H A Dcounter.rs27 fn new() -> Self { in new() functions
34 unsafe { INSTANCE.get_or_insert_with(|| Arc::new(Mutex::new(Counter::new()))).clone() } in get_instance()
61 pub fn new() -> Self { in new() functions
H A Dlib.rs48 AssetError::new(ErrCode::AccessDenied, "[FATAL]HUKS verify auth token failed".to_string()) in transfer_error_code()
51 AssetError::new(ErrCode::StatusMismatch, "[FATAL]Screen status does not match".to_string()) in transfer_error_code()
53 ErrCode::InvalidArgument => AssetError::new(ErrCode::InvalidArgument, "[FATAL]Invalid argument.".to_string()), in transfer_error_code()
54 ErrCode::BmsError => AssetError::new(ErrCode::BmsError, "[FATAL]Get owner info from bms failed.".to_string()), in transfer_error_code()
56 AssetError::new(ErrCode::AccessTokenError, "[FATAL]Get process info failed.".to_string()) in transfer_error_code()
58 _ => AssetError::new(ErrCode::CryptoError, "[FATAL]HUKS execute crypt failed".to_string()), in transfer_error_code()
/base/security/asset/test/unittest/inner_kits_rust/src/
H A Dupdate_abnormal.rs22 let mut update = AssetMap::new(); in update_query_without_alias()
25 let query = AssetMap::new(); in update_query_without_alias()
35 let mut update = AssetMap::new(); in update_query_invalid_alias()
38 let mut query = AssetMap::new(); in update_query_invalid_alias()
55 let mut update = AssetMap::new(); in update_query_alias_with_unmatched_type()
58 let mut query = AssetMap::new(); in update_query_alias_with_unmatched_type()
75 let mut update = AssetMap::new(); in update_query_invalid_accessibility()
77 let mut query = AssetMap::new(); in update_query_invalid_accessibility()
90 let mut update = AssetMap::new(); in update_query_invalid_auth_type()
92 let mut query = AssetMap::new(); in update_query_invalid_auth_type()
[all...]
H A Dupdate.rs25 let mut query = AssetMap::new(); in update_same_secret()
28 let mut update = AssetMap::new(); in update_same_secret()
42 let mut query = AssetMap::new(); in update_different_secret()
47 let mut update = AssetMap::new(); in update_different_secret()
65 let mut query = AssetMap::new(); in update_attr_normal()
69 let mut update = AssetMap::new(); in update_attr_normal()
85 let mut query = AssetMap::new(); in update_non_exist()
88 let mut update = AssetMap::new(); in update_non_exist()
H A Dquery_abnormal.rs21 let mut query = AssetMap::new(); in query_invalid_alias()
31 let mut query = AssetMap::new(); in query_invalid_accessibility()
39 let mut query = AssetMap::new(); in query_invalid_auth_type()
49 let mut query = AssetMap::new(); in query_invalid_sync_type()
59 let mut query = AssetMap::new(); in query_invalid_label()
70 let mut query = AssetMap::new(); in query_invalid_return_limit()
98 let mut query = AssetMap::new(); in query_invalid_return_ordered_by()
106 let mut query = AssetMap::new(); in query_invalid_return_type()
113 let mut query = AssetMap::new(); in query_invalid_auth_challenge()
123 let mut query = AssetMap::new(); in query_invalid_auth_token()
[all...]
H A Dpre_query.rs22 let mut query = AssetMap::new(); in pre_query_non_exist_with_alias()
32 let mut query = AssetMap::new(); in pre_query_with_wrong_auth_type()
43 let mut query = AssetMap::new(); in pre_query_with_wrong_accessibility()
54 let mut query = AssetMap::new(); in pre_query_with_unsupported_auth_type()
65 let mut query = AssetMap::new(); in pre_query_with_wrong_persistent()
76 let mut query = AssetMap::new(); in pre_query_with_wrong_sync_type()
87 let mut query = AssetMap::new(); in pre_query_batch_data()
102 let mut query = AssetMap::new(); in pre_query_single_data()
110 let mut query = AssetMap::new(); in pre_query_single_data()
122 let query = AssetMap::new(); in pre_query_max_times()
[all...]
H A Dpre_query_abnormal.rs21 let mut query = AssetMap::new(); in pre_query_invalid_alias()
31 let mut query = AssetMap::new(); in pre_query_invalid_accessibility()
38 let mut query = AssetMap::new(); in pre_query_invalid_auth_type()
48 let mut query = AssetMap::new(); in pre_query_invalid_sync_type()
56 let mut query = AssetMap::new(); in pre_query_invalid_auth_validity_period()
68 let mut query = AssetMap::new(); in pre_query_invalid_label()
81 let mut query = AssetMap::new(); in pre_query_bool_tag_with_unmatched_type()
95 let mut query = AssetMap::new(); in pre_query_bytes_tag_with_unmatched_type()
108 let mut query = AssetMap::new(); in pre_query_number_tag_with_unmatched_type()
121 let mut query = AssetMap::new(); in pre_query_unsupported_tags()
[all...]
H A Dremove_abnormal.rs21 let mut query = AssetMap::new(); in remove_invalid_alias()
31 let mut query = AssetMap::new(); in remove_invalid_accessibility()
39 let mut query = AssetMap::new(); in remove_invalid_auth_type()
49 let mut query = AssetMap::new(); in remove_invalid_sync_type()
59 let mut query = AssetMap::new(); in remove_invalid_label()
72 let mut query = AssetMap::new(); in remove_bool_tag_with_unmatched_type()
86 let mut query = AssetMap::new(); in remove_bytes_tag_with_unmatched_type()
99 let mut query = AssetMap::new(); in remove_number_tag_with_unmatched_type()
112 let mut query = AssetMap::new(); in remove_unsupported_tags()
126 let mut query = AssetMap::new(); in remove_unsupported_tags()
[all...]
/base/request/request/services/src/manage/scheduler/qos/
H A Drss.rs39 pub(crate) fn new(level: i32) -> Self {
97 RssCapacity::new(0), in ut_rss_capacity()
101 RssCapacity::new(1), in ut_rss_capacity()
105 RssCapacity::new(2), in ut_rss_capacity()
109 RssCapacity::new(3), in ut_rss_capacity()
113 RssCapacity::new(4), in ut_rss_capacity()
117 RssCapacity::new(5), in ut_rss_capacity()
121 RssCapacity::new(6), in ut_rss_capacity()
125 RssCapacity::new(7), in ut_rss_capacity()
H A Dmod.rs32 pub(crate) fn new() -> Self {
62 let mut changes = QosChanges::new();
80 let mut qos_vec = Vec::new(); in reschedule_inner()
92 qos_vec.push(QosDirection::new(task.uid(), task.task_id(), m1_speed)); in reschedule_inner()
94 qos_vec.push(QosDirection::new(task.uid(), task.task_id(), m2_speed)); in reschedule_inner()
131 qos_vec.push(QosDirection::new(task.uid(), task.task_id(), m3_speed)); in reschedule_inner()
158 qos_vec.push(QosDirection::new(task.uid(), task.task_id(), m3_speed)); in reschedule_inner()
/base/request/request/services/src/task/
H A Dfiles.rs61 let mut files = Vec::new(); in open_task_files()
62 let mut sizes = Vec::new(); in open_task_files()
72 return Err(io::Error::new(io::ErrorKind::Other, "none user file")); in open_task_files()
89 files.push(AsyncFile::new(file)); in open_task_files()
102 return Err(io::Error::new(io::ErrorKind::Other, "none user file")); in open_task_files()
113 files.push(AsyncFile::new(file)); in open_task_files()
119 Ok((Files::new(files), sizes)) in open_task_files()
130 let mut body_files = Vec::new(); in open_body_files()
138 body_files.push(AsyncFile::new(file)) in open_body_files()
140 Ok(Files::new(body_file in open_body_files()
187 fn new(files: Vec<AsyncFile>) -> Self { new() functions
[all...]
/base/msdp/device_status/rust/subsystem/input/sys/src/interaction/
H A Dpointer_style.rs34 Self::new() in default()
40 pub fn new() -> Self { in new() functions
56 Self::new() in default()
62 pub fn new() -> Self { in new() functions
/base/security/asset/services/core_service/src/
H A Dunload_handler.rs31 fn new() -> Self { in new() functions
38 unsafe { INSTANCE.get_or_insert_with(|| Arc::new(Mutex::new(UnloadHandler::new()))).clone() }
/base/msdp/device_status/rust/subsystem/distributed_hardware/sys/src/interaction/
H A Ddis_handware.rs40 let pkg_name = CString::new(FI_PKG_NAME)?; in init_device_manager()
54 let pkg_name = CString::new(FI_PKG_NAME)?; in register_device_state()
55 let extra = CString::new("")?; in register_device_state()
75 let pkg_name = CString::new(FI_PKG_NAME)?; in un_register_device_state()
76 let extra = CString::new("")?; in un_register_device_state()
/base/request/request/services/src/utils/
H A Dcommon_event.rs24 fn new(inner: Box<dyn CommonEventSubscriber>) -> Self { in new() functions
36 self.inner.on_receive_event(code, data, Want::new(want)); in on_receive_event()
46 fn new(inner: UniquePtr<WantWrapper>) -> Self { in new() functions
80 let res = ffi::SubscribeCommonEvent(events, Box::new(EventHandler::new(Box::new(handler)))); in fmt()
/base/request/request/services/src/manage/scheduler/state/
H A Drecorder.rs28 pub(crate) fn new() -> Self {
33 active_accounts: HashSet::new(),
45 let mut sql_list = SqlList::new();
63 Some(RssCapacity::new(rss_level))
71 let mut sql_list = SqlList::new();
86 let mut sql_list = SqlList::new();
95 let mut sql_list = SqlList::new();
113 let mut sql_list = SqlList::new();
/base/request/request/services/src/manage/scheduler/queue/
H A Dmod.rs57 pub(crate) fn new(
64 download_queue: HashMap::new(),
65 upload_queue: HashMap::new(),
66 keeper: SAKeeper::new(tx.clone()),
68 running_tasks: HashMap::new(),
72 upload_resume: HashSet::new(),
93 let running_task = RunningTask::new(task.clone(), self.tx.clone(), self.keeper.clone());
94 let abort_flag = Arc::new(AtomicBool::new(false));
103 Some(AbortHandle::new(abort_fla
242 fn new(abort_flag: Arc<AtomicBool>, join_handle: JoinHandle<()>) -> Self { new() functions
[all...]
/base/request/request/request_utils/src/
H A Dqueue_map.rs24 pub fn new() -> Self { in new() functions
26 map: HashMap::new(), in new()
27 v: VecDeque::new(), in new()
28 removed: HashSet::new(), in new()
73 let mut map = QueueMap::new(); in ut_queue_map_fifo()
82 let mut map = QueueMap::new(); in ut_queue_map_remove()
102 let mut map = QueueMap::new(); in ut_queue_map_same_key()
/base/hiviewdfx/hitrace/interfaces/rust/innerkits/hitrace_meter/src/
H A Dlib.rs21 let value_raw_ptr = CString::new(value).unwrap(); in start_trace()
38 let value_raw_ptr = CString::new(value).unwrap(); in start_trace_async()
47 let value_raw_ptr = CString::new(value).unwrap(); in finish_trace_async()
56 let name_raw_ptr = CString::new(name).unwrap(); in count_trace()
/base/request/request/services/src/manage/
H A Ddatabase.rs52 static ONCE: Once = Once::new();
64 user_file_tasks: Mutex::new(HashMap::new()),
74 static ONCE: Once = Once::new();
81 user_file_tasks: Mutex::new(HashMap::new()),
203 .insert(task.task_id(), Arc::new(task));
265 .insert(task.task_id(), Arc::new(task));
381 extras: HashMap::new(),
385 progress: Progress::new(ve
[all...]
H A Dnetwork.rs51 let inner = NetworkInner::new();
54 Box::new(inner.clone()),
55 Box::new(NetworkTaskManagerTx {
77 _registry: Arc::new(registry),
92 pub(crate) fn new() -> Self {
94 state: Arc::new(RwLock::new(NetworkState::Offline)),
169 let notifier = NetworkInner::new(); in ut_network()
172 _registry: Arc::new(UniquePtr::null()), in ut_network()
211 let notifier = NetworkInner::new(); in ut_network_notify()
[all...]
/base/update/updater/services/rust/hash_signed_data/src/
H A Dmacros.rs35 let file_name_str = match std::path::Path::new(file!()).file_name() {
40 let c_file_name = std::ffi::CString::new(file_name).expect("unknown");
41 let c_log_str = std::ffi::CString::new(log_str).expect("default log");
42 // can use CString::new(...).expect(...) because file_name and log_str can't have internal 0 byte
/base/request/request/test/rustest/src/
H A Dlib.rs52 static MESSAGES: OnceCell<Arc<Mutex<HashMap<u32, Vec<MessageInfo>>>>> = OnceCell::new();
56 RequestAgent::new(remote) in test_init()
65 fn new(remote: RemoteObj) -> Self { in new() functions
66 static ONCE: Once = Once::new(); in new()
67 let messages = MESSAGES.get_or_init(|| Arc::new(Mutex::new(HashMap::new()))); in new()
69 let mut data = MsgParcel::new(); in new()
105 let mut data = MsgParcel::new(); in construct()
126 let mut data = MsgParcel::new();
[all...]

Completed in 8 milliseconds

12345678