Home
last modified time | relevance | path

Searched refs:ipc_conn (Results 1 – 14 of 14) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/service_impl/
H A Dtypes.rs16 use crate::ipc_conn;
46 Asset(ipc_conn::CloudAsset),
49 Assets(Vec<ipc_conn::CloudAsset>),
58 impl From<&Value> for ipc_conn::FieldRaw {
68 Value::Assets(a) => ipc_conn::FieldRaw::Assets(ipc_conn::CloudAssets(a.clone())), in from()
73 impl From<&ipc_conn::FieldRaw> for Value {
88 impl From<ipc_conn::FieldRaw> for Value {
146 Ok(ipc_conn::Database { in try_from()
237 Ok(ipc_conn::OrderTable { in try_from()
257 impl From<&ipc_conn::Field> for Field {
[all …]
H A Dcloud_db.rs20 use crate::{ipc_conn, SyncResult};
27 database_ipc: ipc_conn::DatabaseStub,
84 ipc_conn::DatabaseStub::insert, in batch_insert()
105 ipc_conn::DatabaseStub::update, in batch_update()
236 &mut ipc_conn::DatabaseStub, in upload()
238 &ipc_conn::ValueBuckets, in upload()
239 &ipc_conn::ValueBuckets, in upload()
240 ) -> Result<Vec<Option<ipc_conn::ValueBucket>>, ipc_conn::Error>, in upload()
344 pub(crate) values: Vec<ipc_conn::ValueBucket>,
347 impl From<ipc_conn::CloudData> for CloudDbData {
[all …]
H A Dasset_loader.rs16 pub use crate::ipc_conn::{AssetStatus, CloudAsset};
19 use crate::{ipc_conn, SyncResult};
24 asset_loader: ipc_conn::AssetLoader,
35 let asset_loader = ipc_conn::AssetLoader::new(user_id)?; in new()
58 ipc_conn::AssetLoader::upload, in upload()
77 ipc_conn::AssetLoader::download, in download()
97 &ipc_conn::AssetLoader, in upload_download_inner()
101 &ipc_conn::CloudAssets, in upload_download_inner()
102 ) -> Result<Vec<Result<CloudAsset, ipc_conn::Error>>, ipc_conn::Error>, in upload_download_inner()
104 let mut assets_ipc = ipc_conn::CloudAssets::default(); in upload_download_inner()
H A Dcloud_service.rs17 use crate::{ipc_conn, SyncResult};
24 connect: ipc_conn::Connect,
38 connect: ipc_conn::Connect::new(user_id)?, in new()
81 let dbs_ipc = ipc_conn::Databases(vec); in subscribe()
106 let unsub = ipc_conn::UnsubscriptionInfo(relations.clone()); in unsubscribe()
146 impl From<&ipc_conn::Schema> for SchemaMeta {
147 fn from(value: &ipc_conn::Schema) -> Self { in from()
170 impl From<&ipc_conn::ServiceInfo> for CloudInfo {
171 fn from(value: &ipc_conn::ServiceInfo) -> Self { in from()
224 impl From<&ipc_conn::AppInfo> for AppInfo {
[all …]
H A Derror.rs16 use crate::ipc_conn;
43 IPCError(ipc_conn::Error),
46 IPCErrors(Vec<ipc_conn::Error>),
78 impl From<ipc_conn::Error> for SyncError {
79 fn from(value: ipc_conn::Error) -> Self { in from()
84 impl From<ipc_conn::Errors> for SyncError {
85 fn from(value: ipc_conn::Errors) -> Self { in from()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/c_adapter/
H A Dcloud_extension.rs19 use crate::ipc_conn;
34 fn map_ipc_err(e: &ipc_conn::Error) -> c_int { in map_ipc_err()
36 ipc_conn::Error::CreateMsgParcelFailed in map_ipc_err()
37 | ipc_conn::Error::GetProxyObjectFailed in map_ipc_err()
39 ipc_conn::Error::ReadMsgParcelFailed | ipc_conn::Error::WriteMsgParcelFailed => { in map_ipc_err()
44 ipc_conn::Error::UnlockFailed => ERRNO_UNLOCKED, in map_ipc_err()
48 ipc_conn::Error::NetworkError => ERRNO_NETWORK_ERROR, in map_ipc_err()
49 ipc_conn::Error::CloudDisabled => ERRNO_CLOUD_DISABLE, in map_ipc_err()
50 ipc_conn::Error::LockedByOthers => ERRNO_LOCKED_BY_OTHERS, in map_ipc_err()
53 ipc_conn::Error::UnknownError => ERRNO_UNKNOWN, in map_ipc_err()
[all …]
H A Dcloud_ext_types.rs18 use crate::ipc_conn;
66 pub type OhCloudExtCloudAsset = SafeCffiWrapper<ipc_conn::CloudAsset>;
225 ipc_conn::CloudAsset { in get_cloud_asset()
1250 ipc_conn::FieldRaw::Null => { in OhCloudExtValueBucketGetValue()
1255 ipc_conn::FieldRaw::Number(i) => { in OhCloudExtValueBucketGetValue()
1259 ipc_conn::FieldRaw::Real(f) => { in OhCloudExtValueBucketGetValue()
1263 ipc_conn::FieldRaw::Text(s) => { in OhCloudExtValueBucketGetValue()
1268 ipc_conn::FieldRaw::Bool(b) => { in OhCloudExtValueBucketGetValue()
1272 ipc_conn::FieldRaw::Blob(b) => { in OhCloudExtValueBucketGetValue()
1277 ipc_conn::FieldRaw::Asset(a) => { in OhCloudExtValueBucketGetValue()
[all …]
H A Dbasic_rust_types.rs17 use crate::ipc_conn;
56 ValueBucket(Vec<ipc_conn::ValueBucket>),
61 CloudAsset(Vec<ipc_conn::CloudAsset>),
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/
H A Dasset.rs20 use crate::ipc_conn::error::Error;
21 use crate::ipc_conn::ffi::ConnectService;
22 use crate::ipc_conn::function::AssetLoaderFunc::{Download, Upload};
23 use crate::ipc_conn::function::CloudServiceFunc::ConnectAssetLoader;
24 use crate::ipc_conn::{vec_raw_read, vec_raw_write, AssetStatus};
H A Ddatabase.rs20 use crate::ipc_conn::connect::ValueBucket;
21 use crate::ipc_conn::error::Error;
22 use crate::ipc_conn::ffi::ConnectService;
23 use crate::ipc_conn::function::CloudDB::{
26 use crate::ipc_conn::function::CloudServiceFunc::ConnectDatabase;
27 use crate::ipc_conn::*;
H A Dconnect.rs23 use crate::ipc_conn::asset::{CloudAsset, CloudAssets};
24 use crate::ipc_conn::error::{Error, Errors};
25 use crate::ipc_conn::ffi::ConnectService;
26 use crate::ipc_conn::function::CloudServiceFunc::{
29 use crate::ipc_conn::{
904 use crate::ipc_conn::connect::{Response, SubscriptionResultValue, SwitchStatus};
905 use crate::ipc_conn::{
H A Derror.rs21 use crate::ipc_conn::vec_raw_read;
H A Dmod.rs91 use crate::ipc_conn::{vec_raw_read, vec_raw_write};
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/
H A Dlib.rs31 pub mod ipc_conn; module