| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store_connection.h | 160 int PublishLocal(const Key &key, bool deleteLocal, bool updateTimestamp,
163 int PublishLocalCallback(bool updateTimestamp, const SingleVerRecord &localRecord,
166 int PublishInner(SingleVerNaturalStoreCommitNotifyData *committedData, bool updateTimestamp,
169 int UnpublishToLocal(const Key &key, bool deletePublic, bool updateTimestamp);
172 SingleVerRecord &syncRecord, bool updateTimestamp, int &innerErrCode);
175 bool updateTimestamp, int operType);
|
| H A D | sqlite_single_ver_natural_store_connection.cpp | 1452 return PublishLocalCallback(updateTimestamp, localRecord, syncRecord, onConflict); in PublishLocal()
1458 int SQLiteSingleVerNaturalStoreConnection::PublishLocalCallback(bool updateTimestamp, in PublishLocalCallback() argument
1461 …bool isLocalLastest = updateTimestamp ? true : (localRecord.timestamp > syncRecord.writeTimestamp); in PublishLocalCallback()
1472 …bool updateTimestamp, SingleVerRecord &localRecord, SingleVerRecord &syncRecord, bool &isNeedCallb… in PublishInner() argument
1506 if (updateTimestamp) { // local win in PublishInner()
1552 … errCode = UnpublishInner(keyPair, localCommittedData, syncRecord, updateTimestamp, innerErrCode); in UnpublishToLocal()
1599 if (updateTimestamp || localRecord.timestamp <= syncRecord.writeTimestamp) { // sync win in UnpublishInner()
1603 … } else if (updateTimestamp || localRecord.timestamp <= syncRecord.writeTimestamp) { // sync win in UnpublishInner()
1615 errCode = UnpublishOper(committedData, syncRecord, updateTimestamp, localOperation); in UnpublishInner()
1622 const SingleVerRecord &syncRecord, bool updateTimestamp, int operType) in UnpublishOper() argument
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/src/ |
| H A D | lnn_data_cloud_sync.c | 457 cacheInfo->updateTimestamp = parseValue.timestamp; in HandleDBAddChangeInternal()
570 if (IsIgnoreUpdate(cacheInfo.stateVersion, cacheInfo.updateTimestamp, parseValue->stateVersion, in HandleDBUpdateInternal()
720 … IsIgnoreUpdate(oldCacheInfo.stateVersion, oldCacheInfo.updateTimestamp, cacheInfo.stateVersion, in LnnDBDataAddChangeSyncToCache()
721 cacheInfo.updateTimestamp)) { in LnnDBDataAddChangeSyncToCache()
729 …PRIu64, anonyUdid, cacheInfo.stateVersion, cacheInfo.localStateVersion, cacheInfo.updateTimestamp); in LnnDBDataAddChangeSyncToCache()
774 …cacheInfo->feature, cacheInfo->connSubFeature, cacheInfo->updateTimestamp, anonyP2pMac, cacheInfo-… in PrintSyncNodeInfo()
829 oldInfo->updateTimestamp = newInfo->updateTimestamp; in UpdateDevBasicInfoToCache()
914 …u64, anonyUdid, cacheInfo->stateVersion, cacheInfo->localStateVersion, cacheInfo->updateTimestamp); in LnnSaveAndUpdateDistributedNode()
949 … IsIgnoreUpdate(oldCacheInfo.stateVersion, oldCacheInfo.updateTimestamp, cacheInfo.stateVersion, in LnnDBDataChangeSyncToCacheInner()
950 cacheInfo.updateTimestamp)) { in LnnDBDataChangeSyncToCacheInner()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/nbdelegate_fuzzer/ |
| H A D | nbdelegate_fuzzer.cpp | 236 bool updateTimestamp = (size > 3u) ? (data[2] > data[1]) : true; // use index 2 and 1 in FuzzCURD() local
237 kvNbDelegatePtr->UnpublishToLocal(keys[0], deletePublic, updateTimestamp); in FuzzCURD()
254 bool updateTimestamp = (size > 3u) ? (data[2] > data[1]) : true; // use index 2 and 1 in FuzzCURD() local
256 kvNbDelegatePtr->PublishLocal(keys[0], deleteLocal, updateTimestamp, nullptr); in FuzzCURD()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
| H A D | kv_store_nb_delegate_mock.h | 54 DBStatus PublishLocal(const Key &key, bool deleteLocal, bool updateTimestamp,
56 DBStatus UnpublishToLocal(const Key &key, bool deletePublic, bool updateTimestamp);
|
| H A D | kv_store_nb_delegate_mock.cpp | 94 DBStatus KvStoreNbDelegateMock::PublishLocal(const Key &key, bool deleteLocal, bool updateTimestamp, in PublishLocal() argument
100 …us KvStoreNbDelegateMock::UnpublishToLocal(const Key &key, bool deletePublic, bool updateTimestamp) in UnpublishToLocal() argument
|
| H A D | db_store_mock.h | 64 DBStatus PublishLocal(const Key &key, bool deleteLocal, bool updateTimestamp,
66 DBStatus UnpublishToLocal(const Key &key, bool deletePublic, bool updateTimestamp) override;
|
| H A D | db_store_mock.cpp | 98 DBStatus DBStoreMock::PublishLocal(const Key &key, bool deleteLocal, bool updateTimestamp, in PublishLocal() argument
104 DBStatus DBStoreMock::UnpublishToLocal(const Key &key, bool deletePublic, bool updateTimestamp) in UnpublishToLocal() argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | kv_store_nb_delegate.h | 126 DB_API virtual DBStatus PublishLocal(const Key &key, bool deleteLocal, bool updateTimestamp,
131 …API virtual DBStatus UnpublishToLocal(const Key &key, bool deletePublic, bool updateTimestamp) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | kv_store_nb_delegate_impl.h | 70 DBStatus PublishLocal(const Key &key, bool deleteLocal, bool updateTimestamp,
73 DBStatus UnpublishToLocal(const Key &key, bool deletePublic, bool updateTimestamp) override;
|
| H A D | kv_store_nb_delegate_impl.cpp | 293 DBStatus KvStoreNbDelegateImpl::PublishLocal(const Key &key, bool deleteLocal, bool updateTimestamp, in PublishLocal() argument
302 PragmaPublishInfo publishInfo{ key, deleteLocal, updateTimestamp, onConflict }; in PublishLocal()
314 …us KvStoreNbDelegateImpl::UnpublishToLocal(const Key &key, bool deletePublic, bool updateTimestamp) in UnpublishToLocal() argument
322 PragmaUnpublishInfo unpublishInfo{ key, deletePublic, updateTimestamp }; in UnpublishToLocal()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | db_types.h | 71 bool updateTimestamp = false; member
|
| /ohos5.0/foundation/communication/dsoftbus/core/bus_center/lnn/net_ledger/common/include/ |
| H A D | lnn_node_info.h | 193 uint64_t updateTimestamp; member
|
| /ohos5.0/foundation/communication/dsoftbus/core/bus_center/lnn/net_ledger/distributed_ledger/src/ |
| H A D | lnn_distributed_net_ledger.c | 1491 oldInfo->updateTimestamp = newInfo->updateTimestamp; in UpdateDevBasicInfoToDLedger()
1571 … if (IsIgnoreUpdateToLedger(oldInfo->stateVersion, oldInfo->updateTimestamp, newInfo->stateVersion, in LnnUpdateDistributedNodeInfo()
1572 newInfo->updateTimestamp)) { in LnnUpdateDistributedNodeInfo()
|
| H A D | lnn_distributed_net_ledger_manager.c | 1643 *timestamp = nodeInfo->updateTimestamp; in LnnGetDLUpdateTimestamp()
|
| /ohos5.0/foundation/communication/dsoftbus/core/authentication/src/ |
| H A D | auth_session_json.c | 2089 nodeInfo->updateTimestamp = SoftBusGetSysTimeMs(); in UnpackDeviceInfoMessage()
|