/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | single_ver_natural_store_commit_notify_data.cpp | 22 SingleVerNaturalStoreCommitNotifyData::SingleVerNaturalStoreCommitNotifyData() : conflictedFlag_(0)… in SingleVerNaturalStoreCommitNotifyData() function in DistributedDB::SingleVerNaturalStoreCommitNotifyData 45 void SingleVerNaturalStoreCommitNotifyData::SetFilterKey(const Key &key) in SetFilterKey() 50 bool SingleVerNaturalStoreCommitNotifyData::IsChangedDataEmpty() const in IsChangedDataEmpty() 57 bool SingleVerNaturalStoreCommitNotifyData::IsConflictedDataEmpty() const in IsConflictedDataEmpty() 137 const std::list<Entry> SingleVerNaturalStoreCommitNotifyData::FilterEntriesByKey( in FilterEntriesByKey() 188 void SingleVerNaturalStoreCommitNotifyData::SetConflictedNotifiedFlag(int conflictedFlag) in SetConflictedNotifiedFlag() 193 int SingleVerNaturalStoreCommitNotifyData::GetConflictedNotifiedFlag() const in GetConflictedNotifiedFlag() 237 SingleVerNaturalStoreCommitNotifyData::SINGLE_VER_CONFLICT_FOREIGN_KEY_ORIG : in PutIntoConflictData() 258 void SingleVerNaturalStoreCommitNotifyData::DeleteConflictEntry(const Key &key) in DeleteConflictEntry() 272 bool SingleVerNaturalStoreCommitNotifyData::IsKeyPropSet(const Key &key) const in IsKeyPropSet() [all …]
|
H A D | single_ver_natural_store_commit_notify_data.h | 43 class SingleVerNaturalStoreCommitNotifyData final : public KvDBCommitNotifyFilterAbleData { 45 SingleVerNaturalStoreCommitNotifyData(); 46 ~SingleVerNaturalStoreCommitNotifyData() {} in ~SingleVerNaturalStoreCommitNotifyData() 47 DISABLE_COPY_ASSIGN_MOVE(SingleVerNaturalStoreCommitNotifyData); 97 DECLARE_OBJECT_TAG(SingleVerNaturalStoreCommitNotifyData);
|
H A D | storage_executor.h | 84 SingleVerNaturalStoreCommitNotifyData *committedData = nullptr; 94 SingleVerNaturalStoreCommitNotifyData *committedData = nullptr;
|
H A D | single_ver_natural_store.h | 40 void CommitAndReleaseNotifyData(SingleVerNaturalStoreCommitNotifyData *&committedData,
|
H A D | single_ver_utils.h | 70 void InitCommitNotifyDataKeyStatus(SingleVerNaturalStoreCommitNotifyData *committedData, const Key …
|
H A D | single_ver_natural_store.cpp | 103 void SingleVerNaturalStore::CommitAndReleaseNotifyData(SingleVerNaturalStoreCommitNotifyData *&comm… in CommitAndReleaseNotifyData()
|
H A D | single_ver_utils.cpp | 143 void InitCommitNotifyDataKeyStatus(SingleVerNaturalStoreCommitNotifyData *committedData, const Key … in InitCommitNotifyDataKeyStatus()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_single_ver_natural_store_connection.h | 151 void CommitAndReleaseNotifyData(SingleVerNaturalStoreCommitNotifyData *&committedData, 166 int PublishInner(SingleVerNaturalStoreCommitNotifyData *committedData, bool updateTimestamp, 171 …int UnpublishInner(std::pair<Key, Key> &keyPair, SingleVerNaturalStoreCommitNotifyData *&committed… 174 …int UnpublishOper(SingleVerNaturalStoreCommitNotifyData *&committedData, const SingleVerRecord &sy… 177 void ReleaseCommitData(SingleVerNaturalStoreCommitNotifyData *&committedData); 235 SingleVerNaturalStoreCommitNotifyData *committedData_; // used for transaction 236 SingleVerNaturalStoreCommitNotifyData *localCommittedData_;
|
H A D | sqlite_single_ver_storage_executor.h | 44 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData); 59 …Timestamp &maxStamp, SingleVerNaturalStoreCommitNotifyData *committedData, bool isPermitForceWrite… 61 …virtual int DeleteLocalKvData(const Key &key, SingleVerNaturalStoreCommitNotifyData *committedData… 196 virtual int DeleteLocalDataInner(SingleVerNaturalStoreCommitNotifyData *committedData, 220 SingleVerNaturalStoreCommitNotifyData *committedData); 229 const DataOperStatus &dataStatus, SingleVerNaturalStoreCommitNotifyData *commitData);
|
H A D | sqlite_single_ver_storage_engine.h | 117 …void CommitAndReleaseNotifyData(SingleVerNaturalStoreCommitNotifyData *&committedData, int eventTy… 118 void InitConflictNotifiedFlag(SingleVerNaturalStoreCommitNotifyData *&committedData) const;
|
H A D | sqlite_single_ver_natural_store_connection.cpp | 1200 SingleVerNaturalStoreCommitNotifyData *&committedData, bool isNeedCommit, int eventType) in CommitAndReleaseNotifyData() 1272 committedData_ = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData; in StartTransactionNormally() 1280 localCommittedData_ = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData; in StartTransactionNormally() 1426 SingleVerNaturalStoreCommitNotifyData *localCommittedData = nullptr; in PublishLocal() 1428 localCommittedData = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData; in PublishLocal() 1471 int SQLiteSingleVerNaturalStoreConnection::PublishInner(SingleVerNaturalStoreCommitNotifyData *comm… in PublishInner() 1551 SingleVerNaturalStoreCommitNotifyData *localCommittedData = nullptr; in UnpublishToLocal() 1579 …SingleVerNaturalStoreCommitNotifyData *&committedData, SingleVerRecord &syncRecord, bool updateTim… in UnpublishInner() 1621 int SQLiteSingleVerNaturalStoreConnection::UnpublishOper(SingleVerNaturalStoreCommitNotifyData *&co… in UnpublishOper() 1624 committedData = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData; in UnpublishOper() [all …]
|
H A D | sqlite_single_ver_natural_store.h | 272 void InitConflictNotifiedFlag(SingleVerNaturalStoreCommitNotifyData *committedData); 286 Timestamp &maxTimestamp, SingleVerNaturalStoreCommitNotifyData *commitData) const;
|
H A D | sqlite_single_ver_storage_engine.cpp | 142 syncData.committedData = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData(); in MigrateSyncDataByVersion() 999 void SQLiteSingleVerStorageEngine::CommitAndReleaseNotifyData(SingleVerNaturalStoreCommitNotifyData… in CommitAndReleaseNotifyData() 1013 void SQLiteSingleVerStorageEngine::InitConflictNotifiedFlag(SingleVerNaturalStoreCommitNotifyData *… in InitConflictNotifiedFlag() 1074 committedData = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData(); in CommitNotifyForMigrateCache()
|
H A D | sqlite_single_ver_natural_store.cpp | 1028 SingleVerNaturalStoreCommitNotifyData *notifyData = nullptr; in NotifyRemovedData() 1031 notifyData = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData; in NotifyRemovedData() 1168 void SQLiteSingleVerNaturalStore::InitConflictNotifiedFlag(SingleVerNaturalStoreCommitNotifyData *c… in InitConflictNotifiedFlag() 1224 auto *committedData = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData; in SaveSyncDataToMain() 1245 …const DeviceInfo &deviceInfo, Timestamp &maxTimestamp, SingleVerNaturalStoreCommitNotifyData *comm… in SaveSyncItems() 1365 auto commitData = static_cast<SingleVerNaturalStoreCommitNotifyData *>(committedData); in InitStorageEngine()
|
H A D | sqlite_single_ver_storage_executor.cpp | 280 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData) in PutKvData() 1115 const DataOperStatus &status, SingleVerNaturalStoreCommitNotifyData *committedData) in PutIntoCommittedData() 1355 …Timestamp &maxStamp, SingleVerNaturalStoreCommitNotifyData *committedData, bool isPermitForceWrite) in SaveSyncDataItem() 1508 SingleVerNaturalStoreCommitNotifyData *commitData) in PutConflictData() 1619 int SQLiteSingleVerStorageExecutor::DeleteLocalDataInner(SingleVerNaturalStoreCommitNotifyData *com… in DeleteLocalDataInner() 1666 SingleVerNaturalStoreCommitNotifyData *committedData, Value &value, Timestamp ×tamp) in DeleteLocalKvData()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
H A D | rd_single_ver_storage_executor.h | 62 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData); 77 SingleVerNaturalStoreCommitNotifyData *committedData); 79 …int SaveSyncDataItem(const Entry &entry, SingleVerNaturalStoreCommitNotifyData *committedData, boo… 82 …SingleVerNaturalStoreCommitNotifyData *committedData, std::vector<NotifyConflictAndObserverData> &… 85 …int DeleteLocalKvData(const Key &key, SingleVerNaturalStoreCommitNotifyData *committedData, Value … 201 …int DeleteLocalDataInner(SingleVerNaturalStoreCommitNotifyData *committedData, const Key &key, con…
|
H A D | rd_single_ver_natural_store_connection.h | 143 void ReleaseCommitData(SingleVerNaturalStoreCommitNotifyData *&committedData); 153 void CommitAndReleaseNotifyData(SingleVerNaturalStoreCommitNotifyData *&committedData, 169 SingleVerNaturalStoreCommitNotifyData *committedData_; // used for transaction
|
H A D | rd_single_ver_storage_executor.cpp | 254 …SingleVerNaturalStoreCommitNotifyData *committedData, std::vector<NotifyConflictAndObserverData> &… in PrepareNotifyForEntries() 393 SingleVerNaturalStoreCommitNotifyData *committedData) in BatchSaveEntries() 443 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData) in PutKvData() 460 SingleVerNaturalStoreCommitNotifyData *committedData, bool isDelete) in SaveSyncDataItem()
|
H A D | rd_single_ver_natural_store_connection.cpp | 251 SingleVerNaturalStoreCommitNotifyData *&committedData, bool isNeedCommit, int eventType) in CommitAndReleaseNotifyData() 640 void RdSingleVerNaturalStoreConnection::ReleaseCommitData(SingleVerNaturalStoreCommitNotifyData *&c… in ReleaseCommitData() 673 committedData_ = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData; in StartTransactionNormally()
|
H A D | rd_single_ver_natural_store.cpp | 439 auto commitData = static_cast<SingleVerNaturalStoreCommitNotifyData *>(committedData); in InitDatabaseContext()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_sqlite_single_ver_natural_executor_test.cpp | 511 SingleVerNaturalStoreCommitNotifyData data;
|