Home
last modified time | relevance | path

Searched refs:GetDeviceId (Results 1 - 25 of 208) sorted by relevance

123456789

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_syncer_device_manager_test.cpp137 if (targetDev == g_deviceB->GetDeviceId()) { in HWTEST_F()
147 g_communicatorAggregator->OnlineDevice(g_deviceB->GetDeviceId()); in HWTEST_F()
161 g_communicatorAggregator->OnlineDevice(g_deviceB->GetDeviceId()); in HWTEST_F()
168 if (targetDev == g_deviceB->GetDeviceId()) { in HWTEST_F()
177 g_communicatorAggregator->OfflineDevice(g_deviceB->GetDeviceId()); in HWTEST_F()
198 EXPECT_TRUE(deviceList[0] == g_deviceB->GetDeviceId()); in HWTEST_F()
199 EXPECT_TRUE(deviceList[1] == g_deviceC->GetDeviceId()); in HWTEST_F()
200 g_communicatorAggregator->OfflineDevice(g_deviceC->GetDeviceId()); in HWTEST_F()
208 EXPECT_TRUE(deviceList[0] == g_deviceB->GetDeviceId()); in HWTEST_F()
H A Ddistributeddb_single_ver_p2p_simple_sync_test.cpp203 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
204 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
213 CheckWatermark(g_deviceB->GetDeviceId(), g_kvDelegatePtr, info); in HWTEST_F()
214 CheckWatermark(g_deviceC->GetDeviceId(), g_kvDelegatePtr, info); in HWTEST_F()
225 CheckWatermark(g_deviceB->GetDeviceId(), g_kvDelegatePtr, info, false); in HWTEST_F()
226 CheckWatermark(g_deviceC->GetDeviceId(), g_kvDelegatePtr, info, false); in HWTEST_F()
254 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
255 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
307 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
308 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
[all...]
H A Ddistributeddb_single_ver_p2p_permission_sync_test.cpp175 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
176 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
240 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
241 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
308 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
309 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
397 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
398 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
461 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
462 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
[all...]
H A Ddistributeddb_single_ver_p2p_sync_check_test.cpp183 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
184 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
231 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
232 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
301 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
346 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
381 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
428 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
466 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
490 auto deviceB = g_deviceB->GetDeviceId(); in HWTEST_F()
[all...]
H A Dmock_sync_task_context.h88 std::string GetDeviceId() const override
93 return SingleVerKvSyncTaskContext::GetDeviceId();
H A Ddistributeddb_single_ver_multi_user_test.cpp278 devices.push_back(g_deviceB->GetDeviceId()); in TestSyncWithUserChange()
326 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
360 devices.push_back(g_deviceC->GetDeviceId()); in HWTEST_F()
408 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
432 devices.push_back(g_deviceB->GetDeviceId()); in HWTEST_F()
763 std::vector<std::string> devices = {g_deviceB->GetDeviceId(), g_deviceC->GetDeviceId()}; in HWTEST_F()
773 if (pair.first == g_deviceB->GetDeviceId()) { in HWTEST_F()
811 std::vector<std::string> devices = {g_deviceB->GetDeviceId()}; in HWTEST_F()
846 std::vector<std::string> devices = {g_deviceB->GetDeviceId()}; in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync_extend.cpp52 STR_MASK(GetDeviceId()), cmdType); in ControlCmdAckRecv()
58 errCode = subManager->ActiveLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdAckRecv()
60 subManager->RemoveLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlCmdAckRecv()
63 LOGE("[DataSync] ack handle failed,label =%s,dev=%s,type=%u", label_.c_str(), STR_MASK(GetDeviceId()), cmdType); in ControlCmdAckRecv()
112 SingleVerDataSyncUtils::SetMessageHeadInfo(*message, TYPE_REQUEST, context->GetDeviceId(), in SendControlPacket()
143 SingleVerDataSyncUtils::SetMessageHeadInfo(*ackMessage, TYPE_RESPONSE, context->GetDeviceId(), in SendControlAck()
225 STR_MASK(GetDeviceId())); in SubscribeRequestRecv()
229 errCode = subscribeManager->ReserveRemoteSubscribeQuery(context->GetDeviceId(), packet->GetQuery()); in SubscribeRequestRecv()
232 STR_MASK(GetDeviceId())); in SubscribeRequestRecv()
239 subscribeManager->DeleteRemoteSubscribeQuery(context->GetDeviceId(), packe in SubscribeRequestRecv()
[all...]
H A Dsingle_ver_data_sync.cpp187 int errCode = metadata_->GetLastQueryTime(context->GetQuerySyncId(), context->GetDeviceId(), dbLastQueryTime); in TryContinueSync()
189 errCode = metadata_->SetLastQueryTime(context->GetQuerySyncId(), context->GetDeviceId(), lastQueryTime); in TryContinueSync()
247 SetSendConfigParam(storage_->GetDbProperties(), context->GetDeviceId(), false, SEND_TIME_OUT, sendConfig); in Send()
248 int errCode = communicateHandle_->SendMessage(context->GetDeviceId(), message, sendConfig, handler); in Send()
355 int errCode = metadata_->GetLastQueryTime(context->GetQuerySyncId(), context->GetDeviceId(), in GetUnsyncData()
419 int errCode = storage_->InterceptData(copyData, GetDeviceId(), localDeviceName, false); in SaveData()
425 errCode = storage_->PutSyncDataWithQuery(query, copyData, context->GetDeviceId()); in SaveData()
470 const std::string &deviceId = context->GetDeviceId(); in SaveLocalWaterMark()
495 LOGD("label=%s,dev=%s,endTime=%" PRIu64, label_.c_str(), STR_MASK(GetDeviceId()), dataTimeRange.endTime); in SaveLocalWaterMark()
503 LOGD("label=%s,dev=%s,deleteEndTime=%" PRIu64, label_.c_str(), STR_MASK(GetDeviceId()), in SaveLocalWaterMark()
1523 std::string SingleVerDataSync::GetDeviceId() const GetDeviceId() function in DistributedDB::SingleVerDataSync
[all...]
H A Dsingle_ver_sync_state_machine.cpp141 errCode = timeSync_->Initialize(communicator, metaData, syncInterface, context->GetDeviceId()); in Initialize()
145 errCode = dataSync_->Initialize(syncInterface, communicator, metaData, context->GetDeviceId()); in Initialize()
149 errCode = abilitySync_->Initialize(communicator, syncInterface, metaData, context->GetDeviceId()); in Initialize()
232 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in SyncStepInner()
259 STR_MASK(context_->GetDeviceId())); in AbortInner()
292 currentState_, STR_MASK(context_->GetDeviceId())); in PrepareNextSyncTask()
374 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in DoInitiactiveDataSyncWithSlidingWindow()
435 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in DoInitiactiveControlSync()
498 int errCode = communicator_->GetRemoteCommunicatorVersion(context_->GetDeviceId(), remoteCommunicatorVersion); in DoAbilitySync()
516 STR_MASK(context_->GetDeviceId())); in DoAbilitySync()
[all...]
H A Dsingle_ver_data_sync_utils.cpp373 subManager->DeleteLocalSubscribeQuery(context->GetDeviceId(), context->GetQuery()); in ControlAckErrorHandle()
495 param.deviceId = context->GetDeviceId(); in RunPermissionCheckInner()
502 STR_MASK(context->GetDeviceId())); in RunPermissionCheckInner()
531 if (RuntimeContext::GetInstance()->TranslateDeviceId(context.GetDeviceId(), info, clientId) == E_OK) { in RecordClientId()
532 int errCode = metadata->SaveClientId(context.GetDeviceId(), clientId); in RecordClientId()
543 packet.SetSystemTimeOffset(metadata->GetSystemTimeOffset(context.GetDeviceId())); in SetDataRequestCommonInfo()
571 auto remoteSchemaVersion = metadata->GetRemoteSchemaVersion(context.GetDeviceId()); in SchemaVersionMatchCheck()
631 context->SetOperationSyncProcessTotal(context->GetDeviceId(), packet->GetTotalDataCount()); in UpdateSyncProcess()
633 context->UpdateOperationFinishedCount(context->GetDeviceId(), static_cast<uint32_t>(dataSize)); in UpdateSyncProcess()
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/device/
H A Ddevice_info_test.cpp136 * @tc.desc: Verify the GetDeviceId function.
146 EXPECT_EQ(devInfo.GetDeviceId(), ""); in HWTEST_F()
149 EXPECT_EQ(devInfo.GetDeviceId(), "test"); in HWTEST_F()
169 EXPECT_EQ(devInfoTwo.GetDeviceId(), deviceInfo.deviceId); in HWTEST_F()
182 EXPECT_EQ(devInfoTwo.GetDeviceId(), dmDeviceInfoTwo.deviceId); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_data_sync.cpp189 LOGD("MultiVerDataSync::SyncStart dst=%s{private}, begin", context->GetDeviceId().c_str()); in SyncStart()
206 LOGD("MultiVerDataSync::SyncStart dst=%s{private}, end", context->GetDeviceId().c_str()); in SyncStart()
248 errCode, context->GetDeviceId().c_str()); in RequestRecvCallback()
285 context->GetDeviceId().c_str(), entries.size()); in AckRecvCallback()
298 context->GetDeviceId().c_str(), valueHashes.size()); in AckRecvCallback()
337 message->SetTarget(context->GetDeviceId()); in SendFinishedRequest()
356 LOGI("[MultiVerDataSync][SendFinishedRequest] SendFinishedRequest dst=%s{private}", context->GetDeviceId().c_str()); in SendFinishedRequest()
553 LOGD("MultiVerDataSync::GetValidCommit begin, dst=%s{private}, index = %d", context->GetDeviceId().c_str(), index); in GetValidCommit()
558 context->GetDeviceId().c_str(), index, commitsSize); in GetValidCommit()
567 context->GetDeviceId() in GetValidCommit()
[all...]
H A Dmulti_ver_sync_state_machine.cpp77 errCode = timeSync_->Initialize(communicator, metadata, syncInterface, context->GetDeviceId()); in Initialize()
118 LOGD("[MultiVerSyncStateMachine][%s] step to idle", STR_MASK(context_->GetDeviceId())); in StepToIdle()
222 LOGD("[MultiVerSyncStateMachine] SyncStep dst=%s, state = %d", STR_MASK(context_->GetDeviceId()), currentState_); in SyncStepInnerLocked()
432 LOGD("MultiVerSyncStateMachine::Finish merge src=%s", STR_MASK(context_->GetDeviceId())); in Finish()
439 STR_MASK(context_->GetDeviceId()), errCode); in Finish()
457 LOGD("MultiVerSyncStateMachine::OneCommitSyncFinish src=%s, commitIndex = %d,", STR_MASK(context_->GetDeviceId()), in OneCommitSyncFinish()
461 std::string deviceName = context_->GetDeviceId(); in OneCommitSyncFinish()
465 STR_MASK(context_->GetDeviceId()), entries.size()); in OneCommitSyncFinish()
478 STR_MASK(context_->GetDeviceId()), timefixOffset); in OneCommitSyncFinish()
487 STR_MASK(context_->GetDeviceId()), errCod in OneCommitSyncFinish()
[all...]
/foundation/deviceprofile/device_info_manager/services/core/src/utils/
H A Dprofile_cache.cpp101 if (!ProfileUtils::IsKeyValid(deviceProfile.GetDeviceId())) { in AddDeviceProfile()
105 std::string deviceProfileKey = ProfileUtils::GenerateDeviceProfileKey(deviceProfile.GetDeviceId()); in AddDeviceProfile()
119 if (!ProfileUtils::IsKeyValid(serviceProfile.GetDeviceId()) || in AddServiceProfile()
124 std::string serviceProfileKey = ProfileUtils::GenerateServiceProfileKey(serviceProfile.GetDeviceId(), in AddServiceProfile()
139 if (!ProfileUtils::IsKeyValid(charProfile.GetDeviceId()) || in AddCharProfile()
145 std::string charProfileKey = ProfileUtils::GenerateCharProfileKey(charProfile.GetDeviceId(), in AddCharProfile()
160 if (!ProfileUtils::IsKeyValid(charProfile.GetDeviceId()) || in AddStaticCharProfile()
166 std::string charProfileKey = ProfileUtils::GenerateCharProfileKey(charProfile.GetDeviceId(), in AddStaticCharProfile()
316 if (!ProfileUtils::IsKeyValid(deviceProfile.GetDeviceId())) { in IsDeviceProfileExist()
320 std::string deviceProfileKey = ProfileUtils::GenerateDeviceProfileKey(deviceProfile.GetDeviceId()); in IsDeviceProfileExist()
[all...]
/foundation/communication/dsoftbus/core/authentication/bind/
H A Dauth_device_profile_listener.cpp51 DelNotTrustDevice(profile.GetDeviceId().c_str()); in OnTrustDeviceProfileAdd()
52 g_deviceProfileChange.onDeviceProfileAdd(profile.GetDeviceId().c_str(), NULL); in OnTrustDeviceProfileAdd()
64 g_deviceProfileChange.onDeviceProfileDeleted(profile.GetDeviceId().c_str()); in OnTrustDeviceProfileDelete()
/foundation/deviceprofile/device_info_manager/common/src/interfaces/
H A Dservice_profile.cpp40 std::string ServiceProfile::GetDeviceId() const in GetDeviceId() function in OHOS::DistributedDeviceProfile::ServiceProfile
88 bool isNotEqual = (deviceId_ != serviceProfile.GetDeviceId() || serviceName_ != serviceProfile.GetServiceName() || in operator !=()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/resourcemanager_fuzzer/
H A Dresourcemanager_fuzzer.cpp61 CapabilityInfoManager::GetInstance()->GetCapability(capInfo->GetDeviceId(), capInfo->GetDHId(), info); in ResourceManagerFuzzTest()
65 CapabilityInfoManager::GetInstance()->GetDataByKeyPrefix(capInfo->GetDeviceId(), capMap); in ResourceManagerFuzzTest()
/foundation/ability/dmsfwk/services/dtbabilitymgr/src/continuation_manager/
H A Dconnect_status_info.cpp24 std::string ConnectStatusInfo::GetDeviceId() const in GetDeviceId() function in OHOS::DistributedSchedule::ConnectStatusInfo
H A Dcontinuation_result.cpp59 parcel.WriteString16(Str8ToStr16(GetDeviceId())); in Marshalling()
70 std::string ContinuationResult::GetDeviceId() const in GetDeviceId() function in OHOS::DistributedSchedule::ContinuationResult
/foundation/distributedhardware/device_manager/common/include/ipc/model/
H A Dipc_unbind_device_req.h32 const std::string &GetDeviceId() const in GetDeviceId() function in OHOS::DistributedHardware::IpcUnBindDeviceReq
/foundation/communication/ipc/ipc/native/src/core/source/
H A Dstub_refcount_object.cpp39 std::string StubRefCountObject::GetDeviceId() const in GetDeviceId() function in OHOS::StubRefCountObject
/foundation/communication/ipc/ipc/native/src/core/include/
H A Dstub_refcount_object.h28 std::string GetDeviceId() const;
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/
H A Dcapability_info_manager.cpp175 const std::string &deviceId = capabilityInfo->GetDeviceId(); in SyncRemoteCapabilityInfos()
390 std::string uuid = DHContext::GetInstance().GetUUIDByDeviceId(capPtr->GetDeviceId()); in HandleCapabilityAddChange()
393 GetAnonyString(capPtr->GetDeviceId()).c_str()); in HandleCapabilityAddChange()
430 std::string uuid = DHContext::GetInstance().GetUUIDByDeviceId(capPtr->GetDeviceId()); in HandleCapabilityUpdateChange()
433 GetAnonyString(capPtr->GetDeviceId()).c_str()); in HandleCapabilityUpdateChange()
441 std::string enabledDeviceKey = GetCapabilityKey(capPtr->GetDeviceId(), capPtr->GetDHId()); in HandleCapabilityUpdateChange()
475 std::string uuid = DHContext::GetInstance().GetUUIDByDeviceId(capPtr->GetDeviceId()); in HandleCapabilityDeleteChange()
513 isMatch = cap->GetDeviceId().compare(value) == 0; in IsCapabilityMatchFilter()
/foundation/arkui/ace_engine/frameworks/bridge/declarative_frontend/engine/functions/
H A Djs_click_function.cpp52 obj->SetProperty<double>("deviceId", static_cast<int32_t>(info.GetDeviceId())); in Execute()
88 obj->SetProperty<double>("deviceId", static_cast<int32_t>(info.GetDeviceId())); in Execute()
124 obj->SetProperty<double>("deviceId", static_cast<int32_t>(info.GetDeviceId())); in Execute()
169 obj->SetProperty<double>("deviceId", static_cast<int32_t>(info.GetDeviceId())); in Execute()
205 obj->SetProperty<double>("deviceId", static_cast<int32_t>(info.GetDeviceId())); in Execute()
241 obj->SetProperty<double>("deviceId", static_cast<int32_t>(info.GetDeviceId())); in Execute()
/foundation/ability/form_fwk/services/src/
H A Dform_acquire_connection.cpp71 want.SetElementName(info_.GetDeviceId(), info_.GetProviderBundleName(), in OnAbilityConnectDone()
74 info_.GetDeviceId().c_str(), info_.GetProviderBundleName().c_str(), info_.GetAbilityName().c_str()); in OnAbilityConnectDone()

Completed in 21 milliseconds

123456789