Home
last modified time | relevance | path

Searched refs:localInfo (Results 1 - 25 of 38) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_strategy_test.cpp101 LogInfo localInfo; in HWTEST_F() local
107 EXPECT_EQ(strategy->TagSyncDataStatus(false, false, localInfo, cloudInfo), OpType::INSERT); in HWTEST_F()
112 localInfo.timestamp = 1u; in HWTEST_F()
113 localInfo.flag = static_cast<uint64_t>(LogInfoFlag::FLAG_LOCAL); in HWTEST_F()
114 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::ONLY_UPDATE_GID); in HWTEST_F()
119 localInfo.cloudGid = "gid"; in HWTEST_F()
120 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::NOT_HANDLE); in HWTEST_F()
126 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::UPDATE); in HWTEST_F()
132 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::DELETE); in HWTEST_F()
138 localInfo in HWTEST_F()
196 LogInfo localInfo; HWTEST_F() local
246 LogInfo localInfo; HWTEST_F() local
302 LogInfo localInfo; HWTEST_F() local
326 DataInfoWithLog localInfo; HWTEST_F() local
355 LogInfo localInfo; HWTEST_F() local
[all...]
H A Dvirtual_cloud_syncer.cpp110 int VirtualCloudSyncer::CallTagStatusByStrategy(bool isExist, const DataInfoWithLog &localInfo, in CallTagStatusByStrategy() argument
115 dataInfo.localInfo = localInfo; in CallTagStatusByStrategy()
H A Dvirtual_cloud_syncer.h47 int CallTagStatusByStrategy(bool isExist, const DataInfoWithLog &localInfo, const LogInfo &cloudInfo,
H A Ddistributeddb_cloud_db_proxy_test.cpp757 LogInfo localInfo; in HWTEST_F() local
758 localInfo.hashKey = {'k'}; in HWTEST_F()
764 CloudSyncUtils::UpdateLocalCache(OpType::INSERT, cloudInfo, localInfo, localLogInfoCache); in HWTEST_F()
765 std::string hashKey(localInfo.hashKey.begin(), localInfo.hashKey.end()); in HWTEST_F()
771 CloudSyncUtils::UpdateLocalCache(OpType::DELETE, cloudInfo, localInfo, localLogInfoCache); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_sync_strategy.cpp34 [[gnu::unused]] const LogInfo &localInfo, [[gnu::unused]] const LogInfo &cloudInfo) in TagSyncDataStatus()
60 bool CloudSyncStrategy::IsLogNeedUpdate(const LogInfo &cloudInfo, const LogInfo &localInfo) in IsLogNeedUpdate() argument
62 return (cloudInfo.sharingResource != localInfo.sharingResource) || (cloudInfo.version != localInfo.version); in IsLogNeedUpdate()
65 bool CloudSyncStrategy::IsSameVersion(const LogInfo &cloudInfo, const LogInfo &localInfo) in IsSameVersion() argument
67 if (cloudInfo.version.empty() || localInfo.version.empty()) { in IsSameVersion()
70 return (cloudInfo.version == localInfo.version); in IsSameVersion()
73 bool CloudSyncStrategy::IsIgnoreUpdate(const LogInfo &localInfo) const in IsIgnoreUpdate()
78 if ((localInfo.flag & static_cast<uint64_t>(LogInfoFlag::FLAG_LOCAL)) == 0 && IsDelete(localInfo)) { in IsIgnoreUpdate()
33 TagSyncDataStatus([[gnu::unused]] bool existInLocal, [[gnu::unused]] bool isCloudWin, [[gnu::unused]] const LogInfo &localInfo, [[gnu::unused]] const LogInfo &cloudInfo) TagSyncDataStatus() argument
94 IsSameRecord(const LogInfo &cloudInfo, const LogInfo &localInfo) IsSameRecord() argument
[all...]
H A Dcloud_merge_strategy.cpp20 OpType CloudMergeStrategy::TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo, in TagSyncDataStatus() argument
24 bool isLocalDelete = IsDelete(localInfo); in TagSyncDataStatus()
26 return TagCloudUpdateLocal(localInfo, cloudInfo, isCloudDelete, isLocalDelete); in TagSyncDataStatus()
28 if (CloudStorageUtils::IsDataLocked(localInfo.status)) { in TagSyncDataStatus()
34 if (IsIgnoreUpdate(localInfo)) { in TagSyncDataStatus()
37 if ((localInfo.flag & static_cast<uint64_t>(LogInfoFlag::FLAG_LOCAL)) != 0 && in TagSyncDataStatus()
38 localInfo.timestamp > cloudInfo.timestamp) { in TagSyncDataStatus()
39 return TagLocallyNewer(localInfo, cloudInfo, isCloudDelete, isLocalDelete); in TagSyncDataStatus()
49 bool isTimeSame = (localInfo.timestamp == cloudInfo.timestamp) && (localInfo in TagSyncDataStatus()
69 TagLocallyNewer(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete, bool isLocalDelete) TagLocallyNewer() argument
85 TagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete, bool isLocalDelete) TagCloudUpdateLocal() argument
[all...]
H A Dcloud_force_pull_strategy.cpp21 const LogInfo &localInfo, const LogInfo &cloudInfo) in TagSyncDataStatus()
23 if (CloudStorageUtils::IsDataLocked(localInfo.status)) { in TagSyncDataStatus()
27 if (IsIgnoreUpdate(localInfo)) { in TagSyncDataStatus()
30 if (!IsDelete(localInfo) && IsDelete(cloudInfo)) { in TagSyncDataStatus()
35 if (IsDelete(localInfo)) { in TagSyncDataStatus()
38 return TagUpdateLocal(cloudInfo, localInfo); in TagSyncDataStatus()
40 bool gidEmpty = localInfo.cloudGid.empty(); in TagSyncDataStatus()
47 return TagUpdateLocal(cloudInfo, localInfo); in TagSyncDataStatus()
20 TagSyncDataStatus(bool existInLocal, [[gnu::unused]] bool isCloudWin, const LogInfo &localInfo, const LogInfo &cloudInfo) TagSyncDataStatus() argument
H A Dcloud_force_push_strategy.cpp21 const LogInfo &localInfo, const LogInfo &cloudInfo) in TagSyncDataStatus()
23 if (CloudStorageUtils::IsDataLocked(localInfo.status)) { in TagSyncDataStatus()
31 if (localInfo.cloudGid.empty()) { in TagSyncDataStatus()
33 bool isLocalDelete = IsDelete(localInfo); in TagSyncDataStatus()
40 if (localInfo.device == cloud_device_name) { in TagSyncDataStatus()
41 if (localInfo.timestamp == cloudInfo.timestamp) { in TagSyncDataStatus()
47 if (IsLogNeedUpdate(cloudInfo, localInfo)) { in TagSyncDataStatus()
20 TagSyncDataStatus(bool existInLocal, [[gnu::unused]] bool isCloudWin, const LogInfo &localInfo, const LogInfo &cloudInfo) TagSyncDataStatus() argument
H A Dcloud_sync_strategy.h34 virtual OpType TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo,
45 static bool IsLogNeedUpdate(const LogInfo &cloudInfo, const LogInfo &localInfo);
47 OpType TagUpdateLocal(const LogInfo &cloudInfo, const LogInfo &localInfo) const;
49 static bool IsSameVersion(const LogInfo &cloudInfo, const LogInfo &localInfo);
51 bool IsIgnoreUpdate(const LogInfo &localInfo) const;
53 static bool IsSameRecord(const LogInfo &cloudInfo, const LogInfo &localInfo);
H A Dcloud_merge_strategy.h26 OpType TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo,
33 OpType TagLocallyNewer(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete, bool isLocalDelete);
35 OpType TagCloudUpdateLocal(const LogInfo &localInfo, const LogInfo &cloudInfo, bool isCloudDelete,
H A Dcloud_sync_utils.cpp198 const DataInfoWithLog &localInfo, ChangeType type) in SaveChangedDataByType()
203 ret = CloudSyncUtils::GetCloudPkVals(localInfo.primaryKeys, changedData.field, localInfo.logInfo.dataKey, in SaveChangedDataByType()
206 ret = CloudSyncUtils::GetCloudPkVals(datum, changedData.field, localInfo.logInfo.dataKey, cloudPkVals); in SaveChangedDataByType()
346 void CloudSyncUtils::UpdateLocalCache(OpType opType, const LogInfo &cloudInfo, const LogInfo &localInfo, in UpdateLocalCache() argument
350 std::string hashKey(localInfo.hashKey.begin(), localInfo.hashKey.end()); in UpdateLocalCache()
358 updateLogInfo.hashKey = localInfo.hashKey; in UpdateLocalCache()
368 updateLogInfo = localInfo; in UpdateLocalCache()
386 Key hashKey = dataInfo.localInfo in SaveChangedData()
197 SaveChangedDataByType(const VBucket &datum, ChangedData &changedData, const DataInfoWithLog &localInfo, ChangeType type) SaveChangedDataByType() argument
[all...]
H A Dcloud_force_pull_strategy.h22 OpType TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo,
H A Dcloud_force_push_strategy.h22 OpType TagSyncDataStatus(bool existInLocal, bool isCloudWin, const LogInfo &localInfo,
H A Dcloud_sync_utils.h62 static int SaveChangedDataByType(const VBucket &datum, ChangedData &changedData, const DataInfoWithLog &localInfo,
79 const LogInfo &localInfo, std::map<std::string, LogInfo> &localLogInfoCache);
/foundation/communication/dsoftbus/core/bus_center/lnn/net_ledger/local_ledger/src/
H A Dlnn_local_net_ledger.c57 NodeInfo localInfo; member
67 g_localNetLedger.localInfo.stateVersion++; in UpdateStateVersionAndStore()
68 if (g_localNetLedger.localInfo.stateVersion > MAX_STATE_VERSION) { in UpdateStateVersionAndStore()
69 g_localNetLedger.localInfo.stateVersion = 1; in UpdateStateVersionAndStore()
71 g_localNetLedger.localInfo.stateVersionReason = reason; in UpdateStateVersionAndStore()
74 g_localNetLedger.localInfo.stateVersion, g_localNetLedger.localInfo.stateVersionReason); in UpdateStateVersionAndStore()
76 if ((ret = LnnSaveLocalDeviceInfo(&g_localNetLedger.localInfo)) != SOFTBUS_OK) { in UpdateStateVersionAndStore()
83 NodeInfo *info = &g_localNetLedger.localInfo; in LlGetNodeSoftBusVersion()
97 NodeInfo *info = &g_localNetLedger.localInfo; in LlGetDeviceUdid()
[all...]
/foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/src/
H A Dlnn_p2p_info.c167 static bool IsNeedSyncP2pInfo(const NodeInfo *localInfo, const NodeBasicInfo *info) in IsNeedSyncP2pInfo() argument
171 if (!IsFeatureSupport(localInfo->feature, BIT_WIFI_DIRECT_TLV_NEGOTIATION)) { in IsNeedSyncP2pInfo()
200 const NodeInfo *localInfo = LnnGetLocalNodeInfo(); in ProcessSyncP2pInfo() local
201 if (localInfo == NULL) { in ProcessSyncP2pInfo()
205 char *msg = LnnGetP2pInfoMsg(&localInfo->p2pInfo); in ProcessSyncP2pInfo()
216 if (IsNeedSyncP2pInfo(localInfo, &info[i]) && in ProcessSyncP2pInfo()
244 const NodeInfo *localInfo = LnnGetLocalNodeInfo(); in ProcessSyncWifiDirectAddr() local
245 if (localInfo == NULL) { in ProcessSyncWifiDirectAddr()
249 char *msg = LnnGetWifiDirectAddrMsg(localInfo); in ProcessSyncWifiDirectAddr()
H A Dlnn_connection_fsm.c507 const NodeInfo *localInfo = LnnGetLocalNodeInfo(); in GetUdidHashForDfx() local
508 if (localInfo == NULL) { in GetUdidHashForDfx()
509 LNN_LOGE(LNN_BUILDER, "localInfo is NULL"); in GetUdidHashForDfx()
513 rc = SoftBusGenerateStrHash((uint8_t *)localInfo->deviceInfo.deviceUdid, strlen(localInfo->deviceInfo.deviceUdid), in GetUdidHashForDfx()
565 NodeInfo localInfo; in GetDevTypeForDfx() local
566 (void)memset_s(&localInfo, sizeof(NodeInfo), 0, sizeof(NodeInfo)); in GetDevTypeForDfx()
567 if (LnnGetLocalNodeInfoSafe(&localInfo) != SOFTBUS_OK) { in GetDevTypeForDfx()
572 localInfo.deviceInfo.deviceTypeId) < 0) { in GetDevTypeForDfx()
742 NodeInfo localInfo; in GetConnectOnlineReason() local
[all...]
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/heartbeat/src/
H A Dlnn_ble_lpdevice_virtual.c32 void UpdateLocalDeviceInfoToMlps(const NodeInfo *localInfo) in UpdateLocalDeviceInfoToMlps() argument
34 (void)localInfo; in UpdateLocalDeviceInfoToMlps()
H A Dlnn_heartbeat_utils.c386 NodeBasicInfo localInfo = { 0 }; in LnnDumpLocalBasicInfo() local
388 (void)LnnGetLocalDeviceInfo(&localInfo); in LnnDumpLocalBasicInfo()
395 Anonymize(localInfo.networkId, &anonyNetworkId); in LnnDumpLocalBasicInfo()
403 const char *devTypeStr = LnnConvertIdToDeviceType(localInfo.deviceTypeId); in LnnDumpLocalBasicInfo()
411 Anonymize(localInfo.deviceName, &anonyDeviceName); in LnnDumpLocalBasicInfo()
413 "brMac=%{public}s, p2pMac=%{public}s, onlineNodeNum=%{public}d", devTypeStr, localInfo.deviceTypeId, in LnnDumpLocalBasicInfo()
/foundation/arkui/ace_engine/interfaces/napi/kits/observer/
H A Dui_observer.cpp250 auto localInfo = infosForRouterPage_[ref]; in RegisterRouterPageCallback() local
251 if (info.IsEqual(localInfo)) { in RegisterRouterPageCallback()
294 auto localInfo = infosForRouterPage_[ref]; in UnRegisterRouterPageCallback() local
295 if (info.IsEqual(localInfo)) { in UnRegisterRouterPageCallback()
433 auto localInfo = infosForRouterPage_[ref]; in HandleRouterPageStateChange() local
434 if (info.IsEqual(localInfo)) { in HandleRouterPageStateChange()
554 auto localInfo = infosForNavDesSwitch_[ref]; in RegisterNavDestinationSwitchCallback() local
555 if (!info.IsEqual(localInfo)) { in RegisterNavDestinationSwitchCallback()
622 auto localInfo = infosForNavDesSwitch_[ref]; in UnRegisterNavDestinationSwitchCallback() local
623 if (!info.IsEqual(localInfo)) { in UnRegisterNavDestinationSwitchCallback()
708 auto localInfo = infosForNavDesSwitch_[ref]; HandleAbilityUIContextNavDestinationSwitch() local
784 auto localInfo = willClickInfos_[ref]; RegisterWillClickCallback() local
833 auto localInfo = willClickInfos_[ref]; UnRegisterWillClickCallback() local
894 auto localInfo = willClickInfos_[ref]; HandleWillClick() local
932 auto localInfo = didClickInfos_[ref]; RegisterDidClickCallback() local
981 auto localInfo = didClickInfos_[ref]; UnRegisterDidClickCallback() local
1042 auto localInfo = didClickInfos_[ref]; HandleDidClick() local
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/gap/
H A Dgap_le_sec.c59 static bool GapLeSecurityNeedAuthentication(const LeLocalInfo *localInfo) in GapLeSecurityNeedAuthentication() argument
61 return localInfo->mode1Level >= LE_MODE_1_LEVEL_3 || localInfo->mode2Level >= LE_MODE_2_LEVEL_2; in GapLeSecurityNeedAuthentication()
243 LeLocalInfo *localInfo = GapGetLeLocalInfo(); in GapLeAuthenticationRequest() local
252 if (GapLeSecurityNeedAuthentication(localInfo) && pairMethod == SMP_PAIR_METHOD_JUST_WORK) { in GapLeAuthenticationRequest()
458 LeLocalInfo *localInfo = GapGetLeLocalInfo(); in GapLeRemotePairResponse() local
463 if (GapLeSecurityNeedAuthentication(localInfo) && !(param->authReq & SMP_AUTH_REQ_BIT_MITM)) { in GapLeRemotePairResponse()
581 LeLocalInfo *localInfo = GapGetLeLocalInfo(); in GAP_LeRemoteEncryptionKeyRsp() local
598 } else if (GapLeSecurityNeedAuthentication(localInfo)) { in GAP_LeRemoteEncryptionKeyRsp()
902 LeLocalInfo *localInfo in GAP_LeSetMinEncKeySize() local
919 LeLocalInfo *localInfo = NULL; GAP_LePairFeatureRsp() local
[all...]
H A Dgap_le_conn.c361 LeLocalInfo *localInfo = GapGetLeLocalInfo(); in GAP_LeSetBondMode() local
362 localInfo->bondableMode = mode; in GAP_LeSetBondMode()
375 LeLocalInfo *localInfo = GapGetLeLocalInfo(); in GAP_LeSetSecurityMode() local
376 localInfo->mode1Level = mode1Level; in GAP_LeSetSecurityMode()
377 localInfo->mode2Level = mode2Level; in GAP_LeSetSecurityMode()
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/heartbeat/include/
H A Dlnn_ble_lpdevice.h41 void UpdateLocalDeviceInfoToMlps(const NodeInfo *localInfo);
/foundation/communication/dsoftbus/tests/core/bus_center/lnn/net_builder/src/
H A Dlnn_p2p_info_test.cpp166 NodeInfo localInfo; in HWTEST_F() local
167 (void)memset_s(&localInfo, sizeof(NodeInfo), 0, sizeof(NodeInfo)); in HWTEST_F()
170 bool ret = IsNeedSyncP2pInfo(&localInfo, &info); in HWTEST_F()
177 ret = IsNeedSyncP2pInfo(&localInfo, &info); in HWTEST_F()
/foundation/deviceprofile/device_info_manager/old/tools/dp/src/
H A Ddp_command.cpp154 NodeBasicInfo localInfo; in GetDeviceCommand() local
155 ret = GetLocalNodeDeviceInfo("dp", &localInfo); in GetDeviceCommand()
161 resultReceiver_.append("networkId: " + std::string(localInfo.networkId) in GetDeviceCommand()
162 + " deviceName:" + std::string(localInfo.deviceName) + "\n"); in GetDeviceCommand()

Completed in 17 milliseconds

12