| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | schema_meta.cpp | 23 SetValue(node[GET_NAME(databases)], databases); in Marshal()
34 GetValue(node, GET_NAME(databases), databases); in Unmarshal()
107 for (const auto &database : databases) { in GetDataBase()
117 return !bundleName.empty() && !databases.empty(); in IsValid()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_server_impl.cpp | 146 OhCloudExtVector *databases = nullptr; in GetAppSchema() local
147 status = OhCloudExtSchemaMetaGetDatabases(pSchema.get(), &databases); in GetAppSchema()
148 if (status != ERRNO_SUCCESS || databases == nullptr) { in GetAppSchema()
151 auto pDatabases = std::shared_ptr<OhCloudExtVector>(databases, [](auto *databases) { in GetAppSchema()
152 OhCloudExtVectorFree(databases); in GetAppSchema()
158 void CloudServerImpl::GetDatabases(std::shared_ptr<OhCloudExtVector> databases, DBSchemaMeta &dbSchema) in GetDatabases() argument
161 auto status = OhCloudExtVectorGetLength(databases.get(), reinterpret_cast<unsigned int *>(&dbsLen)); in GetDatabases()
165 dbSchema.databases.reserve(dbsLen); in GetDatabases()
169 status = OhCloudExtVectorGet(databases in GetDatabases()
316 OhCloudExtHashMap *databases = OhCloudExtHashMapNew(OhCloudExtRustType::VALUETYPE_VEC_DATABASE); Subscribe() local
349 DoSubscribe(int32_t userId, std::shared_ptr<OhCloudExtCloudSync> server, std::shared_ptr<OhCloudExtHashMap> databases) DoSubscribe() argument
[all...] |
| H A D | cloud_server_impl.h | 52 void GetDatabases(std::shared_ptr<OhCloudExtVector> databases, DBSchemaMeta &dbSchema);
57 std::shared_ptr<OhCloudExtHashMap> databases);
|
| H A D | extension_util.cpp | 116 OhCloudExtHashMap *databases = OhCloudExtHashMapNew(OhCloudExtRustType::VALUETYPE_TABLE); in Convert() local
117 if (databases == nullptr) { in Convert()
133 auto status = OhCloudExtHashMapInsert(databases, in Convert()
142 dbMeta.alias.size(), databases); in Convert()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/ |
| H A D | connect.rs | 521 let databases = Databases(vec_raw_read(parcel)?); in deserialize()
522 Ok(databases) in deserialize()
530 pub(crate) databases: Databases,
546 self.databases = msg_parcel in read()
560 let databases = parcel.read::<Databases>()?; in deserialize()
565 databases, in deserialize()
689 databases: &Databases,
700 .write(databases)
871 databases: &Databases,
874 subscription.subscribe(&self.remote_obj, expiration, bundle_name, databases)
1627 let mut databases = Databases::default(); ut_databases_serialize() variables
1654 let mut databases = Databases::default(); ut_databases_deserialize() variables
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | schema_meta.h | 79 std::vector<Database> databases; member in OHOS::DistributedData::final
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | cloud_service_impl.cpp | 218 for (const auto &database : schemaMeta.databases) { in DoClean()
316 for (auto &db : schemaMeta.databases) { in GetDbInfoFromExtraData()
344 for (auto &db : schemaMeta.databases) { in GetDbInfoFromExtraData()
446 for (auto &database : schemaMeta.databases) { in ExecuteStatistics()
594 std::vector<Database> databases; in QueryLastSyncInfo() local
599 databases = schema.databases; in QueryLastSyncInfo()
600 for (const auto &database : schema.databases) { in QueryLastSyncInfo()
617 for (const auto &database : databases) { in QueryLastSyncInfo()
1090 dbs.insert_or_assign(bundle, std::move(schemaMeta.databases)); in DoSubscribe()
[all...] |
| H A D | sync_manager.cpp | 300 for (const auto &database : schema.databases) { in GetPostEventTask()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | cloud_test.cpp | 96 schemaMeta.databases.emplace_back(database); in HWTEST_F()
|
| H A D | cloud_data_test.cpp | 222 schemaMeta_.databases.emplace_back(database); in InitSchemaMeta()
224 schemaMeta_.databases.emplace_back(database); in InitSchemaMeta()
1503 schemaMeta_.databases[0].name = "test"; in HWTEST_F()
1726 schemaMeta.databases.push_back(database); in HWTEST_F()
1739 schemaMeta.databases.push_back(database); in HWTEST_F()
|
| H A D | cloud_service_impl_test.cpp | 178 schemaMeta.databases.emplace_back(database); in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/c_adapter/ |
| H A D | cloud_extension.rs | 625 HashMapCffi::VecDatabase(databases) => databases,
|
| H A D | cloud_ext_types.rs | 994 /// Get a vector of databases from a SchemaMeta pointer. Parameter `dbs` be updated
1010 let databases = schema_struct.databases();
1011 let vec = VectorCffi::Database(databases.to_vec());
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/cloud_extension/ |
| H A D | cloud_extension_stub.js | 176 u.writeInt(u1.databases.length);
177 u1.databases.forEach((h1) => {
|