| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | single_ver_natural_store.cpp | 103 …eVerNaturalStore::CommitAndReleaseNotifyData(SingleVerNaturalStoreCommitNotifyData *&committedData, in CommitAndReleaseNotifyData() argument
107 if (committedData != nullptr) { in CommitAndReleaseNotifyData()
108 if (!committedData->IsChangedDataEmpty()) { in CommitAndReleaseNotifyData()
109 CommitNotify(eventType, committedData); in CommitAndReleaseNotifyData()
111 if (!committedData->IsConflictedDataEmpty()) { in CommitAndReleaseNotifyData()
113 committedData); in CommitAndReleaseNotifyData()
118 if (committedData != nullptr) { in CommitAndReleaseNotifyData()
119 committedData->DecObjRef(committedData); in CommitAndReleaseNotifyData()
120 committedData = nullptr; in CommitAndReleaseNotifyData()
|
| H A D | storage_executor.h | 84 SingleVerNaturalStoreCommitNotifyData *committedData = nullptr; member
94 SingleVerNaturalStoreCommitNotifyData *committedData = nullptr; member
|
| H A D | single_ver_utils.cpp | 143 void InitCommitNotifyDataKeyStatus(SingleVerNaturalStoreCommitNotifyData *committedData, const Key … in InitCommitNotifyDataKeyStatus() argument
146 if (committedData == nullptr) { in InitCommitNotifyDataKeyStatus()
157 committedData->InitKeyPropRecord(hashKey, existedStatus); in InitCommitNotifyDataKeyStatus()
|
| 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 …
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_engine.cpp | 141 if (syncData.committedData == nullptr) { in MigrateSyncDataByVersion()
143 if (syncData.committedData == nullptr) { in MigrateSyncDataByVersion()
148 InitConflictNotifiedFlag(syncData.committedData); in MigrateSyncDataByVersion()
281 if (syncData.committedData != nullptr) { in MigrateSyncData()
283 syncData.committedData = nullptr; in MigrateSyncData()
1005 RefObject::DecObjRef(committedData); in CommitAndReleaseNotifyData()
1006 committedData = nullptr; in CommitAndReleaseNotifyData()
1010 committedData = nullptr; in CommitAndReleaseNotifyData()
1015 if (committedData == nullptr) { in InitConflictNotifiedFlag()
1052 auto &committedData = syncData.committedData; in CommitNotifyForMigrateCache() local
[all …]
|
| H A D | sqlite_single_ver_natural_store_connection.cpp | 1203 if ((naturalStore != nullptr) && (committedData != nullptr)) { in CommitAndReleaseNotifyData()
1205 if (!committedData->IsChangedDataEmpty()) { in CommitAndReleaseNotifyData()
1208 if (!committedData->IsConflictedDataEmpty()) { in CommitAndReleaseNotifyData()
1211 committedData); in CommitAndReleaseNotifyData()
1215 ReleaseCommitData(committedData); in CommitAndReleaseNotifyData()
1480 if (committedData != nullptr) { in PublishInner()
1625 if (committedData == nullptr) { in UnpublishOper()
1643 committedData); in UnpublishOper()
1655 if (committedData != nullptr) { in ReleaseCommitData()
1656 committedData->DecObjRef(committedData); in ReleaseCommitData()
[all …]
|
| H A D | sqlite_single_ver_natural_store_connection.h | 151 void CommitAndReleaseNotifyData(SingleVerNaturalStoreCommitNotifyData *&committedData,
166 int PublishInner(SingleVerNaturalStoreCommitNotifyData *committedData, bool updateTimestamp,
171 …UnpublishInner(std::pair<Key, Key> &keyPair, SingleVerNaturalStoreCommitNotifyData *&committedData,
174 …int UnpublishOper(SingleVerNaturalStoreCommitNotifyData *&committedData, const SingleVerRecord &sy…
177 void ReleaseCommitData(SingleVerNaturalStoreCommitNotifyData *&committedData);
|
| H A D | sqlite_single_ver_storage_executor.cpp | 280 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData) in PutKvData() argument
290 if (isLocal && committedData != nullptr) { in PutKvData()
297 committedData->InitKeyPropRecord(hashKey, existedStatus); in PutKvData()
304 if (isLocal && committedData != nullptr) { in PutKvData()
1115 const DataOperStatus &status, SingleVerNaturalStoreCommitNotifyData *committedData) in PutIntoCommittedData() argument
1117 if (committedData == nullptr) { in PutIntoCommittedData()
1358 .committedData = committedData in SaveSyncDataItem()
1622 if (committedData != nullptr) { in DeleteLocalDataInner()
1628 committedData->InitKeyPropRecord(hashKey, ExistStatus::EXIST); in DeleteLocalDataInner()
1650 if (committedData != nullptr) { in DeleteLocalDataInner()
[all …]
|
| H A D | sqlite_single_ver_storage_executor.h | 44 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData);
59 …Timestamp &maxStamp, SingleVerNaturalStoreCommitNotifyData *committedData, bool isPermitForceWrite…
61 …leteLocalKvData(const Key &key, SingleVerNaturalStoreCommitNotifyData *committedData, Value &value,
196 virtual int DeleteLocalDataInner(SingleVerNaturalStoreCommitNotifyData *committedData,
220 SingleVerNaturalStoreCommitNotifyData *committedData);
|
| 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.cpp | 1168 …ngleVerNaturalStore::InitConflictNotifiedFlag(SingleVerNaturalStoreCommitNotifyData *committedData) in InitConflictNotifiedFlag() argument
1180 committedData->SetConflictedNotifiedFlag(static_cast<int>(conflictFlag)); in InitConflictNotifiedFlag()
1224 auto *committedData = new (std::nothrow) SingleVerNaturalStoreCommitNotifyData; in SaveSyncDataToMain() local
1225 if (committedData == nullptr) { in SaveSyncDataToMain()
1229 InitConflictNotifiedFlag(committedData); in SaveSyncDataToMain()
1232 int errCode = SaveSyncItems(query, dataItems, deviceInfo, maxTimestamp, committedData); in SaveSyncDataToMain()
1237 CommitAndReleaseNotifyData(committedData, isNeedCommit, in SaveSyncDataToMain()
1360 [&](int eventType, KvDBCommitNotifyFilterAbleData *committedData) { in InitStorageEngine() argument
1365 auto commitData = static_cast<SingleVerNaturalStoreCommitNotifyData *>(committedData); in InitStorageEngine()
|
| H A D | sqlite_single_ver_storage_executor_cache.cpp | 261 notify.committedData = syncData.committedData; in MigrateDataItem()
770 PutConflictData(dataItem, notify.getData, deviceInfo, notify.dataStatus, notify.committedData); in PutIntoConflictAndCommitForMigrateCache()
776 PutIntoCommittedData(dataItem, notify.getData, notify.dataStatus, notify.committedData); in PutIntoConflictAndCommitForMigrateCache()
|
| H A D | sqlite_single_ver_natural_store.h | 272 void InitConflictNotifiedFlag(SingleVerNaturalStoreCommitNotifyData *committedData);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_single_ver_storage_executor.cpp | 254 …SingleVerNaturalStoreCommitNotifyData *committedData, std::vector<NotifyConflictAndObserverData> &… in PrepareNotifyForEntries() argument
259 .committedData = committedData in PrepareNotifyForEntries()
393 SingleVerNaturalStoreCommitNotifyData *committedData) in BatchSaveEntries() argument
410 ret = PrepareNotifyForEntries(entries, committedData, notifys, isDelete); in BatchSaveEntries()
443 Timestamp timestamp, SingleVerNaturalStoreCommitNotifyData *committedData) in PutKvData() argument
460 SingleVerNaturalStoreCommitNotifyData *committedData, bool isDelete) in SaveSyncDataItem() argument
463 .committedData = committedData in SaveSyncDataItem()
713 if (data.committedData == nullptr) { in PutIntoCommittedData()
723 errCode = data.committedData->InsertCommittedData(std::move(entry), dataType, true); in PutIntoCommittedData()
730 errCode = data.committedData->InsertCommittedData(std::move(entry), DataType::DELETE, true); in PutIntoCommittedData()
[all …]
|
| 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.cpp | 251 SingleVerNaturalStoreCommitNotifyData *&committedData, bool isNeedCommit, int eventType) in CommitAndReleaseNotifyData() argument
254 if ((naturalStore != nullptr) && (committedData != nullptr)) { in CommitAndReleaseNotifyData()
256 if (!committedData->IsChangedDataEmpty()) { in CommitAndReleaseNotifyData()
257 naturalStore->CommitNotify(eventType, committedData); in CommitAndReleaseNotifyData()
261 ReleaseCommitData(committedData); in CommitAndReleaseNotifyData()
640 …VerNaturalStoreConnection::ReleaseCommitData(SingleVerNaturalStoreCommitNotifyData *&committedData) in ReleaseCommitData() argument
642 if (committedData != nullptr) { in ReleaseCommitData()
643 committedData->DecObjRef(committedData); in ReleaseCommitData()
644 committedData = nullptr; in ReleaseCommitData()
|
| H A D | rd_single_ver_natural_store_connection.h | 143 void ReleaseCommitData(SingleVerNaturalStoreCommitNotifyData *&committedData);
153 void CommitAndReleaseNotifyData(SingleVerNaturalStoreCommitNotifyData *&committedData,
|
| H A D | rd_single_ver_natural_store.cpp | 438 [&](int eventType, KvDBCommitNotifyFilterAbleData *committedData) { in InitDatabaseContext() argument
439 auto commitData = static_cast<SingleVerNaturalStoreCommitNotifyData *>(committedData); in InitDatabaseContext()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_storage_executor.cpp | 1130 MultiVerNaturalStoreCommitNotifyData *committedData = in CommitNotifiedData() local
1133 if (committedData != nullptr) { in CommitNotifiedData()
1135 …tatic_cast<MultiVerNaturalStore *>(kvDB_)->CommitNotify(NATURAL_STORE_COMMIT_EVENT, committedData); in CommitNotifiedData()
1136 committedData->DecObjRef(committedData); in CommitNotifiedData()
1137 committedData = nullptr; in CommitNotifiedData()
|