Home
last modified time | relevance | path

Searched refs:hashKey (Results 1 - 25 of 85) sorted by relevance

1234

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dmulti_ver_vacuum_executor.h34 std::vector<uint8_t> hashKey; member
53 virtual int GetShadowRecordsOfClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey,
57 virtual int GetShadowRecordsOfNonClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey,
70 virtual int DeleteRecordTotally(uint64_t version, const std::vector<uint8_t> &hashKey) = 0;
73 virtual int MarkRecordAsVacuumDone(uint64_t version, const std::vector<uint8_t> &hashKey) = 0;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Dmulti_ver_vacuum_executor_stub.cpp63 record.hashKey.push_back(i); in GetVacuumNeedRecordsByVersion()
70 const std::vector<uint8_t> &hashKey, std::list<MultiVerRecordInfo> &shadowRecords) in GetShadowRecordsOfClearTypeRecord()
77 const std::vector<uint8_t> &hashKey, std::list<MultiVerRecordInfo> &shadowRecords) in GetShadowRecordsOfNonClearTypeRecord()
84 record.hashKey = hashKey; in GetShadowRecordsOfNonClearTypeRecord()
111 int MultiVerVacuumExecutorStub::DeleteRecordTotally(uint64_t version, const std::vector<uint8_t> &hashKey) in DeleteRecordTotally() argument
117 int MultiVerVacuumExecutorStub::MarkRecordAsVacuumDone(uint64_t version, const std::vector<uint8_t> &hashKey) in MarkRecordAsVacuumDone() argument
69 GetShadowRecordsOfClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey, std::list<MultiVerRecordInfo> &shadowRecords) GetShadowRecordsOfClearTypeRecord() argument
76 GetShadowRecordsOfNonClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey, std::list<MultiVerRecordInfo> &shadowRecords) GetShadowRecordsOfNonClearTypeRecord() argument
H A Dmulti_ver_vacuum_executor_stub.h41 int GetShadowRecordsOfClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey,
43 int GetShadowRecordsOfNonClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey,
50 int DeleteRecordTotally(uint64_t version, const std::vector<uint8_t> &hashKey);
51 int MarkRecordAsVacuumDone(uint64_t version, const std::vector<uint8_t> &hashKey);
H A Ddistributeddb_relational_cloud_syncable_storage_test.cpp163 Bytes hashKey(index.begin(), index.end()); in InitLogData()
171 EXPECT_EQ(SQLiteUtils::BindBlobToStatement(stmt, 1, hashKey, false), E_OK); in InitLogData()
201 Bytes hashKey(id.begin(), id.end()); in UpdateLogGidAndHashKey()
202 EXPECT_EQ(SQLiteUtils::BindBlobToStatement(stmt, 1, hashKey, false), E_OK); in UpdateLogGidAndHashKey()
783 syncData.insData.hashKey.push_back({'3', '3'}); in HWTEST_F()
784 syncData.insData.hashKey.push_back({'3', '3'}); in HWTEST_F()
1098 Bytes hashKey; in HWTEST_F() local
1099 int errCode = SQLiteUtils::GetColumnBlobValue(stmt, 1, hashKey); // 1 is hash_key index in HWTEST_F()
1123 syncData.updData.hashKey.push_back(hashKey); in HWTEST_F()
1503 Bytes hashKey; HWTEST_F() local
1562 Bytes hashKey; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_vacuum_executor_impl.h38 int GetShadowRecordsOfClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey,
42 int GetShadowRecordsOfNonClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey,
55 int DeleteRecordTotally(uint64_t version, const std::vector<uint8_t> &hashKey) override;
58 int MarkRecordAsVacuumDone(uint64_t version, const std::vector<uint8_t> &hashKey) override;
H A Dmulti_ver_vacuum_executor_impl.cpp119 const std::vector<uint8_t> &hashKey, std::list<MultiVerRecordInfo> &shadowRecords) in GetShadowRecordsOfClearTypeRecord()
132 LOGE("[VacuumExec][GetShadowClear] GetOverwrittenClearTypeEntries:%zu fail, err=%d", hashKey.size(), errCode); in GetShadowRecordsOfClearTypeRecord()
147 const std::vector<uint8_t> &hashKey, std::list<MultiVerRecordInfo> &shadowRecords) in GetShadowRecordsOfNonClearTypeRecord()
158 int errCode = handle->GetOverwrittenNonClearTypeEntries(version, hashKey, nonClearShadowRecords); in GetShadowRecordsOfNonClearTypeRecord()
243 int MultiVerVacuumExecutorImpl::DeleteRecordTotally(uint64_t version, const std::vector<uint8_t> &hashKey) in DeleteRecordTotally() argument
253 int errCode = writeHandle_->DeleteEntriesByHashKey(version, hashKey); in DeleteRecordTotally()
261 int MultiVerVacuumExecutorImpl::MarkRecordAsVacuumDone(uint64_t version, const std::vector<uint8_t> &hashKey) in MarkRecordAsVacuumDone() argument
271 int errCode = writeHandle_->UpdateTrimedFlag(version, hashKey); in MarkRecordAsVacuumDone()
118 GetShadowRecordsOfClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey, std::list<MultiVerRecordInfo> &shadowRecords) GetShadowRecordsOfClearTypeRecord() argument
146 GetShadowRecordsOfNonClearTypeRecord(uint64_t version, const std::vector<uint8_t> &hashKey, std::list<MultiVerRecordInfo> &shadowRecords) GetShadowRecordsOfNonClearTypeRecord() argument
H A Dikvdb_multi_ver_transaction.h51 virtual int GetOverwrittenNonClearTypeEntries(Version version, const Key &hashKey,
53 virtual int DeleteEntriesByHashKey(Version version, const Key &hashKey) = 0;
54 virtual int GetValueForTrimSlice(const Key &hashKey, const Version vision, Value &value) const = 0;
H A Dmulti_ver_storage_executor.h102 int GetOverwrittenNonClearTypeEntries(Version version, const Key &hashKey,
105 // Delete the data whose hash key is equal to the hashKey and version is less than the specified.
106 int DeleteEntriesByHashKey(Version version, const Key &hashKey);
109 int UpdateTrimedFlag(Version version, const Key &hashKey);
H A Dmulti_ver_vacuum.cpp360 static_cast<uint32_t>(record.type), record.version, VEC_TO_STR(record.hashKey)); in DealWithLeftBranchVacuumNeedRecord()
363 errCode = inTask.databaseHandle->GetShadowRecordsOfClearTypeRecord(record.version, record.hashKey, in DealWithLeftBranchVacuumNeedRecord()
366 errCode = inTask.databaseHandle->GetShadowRecordsOfNonClearTypeRecord(record.version, record.hashKey, in DealWithLeftBranchVacuumNeedRecord()
371 static_cast<int>(record.type), ULL(record.version), VEC_TO_STR(record.hashKey), errCode); in DealWithLeftBranchVacuumNeedRecord()
391 errCode = inTask.databaseHandle->MarkRecordAsVacuumDone(record.version, record.hashKey); in DealWithLeftBranchVacuumNeedRecord()
394 static_cast<int>(record.type), ULL(record.version), VEC_TO_STR(record.hashKey), errCode); in DealWithLeftBranchVacuumNeedRecord()
481 ULL(record.version), VEC_TO_STR(record.hashKey)); in DoDeleteRecordOfLeftShadowOrRightVacuumNeed()
488 errCode = inTask.databaseHandle->DeleteRecordTotally(record.version, record.hashKey); in DoDeleteRecordOfLeftShadowOrRightVacuumNeed()
491 static_cast<unsigned>(record.type), ULL(record.version), VEC_TO_STR(record.hashKey), errCode); in DoDeleteRecordOfLeftShadowOrRightVacuumNeed()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_upload_recorder.cpp19 void CloudUploadRecorder::RecordUploadRecord(const std::string &table, const Bytes &hashKey, const CloudWaterType &type, in RecordUploadRecord() argument
23 uploadRecord_[currentUser_][table][type][hashKey] = modifyTime; in RecordUploadRecord()
26 bool CloudUploadRecorder::IsIgnoreUploadRecord(const std::string &table, const Bytes &hashKey, in IsIgnoreUploadRecord() argument
42 auto it = typeRecord->second.find(hashKey); in IsIgnoreUploadRecord()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dsingle_ver_natural_store_commit_notify_data.cpp68 Key hashKey; in InsertCommittedData() local
69 DBCommon::CalcValueHash(entry.key, hashKey); in InsertCommittedData()
71 if (!IsKeyPropSet(hashKey)) { in InsertCommittedData()
75 if (keyPropRecord_[hashKey].existStatus == ExistStatus::EXIST) { in InsertCommittedData()
90 DeleteEntryByKey(entry.key, keyPropRecord_[hashKey].latestType); in InsertCommittedData()
93 keyPropRecord_[hashKey].latestType = type; in InsertCommittedData()
112 Key hashKey; in InsertConflictedItem() local
113 DBCommon::CalcValueHash(itemInfo.dataItem.key, hashKey); in InsertConflictedItem()
114 if (!IsKeyPropSet(hashKey)) { in InsertConflictedItem()
119 if (keyPropRecord_[hashKey] in InsertConflictedItem()
[all...]
H A Dstorage_executor.h69 Key hashKey; member
82 Key hashKey; member
89 Key hashKey; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/
H A Dcloud_upload_recorder.h28 void RecordUploadRecord(const std::string &table, const Bytes &hashKey, const CloudWaterType &type,
30 bool IsIgnoreUploadRecord(const std::string &table, const Bytes &hashKey, const CloudWaterType &type,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_relational_ver_sync_db_interface.cpp42 storageItem.hashKey = item.hashKey; in GetEntriesFromItems()
87 entry->GetHashKey(item.hashKey); in PutSyncDataWithQuery()
109 syncData_[query.GetTableName()][GetStr(virtualRowData.logInfo.hashKey)] = virtualRowData; in PutSyncDataWithQuery()
119 localData_[tableName][GetStr(item.logInfo.hashKey)] = item; in PutLocalData()
134 for (const auto &[hashKey, virtualData] : localData_[query.GetTableName()]) { in GetSyncData()
137 LOGD("ignore hashkey %s", DBCommon::TransferStringToHex(hashKey).c_str()); in GetSyncData()
289 const std::string &hashKey, VirtualRowData &data) in GetVirtualSyncData()
294 if (syncData_.find(hashKey) == syncData_.end()) { in GetVirtualSyncData()
297 data = syncData_[tableName][hashKey]; in GetVirtualSyncData()
288 GetVirtualSyncData(const std::string &tableName, const std::string &hashKey, VirtualRowData &data) GetVirtualSyncData() argument
[all...]
H A Drelational_virtual_device.cpp38 const std::string &hashKey, VirtualRowData &data) in GetSyncData()
40 return static_cast<VirtualRelationalVerSyncDBInterface *>(storage_)->GetVirtualSyncData(tableName, hashKey, data); in GetSyncData()
37 GetSyncData(const std::string &tableName, const std::string &hashKey, VirtualRowData &data) GetSyncData() argument
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_executor.h41 int GetKvDataByHashKey(const Key &hashKey, SingleVerRecord &result) const;
65 // delete a row data by hashKey, with no tombstone left.
66 int EraseSyncData(const Key &hashKey);
230 int BindSavedSyncData(sqlite3_stmt *statement, const DataItem &dataItem, const Key &hashKey,
244 int GetSyncDataItemPre(const DataItem &itemPut, DataItem &itemGet, Key &hashKey) const;
248 int GetSyncDataPreByHashKey(const Key &hashKey, DataItem &itemGet) const;
273 int SaveSyncDataToDatabase(const DataItem &dataItem, const Key &hashKey, const std::string &origDev,
288 const DataItem &dataItem, const Key &hashKey, uint64_t recordVersion) const;
291 sqlite3_stmt *statement, const Key &hashKey, uint64_t recordVersion) const;
298 int SaveSyncDataToCacheDatabase(const DataItem &dataItem, const Key &hashKey, uint64_
[all...]
H A Dsqlite_single_ver_storage_executor_cache.cpp86 Key hashKey; in RemoveDeviceDataInCacheMode() local
87 int errCode = DBCommon::CalcValueHash(REMOVE_DEVICE_DATA_KEY, hashKey); in RemoveDeviceDataInCacheMode()
109 errCode = BindSyncDataInCacheMode(statement, dataItem, hashKey, recordVersion); in RemoveDeviceDataInCacheMode()
286 errCode = BindSavedSyncData(statement, dataItem, dataItem.hashKey, { dataItem.origDev, dataItem.dev }, isUpdate); in MigrateDataItem()
503 const DataItem &dataItem, const Key &hashKey, uint64_t recordVersion) const in BindSyncDataInCacheMode()
505 int errCode = BindPrimaryKeySyncDataInCacheMode(statement, hashKey, recordVersion); in BindSyncDataInCacheMode()
546 sqlite3_stmt *statement, const Key &hashKey, uint64_t recordVersion) const in BindPrimaryKeySyncDataInCacheMode()
548 int errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_CACHE_SYNC_HASH_KEY_INDEX, hashKey, false); in BindPrimaryKeySyncDataInCacheMode()
632 Key hashKey; in SaveSyncDataItemInCacheMode() local
635 hashKey in SaveSyncDataItemInCacheMode()
502 BindSyncDataInCacheMode(sqlite3_stmt *statement, const DataItem &dataItem, const Key &hashKey, uint64_t recordVersion) const BindSyncDataInCacheMode() argument
545 BindPrimaryKeySyncDataInCacheMode( sqlite3_stmt *statement, const Key &hashKey, uint64_t recordVersion) const BindPrimaryKeySyncDataInCacheMode() argument
666 SaveSyncDataToCacheDatabase(const DataItem &dataItem, const Key &hashKey, uint64_t recordVersion) const SaveSyncDataToCacheDatabase() argument
[all...]
H A Dsqlite_cloud_kv_executor_utils.cpp110 Bytes hashKey = std::get<Bytes>(extraLog[CloudDbConstant::HASH_KEY]); in GetCloudDataForSync() local
111 cloudDataResult.revisedData.push_back({hashKey, revisedTime, invalidTime}); in GetCloudDataForSync()
189 Bytes hashKey; in GetCloudExtraLog() local
190 (void)SQLiteUtils::GetColumnBlobValue(stmt, CLOUD_QUERY_HASH_KEY_INDEX, hashKey); in GetCloudExtraLog()
191 flags.insert_or_assign(CloudDbConstant::HASH_KEY, hashKey); in GetCloudExtraLog()
263 Bytes hashKey; in GetLogInfo() local
264 DBCommon::CalcValueHash(key, hashKey); in GetLogInfo()
266 std::tie(errCode, stmt) = GetLogInfoStmt(db, cloudData, !hashKey.empty(), userId.empty()); in GetLogInfo()
277 return GetLogInfoInner(stmt, isMemory, gid, hashKey, userId); in GetLogInfo()
371 (void)SQLiteUtils::GetColumnBlobValue(stmt, index++, dataInfoWithLog.logInfo.hashKey); in FillLogInfoWithStmt()
[all...]
H A Dsqlite_single_ver_storage_executor.cpp174 Key hashKey; in BindPutKvData() local
175 errCode = DBCommon::CalcValueHash(key, hashKey); in BindPutKvData()
180 errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_LOCAL_HASH_KEY_INDEX, hashKey, false); in BindPutKvData()
195 int SQLiteSingleVerStorageExecutor::GetKvDataByHashKey(const Key &hashKey, SingleVerRecord &result) const in GetKvDataByHashKey() argument
205 errCode = SQLiteUtils::BindBlobToStatement(statement, 1, hashKey, false); // bind the first arg hashkey. in GetKvDataByHashKey()
212 result.hashKey = hashKey; in GetKvDataByHashKey()
292 Key hashKey; in PutKvData() local
293 int innerErrCode = DBCommon::CalcValueHash(key, hashKey); in PutKvData()
297 committedData->InitKeyPropRecord(hashKey, existedStatu in PutKvData()
1201 SaveSyncDataToDatabase(const DataItem &dataItem, const Key &hashKey, const std::string &origDev, const std::string &deviceName, bool isUpdate) SaveSyncDataToDatabase() argument
1470 BindSavedSyncData(sqlite3_stmt *statement, const DataItem &dataItem, const Key &hashKey, const SyncDataDevices &devices, bool isUpdate) BindSavedSyncData() argument
1582 GetSyncDataPreByHashKey(const Key &hashKey, DataItem &itemGet) const GetSyncDataPreByHashKey() argument
1622 Key hashKey; DeleteLocalDataInner() local
1675 EraseSyncData(const Key &hashKey) EraseSyncData() argument
2218 Key hashKey; CalHashKey() local
[all...]
H A Dsqlite_multi_ver_transaction.h97 int GetOverwrittenNonClearTypeEntries(Version version, const Key &hashKey,
100 int DeleteEntriesByHashKey(Version version, const Key &hashKey) override;
102 int GetValueForTrimSlice(const Key &hashKey, const Version version, Value &value) const override;
160 int GetKeyAndValueByHashKey(sqlite3_stmt *statement, const Key &hashKey, Key &key, Value &value,
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/relational/
H A Drelational_store_client.h49 DB_API DistributedDB::DBStatus Lock(const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey,
52 DB_API DistributedDB::DBStatus UnLock(const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey,
/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/
H A Drelational_store_client.h48 const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db);
51 const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db);
H A Dmock.cpp92 const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db) in Lock()
98 const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db) in UnLock()
91 Lock(const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db) Lock() argument
97 UnLock( const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db) UnLock() argument
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dintercepted_data_impl.cpp132 Key hashKey; in ModifyKey() local
133 int errCode = DBCommon::CalcValueHash(newKey, hashKey); in ModifyKey()
139 entry->SetHashKey(hashKey); in ModifyKey()
/foundation/ability/idl_tool/idl_tool_2/hash/
H A Dhash.cpp88 bool Hash::GenFileHashKey(const std::string &path, size_t &hashKey) in GenFileHashKey() argument
99 hashKey = std::hash<std::string>()(buffer.str()); in GenFileHashKey()

Completed in 16 milliseconds

1234