Home
last modified time | relevance | path

Searched refs:bucket (Results 1 - 25 of 53) sorted by relevance

123

/foundation/distributeddatamgr/relational_store/interfaces/ndk/src/
H A Drelational_values_bucket.cpp30 int RelationalValuesBucket::PutText(OH_VBucket *bucket, const char *field, const char *value) in PutText() argument
32 return PutValueObject(bucket, field, OHOS::NativeRdb::ValueObject(value)); in PutText()
35 int RelationalValuesBucket::PutInt64(OH_VBucket *bucket, const char *field, int64_t value) in PutInt64() argument
37 return PutValueObject(bucket, field, OHOS::NativeRdb::ValueObject(value)); in PutInt64()
40 int RelationalValuesBucket::PutReal(OH_VBucket *bucket, const char *field, double value) in PutReal() argument
42 return PutValueObject(bucket, field, OHOS::NativeRdb::ValueObject(value)); in PutReal()
45 int RelationalValuesBucket::PutBlob(OH_VBucket *bucket, const char *field, const uint8_t *value, uint32_t size) in PutBlob() argument
55 return PutValueObject(bucket, field, OHOS::NativeRdb::ValueObject(blobValue)); in PutBlob()
58 int RelationalValuesBucket::PutNull(OH_VBucket *bucket, const char *field) in PutNull() argument
60 return PutValueObject(bucket, fiel in PutNull()
63 Clear(OH_VBucket *bucket) Clear() argument
74 Destroy(OH_VBucket *bucket) Destroy() argument
103 GetSelf(OH_VBucket *bucket) GetSelf() argument
112 PutValueObject(OH_VBucket *bucket, const char *field, OHOS::NativeRdb::ValueObject &&value) PutValueObject() argument
127 OH_VBucket_PutAsset(OH_VBucket *bucket, const char *field, Data_Asset *value) OH_VBucket_PutAsset() argument
138 OH_VBucket_PutAssets(OH_VBucket *bucket, const char *field, Data_Asset **value, uint32_t count) OH_VBucket_PutAssets() argument
[all...]
H A Drelational_values_bucket.h27 static RelationalValuesBucket *GetSelf(OH_VBucket *bucket);
31 static int PutText(OH_VBucket *bucket, const char *field, const char *value);
32 static int PutInt64(OH_VBucket *bucket, const char *field, int64_t value);
33 static int PutReal(OH_VBucket *bucket, const char *field, double value);
34 static int PutBlob(OH_VBucket *bucket, const char *field, const uint8_t *value, uint32_t size);
35 static int PutNull(OH_VBucket *bucket, const char *field);
36 static int Clear(OH_VBucket *bucket);
37 static int Destroy(OH_VBucket *bucket);
38 static int PutValueObject(OH_VBucket *bucket, const char *field, OHOS::NativeRdb::ValueObject &&value);
/foundation/systemabilitymgr/samgr_lite/samgr_endpoint/source/
H A Dtoken_bucket.c19 int TB_CheckMessage(TokenBucket *bucket) in TB_CheckMessage() argument
21 if (bucket == NULL) { in TB_CheckMessage()
25 uint64 generated = (now > bucket->last) ? ((now - bucket->last) * bucket->rate) : 0; in TB_CheckMessage()
26 int used = bucket->used + TOKEN_PRE_MSG; in TB_CheckMessage()
28 if (used >= bucket->burst * TOKEN_PRE_MSG) { in TB_CheckMessage()
31 bucket->used = used; in TB_CheckMessage()
32 bucket->last = now; in TB_CheckMessage()
H A Dtoken_bucket.h29 int burst; // The burst size of the token bucket
39 inline static void TB_InitBucket(TokenBucket *bucket, int rate, int burst) in TB_InitBucket() argument
41 bucket->last = 0; in TB_InitBucket()
42 bucket->rate = rate; in TB_InitBucket()
43 bucket->burst = burst; in TB_InitBucket()
44 bucket->used = 0; in TB_InitBucket()
46 int TB_CheckMessage(TokenBucket *bucket);
/foundation/distributeddatamgr/relational_store/interfaces/ndk/include/
H A Doh_values_bucket.h65 * @param bucket Represents a pointer to an {@link OH_VBucket} instance.
72 int (*putText)(OH_VBucket *bucket, const char *field, const char *value);
77 * @param bucket Represents a pointer to an {@link OH_VBucket} instance.
84 int (*putInt64)(OH_VBucket *bucket, const char *field, int64_t value);
89 * @param bucket Represents a pointer to an {@link OH_VBucket} instance.
96 int (*putReal)(OH_VBucket *bucket, const char *field, double value);
101 * @param bucket Represents a pointer to an {@link OH_VBucket} instance.
109 int (*putBlob)(OH_VBucket *bucket, const char *field, const uint8_t *value, uint32_t size);
114 * @param bucket Represents a pointer to an {@link OH_VBucket} instance.
120 int (*putNull)(OH_VBucket *bucket, cons
[all...]
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_bigint_test.cpp89 ValuesBucket bucket; in HWTEST_F() local
90 bucket.Put("value1", BigInteger(158)); in HWTEST_F()
91 bucket.Put("value2", BigInteger(-158)); in HWTEST_F()
92 auto status = rdbStore_->Insert(outRowId, "bigint_table", bucket); in HWTEST_F()
123 ValuesBucket bucket; in HWTEST_F() local
124 bucket.Put("value1", BigInteger(158)); in HWTEST_F()
125 bucket.Put("value2", BigInteger(-158)); in HWTEST_F()
126 auto status = rdbStore_->Insert(outRowId, "bigint_table", bucket); in HWTEST_F()
159 ValuesBucket bucket; in HWTEST_F() local
160 bucket in HWTEST_F()
195 ValuesBucket bucket; HWTEST_F() local
231 ValuesBucket bucket; HWTEST_F() local
273 ValuesBucket bucket; HWTEST_F() local
315 ValuesBucket bucket; HWTEST_F() local
358 ValuesBucket bucket; HWTEST_F() local
396 ValuesBucket bucket; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/
H A Dkv_utils_test.cpp504 * @tc.desc: dataShare values bucket to entry, the bucket is invalid
511 DataShareValuesBucket bucket {}; in HWTEST_F()
513 auto entry = KvUtils::ToEntry(bucket); in HWTEST_F()
515 bucket.Put("invalid key", "value"); in HWTEST_F()
516 EXPECT_FALSE(bucket.IsEmpty()); in HWTEST_F()
517 entry = KvUtils::ToEntry(bucket); in HWTEST_F()
519 bucket.Put(KEY, "value"); in HWTEST_F()
520 entry = KvUtils::ToEntry(bucket); in HWTEST_F()
526 * @tc.desc: dataShare values bucket t
704 DataShareValuesBucket bucket; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/
H A DRdbStoreValueType.test.js66 let bucket = {
71 console.log(TAG + "insert(bigint_table," + bucket + ")");
72 let rowid = await store.insert("bigint_table", bucket);
83 expect(value1).assertEqual(bucket["value1"]);
88 expect(value2).assertEqual(bucket["value2"]);
105 let bucket = {
110 console.log(TAG + "insert(bigint_table," + bucket + ")");
111 let rowid = await store.insert("bigint_table", bucket);
122 expect(value1).assertEqual(bucket["value1"]);
127 expect(value2).assertEqual(bucket["value
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dvalues_buckets.cpp36 void ValuesBuckets::Put(const ValuesBucket &bucket) in Put() argument
39 for (const auto &[field, value] : bucket.values_) { in Put()
56 auto &bucket = buckets_[row]; in Get() local
57 auto it = bucket.find(field); in Get()
58 if (it == bucket.end()) { in Get()
H A Dvalues_bucket.cpp158 ValuesBucket bucket; in Unmarshalling() local
159 ITypesUtil::Unmarshal(*data, bucket.values_); in Unmarshalling()
160 return bucket; in Unmarshalling()
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/pipeline/
H A Drs_render_node_gc.cpp39 auto& bucket = nodeBucket_.back(); in NodeDestructorInner() local
40 if (bucket.size() < BUCKET_MAX_SIZE) { in NodeDestructorInner()
41 bucket.push_back(ptr); in NodeDestructorInner()
108 auto& bucket = drawableBucket_.back(); in DrawableDestructorInner() local
109 if (bucket.size() < BUCKET_MAX_SIZE) { in DrawableDestructorInner()
110 bucket.push_back(ptr); in DrawableDestructorInner()
161 auto& bucket = offTreeBucket_.back(); in AddToOffTreeNodeBucket() local
162 if (bucket.size() < OFF_TREE_BUCKET_MAX_SIZE) { in AddToOffTreeNodeBucket()
163 bucket.emplace_back(node); in AddToOffTreeNodeBucket()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/common/
H A Dvalue_proxy.h167 Bucket(Bucket &&bucket) noexcept
169 *this = std::move(bucket);
171 Bucket &operator=(Bucket &&bucket) noexcept;
175 std::map<std::string, T> bucket; in operator std::map() local
177 bucket.insert_or_assign(key, std::move(static_cast<T>(value))); in operator std::map()
180 return bucket; in operator std::map()
202 for (auto &bucket : value_) { in operator std::vector()
203 buckets.emplace_back(std::move(bucket)); in operator std::vector()
222 static Bucket Convert(DistributedData::VBucket &&bucket);
223 static Bucket Convert(NativeRdb::ValuesBucket &&bucket);
[all...]
H A Dvalue_proxy.cpp88 ValueProxy::Bucket ValueProxy::Convert(DistributedData::VBucket &&bucket) in Convert() argument
91 for (auto &[key, value] : bucket) { in Convert()
97 ValueProxy::Bucket ValueProxy::Convert(NativeRdb::ValuesBucket &&bucket) in Convert() argument
100 for (auto &[key, value] : bucket.values_) { in Convert()
106 ValueProxy::Bucket ValueProxy::Convert(CommonType::ValuesBucket &&bucket) in Convert() argument
109 for (auto &[key, value] : bucket) { in Convert()
115 ValueProxy::Bucket ValueProxy::Convert(DistributedDB::VBucket &&bucket) in Convert() argument
118 for (auto &[key, value] : bucket) { in Convert()
128 for (auto &bucket : buckets) { in Convert()
129 proxy.value_.emplace_back(Convert(std::move(bucket))); in Convert()
506 NativeRdb::ValuesBucket bucket; operator NativeRdb::ValuesBucket() local
516 CommonType::ValuesBucket bucket; operator CommonType::ValuesBucket() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_cursor.cpp82 std::map<std::string, VariantData> bucket; in GetRow() local
83 auto ret = resultSet_->GetRow(bucket); in GetRow()
84 data = ValueProxy::Convert(std::move(bucket)); in GetRow()
95 VBucket bucket; in Get() local
96 if (GetRow(bucket) != GeneralError::E_OK) { in Get()
99 value = bucket[name]; in Get()
/foundation/communication/nfc/services/src/external_deps/
H A Dnfc_data_share_impl.cpp94 DataShare::DataShareValuesBucket bucket; in SetValue() local
95 bucket.Put(KITS::NFC_DATA_COLUMN_VALUE, valueObj); in SetValue()
96 bucket.Put(KITS::NFC_DATA_COLUMN_KEYWORD, keyObj); in SetValue()
99 result = dataShareHelper_->Insert(uri, bucket); in SetValue()
103 result = dataShareHelper_->Update(uri, predicates, bucket); in SetValue()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_db_data_utils.cpp32 VBucket bucket; in GenerateRecord() local
58 bucket[field.colName] = std::move(value); in GenerateRecord()
60 return bucket; in GenerateRecord()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dextension_util.cpp28 for (auto &bucket : buckets) { in Convert()
29 auto value = Convert(bucket); in Convert()
42 std::pair<OhCloudExtHashMap *, size_t> ExtensionUtil::Convert(const DBVBucket &bucket) in Convert() argument
49 for (auto &[col, dbValue] : bucket) { in Convert()
204 DBVBucket bucket; in ConvertBucket() local
209 return bucket; in ConvertBucket()
220 return bucket; in ConvertBucket()
227 return bucket; in ConvertBucket()
233 return bucket; in ConvertBucket()
237 bucket[keyOu in ConvertBucket()
257 ConvertValues(OhCloudExtValueBucket *bucket, const std::string &key) ConvertValues() argument
[all...]
H A Dextension_util.h49 static DBValue ConvertValues(OhCloudExtValueBucket *bucket, const std::string &key);
53 static std::pair<OhCloudExtHashMap *, size_t> Convert(const DBVBucket &bucket);
/foundation/ability/dmsfwk/services/dtbschedmgr/src/
H A Ddatashare_manager.cpp153 DataShare::DataShareValuesBucket bucket; in UpdateSwitchStatus() local
154 bucket.Put(SwitchStatusDependency::SETTINGS_DATA_FIELD_KEY, key); in UpdateSwitchStatus()
155 bucket.Put(SwitchStatusDependency::SETTINGS_DATA_FIELD_VAL, value); in UpdateSwitchStatus()
157 auto result = dataShareHelper->UpdateEx(uri, predicates, bucket); in UpdateSwitchStatus()
/foundation/communication/nfc/services/src/card_emulation/
H A Dsetting_data_share_impl.cpp140 DataShare::DataShareValuesBucket bucket; in SetElementName() local
141 bucket.Put(KITS::NFC_DATA_COLUMN_VALUE, valueObj); in SetElementName()
142 bucket.Put(KITS::NFC_DATA_COLUMN_KEYWORD, keyObj); in SetElementName()
145 result = dataShareHelper_->Insert(uri, bucket); in SetElementName()
149 result = dataShareHelper_->Update(uri, predicates, bucket); in SetElementName()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
H A Ddata_share_service_stub.cpp45 DataShareValuesBucket bucket; in OnInsertEx() local
46 if (!ITypesUtil::Unmarshal(data, uri, extUri, bucket.valuesMap)) { in OnInsertEx()
47 ZLOGE("Unmarshal uri:%{public}s bucket size:%{public}zu", DistributedData::Anonymous::Change(uri).c_str(), in OnInsertEx()
48 bucket.valuesMap.size()); in OnInsertEx()
51 auto [errCode, status] = InsertEx(uri, extUri, bucket); in OnInsertEx()
64 DataShareValuesBucket bucket; in OnUpdateEx() local
65 if (!ITypesUtil::Unmarshal(data, uri, extUri, predicate, bucket.valuesMap)) { in OnUpdateEx()
66 ZLOGE("Unmarshal uri:%{public}s bucket size:%{public}zu", DistributedData::Anonymous::Change(uri).c_str(), in OnUpdateEx()
67 bucket.valuesMap.size()); in OnUpdateEx()
70 auto [errCode, status] = UpdateEx(uri, extUri, predicate, bucket); in OnUpdateEx()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dlru_bucket.h30 LRUBucket(LRUBucket &&bucket) noexcept = delete;
31 LRUBucket(const LRUBucket &bucket) = delete; member in OHOS::LRUBucket
32 LRUBucket &operator=(LRUBucket &&bucket) noexcept = delete;
33 LRUBucket &operator=(const LRUBucket &bucket) = delete; member in OHOS::LRUBucket
/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/
H A Dlru_bucket.h30 LRUBucket(LRUBucket &&bucket) noexcept = delete;
31 LRUBucket(const LRUBucket &bucket) = delete; member in OHOS::LRUBucket
32 LRUBucket &operator=(LRUBucket &&bucket) noexcept = delete;
33 LRUBucket &operator=(const LRUBucket &bucket) = delete; member in OHOS::LRUBucket
/foundation/distributeddatamgr/data_share/frameworks/native/common/include/
H A Ddatashare_itypes_utils.h57 bool Marshalling(const Predicates &bucket, MessageParcel &parcel);
84 bool Marshalling(const DataShareValuesBucket &bucket, MessageParcel &parcel);
87 bool Unmarshalling(DataShareValuesBucket &bucket, MessageParcel &parcel);
/foundation/window/window_manager/window_scene/screen_session_manager/src/
H A Dsetting_provider.cpp234 DataShare::DataShareValuesBucket bucket; in PutStringValue() local
235 bucket.Put(SETTING_COLUMN_KEYWORD, keyObj); in PutStringValue()
236 bucket.Put(SETTING_COLUMN_VALUE, valueObj); in PutStringValue()
240 if (helper->Update(uri, predicates, bucket) <= 0) { in PutStringValue()
242 helper->Insert(uri, bucket); in PutStringValue()

Completed in 10 milliseconds

123