Home
last modified time | relevance | path

Searched refs:clone (Results 1 - 25 of 64) sorted by relevance

123

/base/security/certificate_framework/frameworks/core/v1.0/certificate/
H A Dcert_crl_common.c28 HcfX509Certificate *clone = NULL; in CloneCertificateObj() local
29 res = HcfX509CertificateCreate(&encodingBlob, &clone); in CloneCertificateObj()
35 *out = clone; in CloneCertificateObj()
48 HcfX509Crl *clone = NULL; in CloneCrlObj() local
49 res = HcfX509CrlCreate(&encodingBlob, &clone); in CloneCrlObj()
55 *out = clone; in CloneCrlObj()
/base/request/request/services/src/manage/scheduler/queue/
H A Dkeeper.rs40 let handle = count_down(tx.clone());
42 tx: tx.clone(),
52 fn clone(&self) -> Self { in clone() functions
66 tx: self.tx.clone(), in clone()
67 inner: self.inner.clone(), in clone()
80 inner.handle = Some(count_down(self.tx.clone())); in drop()
H A Dmod.rs66 keeper: SAKeeper::new(tx.clone()),
93 let running_task = RunningTask::new(task.clone(), self.tx.clone(), self.keeper.clone());
95 let abort_flag_clone = abort_flag.clone();
97 running_task.run(abort_flag_clone.clone()).await;
170 self.network.clone(),
192 new_queue.insert((uid, task_id), task.clone());
200 let running_task = RunningTask::new(task.clone(), self.tx.clone(), sel
[all...]
H A Drunning_task.rs48 download(self.task.clone(), abort_flag).await;
51 upload(self.task.clone(), abort_flag).await;
/base/request/request/services/src/
H A Dability.rs91 let task_manager = TaskManager::init(runcount_manager.clone(), client_manger.clone()); in init()
92 *self.task_manager.lock().unwrap() = Some(task_manager.clone()); in init()
96 AppStateListener::init(client_manger.clone(), task_manager.clone()); in init()
110 handler.clone(), in init()
114 self.remote_busy.clone(), in init()
/base/request/request/services/src/manage/
H A Daccount.rs67 let old_background = BACKGROUND_ACCOUNTS.lock().unwrap().clone();
134 TASK_MANAGER_TX = Some(task_manager.clone());
142 Box::new(task_manager.clone()),
144 |_new_id, _old_id, task_manager| update_accounts(task_manager.clone()),
161 Box::new(task_manager.clone()),
162 |_id, task_manager| update_accounts(task_manager.clone()),
180 Box::new(task_manager.clone()),
201 Box::new(task_manager.clone()),
202 |_id, task_manager| update_accounts(task_manager.clone()),
217 update_accounts(task_manager.clone());
[all...]
H A Dnetwork.rs44 self.inner.state.read().unwrap().clone()
54 Box::new(inner.clone()),
56 inner: task_manager.clone(),
110 *state = Online(info.clone());
171 inner: notifier.clone(), in ut_network()
H A Dtask_manager.rs82 registry_account_subscribe(tx.clone());
85 let network = register_network_change(tx.clone());
86 subscribe_notification_bar(tx.clone());
94 AppUninstallSubscriber::new(tx.clone()),
99 let task_manager = Self::new(tx.clone(), rx, runcount_manager, client_manager, network);
114 runtime_spawn(restore_all_tasks(tx.clone()));
116 runtime_spawn(clear_timeout_tasks(tx.clone()));
130 tx.clone(),
132 client_manager.clone(),
133 network.clone(),
[all...]
/base/security/asset/test/unittest/module_test/src/crypto_manager/
H A Dlib.rs107 let mut crypto = Crypto::build(secret_key.clone(), calling_info, 600).unwrap(); in crypto_init()
123 let mut crypto = Crypto::build(secret_key.clone(), calling_info, 600).unwrap(); in crypto_exec()
138 let mut crypto1 = Crypto::build(secret_key1.clone(), calling_info.clone(), 600).unwrap(); in crypto_manager()
139 let challenge1 = crypto1.init_key().unwrap().clone(); in crypto_manager()
144 let mut crypto2 = Crypto::build(secret_key2.clone(), calling_info.clone(), 600).unwrap(); in crypto_manager()
145 let challenge2 = crypto2.init_key().unwrap().clone(); in crypto_manager()
/base/msdp/device_status/rust/subsystem/device_profile/sys/src/
H A Dbinding.rs39 /// Type definition for the clone function of the `CIProfileEvents` struct.
47 /// An optional clone function pointer for creating a clone of the `CIProfileEvents` object.
48 pub clone: Option<CIProfileEventsClone>,
66 /// Type definition for the clone function of the `CISubscribeInfos` struct.
74 /// An optional clone function for creating a clone of the `CISubscribeInfos` object.
75 pub clone: Option<CISubscribeInfosClone>,
124 /// Type definition for the clone function of a CIProfileEventCb.
134 /// The clone functio
[all...]
/base/msdp/device_status/rust/subsystem/device_profile/binding/include/
H A Dfusion_device_profile_adapter.h23 CIStringVector* (*clone)(CIStringVector *); member
30 CICrossStateListener* (*clone)(CICrossStateListener* listener); member
H A Dfusion_device_profile.h30 CIProfileEvents* (*clone)(CIProfileEvents* cb); member
68 CIProfileEventCb* (*clone)(CIProfileEventCb* cb); member
H A Dfusion_security.h27 CIString* (*clone)(CIString*); member
/base/request/request/services/src/task/
H A Drequest_task.rs82 self.mime_type.lock().unwrap().clone()
149 let mut sizes = files.sizes.clone();
218 let mime_type = info.mime_type.clone();
253 bundle: self.conf.bundle.clone(),
255 progress: self.progress.lock().unwrap().clone(),
266 let progress = self.progress.lock().unwrap().clone();
284 let url = self.conf.url.clone();
374 let request = request_builder.body(Body::slice(self.conf.data.clone()))?;
475 let headers = response.headers().clone();
531 path: file_spec.path.clone(),
[all...]
H A Dinfo.rs48 self.mime_type.clone()
56 self.token.clone()
160 bundle: self.bundle.clone(),
161 progress: self.progress.clone(),
164 each_file_status: self.each_file_status.clone(),
H A Ddownload.rs75 if let Err(e) = download_inner(task.clone(), abort_flag.clone()).await {
218 let mut downloader = build_downloader(task.clone(), response, abort_flag);
302 TaskManager::init(RUN_COUNT_MANAGER.clone(), CLIENT.clone(), NETWORK.clone()) in build_task()
310 CLIENT.clone(), in build_task()
311 NETWORK.clone(), in build_task()
407 let clone_task = task.clone(); in ut_download_resume_not_support_range()
412 let err = download_inner(task.clone()) in ut_download_resume_not_support_range()
[all...]
/base/security/asset/services/db_operator/src/
H A Ddatabase_file_upgrade.rs59 let mut split_owner_info_mut = split_owner_info.clone(); in construct_splited_db_name()
63 let owner_info = split_owner_info_mut.join("_").clone(); in construct_splited_db_name()
82 Some(value) => Ok(value.clone()), in get_value_from_db_map()
90 remove_db_files.push(path.clone()); in remove_old_db()
128 old_data_query_condition.insert(column::OWNER, Value::Bytes(owner_info.clone())); in construct_old_query_condition()
153 let mut data_clone = data.clone(); in migrate_data()
/base/request/request/services/src/manage/events/
H A Dconstruct.rs74 self.client_manager.clone(),
75 self.network.clone(),
/base/msdp/device_status/rust/subsystem/device_profile/binding/src/
H A Dfusion_device_profile.cpp46 if ((eventCb != nullptr) && (eventCb->clone != nullptr)) { in ProfileEventCallbackImpl()
47 eventCb_ = eventCb->clone(eventCb); in ProfileEventCallbackImpl()
124 events->clone = nullptr; in SubscribeProfileEvents()
172 events->clone = nullptr; in UnsubscribeProfileEvents()
/base/request/request/services/src/service/
H A Dnotification_bar.rs38 task.conf.file_specs[index].file_name.clone(),
39 task.progress.lock().unwrap().clone(),
54 .clone(),
69 .clone(),
/base/security/asset/services/core_service/src/operations/
H A Doperation_add.rs58 let mut condition = query.clone(); in resolve_conflict()
74 query.insert(column::ALIAS, Value::Bytes(alias.clone())); in get_query_condition()
75 query.insert(column::OWNER, Value::Bytes(calling_info.owner_info().clone())); in get_query_condition()
84 db_data.insert(column::CREATE_TIME, Value::Bytes(time.clone())); in add_system_attrs()
/base/startup/appspawn/common/
H A Dappspawn_server.c165 *pid = clone(CloneAppSpawn, NULL, CLONE_NEWNET | SIGCHLD, (void *)&arg); in NwebSpawnCloneChildProcess()
167 *pid = clone(CloneAppSpawn, NULL, content->sandboxNsFlags | SIGCHLD, (void *)&arg); in NwebSpawnCloneChildProcess()
170 *pid = clone(CloneAppSpawn, NULL, content->sandboxNsFlags | SIGCHLD, (void *)&arg); in NwebSpawnCloneChildProcess()
/base/msdp/device_status/rust/modules/scheduler/test/src/
H A Dlib.rs164 assert!(handler.add_epoll_handler(epoll.clone()).is_ok()); in test_add_epoll_handler()
212 let cloned_epoll = epoll.clone(); in test_post_perioric_task()
213 assert!(handler.add_epoll_handler(epoll.clone()).is_ok()); in test_post_perioric_task()
231 assert!(handler.add_epoll_handler(epoll.clone()).is_ok()); in test_post_delayed_task()
233 let cloned_epoll = epoll.clone(); in test_post_delayed_task()
/base/security/asset/services/crypto_manager/src/
H A Dsecret_key.rs91 let prefixed_new_alias = [ALIAS_PREFIX.to_vec(), new_alias.clone()].concat(); in get_existing_key_alias()
97 alias: prefixed_new_alias.clone(), in get_existing_key_alias()
109 alias: new_alias.clone(), in get_existing_key_alias()
122 alias: old_alias.clone(), in get_existing_key_alias()
207 let prefixed_new_alias = [ALIAS_PREFIX.to_vec(), new_alias.clone()].concat(); in new_without_alias()
/base/security/asset/services/core_service/src/common_event/
H A Dlistener.rs113 delete_cond.insert(column::OWNER, Value::Bytes(owner.clone())); in delete_on_package_removed()
139 let calling_info = CallingInfo::new(user_id, OwnerType::Hap, owner.clone()); in delete_data_by_owner()
314 Database::check_db_accessible(from_path.clone(), user_id, db_name.clone(), None)?; in backup_de_db_if_accessible()
333 Database::check_db_accessible(from_path.clone(), user_id, db_name.clone(), Some(&db_key))?; in backup_ce_db_if_accessible()
422 if SubscribeSystemEvent(call_back.clone()) {

Completed in 9 milliseconds

123