| /foundation/distributeddatamgr/data_share/test/native/unittest/mediadatashare_test/src/ |
| H A D | valueproxy_test.cpp | 34 DataShareObserver::ChangeInfo::VBuckets extends;
in HWTEST_F() local
35 extends = ValueProxy::Convert(std::move(VBuckets));
in HWTEST_F()
36 ASSERT_EQ(extends.size(), 2);
in HWTEST_F()
42 DataShareObserver::ChangeInfo::VBuckets extends = {
in HWTEST_F() local
46 VBuckets = ValueProxy::Convert(std::move(extends));
in HWTEST_F()
|
| H A D | mediadatashare_unit_test.cpp | 1513 DataShareObserver::ChangeInfo::VBuckets extends; in HWTEST_F() local
1514 extends = ValueProxy::Convert(std::move(VBuckets)); in HWTEST_F()
1515 ChangeInfo uriChanges = { DataShareObserver::ChangeType::INSERT, { uri }, nullptr, 0, extends}; in HWTEST_F()
1541 DataShareObserver::ChangeInfo::VBuckets extends; in HWTEST_F() local
1542 extends = ValueProxy::Convert(std::move(VBuckets)); in HWTEST_F()
1543 ChangeInfo uriChanges = { DataShareObserver::ChangeType::UPDATE, { uri }, nullptr, 0, extends}; in HWTEST_F()
1569 DataShareObserver::ChangeInfo::VBuckets extends; in HWTEST_F() local
1570 extends = ValueProxy::Convert(std::move(VBuckets)); in HWTEST_F()
1571 ChangeInfo uriChanges = { DataShareObserver::ChangeType::DELETE, { uri }, nullptr, 0, extends}; in HWTEST_F()
1596 DataShareObserver::ChangeInfo::VBuckets extends; in HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_db_impl.cpp | 54 int32_t CloudDbImpl::BatchInsert(const std::string &table, DBVBuckets &&values, DBVBuckets &extends) in BatchInsert() argument
58 auto exdIn = ExtensionUtil::Convert(std::move(extends)); in BatchInsert()
67 extends = ExtensionUtil::ConvertBuckets(exdIn.first); in BatchInsert()
74 int32_t CloudDbImpl::BatchUpdate(const std::string &table, DBVBuckets &&values, DBVBuckets &extends) in BatchUpdate() argument
76 auto exdIn = ExtensionUtil::Convert(std::move(extends)); in BatchUpdate()
86 extends = ExtensionUtil::ConvertBuckets(exdIn.first); in BatchUpdate()
93 int32_t CloudDbImpl::BatchUpdate(const std::string &table, DBVBuckets &&values, const DBVBuckets &extends) in BatchUpdate() argument
95 auto exdIn = ExtensionUtil::Convert(std::move(const_cast<DBVBuckets &>(extends))); in BatchUpdate()
109 int32_t CloudDbImpl::BatchDelete(const std::string &table, DBVBuckets &extends) in BatchDelete() argument
111 auto data = ExtensionUtil::Convert(std::move(extends)); in BatchDelete()
[all...] |
| H A D | cloud_db_impl.h | 35 int32_t BatchInsert(const std::string &table, DBVBuckets &&values, DBVBuckets &extends) override;
36 int32_t BatchUpdate(const std::string &table, DBVBuckets &&values, DBVBuckets &extends) override;
37 int32_t BatchUpdate(const std::string &table, DBVBuckets &&values, const DBVBuckets &extends) override;
38 int32_t BatchDelete(const std::string &table, DBVBuckets &extends) override;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/service_impl/ |
| H A D | cloud_db.rs | 57 /// Values and extends are all value buckets from the users, but for the convenience, split
64 extends: &mut Vec<RawValueBucket>, in batch_insert()
69 if i < extends.len() { in batch_insert()
70 extends[i].insert(GID_FIELD.to_string(), Value::String(id.to_string())); in batch_insert()
74 extends.push(vb); in batch_insert()
81 extends, in batch_insert()
90 /// Values and extends are all value buckets from the users, but for the convenience, split
97 extends: &mut [RawValueBucket], in batch_update()
102 extends, in batch_update()
111 /// Values and extends ar
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | cloud_db.cpp | 23 int32_t CloudDB::BatchInsert(const std::string &table, VBuckets &&values, VBuckets &extends) in BatchInsert() argument
28 int32_t CloudDB::BatchUpdate(const std::string &table, VBuckets &&values, VBuckets &extends) in BatchUpdate() argument
30 return BatchUpdate(table, std::move(values), static_cast<const VBuckets &>(extends)); in BatchUpdate()
33 int32_t CloudDB::BatchUpdate(const std::string &table, VBuckets &&values, const VBuckets &extends) in BatchUpdate() argument
38 int32_t CloudDB::BatchDelete(const std::string &table, VBuckets &extends) in BatchDelete() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_cloud.cpp | 38 VBuckets extends = ValueProxy::Convert(std::move(extend)); in BatchInsert() local
41 PostEvent(records, skipAssets, extends, DistributedData::AssetEvent::UPLOAD); in BatchInsert()
43 auto error = cloudDB_->BatchInsert(tableName, std::move(records), extends); in BatchInsert()
44 PostEvent(temp, skipAssets, extends, DistributedData::AssetEvent::UPLOAD_FINISHED); in BatchInsert()
45 ConvertErrorField(extends); in BatchInsert()
46 extend = ValueProxy::Convert(std::move(extends)); in BatchInsert()
54 VBuckets extends = ValueProxy::Convert(std::move(extend)); in BatchUpdate() local
57 PostEvent(records, skipAssets, extends, DistributedData::AssetEvent::UPLOAD); in BatchUpdate()
59 auto error = cloudDB_->BatchUpdate(tableName, std::move(records), extends); in BatchUpdate()
60 PostEvent(temp, skipAssets, extends, DistributedDat in BatchUpdate()
68 VBuckets extends = ValueProxy::Convert(std::move(extend)); BatchDelete() local
334 ConvertErrorField(DistributedData::VBuckets& extends) ConvertErrorField() argument
[all...] |
| H A D | rdb_cloud.h | 67 static void ConvertErrorField(DistributedData::VBuckets& extends);
|
| H A D | rdb_general_store.cpp | 584 VBuckets extends = ExtractExtend(values); in PreSharing() local
585 rdbCloud->PreSharing(*tables.begin(), extends); in PreSharing()
586 for (auto value = values.begin(), extend = extends.begin(); value != values.end() && extend != extends.end(); in PreSharing()
596 VBuckets extends(values.size()); in ExtractExtend()
597 for (auto value = values.begin(), extend = extends.begin(); value != values.end() && extend != extends.end(); in ExtractExtend()
609 return extends; in ExtractExtend()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | rdb_cloud_test.cpp | 81 DBVBucket extends = {
in HWTEST_F() local
85 result = rdbCloud.Query(tableName, extends, g_DBVBucket);
in HWTEST_F()
114 DBVBucket extends = {
in HWTEST_F() local
121 auto result = rdbCloud.Query(tableName, extends, data);
in HWTEST_F()
124 extends = {
in HWTEST_F()
128 result = rdbCloud.Query(tableName, extends, data);
in HWTEST_F()
131 extends = {
in HWTEST_F()
135 result = rdbCloud.Query(tableName, extends, data);
in HWTEST_F()
|
| H A D | value_proxy_test.cpp | 38 OHOS::DistributedData::VBuckets extends = { in HWTEST_F() local
42 dbVBuckets = ValueProxy::Convert(std::move(extends)); in HWTEST_F()
59 OHOS::DistributedData::VBuckets extends; in HWTEST_F() local
60 extends = ValueProxy::Convert(std::move(dbVBuckets)); in HWTEST_F()
61 ASSERT_EQ(extends.size(), 2); in HWTEST_F()
75 OHOS::DistributedData::VBuckets extends = { in HWTEST_F() local
79 rdbVBuckets = ValueProxy::Convert(std::move(extends)); in HWTEST_F()
105 OHOS::DistributedData::VBuckets extends; in HWTEST_F() local
106 extends = ValueProxy::Convert(std::move(rdbVBuckets)); in HWTEST_F()
107 ASSERT_EQ(extends in HWTEST_F()
[all...] |
| H A D | rdb_general_store_test.cpp | 503 DistributedData::VBuckets extends = { { { "#gid", { "0000000" } }, { "#flag", { true } },
in HWTEST_F() local
506 result = store->Insert("", std::move(extends));
in HWTEST_F()
514 result = store->Insert(table, std::move(extends));
in HWTEST_F()
530 DistributedData::VBuckets extends = { { g_RdbVBucket } };
in HWTEST_F() local
531 auto result = store->Insert(table, std::move(extends));
in HWTEST_F()
536 result = store->Insert(table, std::move(extends));
in HWTEST_F()
540 result = store->Insert(test, std::move(extends));
in HWTEST_F()
543 result = store->Insert(test, std::move(extends));
in HWTEST_F()
547 result = store->Insert(test, std::move(extends));
in HWTEST_F()
703 DistributedData::VBuckets extends in HWTEST_F() local
767 DistributedData::VBuckets extends = { { extend } }; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_db_data_utils.cpp | 65 std::vector<VBucket> extends; in GenerateExtends() local
66 extends.resize(extendCounts); in GenerateExtends()
71 extends.push_back(info); in GenerateExtends()
73 return extends; in GenerateExtends()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | cloud_db.h | 35 virtual int32_t BatchInsert(const std::string &table, VBuckets &&values, VBuckets &extends);
37 virtual int32_t BatchUpdate(const std::string &table, VBuckets &&values, VBuckets &extends);
39 virtual int32_t BatchUpdate(const std::string &table, VBuckets &&values, const VBuckets &extends);
41 virtual int32_t BatchDelete(const std::string &table, VBuckets &extends);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/ |
| H A D | database.rs | 138 extends: &ValueBuckets,
149 .write(extends)
186 extends: &ValueBuckets,
196 .write(extends)
232 extends: &ValueBuckets,
239 .write(extends)
|