Home
last modified time | relevance | path

Searched refs:itemGet (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_executor.cpp1129 entry.key = itemGet.key; in PutIntoCommittedData()
1130 entry.value = itemGet.value; in PutIntoCommittedData()
1236 if ((itemGet.flag & DataItem::DELETE_FLAG) != 0) { in JudgeSyncSaveType()
1242 if (itemGet.writeTimestamp >= dataItem.writeTimestamp) { in JudgeSyncSaveType()
1249 dataItem.writeTimestamp = itemGet.writeTimestamp + 1; in JudgeSyncSaveType()
1250 dataItem.timestamp = itemGet.timestamp; in JudgeSyncSaveType()
1527 origKey = itemGet.key; in PutConflictData()
1533 std::vector<uint8_t> getDevVect(itemGet.dev.begin(), itemGet.dev.end()); in PutConflictData()
1534 DataItemInfo orgItemInfo = {itemGet, true, getDevVect}; in PutConflictData()
1580 return GetSyncDataPreByHashKey(hashKey, itemGet); in GetSyncDataItemPre()
[all …]
H A Dsqlite_single_ver_storage_executor.h219 …void PutIntoCommittedData(const DataItem &itemPut, const DataItem &itemGet, const DataOperStatus &…
228 …static void PutConflictData(const DataItem &itemPut, const DataItem &itemGet, const DeviceInfo &de…
231 DataOperStatus JudgeSyncSaveType(DataItem &dataItem, const DataItem &itemGet,
236 int GetSyncDataItemPre(const DataItem &itemPut, DataItem &itemGet, Key &hashKey) const;
238 …int GetSyncDataItemExt(const DataItem &dataItem, DataItem &itemGet, const DataOperStatus &dataStat…
240 int GetSyncDataPreByHashKey(const Key &hashKey, DataItem &itemGet) const;
369 bool IsFromDataOwner(const DataItem &itemGet, const std::string &syncDev);
H A Dsqlite_single_ver_storage_executor_extend.cpp341 bool SQLiteSingleVerStorageExecutor::IsFromDataOwner(const DataItem &itemGet, const std::string &sy… in IsFromDataOwner() argument
343 return itemGet.dev == syncDev || in IsFromDataOwner()
344 (conflictResolvePolicy_ == DENY_OTHER_DEV_AMEND_CUR_DEV_DATA && itemGet.origDev == syncDev); in IsFromDataOwner()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dsingle_ver_natural_store_commit_notify_data.cpp199 const DataItem &itemGet) const in IsConflictedNotifyMatched()
207 if (itemPut.origDev != itemGet.origDev) { in IsConflictedNotifyMatched()
H A Dsingle_ver_natural_store_commit_notify_data.h73 bool IsConflictedNotifyMatched(const DataItem &itemPut, const DataItem &itemGet) const;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.cpp738 int RdSingleVerStorageExecutor::GetSyncDataPreByKey(const Key &key, DataItem &itemGet) const in GetSyncDataPreByKey()
744 itemGet.key = key; in GetSyncDataPreByKey()
745 itemGet.value = value; in GetSyncDataPreByKey()
H A Drd_single_ver_storage_executor.h206 int GetSyncDataPreByKey(const Key &key, DataItem &itemGet) const;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp953 DataItem &itemGet) in GetSyncDataPre() argument
957 itemGet.timestamp = logInfoGet.timestamp; in GetSyncDataPre()
971 DataItem itemGet; in CheckDataConflictDefeated() local
972 int errCode = GetSyncDataPre(dataItem, queryStmt, itemGet); in CheckDataConflictDefeated()
977 …isDefeated = (dataItem.timestamp <= itemGet.timestamp); // defeated if item timestamp is earlier t… in CheckDataConflictDefeated()
H A Dsqlite_single_ver_relational_storage_executor.h254 int GetSyncDataPre(const DataItem &dataItem, sqlite3_stmt *queryStmt, DataItem &itemGet);