| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | single_ver_natural_store_commit_notify_data.cpp | 241 bool isDeleted = ((orgItemInfo.dataItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG); in PutIntoConflictData()
244 isDeleted = ((newItemInfo.dataItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG); in PutIntoConflictData()
|
| H A D | data_transformer.cpp | 78 if ((dataItem.flag & DataItem::DELETE_FLAG) == 0 && in DeSerializeDataItem()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store_connection.cpp | 966 dataItem.flag |= DataItem::DELETE_FLAG; in SaveEntry()
995 dataItem.flag = DataItem::DELETE_FLAG; in SaveLocalEntry()
1010 if ((dataItem.flag & DataItem::DELETE_FLAG) == 0) { in SaveLocalItem()
1462 if ((syncRecord.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG) { in PublishLocalCallback()
1557 if (deletePublic && (syncRecord.flag & DataItem::DELETE_FLAG) != DataItem::DELETE_FLAG) { in UnpublishToLocal()
1598 if ((syncRecord.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG) { in UnpublishInner()
1609 if ((syncRecord.flag & DataItem::DELETE_FLAG) != DataItem::DELETE_FLAG) { in UnpublishInner()
|
| H A D | sqlite_single_ver_storage_executor_cache.cpp | 512 if ((dataItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG) { in BindSyncDataInCacheMode()
634 if ((dataItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG) { in SaveSyncDataItemInCacheMode()
719 if ((dataItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG) { in BindLocalDataInCacheMode()
|
| H A D | sqlite_single_ver_storage_executor.cpp | 489 if ((dataItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG) { in GetDataItemForSync()
1233 status.isDeleted = ((dataItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG || in JudgeSyncSaveType()
1236 if ((itemGet.flag & DataItem::DELETE_FLAG) != 0) { in JudgeSyncSaveType()
1328 (dataItem.flag & DataItem::DELETE_FLAG) != 0 && in PrepareForNotifyConflictAndObserver()
1482 if ((dataItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG) { in BindSavedSyncData()
1525 if ((itemPut.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG || in PutConflictData()
1570 } else if ((itemPut.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG || in GetSyncDataItemPre()
|
| H A D | sqlite_single_ver_natural_store_extend.cpp | 239 if ((eachItem.flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG || in CheckAmendValueContentForSyncProcedure()
|
| H A D | sqlite_single_ver_natural_store.cpp | 108 bool getDeleteData = ((dataItems.back().flag & DataItem::DELETE_FLAG) != 0); in ProcessContinueTokenForQuerySync()
1196 errCode = CheckDataStatus(item.key, item.value, (item.flag & DataItem::DELETE_FLAG) != 0); in SaveSyncDataItems()
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 114 if ((static_cast<uint64_t>(flag) & DataItem::DELETE_FLAG) == 0) { in GetCloudDataForSync()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_single_ver_sync_db_Interface.cpp | 200 item.flag = VirtualDataItem::DELETE_FLAG; in RemoveDeviceData()
212 if (iter->flag == VirtualDataItem::DELETE_FLAG) { in GetSyncData()
424 if ((data.flag & VirtualDataItem::DELETE_FLAG) != 0) { in GetSyncData()
|
| H A D | virtual_single_ver_sync_db_Interface.h | 36 static const uint64_t DELETE_FLAG = 0x01; member
|
| H A D | virtual_relational_ver_sync_db_interface.cpp | 281 if (entry.second.logInfo.flag != DataItem::DELETE_FLAG) { in GetAllSyncData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | intercepted_data_impl.cpp | 184 if ((kvEntry->GetFlag() & DataItem::DELETE_FLAG) == 0) { // For deleted data, do not modify. in GetKvEntries()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | db_types.h | 58 static constexpr uint64_t DELETE_FLAG = 0x01; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_continue_token.cpp | 69 if ((theLastItem.flag & DataItem::DELETE_FLAG) != 0) { // The last one could be non-deleted. in SetNextBeginTime()
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 883 if ((dataItem.flag & DataItem::DELETE_FLAG) != 0) { in SaveSyncDataItem()
1650 if ((static_cast<uint64_t>(flag) & DataItem::DELETE_FLAG) == 0) { in GetCloudDataForSync()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync_utils.cpp | 436 if ((inData[i]->GetFlag() & DataItem::DELETE_FLAG) == 0) { // query data in GetQuerySyncDataTimeRange()
445 if ((inData[i]->GetFlag() & DataItem::DELETE_FLAG) != 0) { // delete data in GetQuerySyncDataTimeRange()
|
| /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 | 1079 item.flag = DataItem::DELETE_FLAG;
1090 dataItem.flag = DataItem::DELETE_FLAG;
|
| H A D | distributeddb_relational_get_data_test.cpp | 276 dataItem.flag = DataItem::DELETE_FLAG; in SetNextBeginTime001()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.cpp | 1792 if ((localLogInfoCache[hashKey].flag & DataItem::DELETE_FLAG) == DataItem::DELETE_FLAG) { in GetLocalInfo()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 1291 bool isDelete = ((static_cast<uint64_t>(*flag) & DataItem::DELETE_FLAG) != 0); in IdentifyCloudTypeInner()
|