| /foundation/ability/ability_runtime/services/dataobsmgr/src/ |
| H A D | dataobs_mgr_changeinfo.cpp | 89 VBuckets buckets; in Unmarshalling() local
90 if (!(DataObsUtils::Unmarshal(parcel, buckets))) { in Unmarshalling()
97 output.valueBuckets_ = std::move(buckets); in Unmarshalling()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/common/ |
| H A D | value_proxy.h | 192 Buckets(Buckets &&buckets) noexcept
194 *this = std::move(buckets);
196 Buckets &operator=(Buckets &&buckets) noexcept;
200 std::vector<T> buckets; in operator std::vector() local
201 buckets.reserve(value_.size()); in operator std::vector()
203 buckets.emplace_back(std::move(bucket)); in operator std::vector()
206 return buckets; in operator std::vector()
226 static Buckets Convert(DistributedData::VBuckets &&buckets);
227 static Buckets Convert(std::vector<NativeRdb::ValuesBucket> &&buckets);
228 static Buckets Convert(std::vector<CommonType::ValuesBucket> &&buckets);
[all...] |
| H A D | value_proxy.cpp | 124 ValueProxy::Buckets ValueProxy::Convert(std::vector<NativeRdb::ValuesBucket> &&buckets) in Convert() argument
127 proxy.value_.reserve(buckets.size()); in Convert()
128 for (auto &bucket : buckets) { in Convert()
134 ValueProxy::Buckets ValueProxy::Convert(std::vector<CommonType::ValuesBucket> &&buckets) in Convert() argument
137 proxy.value_.reserve(buckets.size()); in Convert()
138 for (auto &bucket : buckets) { in Convert()
144 ValueProxy::Buckets ValueProxy::Convert(std::vector<DistributedDB::VBucket> &&buckets) in Convert() argument
147 proxy.value_.reserve(buckets.size()); in Convert()
148 for (auto &bucket : buckets) { in Convert()
154 ValueProxy::Buckets ValueProxy::Convert(DistributedData::VBuckets &&buckets) in Convert() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | extension_util.cpp | 21 std::pair<OhCloudExtVector *, size_t> ExtensionUtil::Convert(DBVBuckets &&buckets) in Convert() argument
28 for (auto &bucket : buckets) { in Convert()
179 DBVBuckets buckets; in ConvertBuckets() local
183 return buckets; in ConvertBuckets()
185 buckets.reserve(len); in ConvertBuckets()
191 return buckets; in ConvertBuckets()
197 buckets.emplace_back(ConvertBucket(pValues.get())); in ConvertBuckets()
199 return buckets; in ConvertBuckets()
|
| H A D | extension_util.h | 54 static std::pair<OhCloudExtVector *, size_t> Convert(DBVBuckets &&buckets);
|
| /foundation/filemanagement/dfs_service/test/unittests/clouddisk_database/mock/ |
| H A D | meta_file_clouddisk_mock.cpp | 256 uint64_t buckets = (1ULL << (level + 1)) - 1; in GetOverallBucket() local
257 return static_cast<uint32_t>(buckets); in GetOverallBucket()
262 size_t buckets = GetOverallBucket(level); in GetDcacheFileSize() local
263 return buckets * DENTRYGROUP_SIZE * BUCKET_BLOCKS + DENTRYGROUP_HEADER; in GetDcacheFileSize()
287 uint64_t buckets = (1ULL << level); in GetBucketByLevel() local
288 return static_cast<uint32_t>(buckets); in GetBucketByLevel()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
| H A D | kv_utils_test.cpp | 682 * @tc.desc: dataShare values bucket to entries, the buckets is invalid
689 std::vector<DataShareValuesBucket> buckets {}; in HWTEST_F()
690 auto entries = KvUtils::ToEntries(buckets); in HWTEST_F()
696 * @tc.desc: dataShare values bucket to entries, the buckets has valid value
703 std::vector<DataShareValuesBucket> buckets {}; in HWTEST_F()
713 buckets.emplace_back(bucket); in HWTEST_F()
721 buckets.emplace_back(bucket); in HWTEST_F()
724 auto entries = KvUtils::ToEntries(buckets); in HWTEST_F()
|
| /foundation/filemanagement/dfs_service/utils/dentry/src/ |
| H A D | meta_file_clouddisk.cpp | 231 uint64_t buckets = (1ULL << (level + 1)) - 1; in GetOverallBucket() local
232 return static_cast<uint32_t>(buckets); in GetOverallBucket()
237 size_t buckets = GetOverallBucket(level); in GetDcacheFileSize() local
238 return buckets * DENTRYGROUP_SIZE * BUCKET_BLOCKS + DENTRYGROUP_HEADER; in GetDcacheFileSize()
262 uint64_t buckets = (1ULL << level); in GetBucketByLevel() local
263 return static_cast<uint32_t>(buckets); in GetBucketByLevel()
|
| H A D | meta_file.cpp | 220 uint64_t buckets = (1ULL << (level + 1)) - 1; in GetOverallBucket() local
221 return static_cast<uint32_t>(buckets); in GetOverallBucket()
226 size_t buckets = GetOverallBucket(level); in GetDcacheFileSize() local
227 return buckets * DENTRYGROUP_SIZE * BUCKET_BLOCKS + DENTRYGROUP_HEADER; in GetDcacheFileSize()
251 uint64_t buckets = (1ULL << level); in GetBucketByLevel() local
252 return static_cast<uint32_t>(buckets); in GetBucketByLevel()
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | sqlite_sql_builder.cpp | 301 SqliteSqlBuilder::BatchRefSqls SqliteSqlBuilder::GenerateSqls(const std::string &table, const ValuesBuckets &buckets, in GenerateSqls() argument
304 auto [fields, values] = buckets.GetFieldsAndValues(); in GenerateSqls()
306 auto rowSize = buckets.RowSize(); in GenerateSqls()
313 auto [errorCode, value] = buckets.Get(row, std::ref(field)); in GenerateSqls()
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | sqlite_sql_builder.h | 52 static BatchRefSqls GenerateSqls(const std::string &table, const ValuesBuckets &buckets, int limit);
|