openharmony/distributeddatamgr_datamgr_service
1
0
Fork 0
mirror of https://gitee.com/openharmony/distributeddatamgr_datamgr_service synced 2024-11-23 06:50:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

适配ipc, samgr safwk 接口变更

Browse Source 
Signed-off-by: fqwert <yanglv2@huawei.com>
Change-Id: I1a5695c3ec8706d2158aaba27ddc9f68eaaaa54e
This commit is contained in:
fqwert 2024-04-07 11:30:37 +08:00
parent a169d6df6d
commit 22e4e55d48
9 changed files with 341 additions and 367 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
Cargo.toml Normal file
View File

@ -0,0 +1,18 @@
# Copyright (C) 2024 Huawei Device Co., Ltd.
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
[workspace]
resolver = "2"
members = [
"services/distributeddataservice/rust/ylong_cloud_extension",
]

19
rustfmt.toml Normal file
View File

@ -0,0 +1,19 @@
# Copyright (C) 2024 Huawei Device Co., Ltd.
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
edition = "2021"
wrap_comments = true
imports_granularity = "Module"
group_imports = "StdExternalCrate"
format_code_in_doc_comments = true
normalize_comments = true

4
services/distributeddataservice/rust/ylong_cloud_extension/Cargo.toml
View File

@ -33,5 +33,5 @@ name = "cloud_extension"
crate-type = ["cdylib", "staticlib", "lib"]
[dependencies]
ipc_rust = {path = "../ipc_rust", version = "0.1.0"}
hilog_rust = { path = "../hilog_rust", version = "0.1.0" }
ipc = { git = "https://gitee.com/openharmony/communication_ipc" }
hilog_rust = { git = "https://gitee.com/openharmony/hiviewdfx_hilog.git" }

116
services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/asset.rs
View File

@ -13,18 +13,19 @@
* limitations under the License.
*/
use ipc::parcel::{Deserialize, MsgParcel, Serialize};
use ipc::remote::RemoteObj;
use ipc::IpcResult;
use crate::ipc_conn::error::Error;
use crate::ipc_conn::ffi::ConnectService;
use crate::ipc_conn::function::AssetLoaderFunc::{Download, Upload};
use crate::ipc_conn::function::CloudServiceFunc::ConnectAssetLoader;
use crate::ipc_conn::{vec_raw_read, vec_raw_write, AssetStatus};
use ipc_rust::{
BorrowedMsgParcel, Deserialize, IRemoteObj, MsgParcel, RemoteObj, Serialize, String16,
};
pub(crate) type AssetLoaderResult<T> = Result<T, Error>;
/// CloudAsset struct storing relating information to upload and download assets.
/// CloudAsset struct storing relating information to upload and download
/// assets.
#[derive(Default, PartialEq, Clone, Debug)]
pub struct CloudAsset {
pub(crate) asset_id: String,
@ -121,50 +122,41 @@ impl CloudAsset {
}
impl Serialize for CloudAsset {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
let asset_name = String16::new(&self.asset_name);
let uri = String16::new(&self.uri);
let sub_path = String16::new(&self.sub_path);
let create_time = String16::new(&self.create_time);
let modify_time = String16::new(&self.modify_time);
let size = String16::new(&self.size);
let asset_id = String16::new(&self.asset_id);
let hash = String16::new(&self.hash);
parcel.write(&asset_name)?;
parcel.write(&uri)?;
parcel.write(&sub_path)?;
parcel.write(&create_time)?;
parcel.write(&modify_time)?;
parcel.write(&size)?;
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
parcel.write_string16(&self.asset_name)?;
parcel.write_string16(&self.uri)?;
parcel.write_string16(&self.sub_path)?;
parcel.write_string16(&self.create_time)?;
parcel.write_string16(&self.modify_time)?;
parcel.write_string16(&self.size)?;
parcel.write(&self.status)?;
parcel.write(&asset_id)?;
parcel.write(&hash)?;
parcel.write_string16(&self.asset_id)?;
parcel.write_string16(&self.hash)?;
Ok(())
}
}
impl Deserialize for CloudAsset {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
let asset_name = parcel.read::<String16>()?;
let uri = parcel.read::<String16>()?;
let sub_path = parcel.read::<String16>()?;
let create_time = parcel.read::<String16>()?;
let modify_time = parcel.read::<String16>()?;
let size = parcel.read::<String16>()?;
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let asset_name = parcel.read_string16()?;
let uri = parcel.read_string16()?;
let sub_path = parcel.read_string16()?;
let create_time = parcel.read_string16()?;
let modify_time = parcel.read_string16()?;
let size = parcel.read_string16()?;
let operation_type = parcel.read::<AssetStatus>()?;
let asset_id = parcel.read::<String16>()?;
let hash = parcel.read::<String16>()?;
let asset_id = parcel.read_string16()?;
let hash = parcel.read_string16()?;
let result = CloudAsset {
asset_id: asset_id.get_string(),
asset_name: asset_name.get_string(),
hash: hash.get_string(),
uri: uri.get_string(),
sub_path: sub_path.get_string(),
create_time: create_time.get_string(),
modify_time: modify_time.get_string(),
size: size.get_string(),
asset_id,
asset_name,
hash,
uri,
sub_path,
create_time,
modify_time,
size,
status: operation_type,
};
Ok(result)
@ -176,13 +168,13 @@ impl Deserialize for CloudAsset {
pub struct CloudAssets(pub Vec<CloudAsset>);
impl Serialize for CloudAssets {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
vec_raw_write(parcel, &self.0)
}
}
impl Deserialize for CloudAssets {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let result = CloudAssets(vec_raw_read::<CloudAsset>(parcel)?);
Ok(result)
}
@ -194,16 +186,16 @@ pub(crate) struct AssetLoader {
impl AssetLoader {
pub(crate) fn new(user_id: i32) -> AssetLoaderResult<Self> {
let msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let mut msg_parcel = MsgParcel::new();
let function_number = ConnectAssetLoader as u32;
let remote_obj = unsafe { RemoteObj::from_raw_ciremoteobj(ConnectService(user_id)) }
let remote_obj = unsafe { RemoteObj::from_ciremote(ConnectService(user_id)) }
.ok_or(Error::GetProxyObjectFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let result = receive
.read::<RemoteObj>()
.read_remote()
.map_err(|_| Error::ReadMsgParcelFailed)?;
Ok(Self {
remote_obj: Some(result),
@ -218,18 +210,15 @@ impl AssetLoader {
prefix: &str,
assets: &CloudAssets,
) -> AssetLoaderResult<Vec<Result<CloudAsset, Error>>> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let table = String16::new(table);
let gid = String16::new(gid);
let prefix = String16::new(prefix);
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&table)
.write_string16(table)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(&gid)
.write_string16(gid)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(&prefix)
.write_string16(prefix)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(assets)
@ -240,8 +229,8 @@ impl AssetLoader {
.remote_obj
.as_ref()
.ok_or(Error::GetProxyObjectFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let mut results = vec![];
@ -273,18 +262,15 @@ impl AssetLoader {
prefix: &str,
assets: &CloudAssets,
) -> AssetLoaderResult<Vec<Result<CloudAsset, Error>>> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let table = String16::new(table);
let gid = String16::new(gid);
let prefix = String16::new(prefix);
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&table)
.write_string16(table)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(&gid)
.write_string16(gid)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(&prefix)
.write_string16(prefix)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(assets)
@ -295,8 +281,8 @@ impl AssetLoader {
.remote_obj
.as_ref()
.ok_or(Error::GetProxyObjectFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let mut results = vec![];

391
services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/connect.rs
View File

@ -13,6 +13,13 @@
* limitations under the License.
*/
use std::collections::HashMap;
use std::sync::{RwLock, RwLockReadGuard};
use ipc::parcel::{Deserialize, MsgParcel, Serialize};
use ipc::remote::RemoteObj;
use ipc::{IpcResult, IpcStatusCode};
use crate::ipc_conn::asset::{CloudAsset, CloudAssets};
use crate::ipc_conn::error::{Error, Errors};
use crate::ipc_conn::ffi::ConnectService;
@ -22,14 +29,9 @@ use crate::ipc_conn::function::CloudServiceFunc::{
use crate::ipc_conn::{
string_hash_map_raw_read, string_hash_map_raw_write, vec_raw_read, vec_raw_write,
};
use ipc_rust::{
BorrowedMsgParcel, Deserialize, IRemoteObj, IpcResult, IpcStatusCode, MsgParcel, RemoteObj,
Serialize, String16,
};
use std::collections::HashMap;
use std::sync::{RwLock, RwLockReadGuard};
/************** All AppSchema struct-related structures and methods **************/
/// ************ All AppSchema struct-related structures and methods
/// *************
#[derive(Default, Debug, PartialEq, Clone)]
pub(crate) struct Response {
@ -39,26 +41,24 @@ pub(crate) struct Response {
}
impl Serialize for Response {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
let device_name = String16::new(&self.device_name);
let app_id = String16::new(&self.app_id);
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
parcel.write(&self.time)?;
parcel.write(&device_name)?;
parcel.write(&app_id)?;
parcel.write_string16(&self.device_name)?;
parcel.write_string16(&self.app_id)?;
Ok(())
}
}
impl Deserialize for Response {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let time = parcel.read::<u64>()?;
let device_name = parcel.read::<String16>()?;
let app_id = parcel.read::<String16>()?;
let device_name = parcel.read_string16()?;
let app_id = parcel.read_string16()?;
let result = Response {
time,
device_name: device_name.get_string(),
app_id: app_id.get_string(),
device_name,
app_id,
};
Ok(result)
}
@ -89,7 +89,7 @@ impl Default for AssetStatus {
}
impl Serialize for AssetStatus {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
match self {
AssetStatus::Normal => parcel.write(&0_i32),
AssetStatus::Insert => parcel.write(&1_i32),
@ -102,7 +102,7 @@ impl Serialize for AssetStatus {
}
impl Deserialize for AssetStatus {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let index = parcel.read::<i32>()?;
match index {
0 => Ok(AssetStatus::Normal),
@ -130,7 +130,7 @@ impl Default for SwitchStatus {
}
impl Serialize for SwitchStatus {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
match self {
SwitchStatus::Close => parcel.write(&0_u32),
SwitchStatus::Open => parcel.write(&1_u32),
@ -140,7 +140,7 @@ impl Serialize for SwitchStatus {
}
impl Deserialize for SwitchStatus {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let index = parcel.read::<u32>()?;
match index {
0 => Ok(SwitchStatus::Close),
@ -179,7 +179,7 @@ impl From<FieldRaw> for u8 {
}
impl Serialize for FieldRaw {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
match self {
FieldRaw::Null => parcel.write(&0_u32),
FieldRaw::Number(number) => {
@ -192,8 +192,7 @@ impl Serialize for FieldRaw {
}
FieldRaw::Text(text) => {
parcel.write(&3_u32)?;
let text = String16::new(text);
parcel.write(&text)
parcel.write_string16(text)
}
FieldRaw::Bool(boolean) => {
parcel.write(&4_u32)?;
@ -216,7 +215,7 @@ impl Serialize for FieldRaw {
}
impl Deserialize for FieldRaw {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let index = parcel.read::<u32>()?;
match index {
0 => Ok(FieldRaw::Null),
@ -229,8 +228,8 @@ impl Deserialize for FieldRaw {
Ok(FieldRaw::Real(real))
}
3 => {
let text = parcel.read::<String16>()?;
Ok(FieldRaw::Text(text.get_string()))
let text = parcel.read_string16()?;
Ok(FieldRaw::Text(text))
}
4 => {
let boolean = parcel.read::<bool>()?;
@ -258,13 +257,13 @@ impl Deserialize for FieldRaw {
pub struct ValueBucket(pub HashMap<String, FieldRaw>);
impl Serialize for ValueBucket {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
string_hash_map_raw_write(parcel, &self.0)
}
}
impl Deserialize for ValueBucket {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let result = string_hash_map_raw_read::<FieldRaw>(parcel)?;
Ok(ValueBucket(result))
}
@ -274,13 +273,13 @@ impl Deserialize for ValueBucket {
pub(crate) struct ValueBuckets(pub(crate) Vec<ValueBucket>);
impl Serialize for ValueBuckets {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
vec_raw_write(parcel, &self.0)
}
}
impl Deserialize for ValueBuckets {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let result = ValueBuckets(vec_raw_read::<ValueBucket>(parcel)?);
Ok(result)
}
@ -294,13 +293,13 @@ pub(crate) struct CloudData {
}
impl Deserialize for CloudData {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
let next_cursor = parcel.read::<String16>()?;
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let next_cursor = parcel.read_string16()?;
let has_more = parcel.read::<bool>()?;
let values = parcel.read::<ValueBuckets>()?;
let cloud_data = CloudData {
next_cursor: next_cursor.get_string(),
next_cursor,
has_more,
values,
};
@ -316,20 +315,18 @@ pub(crate) struct Database {
}
impl Serialize for Database {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
let alias = String16::new(&self.alias);
let name = String16::new(&self.name);
parcel.write(&alias)?;
parcel.write(&name)?;
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
parcel.write_string16(&self.alias)?;
parcel.write_string16(&self.name)?;
parcel.write(&self.tables)?;
Ok(())
}
}
impl Deserialize for Database {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
let alias = parcel.read::<String16>()?.get_string();
let name = parcel.read::<String16>()?.get_string();
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let alias = parcel.read_string16()?;
let name = parcel.read_string16()?;
let tables = parcel.read::<SchemaOrderTables>()?;
let result = Database {
@ -389,14 +386,14 @@ impl TryFrom<u8> for FieldType {
}
impl Serialize for FieldType {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
let code = u8::from(self) as u32;
parcel.write(&code)
}
}
impl Deserialize for FieldType {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let index = parcel.read::<i32>()?;
match index {
0 => Ok(FieldType::Null),
@ -422,11 +419,9 @@ pub(crate) struct Field {
}
impl Serialize for Field {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> IpcResult<()> {
let alias = String16::new(&self.alias);
let col_name = String16::new(&self.col_name);
parcel.write(&alias)?;
parcel.write(&col_name)?;
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
parcel.write_string16(&self.alias)?;
parcel.write_string16(&self.col_name)?;
parcel.write(&self.typ)?;
parcel.write(&self.primary)?;
parcel.write(&self.nullable)?;
@ -435,16 +430,16 @@ impl Serialize for Field {
}
impl Deserialize for Field {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> IpcResult<Self> {
let col_name = parcel.read::<String16>()?;
let cloud_name = parcel.read::<String16>()?;
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let col_name = parcel.read_string16()?;
let cloud_name = parcel.read_string16()?;
let typ = parcel.read::<FieldType>()?;
let primary = parcel.read::<bool>()?;
let nullable = parcel.read::<bool>()?;
let result = Field {
col_name: col_name.get_string(),
alias: cloud_name.get_string(),
col_name,
alias: cloud_name,
typ,
primary,
nullable,
@ -457,13 +452,13 @@ impl Deserialize for Field {
pub(crate) struct Fields(pub(crate) Vec<Field>);
impl Serialize for Fields {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
vec_raw_write(parcel, &self.0)
}
}
impl Deserialize for Fields {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let result = Fields(vec_raw_read::<Field>(parcel)?);
Ok(result)
}
@ -477,21 +472,19 @@ pub(crate) struct OrderTable {
}
impl Serialize for OrderTable {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
let alias = String16::new(&self.alias);
let table_name = String16::new(&self.table_name);
parcel.write(&alias)?;
parcel.write(&table_name)?;
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
parcel.write_string16(&self.alias)?;
parcel.write_string16(&self.table_name)?;
parcel.write(&self.fields)?;
Ok(())
}
}
impl Deserialize for OrderTable {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let result = OrderTable {
alias: parcel.read::<String16>()?.get_string(),
table_name: parcel.read::<String16>()?.get_string(),
alias: parcel.read_string16()?,
table_name: parcel.read_string16()?,
fields: parcel.read::<Fields>()?,
};
Ok(result)
@ -502,13 +495,13 @@ impl Deserialize for OrderTable {
pub(crate) struct SchemaOrderTables(pub(crate) Vec<OrderTable>);
impl Serialize for SchemaOrderTables {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
vec_raw_write(parcel, &self.0)
}
}
impl Deserialize for SchemaOrderTables {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let result = SchemaOrderTables(vec_raw_read::<OrderTable>(parcel)?);
Ok(result)
}
@ -518,13 +511,13 @@ impl Deserialize for SchemaOrderTables {
pub(crate) struct Databases(pub(crate) Vec<Database>);
impl Serialize for Databases {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
vec_raw_write(parcel, &self.0)
}
}
impl Deserialize for Databases {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let databases = Databases(vec_raw_read(parcel)?);
Ok(databases)
}
@ -538,7 +531,7 @@ pub(crate) struct Schema {
}
impl Schema {
fn read(&mut self, msg_parcel: &MsgParcel) -> Result<(), Error> {
fn read(&mut self, msg_parcel: &mut MsgParcel) -> Result<(), Error> {
if msg_parcel
.read::<i32>()
.map_err(|_| Error::ReadMsgParcelFailed)?
@ -548,9 +541,8 @@ impl Schema {
.read::<i32>()
.map_err(|_| Error::ReadMsgParcelFailed)?;
self.bundle_name = msg_parcel
.read::<String16>()
.map_err(|_| Error::ReadMsgParcelFailed)?
.get_string();
.read_string16()
.map_err(|_| Error::ReadMsgParcelFailed)?;
self.databases = msg_parcel
.read::<Databases>()
.map_err(|_| Error::ReadMsgParcelFailed)?;
@ -562,9 +554,9 @@ impl Schema {
}
impl Deserialize for Schema {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let version = parcel.read::<i32>()?;
let bundle_name = parcel.read::<String16>()?.get_string();
let bundle_name = parcel.read_string16()?;
let databases = parcel.read::<Databases>()?;
let result = Schema {
@ -576,7 +568,7 @@ impl Deserialize for Schema {
}
}
/************** All AppInfo struct-related structures and methods **************/
/// ************ All AppInfo struct-related structures and methods *************
#[derive(Default, Debug, PartialEq)]
pub(crate) struct AppInfo {
@ -587,9 +579,9 @@ pub(crate) struct AppInfo {
}
impl Deserialize for AppInfo {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
let app_id = parcel.read::<String16>()?.get_string();
let bundle_name = parcel.read::<String16>()?.get_string();
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let app_id = parcel.read_string16()?;
let bundle_name = parcel.read_string16()?;
let cloud_switch = parcel.read::<i32>()? != 0;
let instance_id = parcel.read::<i32>()?;
@ -603,7 +595,8 @@ impl Deserialize for AppInfo {
}
}
/************** All ServiceInfo struct-related structures and methods **************/
/// ************ All ServiceInfo struct-related structures and methods
/// *************
#[derive(Default)]
pub(crate) struct ServiceInfo {
// Whether cloud is enabled.
@ -623,14 +616,13 @@ pub(crate) struct ServiceInfo {
}
impl ServiceInfo {
fn read(&mut self, msg_parcel: &MsgParcel) -> Result<(), Error> {
fn read(&mut self, msg_parcel: &mut MsgParcel) -> Result<(), Error> {
self.enable_cloud = msg_parcel
.read::<bool>()
.map_err(|_| Error::ReadMsgParcelFailed)?;
self.account_id = msg_parcel
.read::<String16>()
.map_err(|_| Error::ReadMsgParcelFailed)?
.get_string();
.read_string16()
.map_err(|_| Error::ReadMsgParcelFailed)?;
self.total_space = msg_parcel
.read::<u64>()
.map_err(|_| Error::ReadMsgParcelFailed)?;
@ -644,7 +636,8 @@ impl ServiceInfo {
}
}
/************** All Subscribe struct-related structures and methods **************/
/// ************ All Subscribe struct-related structures and methods
/// *************
#[derive(Default)]
#[non_exhaustive]
@ -654,12 +647,12 @@ pub(crate) struct Subscription;
pub(crate) struct SubscriptionResultValue(pub(crate) Vec<(String, String)>);
impl Deserialize for SubscriptionResultValue {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let length = parcel.read::<i32>()? as usize;
let mut vector = Vec::with_capacity(length);
for _ in 0..length {
let alias = parcel.read::<String16>()?.get_string();
let subscription_id = parcel.read::<String16>()?.get_string();
let alias = parcel.read_string16()?;
let subscription_id = parcel.read_string16()?;
vector.push((alias, subscription_id));
}
Ok(SubscriptionResultValue(vector))
@ -670,7 +663,7 @@ impl Deserialize for SubscriptionResultValue {
pub(crate) struct SubscriptionResult(pub(crate) (i64, HashMap<String, SubscriptionResultValue>));
impl Deserialize for SubscriptionResult {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let interval = parcel.read::<i64>()?;
let result = string_hash_map_raw_read::<SubscriptionResultValue>(parcel)?;
Ok(SubscriptionResult((interval, result)))
@ -681,7 +674,7 @@ impl Deserialize for SubscriptionResult {
pub(crate) struct UnsubscriptionInfo(pub(crate) HashMap<String, Vec<String>>);
impl Serialize for UnsubscriptionInfo {
fn serialize(&self, parcel: &mut BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<()> {
fn serialize(&self, parcel: &mut MsgParcel) -> IpcResult<()> {
string_hash_map_raw_write(parcel, &self.0)
}
}
@ -695,13 +688,13 @@ impl Subscription {
bundle_name: &str,
databases: &Databases,
) -> Result<SubscriptionResult, Errors> {
let mut msg_parcel = MsgParcel::new().ok_or(Errors(vec![Error::CreateMsgParcelFailed]))?;
let bundle_name = String16::new(bundle_name);
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&expiration)
.map_err(|_| Errors(vec![Error::WriteMsgParcelFailed]))?;
msg_parcel
.write(&bundle_name)
.write_string16(bundle_name)
.map_err(|_| Errors(vec![Error::WriteMsgParcelFailed]))?;
msg_parcel
.write(databases)
@ -711,8 +704,8 @@ impl Subscription {
let remote_obj = remote
.as_ref()
.ok_or(Errors(vec![Error::CreateMsgParcelFailed]))?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Errors(vec![Error::SendRequestFailed]))?;
let mut errs = Errors::default();
@ -733,7 +726,8 @@ impl Subscription {
remote: &Option<RemoteObj>,
info: &UnsubscriptionInfo,
) -> Result<(), Errors> {
let mut msg_parcel = MsgParcel::new().ok_or(Errors(vec![Error::CreateMsgParcelFailed]))?;
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(info)
.map_err(|_| Errors(vec![Error::WriteMsgParcelFailed]))?;
@ -742,8 +736,8 @@ impl Subscription {
let remote_obj = remote
.as_ref()
.ok_or(Errors(vec![Error::CreateMsgParcelFailed]))?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Errors(vec![Error::SendRequestFailed]))?;
if let Ok(errs) = receive.read::<Errors>() {
@ -754,7 +748,7 @@ impl Subscription {
}
}
/************** All Connect struct-related structures and methods **************/
/// ************ All Connect struct-related structures and methods *************
pub(crate) type ConnectResult<T> = Result<T, Error>;
@ -764,9 +758,10 @@ pub(crate) struct Connect {
}
impl Connect {
// Creates a structure `Connect` for connecting to the cloud and getting various information about the cloud.
// Creates a structure `Connect` for connecting to the cloud and getting various
// information about the cloud.
pub(crate) fn new(user_id: i32) -> ConnectResult<Self> {
let remote_obj = unsafe { RemoteObj::from_raw_ciremoteobj(ConnectService(user_id)) }
let remote_obj = unsafe { RemoteObj::from_ciremote(ConnectService(user_id)) }
.ok_or(Error::GetProxyObjectFailed)?;
Ok(Self {
remote_obj: Some(remote_obj),
@ -786,15 +781,15 @@ impl Connect {
let mut lock = infos.app_infos.write().unwrap();
let msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let mut msg_parcel = MsgParcel::new();
let function_number = GetAppBriefInfo as u32;
let remote_obj = self
.remote_obj
.as_ref()
.ok_or(Error::GetProxyObjectFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
lock.0 = receive
@ -819,18 +814,18 @@ impl Connect {
let mut lock = infos.service_info.write().unwrap();
let msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let mut msg_parcel = MsgParcel::new();
let function_number = GetServiceInfo as u32;
let remote_obj = self
.remote_obj
.clone()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
lock.read(&receive)?;
lock.read(&mut receive)?;
drop(lock);
@ -847,10 +842,10 @@ impl Connect {
let mut lock = infos.app_schema.write().unwrap();
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let bundle_name = String16::new(bundle_name);
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&bundle_name)
.write_string16(bundle_name)
.map_err(|_| Error::WriteMsgParcelFailed)?;
let function_number = GetAppSchema as u32;
@ -858,11 +853,11 @@ impl Connect {
.remote_obj
.clone()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
lock.read(&receive)?;
lock.read(&mut receive)?;
drop(lock);
@ -889,7 +884,7 @@ impl Connect {
pub(crate) struct AppInfos(pub(crate) HashMap<String, AppInfo>);
impl Deserialize for AppInfos {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let result = AppInfos(string_hash_map_raw_read::<AppInfo>(parcel)?);
Ok(result)
}
@ -904,12 +899,13 @@ pub(crate) struct Infos {
#[cfg(test)]
mod connect_test {
use crate::ipc_conn::connect::{SubscriptionResultValue, SwitchStatus};
use ipc::parcel::MsgParcel;
use crate::ipc_conn::connect::{Response, SubscriptionResultValue, SwitchStatus};
use crate::ipc_conn::{
connect::Response, AppInfo, AssetStatus, CloudAsset, CloudAssets, CloudData, Database,
Databases, FieldRaw, OrderTable, Schema, SchemaOrderTables, ValueBucket, ValueBuckets,
AppInfo, AssetStatus, CloudAsset, CloudAssets, CloudData, Database, Databases, FieldRaw,
OrderTable, Schema, SchemaOrderTables, ValueBucket, ValueBuckets,
};
use ipc_rust::{MsgParcel, String16};
/// UT test for response_serialize.
///
@ -924,18 +920,12 @@ mod connect_test {
fn ut_response_serialize() {
let response = Response::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&response).unwrap();
assert_eq!(msg_parcel.read::<i64>().unwrap(), 0);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
}
/// UT test for response_deserialize.
@ -953,7 +943,7 @@ mod connect_test {
fn ut_response_deserialize() {
let response = Response::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&response).unwrap();
assert_eq!(msg_parcel.read::<Response>().unwrap(), response);
@ -977,7 +967,7 @@ mod connect_test {
let abnormal = AssetStatus::Abnormal;
let downloading = AssetStatus::Downloading;
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&normal).unwrap();
msg_parcel.write(&insert).unwrap();
msg_parcel.write(&update).unwrap();
@ -1013,7 +1003,7 @@ mod connect_test {
let abnormal = AssetStatus::Abnormal;
let downloading = AssetStatus::Downloading;
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&normal).unwrap();
msg_parcel.write(&insert).unwrap();
msg_parcel.write(&update).unwrap();
@ -1044,7 +1034,7 @@ mod connect_test {
let open = SwitchStatus::Open;
let not_enable = SwitchStatus::NotEnable;
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&close).unwrap();
msg_parcel.write(&open).unwrap();
msg_parcel.write(&not_enable).unwrap();
@ -1071,7 +1061,7 @@ mod connect_test {
let open = SwitchStatus::Open;
let not_enable = SwitchStatus::NotEnable;
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&close).unwrap();
msg_parcel.write(&open).unwrap();
msg_parcel.write(&not_enable).unwrap();
@ -1094,45 +1084,21 @@ mod connect_test {
fn ut_asset_serialize() {
let asset = CloudAsset::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&asset).unwrap();
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(
msg_parcel.read::<AssetStatus>().unwrap(),
AssetStatus::Normal
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
}
/// UT test for asset_deserialize.
@ -1150,7 +1116,7 @@ mod connect_test {
fn ut_asset_deserialize() {
let asset = CloudAsset::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&asset).unwrap();
let result = msg_parcel.read::<CloudAsset>().unwrap();
@ -1182,7 +1148,7 @@ mod connect_test {
assets.0.push(asset_one);
assets.0.push(asset_two);
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&assets).unwrap();
assert_eq!(msg_parcel.read::<u32>().unwrap(), 2);
@ -1231,7 +1197,7 @@ mod connect_test {
assets.0.push(asset_one);
assets.0.push(asset_two);
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&assets).unwrap();
assert!(msg_parcel.read::<CloudAssets>().is_ok());
@ -1257,7 +1223,7 @@ mod connect_test {
let asset = FieldRaw::Asset(CloudAsset::default());
let assets = FieldRaw::Assets(CloudAssets::default());
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&null).unwrap();
msg_parcel.write(&number).unwrap();
msg_parcel.write(&real).unwrap();
@ -1276,10 +1242,7 @@ mod connect_test {
assert_eq!(msg_parcel.read::<f64>().unwrap(), 2.0);
assert_eq!(msg_parcel.read::<u32>().unwrap(), 3);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("text")
);
assert_eq!(msg_parcel.read_string16().unwrap(), String::from("text"));
assert_eq!(msg_parcel.read::<u32>().unwrap(), 4);
assert!(msg_parcel.read::<bool>().unwrap());
@ -1315,7 +1278,7 @@ mod connect_test {
let asset = FieldRaw::Asset(CloudAsset::default());
let assets = FieldRaw::Assets(CloudAssets::default());
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&null).unwrap();
msg_parcel.write(&number).unwrap();
msg_parcel.write(&text).unwrap();
@ -1352,19 +1315,13 @@ mod connect_test {
.0
.insert(String::from("key2"), FieldRaw::Number(1));
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&value_bucket_data).unwrap();
assert_eq!(msg_parcel.read::<i32>().unwrap(), 2);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("key1")
);
assert_eq!(msg_parcel.read_string16().unwrap(), String::from("key1"));
assert!(msg_parcel.read::<FieldRaw>().is_ok());
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("key2")
);
assert_eq!(msg_parcel.read_string16().unwrap(), String::from("key2"));
assert!(msg_parcel.read::<FieldRaw>().is_ok());
}
@ -1389,7 +1346,7 @@ mod connect_test {
.0
.insert(String::from("key2"), FieldRaw::Number(1));
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&value_bucket_data).unwrap();
assert!(msg_parcel.read::<ValueBucket>().is_ok());
@ -1408,7 +1365,7 @@ mod connect_test {
fn ut_value_bucket_serialize() {
let value_bucket = ValueBucket::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&value_bucket).unwrap();
assert_eq!(msg_parcel.read::<i32>().unwrap(), 0);
@ -1429,7 +1386,7 @@ mod connect_test {
fn ut_value_bucket_deserialize() {
let value_bucket = ValueBucket::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&value_bucket).unwrap();
assert!(msg_parcel.read::<ValueBucket>().is_ok());
@ -1452,7 +1409,7 @@ mod connect_test {
value_buckets.0.push(value_bucket_one);
value_buckets.0.push(value_bucket_two);
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&value_buckets).unwrap();
assert_eq!(msg_parcel.read::<u32>().unwrap(), 2);
@ -1480,7 +1437,7 @@ mod connect_test {
value_buckets.0.push(value_bucket_one);
value_buckets.0.push(value_bucket_two);
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&value_buckets).unwrap();
assert!(msg_parcel.read::<ValueBuckets>().is_ok());
@ -1499,12 +1456,12 @@ mod connect_test {
/// 5. Check if it is correct.
#[test]
fn ut_cloud_data_deserialize() {
let next_cursor = String16::new("");
let next_cursor = String::from("");
let has_more = false;
let values = ValueBuckets::default();
let mut msg_parcel = MsgParcel::new().unwrap();
msg_parcel.write(&next_cursor).unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write_string16(&next_cursor).unwrap();
msg_parcel.write(&has_more).unwrap();
msg_parcel.write(&values).unwrap();
@ -1524,17 +1481,11 @@ mod connect_test {
fn ut_database_serialize() {
let database = Database::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&database).unwrap();
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::from("")
);
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(msg_parcel.read_string16().unwrap(), String::from(""));
assert_eq!(
msg_parcel.read::<SchemaOrderTables>().unwrap(),
SchemaOrderTables::default()
@ -1556,7 +1507,7 @@ mod connect_test {
fn ut_database_deserialize() {
let database = Database::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&database).unwrap();
assert!(msg_parcel.read::<Database>().is_ok());
@ -1575,17 +1526,11 @@ mod connect_test {
fn ut_order_table_serialize() {
let order_table = OrderTable::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&order_table).unwrap();
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::default()
);
assert_eq!(
msg_parcel.read::<String16>().unwrap().get_string(),
String::default()
);
assert_eq!(msg_parcel.read_string16().unwrap(), String::default());
assert_eq!(msg_parcel.read_string16().unwrap(), String::default());
}
/// UT test for order_table_deserialize.
@ -1603,7 +1548,7 @@ mod connect_test {
fn ut_order_table_deserialize() {
let order_table = OrderTable::default();
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&order_table).unwrap();
assert_eq!(msg_parcel.read::<OrderTable>().unwrap(), order_table);
@ -1626,7 +1571,7 @@ mod connect_test {
schema_order_tables.0.push(order_table_one);
schema_order_tables.0.push(order_table_two);
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&schema_order_tables).unwrap();
assert_eq!(msg_parcel.read::<i32>().unwrap(), 2);
@ -1659,7 +1604,7 @@ mod connect_test {
schema_order_tables.0.push(order_table_one);
schema_order_tables.0.push(order_table_two);
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&schema_order_tables).unwrap();
assert_eq!(
@ -1685,7 +1630,7 @@ mod connect_test {
databases.0.push(database_one);
databases.0.push(database_two);
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&databases).unwrap();
assert_eq!(msg_parcel.read::<i32>().unwrap(), 2);
@ -1712,7 +1657,7 @@ mod connect_test {
databases.0.push(database_one);
databases.0.push(database_two);
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&databases).unwrap();
assert!(msg_parcel.read::<Databases>().is_ok());
@ -1731,9 +1676,9 @@ mod connect_test {
/// 5. Check if it is correct.
#[test]
fn ut_schema_deserialize() {
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&0_i32).unwrap();
msg_parcel.write(&String16::new("")).unwrap();
msg_parcel.write_string16("").unwrap();
msg_parcel.write(&Databases::default()).unwrap();
assert!(msg_parcel.read::<Schema>().is_ok());
@ -1754,9 +1699,9 @@ mod connect_test {
fn ut_app_info_deserialize() {
let app_info = AppInfo::default();
let mut msg_parcel = MsgParcel::new().unwrap();
msg_parcel.write(&String16::new("")).unwrap();
msg_parcel.write(&String16::new("")).unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write_string16("").unwrap();
msg_parcel.write_string16("").unwrap();
msg_parcel.write(&bool::default()).unwrap();
msg_parcel.write(&0_i32).unwrap();
msg_parcel.write(&0_i32).unwrap();
@ -1782,10 +1727,10 @@ mod connect_test {
.0
.push((String::from("test1"), String::from("2")));
let mut msg_parcel = MsgParcel::new().unwrap();
let mut msg_parcel = MsgParcel::new();
msg_parcel.write(&1_i32).unwrap();
msg_parcel.write(&String16::new("test1")).unwrap();
msg_parcel.write(&String16::new("2")).unwrap();
msg_parcel.write_string16(&String::from("test1")).unwrap();
msg_parcel.write_string16(&String::from("2")).unwrap();
assert_eq!(
msg_parcel.read::<SubscriptionResultValue>().unwrap(),

105
services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/database.rs
View File

@ -13,6 +13,10 @@
* limitations under the License.
*/
use ipc::parcel::{Deserialize, MsgParcel};
use ipc::remote::RemoteObj;
use ipc::IpcResult;
use crate::ipc_conn::connect::ValueBucket;
use crate::ipc_conn::error::Error;
use crate::ipc_conn::ffi::ConnectService;
@ -21,9 +25,6 @@ use crate::ipc_conn::function::CloudDB::{
};
use crate::ipc_conn::function::CloudServiceFunc::ConnectDatabase;
use crate::ipc_conn::*;
use ipc_rust::{
BorrowedMsgParcel, Deserialize, IRemoteObj, IpcResult, MsgParcel, RemoteObj, String16,
};
pub(crate) type DatabaseStubResult<T> = Result<T, Error>;
@ -37,7 +38,7 @@ pub(crate) struct LockInfo {
}
impl Deserialize for LockInfo {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let interval = parcel.read::<i32>()?;
let session_id = parcel.read::<i32>()?;
let result = Self {
@ -58,24 +59,26 @@ impl DatabaseStub {
bundle_name: &str,
database: &Database,
) -> DatabaseStubResult<Self> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let bundle_name = String16::new(bundle_name);
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&bundle_name)
.write_string16(bundle_name)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(database)
.map_err(|_| Error::WriteMsgParcelFailed)?;
let function_number = ConnectDatabase as u32;
let remote_obj = unsafe { RemoteObj::from_raw_ciremoteobj(ConnectService(user_id)) }
let remote_obj = unsafe { RemoteObj::from_ciremote(ConnectService(user_id)) }
.ok_or(Error::GetProxyObjectFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let result = receive
.read::<RemoteObj>()
.read_remote()
.map_err(|_| Error::ReadMsgParcelFailed)?;
Ok(Self {
remote_obj: Some(result),
@ -87,14 +90,20 @@ impl DatabaseStub {
struct Ids(Vec<String>);
impl Deserialize for Ids {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
let id_vec = vec_raw_read::<String16>(parcel)?;
let ids = Ids(id_vec.iter().map(|x| x.get_string()).collect());
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let length = parcel.read::<i32>()? as usize;
let mut id_vec = Vec::with_capacity(length);
for _ in 0..length {
let value = parcel.read_string16()?;
id_vec.push(value);
}
let ids = Ids(id_vec.into_iter().collect());
Ok(ids)
}
}
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&number)
.map_err(|_| Error::WriteMsgParcelFailed)?;
@ -104,8 +113,9 @@ impl DatabaseStub {
.remote_obj
.as_ref()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let error = receive
@ -127,10 +137,10 @@ impl DatabaseStub {
values: &ValueBuckets,
extends: &ValueBuckets,
) -> DatabaseStubResult<Vec<Option<ValueBucket>>> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let table = String16::new(table);
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&table)
.write_string16(table)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(values)
@ -144,8 +154,8 @@ impl DatabaseStub {
.remote_obj
.as_ref()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let mut results = vec![];
@ -175,10 +185,9 @@ impl DatabaseStub {
values: &ValueBuckets,
extends: &ValueBuckets,
) -> DatabaseStubResult<Vec<Option<ValueBucket>>> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let table = String16::new(table);
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&table)
.write_string16(table)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(values)
@ -192,8 +201,8 @@ impl DatabaseStub {
.remote_obj
.as_ref()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let mut results = vec![];
@ -222,10 +231,9 @@ impl DatabaseStub {
table: &str,
extends: &ValueBuckets,
) -> DatabaseStubResult<Vec<Option<ValueBucket>>> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let table = String16::new(table);
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&table)
.write_string16(table)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(extends)
@ -236,8 +244,8 @@ impl DatabaseStub {
.remote_obj
.as_ref()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let mut results = vec![];
@ -268,21 +276,18 @@ impl DatabaseStub {
result_limit: i32,
cursor: &str,
) -> DatabaseStubResult<CloudData> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let table = String16::new(table);
let columns: Vec<String16> = columns.iter().map(|x| String16::new(x)).collect();
let cursor = String16::new(cursor);
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&table)
.write_string16(table)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(&columns)
.write_string16_vec(columns)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(&result_limit)
.map_err(|_| Error::WriteMsgParcelFailed)?;
msg_parcel
.write(&cursor)
.write_string16(cursor)
.map_err(|_| Error::WriteMsgParcelFailed)?;
let function_number = Query as u32;
@ -290,8 +295,8 @@ impl DatabaseStub {
.remote_obj
.as_ref()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let error = receive
@ -307,7 +312,7 @@ impl DatabaseStub {
}
pub(crate) fn lock(&mut self, interval: i32) -> DatabaseStubResult<LockInfo> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&interval)
.map_err(|_| Error::WriteMsgParcelFailed)?;
@ -317,8 +322,8 @@ impl DatabaseStub {
.remote_obj
.as_ref()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let error = receive
@ -334,7 +339,7 @@ impl DatabaseStub {
}
pub(crate) fn unlock(&mut self, session_id: i32) -> DatabaseStubResult<()> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&session_id)
.map_err(|_| Error::WriteMsgParcelFailed)?;
@ -344,8 +349,8 @@ impl DatabaseStub {
.remote_obj
.as_ref()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let error = receive
@ -358,7 +363,7 @@ impl DatabaseStub {
}
pub(crate) fn heartbeat(&self, session_id: i32) -> DatabaseStubResult<LockInfo> {
let mut msg_parcel = MsgParcel::new().ok_or(Error::CreateMsgParcelFailed)?;
let mut msg_parcel = MsgParcel::new();
msg_parcel
.write(&session_id)
.map_err(|_| Error::WriteMsgParcelFailed)?;
@ -368,8 +373,8 @@ impl DatabaseStub {
.remote_obj
.as_ref()
.ok_or(Error::CreateMsgParcelFailed)?;
let receive = remote_obj
.send_request(function_number, &msg_parcel, false)
let mut receive = remote_obj
.send_request(function_number, &mut msg_parcel)
.map_err(|_| Error::SendRequestFailed)?;
let error = receive

11
services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/error.rs
View File

@ -13,15 +13,18 @@
* limitations under the License.
*/
use crate::ipc_conn::vec_raw_read;
use ipc_rust::{BorrowedMsgParcel, Deserialize, IpcStatusCode};
use std::fmt::{Debug, Display, Formatter};
use ipc::parcel::{Deserialize, MsgParcel};
use ipc::{IpcResult, IpcStatusCode};
use crate::ipc_conn::vec_raw_read;
#[derive(Default, Debug)]
pub(crate) struct Errors(pub(crate) Vec<Error>);
impl Deserialize for Errors {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let result = Errors(vec_raw_read::<Error>(parcel)?);
Ok(result)
}
@ -113,7 +116,7 @@ impl Display for Error {
impl std::error::Error for Error {}
impl Deserialize for Error {
fn deserialize(parcel: &BorrowedMsgParcel<'_>) -> ipc_rust::IpcResult<Self> {
fn deserialize(parcel: &mut MsgParcel) -> IpcResult<Self> {
let index = parcel.read::<u32>()?;
match index {
0 => Ok(Error::Success),

5
services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/ffi.rs
View File

@ -13,10 +13,11 @@
* limitations under the License.
*/
use ipc_rust::CIRemoteObject;
use std::ffi::c_int;
use ipc::cxx_share::IRemoteObject;
#[link(name = "conn_adapter.z")]
extern "C" {
pub(crate) fn ConnectService(user_id: c_int) -> *mut CIRemoteObject;
pub(crate) fn ConnectService(user_id: c_int) -> *mut IRemoteObject;
}

37
services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/mod.rs
View File

@ -20,7 +20,6 @@ mod error;
mod ffi;
mod function;
use ipc_rust::{BorrowedMsgParcel, Deserialize, Serialize, String16};
use std::collections::HashMap;
pub(crate) use asset::AssetLoader;
@ -31,32 +30,33 @@ pub(crate) use connect::{
};
pub use connect::{AssetStatus, ValueBucket};
pub(crate) use database::DatabaseStub;
pub(crate) use error::Errors;
/// Error message at the ipc.
pub use error::Error;
pub(crate) use error::Errors;
use ipc::parcel::{Deserialize, MsgParcel, Serialize};
use ipc::IpcResult;
pub(crate) fn string_hash_map_raw_write<V: Serialize>(
msg_parcel: &mut BorrowedMsgParcel<'_>,
msg_parcel: &mut MsgParcel,
hash_map: &HashMap<String, V>,
) -> ipc_rust::IpcResult<()> {
) -> IpcResult<()> {
msg_parcel.write(&(hash_map.len() as i32))?;
let mut keys: Vec<&String> = hash_map.keys().collect();
keys.sort();
for key in keys {
msg_parcel.write(&String16::new(key))?;
msg_parcel.write_string16(&String::from(key))?;
msg_parcel.write(&hash_map[key])?;
}
Ok(())
}
pub(crate) fn string_hash_map_raw_read<V: Deserialize>(
msg_parcel: &BorrowedMsgParcel<'_>,
) -> ipc_rust::IpcResult<HashMap<String, V>> {
msg_parcel: &mut MsgParcel,
) -> IpcResult<HashMap<String, V>> {
let length = msg_parcel.read::<i32>()?;
let mut hash_map = HashMap::new();
for _ in 0..length {
let key = msg_parcel.read::<String16>()?.get_string();
let key = msg_parcel.read_string16()?;
let value = msg_parcel.read::<V>()?;
hash_map.insert(key, value);
}
@ -64,9 +64,9 @@ pub(crate) fn string_hash_map_raw_read<V: Deserialize>(
}
pub(crate) fn vec_raw_write<T: Serialize>(
msg_parcel: &mut BorrowedMsgParcel<'_>,
msg_parcel: &mut MsgParcel,
vector: &Vec<T>,
) -> ipc_rust::IpcResult<()> {
) -> IpcResult<()> {
msg_parcel.write(&(vector.len() as i32))?;
for value in vector {
msg_parcel.write(value)?;
@ -74,9 +74,7 @@ pub(crate) fn vec_raw_write<T: Serialize>(
Ok(())
}
pub(crate) fn vec_raw_read<T: Deserialize>(
msg_parcel: &BorrowedMsgParcel<'_>,
) -> ipc_rust::IpcResult<Vec<T>> {
pub(crate) fn vec_raw_read<T: Deserialize>(msg_parcel: &mut MsgParcel) -> IpcResult<Vec<T>> {
let length = msg_parcel.read::<i32>()? as usize;
let mut vector = Vec::with_capacity(length);
for _ in 0..length {
@ -88,8 +86,9 @@ pub(crate) fn vec_raw_read<T: Deserialize>(
#[cfg(test)]
mod test {
use ipc::parcel::MsgParcel;
use crate::ipc_conn::{vec_raw_read, vec_raw_write};
use ipc_rust::MsgParcel;
/// UT test for vec_raw_write.
///
@ -108,8 +107,7 @@ mod test {
String::from("value3"),
];
let mut msg_parcel = MsgParcel::new().unwrap();
let mut parcel = msg_parcel.borrowed();
let mut parcel = MsgParcel::new();
assert!(vec_raw_write(&mut parcel, &vector).is_ok());
assert_eq!(parcel.read::<i32>().unwrap(), 3);
@ -136,11 +134,10 @@ mod test {
String::from("value3"),
];
let mut msg_parcel = MsgParcel::new().unwrap();
let mut parcel = msg_parcel.borrowed();
let mut parcel = MsgParcel::new();
assert!(vec_raw_write(&mut parcel, &vector).is_ok());
let result = vec_raw_read::<String>(&parcel).unwrap();
let result = vec_raw_read::<String>(&mut parcel).unwrap();
assert_eq!(vector, result);
}
}