Home
last modified time | relevance | path

Searched refs:bucket (Results 1 – 25 of 102) sorted by relevance

12345

/ohos5.0/foundation/distributeddatamgr/relational_store/interfaces/ndk/src/
H A Drelational_values_bucket.cpp58 int RelationalValuesBucket::PutNull(OH_VBucket *bucket, const char *field) in PutNull() argument
60 return PutValueObject(bucket, field, OHOS::NativeRdb::ValueObject()); in PutNull()
63 int RelationalValuesBucket::Clear(OH_VBucket *bucket) in Clear() argument
65 auto self = GetSelf(bucket); in Clear()
74 int RelationalValuesBucket::Destroy(OH_VBucket *bucket) in Destroy() argument
76 auto self = GetSelf(bucket); in Destroy()
105 if (bucket == nullptr || bucket->id != OHOS::RdbNdk::RDB_VBUCKET_CID) { in GetSelf()
109 return static_cast<OHOS::RdbNdk::RelationalValuesBucket *>(bucket); in GetSelf()
114 auto self = GetSelf(bucket); in PutValueObject()
129 auto self = RelationalValuesBucket::GetSelf(bucket); in OH_VBucket_PutAsset()
[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 &&va…
/ohos5.0/base/telephony/call_manager/services/call/call_state_observer/src/
H A Dcall_records_handler.cpp75 DataShare::DataShareValuesBucket bucket; in AddCallLogInfo() local
78 bool ret = callDataPtr_->Insert(bucket); in AddCallLogInfo()
105 bucket.Put(CALL_DISPLAY_NAME, displayName); in MakeCallLogInsertBucket()
108 bucket.Put(CALL_SIM_TYPE, 0); in MakeCallLogInsertBucket()
110 bucket.Put(CALL_IS_READ, 0); in MakeCallLogInsertBucket()
115 bucket.Put(CALL_NUMBER_TYPE, 0); in MakeCallLogInsertBucket()
118 bucket.Put(CALL_END_TIME, info.callEndTime); in MakeCallLogInsertBucket()
122 bucket.Put(CALL_PHOTO_ID, 0); in MakeCallLogInsertBucket()
123 bucket.Put(CALL_SLOT_ID, info.slotId); in MakeCallLogInsertBucket()
124 bucket.Put(CALL_FEATURES, info.features); in MakeCallLogInsertBucket()
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_bigint_test.cpp89 ValuesBucket bucket; variable
123 ValuesBucket bucket; variable
159 ValuesBucket bucket; variable
160 bucket.Put("value1", value1);
161 bucket.Put("value2", value2);
195 ValuesBucket bucket; variable
231 ValuesBucket bucket; variable
273 ValuesBucket bucket; variable
315 ValuesBucket bucket; variable
358 ValuesBucket bucket; variable
[all …]
/ohos5.0/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.h39 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);
/ohos5.0/foundation/distributeddatamgr/relational_store/interfaces/ndk/include/
H A Doh_values_bucket.h72 int (*putText)(OH_VBucket *bucket, const char *field, const char *value);
84 int (*putInt64)(OH_VBucket *bucket, const char *field, int64_t value);
96 int (*putReal)(OH_VBucket *bucket, const char *field, double value);
109 int (*putBlob)(OH_VBucket *bucket, const char *field, const uint8_t *value, uint32_t size);
120 int (*putNull)(OH_VBucket *bucket, const char *field);
130 int (*clear)(OH_VBucket *bucket);
140 int (*destroy)(OH_VBucket *bucket);
155 int OH_VBucket_PutAsset(OH_VBucket *bucket, const char *field, Data_Asset *value);
170 int OH_VBucket_PutAssets(OH_VBucket *bucket, const char *field, Data_Asset **value, uint32_t count);
/ohos5.0/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/
H A Dapp_event_dao.cpp81 NativeRdb::ValuesBucket bucket; in Insert() local
82 bucket.PutString(Events::FIELD_DOMAIN, event->GetDomain()); in Insert()
83 bucket.PutString(Events::FIELD_NAME, event->GetName()); in Insert()
84 bucket.PutInt(Events::FIELD_TYPE, event->GetType()); in Insert()
85 bucket.PutLong(Events::FIELD_TIME, event->GetTime()); in Insert()
86 bucket.PutString(Events::FIELD_TZ, event->GetTimeZone()); in Insert()
87 bucket.PutInt(Events::FIELD_PID, event->GetPid()); in Insert()
88 bucket.PutInt(Events::FIELD_TID, event->GetTid()); in Insert()
89 bucket.PutLong(Events::FIELD_TRACE_ID, event->GetTraceId()); in Insert()
90 bucket.PutLong(Events::FIELD_SPAN_ID, event->GetSpanId()); in Insert()
[all …]
H A Dcustom_event_param_dao.cpp77 NativeRdb::ValuesBucket bucket; in Insert() local
78 bucket.PutString(FIELD_RUNNING_ID, runningId); in Insert()
79 bucket.PutString(FIELD_DOMAIN, domain); in Insert()
80 bucket.PutString(FIELD_NAME, name); in Insert()
81 bucket.PutString(FIELD_PARAM_KEY, param.key); in Insert()
82 bucket.PutString(FIELD_PARAM_VALUE, param.value); in Insert()
83 bucket.PutInt(FIELD_PARAM_TYPE, param.type); in Insert()
85 if (dbStore_->Insert(seq, TABLE, bucket) != NativeRdb::E_OK) { in Insert()
98 NativeRdb::ValuesBucket bucket; in Update() local
99 bucket.PutString(FIELD_PARAM_VALUE, param.value); in Update()
[all …]
H A Duser_id_dao.cpp70 NativeRdb::ValuesBucket bucket; in Insert() local
71 bucket.PutString(FIELD_NAME, name); in Insert()
72 bucket.PutString(FIELD_VALUE, value); in Insert()
74 if (dbStore_->Insert(seq, TABLE, bucket) != NativeRdb::E_OK) { in Insert()
87 NativeRdb::ValuesBucket bucket; in Update() local
88 bucket.PutString(FIELD_NAME, name); in Update()
89 bucket.PutString(FIELD_VALUE, value); in Update()
94 if (dbStore_->Update(changedRows, bucket, predicates) != NativeRdb::E_OK) { in Update()
H A Duser_property_dao.cpp70 NativeRdb::ValuesBucket bucket; in Insert() local
71 bucket.PutString(FIELD_NAME, name); in Insert()
72 bucket.PutString(FIELD_VALUE, value); in Insert()
74 if (dbStore_->Insert(seq, TABLE, bucket) != NativeRdb::E_OK) { in Insert()
87 NativeRdb::ValuesBucket bucket; in Update() local
88 bucket.PutString(FIELD_NAME, name); in Update()
89 bucket.PutString(FIELD_VALUE, value); in Update()
94 if (dbStore_->Update(changedRows, bucket, predicates) != NativeRdb::E_OK) { in Update()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/
H A Dkv_utils_test.cpp534 bucket.Put(KEY, {});
535 bucket.Put(VALUE, {});
556 bucket.Put(KEY, varKey);
579 bucket.Put(KEY, varKey);
602 bucket.Put(KEY, varKey);
625 bucket.Put(KEY, varKey);
649 bucket.Put(KEY, varKey);
673 bucket.Put(KEY, varKey);
711 bucket.Put(KEY, varKey);
716 bucket.Clear();
[all …]
/ohos5.0/base/hiviewdfx/hiview/framework/native/unified_collection/collector/utils/
H A Dapp_event_task_storage.cpp172 NativeRdb::ValuesBucket bucket; in InsertAppEventTask() local
173 bucket.PutLong(COLUMN_TASK_DATE, appEventTask.taskDate_); in InsertAppEventTask()
174 bucket.PutInt(COLUMN_TASK_TYPE, appEventTask.taskType_); in InsertAppEventTask()
175 bucket.PutInt(COLUMN_UID, appEventTask.uid_); in InsertAppEventTask()
176 bucket.PutInt(COLUMN_PID, appEventTask.pid_); in InsertAppEventTask()
177 bucket.PutString(COLUMN_BUNDLE_NAME, appEventTask.bundleName_); in InsertAppEventTask()
179 bucket.PutLong(COLUMN_START_TIME, appEventTask.startTime_); in InsertAppEventTask()
180 bucket.PutLong(COLUMN_FINISH_TIME, appEventTask.finishTime_); in InsertAppEventTask()
182 bucket.PutInt(COLUMN_RESOURCE_SIZE, appEventTask.resourceSize_); in InsertAppEventTask()
183 bucket.PutDouble(COLUMN_COST_CPU, appEventTask.costCpu_); in InsertAppEventTask()
[all …]
H A Dtrace_storage.cpp42 NativeRdb::ValuesBucket bucket; in GetBucket() local
43 bucket.PutString(COLUMN_SYSTEM_TIME, traceFlowRecord.systemTime); in GetBucket()
44 bucket.PutString(COLUMN_CALLER_NAME, traceFlowRecord.callerName); in GetBucket()
45 bucket.PutLong(COLUMN_USED_SIZE, traceFlowRecord.usedSize); in GetBucket()
46 return bucket; in GetBucket()
142 NativeRdb::ValuesBucket bucket = GetBucket(traceFlowRecord); in UpdateTable() local
146 if (dbStore_->Update(changeRows, bucket, predicates) != NativeRdb::E_OK) { in UpdateTable()
153 NativeRdb::ValuesBucket bucket = GetBucket(traceFlowRecord); in InsertTable() local
155 if (dbStore_->Insert(seq, TABLE_NAME, bucket) != NativeRdb::E_OK) { in InsertTable()
/ohos5.0/base/hiviewdfx/hiview/plugins/unified_collector/storage/
H A Dcpu_storage.cpp138 NativeRdb::ValuesBucket bucket; in StoreSysVersion() local
139 bucket.PutString(COLUMN_VERSION_NAME, version); in StoreSysVersion()
319 NativeRdb::ValuesBucket bucket; in StoreProcessData() local
321 bucket.PutLong(COLUMN_END_TIME, static_cast<int64_t>(cpuCollectionInfo.endTime)); in StoreProcessData()
322 bucket.PutInt(COLUMN_PID, cpuCollectionInfo.pid); in StoreProcessData()
324 bucket.PutString(COLUMN_PROC_NAME, cpuCollectionInfo.procName); in StoreProcessData()
327 bucket.PutInt(COLUMN_THREAD_CNT, cpuCollectionInfo.threadCount); in StoreProcessData()
337 NativeRdb::ValuesBucket bucket; in StoreThreadData() local
339 bucket.PutLong(COLUMN_END_TIME, static_cast<int64_t>(cpuCollection.endTime)); in StoreThreadData()
340 bucket.PutInt(COLUMN_TID, cpuCollection.tid); in StoreThreadData()
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/
H A DRdbStoreValueType.test.js66 let bucket = { class in AnonymousFunction425b04840100.AnonymousFunction425b04840600
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 = { class in AnonymousFunction425b04840100.AnonymousFunction425b04840700
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["value2"]);
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/common/
H A Dvalue_proxy.h167 Bucket(Bucket &&bucket) noexcept in Bucket() argument
169 *this = std::move(bucket); in Bucket()
171 Bucket &operator=(Bucket &&bucket) noexcept;
175 std::map<std::string, T> bucket; in map() local
180 return bucket; in map()
202 for (auto &bucket : value_) { in vector()
203 buckets.emplace_back(std::move(bucket)); in vector()
223 static Bucket Convert(NativeRdb::ValuesBucket &&bucket);
225 static Bucket Convert(DistributedDB::VBucket &&bucket);
238 Bucket bucket; variable
[all …]
H A Dvalue_proxy.cpp91 for (auto &[key, value] : bucket) { in Convert()
109 for (auto &[key, value] : bucket) { in Convert()
128 for (auto &bucket : buckets) { in Convert() local
138 for (auto &bucket : buckets) { in Convert() local
148 for (auto &bucket : buckets) { in Convert() local
158 for (auto &bucket : buckets) { in Convert() local
498 if (this == &bucket) { in operator =()
507 NativeRdb::ValuesBucket bucket; variable
512 return bucket;
517 CommonType::ValuesBucket bucket; variable
[all …]
/ohos5.0/base/hiviewdfx/hiview/plugins/usage_event_report/cache/
H A Devent_db_helper.cpp228 NativeRdb::ValuesBucket bucket; in InsertPluginStatsTable() local
229 bucket.PutString(DB_COLUMIN_PLUGIN, pluginName); in InsertPluginStatsTable()
230 bucket.PutString(DB_COLUMIN_EVNET, eventStr); in InsertPluginStatsTable()
232 if (rdbStore_->Insert(seq, DB_TABLE_PLUGIN_STATS, bucket) != NativeRdb::E_OK) { in InsertPluginStatsTable()
247 NativeRdb::ValuesBucket bucket; in InsertSysUsageTable() local
248 bucket.PutString(DB_COLUMIN_EVNET, eventStr); in InsertSysUsageTable()
250 if (rdbStore_->Insert(seq, table, bucket) != NativeRdb::E_OK) { in InsertSysUsageTable()
260 NativeRdb::ValuesBucket bucket; in UpdatePluginStatsTable() local
261 bucket.PutString(DB_COLUMIN_EVNET, eventStr); in UpdatePluginStatsTable()
275 NativeRdb::ValuesBucket bucket; in UpdateSysUsageTable() local
[all …]
/ohos5.0/base/hiviewdfx/hiview/plugins/sysevent_source/control/db/
H A Ddaily_db_helper.cpp124 NativeRdb::ValuesBucket bucket; in InsertEventInfo() local
125 bucket.PutString(EVENTS_COLUMIN_DOMAIN, info.domain); in InsertEventInfo()
126 bucket.PutString(EVENTS_COLUMIN_NAME, info.name); in InsertEventInfo()
127 bucket.PutInt(EVENTS_COLUMIN_COUNT, info.count); in InsertEventInfo()
128 bucket.PutLong(EVENTS_COLUMIN_EXCEED_TIME, info.exceedTime); in InsertEventInfo()
130 if (auto ret = dbStore_->Insert(seq, EVENTS_TABLE, bucket); ret != NativeRdb::E_OK) { in InsertEventInfo()
146 NativeRdb::ValuesBucket bucket; in UpdateEventInfo() local
147 bucket.PutInt(EVENTS_COLUMIN_COUNT, info.count); in UpdateEventInfo()
149 bucket.PutLong(EVENTS_COLUMIN_EXCEED_TIME, info.exceedTime); in UpdateEventInfo()
155 if (dbStore_->Update(changeRows, bucket, predicates) != NativeRdb::E_OK || changeRows == 0) { in UpdateEventInfo()
/ohos5.0/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()
119 auto& bucket = drawableBucket_.back(); in DrawableDestructorInner() local
120 if (bucket.size() < BUCKET_MAX_SIZE) { in DrawableDestructorInner()
121 bucket.push_back(ptr); in DrawableDestructorInner()
188 auto& bucket = offTreeBucket_.back(); in AddToOffTreeNodeBucket() local
189 if (bucket.size() < OFF_TREE_BUCKET_MAX_SIZE) { in AddToOffTreeNodeBucket()
190 bucket.emplace_back(node); in AddToOffTreeNodeBucket()
/ohos5.0/base/security/access_token/services/accesstokenmanager/main/cpp/src/database/
H A Daccess_token_db_util.cpp56 …id AccessTokenDbUtil::ToRdbValueBucket(const GenericValues& value, NativeRdb::ValuesBucket& bucket) in ToRdbValueBucket() argument
65 bucket.PutString(column, value.GetString(column)); in ToRdbValueBucket()
67 bucket.PutInt(column, value.GetInt(column)); in ToRdbValueBucket()
76 NativeRdb::ValuesBucket bucket; in ToRdbValueBuckets() local
78 ToRdbValueBucket(value, bucket); in ToRdbValueBuckets()
79 if (bucket.IsEmpty()) { in ToRdbValueBuckets()
82 buckets.emplace_back(bucket); in ToRdbValueBuckets()
/ohos5.0/base/hiviewdfx/hiview/base/event_store/store/
H A Dsys_event_repeat_db.cpp140 NativeRdb::ValuesBucket bucket; in Insert() local
141 bucket.PutString(COLUMN_DOMAIN, sysEventHashRecord.domain); in Insert()
142 bucket.PutString(COLUMN_NAME, sysEventHashRecord.name); in Insert()
143 bucket.PutString(COLUMN_EVENT_HASH, sysEventHashRecord.eventHash); in Insert()
144 bucket.PutLong(COLUMN_HAPPENTIME, sysEventHashRecord.happentime); in Insert()
146 int ret = dbStore_->Insert(seq, TABLE_NAME, bucket); in Insert()
164 NativeRdb::ValuesBucket bucket; in Update() local
165 bucket.PutLong(COLUMN_HAPPENTIME, sysEventHashRecord.happentime); in Update()
167 if (dbStore_->Update(updateRowNum, bucket, predicates) != NativeRdb::E_OK) { in Update()
/ohos5.0/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()
/ohos5.0/base/hiviewdfx/hiview/plugins/event_store/event_export/database/adapter/
H A Dexport_db_storage.cpp91 NativeRdb::ValuesBucket bucket; in InsertExportDetailRecord() local
92 bucket.PutString(COLUMN_MODULE_NAME, record.moduleName); in InsertExportDetailRecord()
93 bucket.PutLong(COLUMN_EXPORT_ENABLED_SEQ, record.exportEnabledSeq); in InsertExportDetailRecord()
94 bucket.PutLong(COLUMN_EXPORTED_MAX_SEQ, record.exportedMaxSeq); in InsertExportDetailRecord()
96 if (dbStore_->Insert(id, MODULE_EXPORT_DETAILS_TABLE_NAME, bucket) != NativeRdb::E_OK) { in InsertExportDetailRecord()
171 NativeRdb::ValuesBucket bucket; in UpdateExportDetailRecordSeq() local
172 bucket.PutLong(seqName, seqValue); in UpdateExportDetailRecordSeq()
176 if (dbStore_->Update(changeRow, MODULE_EXPORT_DETAILS_TABLE_NAME, bucket, in UpdateExportDetailRecordSeq()

12345