Home
last modified time | relevance | path

Searched refs:DistributedData (Results 1 – 25 of 420) sorted by relevance

12345678910>>...17

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_cloud.h37 using DataBucket = DistributedData::VBucket;
38 using BindAssets = DistributedData::BindAssets;
39 using GeneralError = DistributedData::GeneralError;
49 …DistributedData::GeneralError PreSharing(const std::string &tableName, DistributedData::VBuckets &…
55 static DBStatus ConvertStatus(DistributedData::GeneralError error);
64 using QueryNodes = std::vector<DistributedData::QueryNode>;
67 static void ConvertErrorField(DistributedData::VBuckets& extends);
69 std::shared_ptr<DistributedData::CloudDB> cloudDB_;
75 DistributedData::VBuckets& extend, DistributedData::AssetEvent eventId);
77 DistributedData::AssetEvent eventId);
[all …]
H A Drdb_asset_loader.cpp25 using ValueProxy = OHOS::DistributedData::ValueProxy;
35 DistributedData::VBucket downLoadAssets = ValueProxy::Convert(assets); in Download()
38 PostEvent(skipAssets, downLoadAssets, DistributedData::AssetEvent::DOWNLOAD, deleteAssets); in Download()
41 …PostEvent(skipAssets, downLoadAssets, DistributedData::AssetEvent::DOWNLOAD_FINISHED, deleteAssets… in Download()
51 return RdbCloud::ConvertStatus(static_cast<DistributedData::GeneralError>(error)); in RemoveLocalAssets()
55 DistributedData::AssetEvent eventId, std::set<std::string>& deleteAssets) in PostEvent()
58 auto* downLoadAssets = Traits::get_if<DistributedData::Assets>(&asset.second); in PostEvent()
66 void RdbAssetLoader::PostEvent(DistributedData::AssetEvent eventId, DistributedData::Assets& assets, in PostEvent()
70 if (downLoadAsset.status == DistributedData::Asset::STATUS_DELETE) { in PostEvent()
82 if (eventId == DistributedData::DOWNLOAD) { in PostEvent()
[all …]
H A Drdb_result_set_impl.h30 using ValueProxy = DistributedData::ValueProxy;
77 DistributedData::Value var; in GetValue()
79 if (status != DistributedData::GeneralError::E_OK) { in GetValue()
86 static constexpr ColumnType COLUMNTYPES[DistributedData::TYPE_MAX] = {
88 [DistributedData::TYPE_INDEX<int64_t>] = ColumnType::TYPE_INTEGER,
89 [DistributedData::TYPE_INDEX<double>] = ColumnType::TYPE_FLOAT,
91 [DistributedData::TYPE_INDEX<bool>] = ColumnType::TYPE_INTEGER,
92 [DistributedData::TYPE_INDEX<DistributedData::Bytes>] = ColumnType::TYPE_BLOB,
93 [DistributedData::TYPE_INDEX<DistributedData::Asset>] = ColumnType::TYPE_BLOB,
94 [DistributedData::TYPE_INDEX<DistributedData::Assets>] = ColumnType::TYPE_BLOB,
[all …]
H A Drdb_cloud.cpp28 using namespace DistributedData;
95 DistributedData::VBucket entry; in Query()
104 DistributedData::Value cursorFlag; in Query()
270 DistributedData::AssetEvent eventId) in PostEvent()
282 DistributedData::AssetEvent eventId) in PostEvent()
284 …if (value.index() != TYPE_INDEX<DistributedData::Asset> && value.index() != TYPE_INDEX<Distributed… in PostEvent()
288 if (value.index() == TYPE_INDEX<DistributedData::Asset>) { in PostEvent()
293 if (value.index() == TYPE_INDEX<DistributedData::Assets>) { in PostEvent()
302 DistributedData::AssetEvent eventId) in PostEventAsset()
312 if (eventId == DistributedData::UPLOAD) { in PostEventAsset()
[all …]
H A Dcache_cursor.h21 class CacheCursor : public DistributedData::Cursor {
23 explicit CacheCursor(std::vector<DistributedData::VBucket> &&records);
32 int32_t GetEntry(DistributedData::VBucket &entry) override;
33 int32_t GetRow(DistributedData::VBucket &data) override;
34 int32_t Get(int32_t col, DistributedData::Value &value) override;
35 int32_t Get(const std::string &col, DistributedData::Value &value) override;
43 std::vector<DistributedData::VBucket> records_;
H A Drdb_asset_loader.h31 using BindAssets = DistributedData::BindAssets;
33 …explicit RdbAssetLoader(std::shared_ptr<DistributedData::AssetLoader> cloudAssetLoader, BindAssets…
43 std::shared_ptr<DistributedData::AssetLoader> assetLoader_;
45 …void PostEvent(std::set<std::string>& skipAssets, std::map<std::string, DistributedData::Value>& a…
46 DistributedData::AssetEvent eventId, std::set<std::string>& deleteAssets);
47 void PostEvent(DistributedData::AssetEvent eventId, DistributedData::Assets& assets,
H A Drdb_general_store.h35 using Cursor = DistributedData::Cursor;
36 using GenQuery = DistributedData::GenQuery;
37 using VBucket = DistributedData::VBucket;
38 using VBuckets = DistributedData::VBuckets;
39 using Value = DistributedData::Value;
40 using Values = DistributedData::Values;
42 using Database = DistributedData::Database;
43 using GenErr = DistributedData::GeneralError;
45 using Reference = DistributedData::Reference;
46 using Snapshot = DistributedData::Snapshot;
[all …]
H A Drdb_cloud_data_translate.cpp26 using ValueProxy = DistributedData::ValueProxy;
35 auto size = DistributedData::HostToNet((uint16_t)data.length()); in AssetToBlob()
36 auto leMagic = DistributedData::HostToNet(ASSET_MAGIC); in AssetToBlob()
48 auto num = DistributedData::HostToNet((uint16_t)assets.size()); in AssetsToBlob()
49 auto leMagic = DistributedData::HostToNet(ASSETS_MAGIC); in AssetsToBlob()
89 …auto hostMagicWord = DistributedData::NetToHost(*(reinterpret_cast<decltype(&ASSET_MAGIC)>(alignDa… in ParserRawData()
98 size = DistributedData::NetToHost(*(reinterpret_cast<decltype(&size)>(alignData.data()))); in ParserRawData()
122 …auto hostMagicWord = DistributedData::NetToHost(*(reinterpret_cast<decltype(&ASSETS_MAGIC)>(alignD… in ParserRawData()
131 num = DistributedData::NetToHost(*(reinterpret_cast<decltype(&num)>(alignData.data()))); in ParserRawData()
147 bool RdbCloudDataTranslate::InnerAsset::Marshal(OHOS::DistributedData::Serializable::json &node) co… in Marshal()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dvalue_proxy_test.cpp22 using namespace OHOS::DistributedData;
36 OHOS::DistributedData::VBuckets extends = {
57 OHOS::DistributedData::VBuckets extends;
73 OHOS::DistributedData::VBuckets extends = {
103 OHOS::DistributedData::VBuckets extends;
162 using NormalAsset = OHOS::DistributedData::Asset;
163 using NormalAssets = OHOS::DistributedData::Assets;
222 using NormalAsset = OHOS::DistributedData::Asset;
223 using NormalAssets = OHOS::DistributedData::Assets;
261 EXPECT_EQ(result, DistributedData::Asset::STATUS_DELETE);
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/common/
H A Dvalue_proxy.cpp18 namespace OHOS::DistributedData { namespace
19 using namespace OHOS::DistributedData;
180 ValueProxy::Asset::Asset(DistributedData::Asset asset) in Asset()
278 ValueProxy::Asset::operator DistributedData::Asset()
332 case DistributedData::Asset::STATUS_NORMAL: in ConvertToDBStatus()
338 case DistributedData::Asset::STATUS_INSERT: in ConvertToDBStatus()
341 case DistributedData::Asset::STATUS_UPDATE: in ConvertToDBStatus()
344 case DistributedData::Asset::STATUS_DELETE: in ConvertToDBStatus()
432 DistributedData::Assets assets;
473 ValueProxy::Value::operator DistributedData::Value()
[all …]
H A Dvalue_proxy.h26 namespace OHOS::DistributedData {
46 using Bytes = DistributedData::Bytes;
58 Asset(DistributedData::Asset asset);
66 operator DistributedData::Asset();
72 DistributedData::Asset asset_;
82 DistributedData::Asset asset_;
96 Assets(DistributedData::Assets assets);
104 operator DistributedData::Assets();
123 operator DistributedData::Value();
214 static Value Convert(DistributedData::Value &&value);
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dextension_util.h29 using DBMeta = DistributedData::Database;
30 using DBTable = DistributedData::Table;
31 using DBErr = DistributedData::GeneralError;
32 using DBValue = DistributedData::Value;
33 using DBBytes = DistributedData::Bytes;
34 using DBAsset = DistributedData::Asset;
35 using DBAssets = DistributedData::Assets;
37 using DBInfo = DistributedData::CloudInfo::AppInfo;
38 using DBVBucket = DistributedData::VBucket;
39 using DBVBuckets = DistributedData::VBuckets;
[all …]
H A Dasset_loader_impl.h24 using DBValue = DistributedData::Value;
25 using DBVBucket = DistributedData::VBucket;
26 using DBMeta = DistributedData::Database;
27 using DBAssets = DistributedData::Assets;
28 using DBAsset = DistributedData::Asset;
29 using DBErr = DistributedData::GeneralError;
30 class AssetLoaderImpl : public DistributedData::AssetLoader {
H A Dcloud_server_impl.h27 using DBMeta = DistributedData::SchemaMeta::Database;
28 using DBAssetLoader = DistributedData::AssetLoader;
29 using DBCloudDB = DistributedData::CloudDB;
30 using DBCloudInfo = DistributedData::CloudInfo;
31 using DBSchemaMeta = DistributedData::SchemaMeta;
32 using DBTable = DistributedData::Table;
33 using DBField = DistributedData::Field;
34 using DBSub = DistributedData::Subscription;
36 using DBErr = DistributedData::GeneralError;
37 class CloudServerImpl : public DistributedData::CloudServer {
H A Dcloud_cursor_impl.h26 using DBVBucket = DistributedData::VBucket;
27 using DBSchemaMeta = DistributedData::SchemaMeta;
28 using DBValue = DistributedData::Value;
29 using DBErr = DistributedData::GeneralError;
30 class CloudCursorImpl : public DistributedData::Cursor {
60 inline static constexpr auto TYPE_INDEX = DistributedData::TYPE_INDEX<T>;
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dsync_manager.h35 using GenAsync = DistributedData::GenAsync;
36 using GenStore = DistributedData::GeneralStore;
37 using GenQuery = DistributedData::GenQuery;
38 using RefCount = DistributedData::RefCount;
39 using AutoCache = DistributedData::AutoCache;
41 using SchemaMeta = DistributedData::SchemaMeta;
43 using SyncStage = DistributedData::SyncStage;
44 using ReportParam = DistributedData::ReportParam;
101 using Event = DistributedData::Event;
107 using CloudInfo = DistributedData::CloudInfo;
[all …]
H A Dcloud_value_util.h26 using SharingPtpant = OHOS::DistributedData::SharingCenter::Participant;
27 using SharingPlege = OHOS::DistributedData::SharingCenter::Privilege;
28 using SharingCfm = OHOS::DistributedData::SharingCenter::Confirmation;
29 using SharingRole = OHOS::DistributedData::SharingCenter::Role;
30 using SharingResults = OHOS::DistributedData::SharingCenter::QueryResults;
31 using CenterCode = OHOS::DistributedData::SharingCenter::SharingCode;
33 using GenErr = DistributedData::GeneralError;
H A Dcloud_service_impl.h35 using StoreMetaData = DistributedData::StoreMetaData;
36 using StoreInfo = DistributedData::StoreInfo;
75 using StaticActs = DistributedData::StaticActs;
92 using CloudInfo = DistributedData::CloudInfo;
93 using SchemaMeta = DistributedData::SchemaMeta;
94 using Event = DistributedData::Event;
95 using CloudEvent = DistributedData::CloudEvent;
96 using Subscription = DistributedData::Subscription;
102 using AutoCache = DistributedData::AutoCache;
154 DistributedData::GenQuery& query);
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/
H A Dcursor_mock.h23 namespace DistributedData {
24 class CursorMock : public DistributedData::Cursor {
26 using ResultSet = std::vector<std::map<std::string, DistributedData::Value>>;
36 int32_t GetEntry(DistributedData::VBucket &entry) override;
37 int32_t GetRow(DistributedData::VBucket &data) override;
38 int32_t Get(int32_t col, DistributedData::Value &value) override;
39 int32_t Get(const std::string &col, DistributedData::Value &value) override;
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/strategies/general/
H A Dload_config_data_info_strategy.cpp34 DistributedData::StoreMetaData &metaData, const int32_t userId, const int32_t appIndex) in QueryMetaData()
36 DistributedData::StoreMetaData meta; in QueryMetaData()
37 meta.deviceId = DistributedData::DeviceManagerAdapter::GetInstance().GetLocalDevice().uuid; in QueryMetaData()
41 …bool isCreated = DistributedData::MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), metaData,… in QueryMetaData()
54 DistributedData::StoreMetaData metaData; in operator ()()
62 … ZLOGE("QueryMetaData fail, %{public}s", DistributedData::Anonymous::Change(context->uri).c_str()); in operator ()()
77 DistributedData::StoreMetaData metaData; in operator ()()
83 … ZLOGE("QueryMetaData fail, %{public}s", DistributedData::Anonymous::Change(context->uri).c_str()); in operator ()()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
H A Ddata_share_db_config.cpp32 std::pair<bool, DistributedData::StoreMetaData> DataShareDbConfig::QueryMetaData( in QueryMetaData()
35 DistributedData::StoreMetaData meta; in QueryMetaData()
36 meta.deviceId = DistributedData::DeviceManagerAdapter::GetInstance().GetLocalDevice().uuid; in QueryMetaData()
41 DistributedData::StoreMetaData metaData; in QueryMetaData()
42 …bool isCreated = DistributedData::MetaDataManager::GetInstance().LoadMeta(meta.GetKey(), metaData,… in QueryMetaData()
46 std::pair<int, DistributedData::StoreMetaData> DataShareDbConfig::GetMetaData(const DbConfig &dbCon… in GetMetaData()
65 std::tuple<int, DistributedData::StoreMetaData, std::shared_ptr<DBDelegate>> DataShareDbConfig::Get… in GetDbConfig()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Dscheduler_manager.cpp41 DistributedData::StoreMetaData meta; in Execute()
46 ZLOGE("malloc fail %{public}s", DistributedData::Anonymous::Change(uri).c_str()); in Execute()
57 DistributedData::StoreMetaData meta; in Execute()
62 ZLOGE("malloc fail %{public}s", DistributedData::Anonymous::Change(key.uri).c_str()); in Execute()
119 … DistributedData::Anonymous::Change(key.uri).c_str(), key.subscriberId, key.bundleName.c_str()); in SetTimer()
126 "%{public}s", DistributedData::Anonymous::Change(key.uri).c_str(), in SetTimer()
147 … DistributedData::Anonymous::Change(key.uri).c_str(), key.subscriberId, key.bundleName.c_str()); in SetTimer()
157 … DistributedData::Anonymous::Change(key.uri).c_str(), key.subscriberId, key.bundleName.c_str()); in ExecuteSchedulerSQL()
162 … DistributedData::Anonymous::Change(key.uri).c_str(), key.subscriberId, key.bundleName.c_str()); in ExecuteSchedulerSQL()
169 … DistributedData::Anonymous::Change(key.uri).c_str(), key.subscriberId, key.bundleName.c_str()); in ExecuteSchedulerSQL()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_asset_loader.cpp39 const DistributedData::Asset& asset) in Transfer()
45 DistributedData::Anonymous::Change(deviceId).c_str(), assetInfo.assetName.c_str()); in Transfer()
53 … asset.name.c_str(), DistributedData::Anonymous::Change(deviceId).c_str(), bundleName.c_str()); in Transfer()
59 status, asset.name.c_str(), DistributedData::Anonymous::Change(deviceId).c_str()); in Transfer()
63 DistributedData::Anonymous::Change(deviceId).c_str(), assetInfo.assetName.c_str()); in Transfer()
68 …const std::string& deviceId, const std::vector<DistributedData::Asset>& assets, const TransferFunc… in TransferAssetsAsync()
72 bundleName.c_str(), DistributedData::Anonymous::Change(deviceId).c_str(), userId); in TransferAssetsAsync()
77 DistributedData::Assets downloadAssets; in TransferAssetsAsync()
134 void ObjectAssetLoader::UpdateDownloaded(const DistributedData::Asset& asset) in UpdateDownloaded()
147 bool ObjectAssetLoader::IsDownloading(const DistributedData::Asset& asset) in IsDownloading()
[all …]
H A Dobject_service_impl.cpp42 using DmAdapter = OHOS::DistributedData::DeviceManagerAdapter;
43 using StoreMetaData = OHOS::DistributedData::StoreMetaData;
44 using FeatureSystem = OHOS::DistributedData::FeatureSystem;
45 using DumpManager = OHOS::DistributedData::DumpManager;
146 saveMeta.bundleName = DistributedData::Bootstrap::GetInstance().GetProcessLabel(); in OnInitialize()
147 saveMeta.appId = DistributedData::Bootstrap::GetInstance().GetProcessLabel(); in OnInitialize()
164 DistributedData::AppIDMetaData appIdMeta; in OnInitialize()
262 DistributedData::CheckerManager::StoreInfo storeInfo; in IsBundleNameEqualTokenId()
301 param.appId.c_str(), DistributedData::Anonymous::Change(param.storeId).c_str(), in ResolveAutoLaunch()
302 DistributedData::Anonymous::Change(identifier).c_str()); in ResolveAutoLaunch()
[all …]
H A Dobject_service_stub.cpp39 DistributedData::Anonymous::Change(sessionId).c_str(), bundleName.c_str(), in ObjectStoreSaveOnRemote()
40 … DistributedData::Anonymous::Change(deviceId).c_str(), objectData.size(), obj == nullptr); in ObjectStoreSaveOnRemote()
58 DistributedData::Anonymous::Change(sessionId).c_str(), bundleName.c_str(), in OnAssetChangedOnRemote()
59 DistributedData::Anonymous::Change(deviceId).c_str()); in OnAssetChangedOnRemote()
83 DistributedData::Anonymous::Change(sessionId).c_str(), bundleName.c_str(), in ObjectStoreBindAssetOnRemote()
103 … DistributedData::Anonymous::Change(sessionId).c_str(), bundleName.c_str(), obj == nullptr); in ObjectStoreRevokeSaveOnRemote()
121 … DistributedData::Anonymous::Change(sessionId).c_str(), bundleName.c_str(), obj == nullptr); in ObjectStoreRetrieveOnRemote()
139 … DistributedData::Anonymous::Change(sessionId).c_str(), bundleName.c_str(), obj == nullptr); in OnSubscribeRequest()
156 DistributedData::Anonymous::Change(sessionId).c_str(), bundleName.c_str()); in OnUnsubscribeRequest()
173 DistributedData::Anonymous::Change(sessionId).c_str(), bundleName.c_str()); in OnDeleteSnapshot()

12345678910>>...17