| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | db_status_adapter.cpp | 123 void DBStatusAdapter::NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) in NotifyDBInfos() argument
125 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, devInfos, dbInfos]() { in NotifyDBInfos()
130 bool isLocal = IsLocalDeviceId(devInfos.identifier); in NotifyDBInfos()
131 if (!isLocal && !IsSupport(devInfos.identifier)) { in NotifyDBInfos()
132 … LOGW("[DBStatusAdapter][NotifyDBInfos] no support dev %s", STR_MASK(devInfos.identifier)); in NotifyDBInfos()
135 bool isChange = LoadIntoCache(isLocal, devInfos, dbInfos); in NotifyDBInfos()
138 remoteCallback_(devInfos.identifier, dbInfos); in NotifyDBInfos()
242 bool DBStatusAdapter::LoadIntoCache(bool isLocal, const DeviceInfos &devInfos, const std::vector<DB… in LoadIntoCache() argument
249 if (remoteDBInfos_.find(devInfos.identifier) == remoteDBInfos_.end()) { in LoadIntoCache()
250 remoteDBInfos_.insert({devInfos.identifier, {}}); in LoadIntoCache()
[all …]
|
| H A D | network_adapter.cpp | 195 DeviceInfos devInfos; in GetTimeout() local
196 devInfos.identifier = target; in GetTimeout()
197 uint32_t timeout = processCommunicator_->GetTimeout(devInfos); in GetTimeout()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/ |
| H A D | dev_manager_test.cpp | 108 auto devInfos = devManager.GetRemoteDevices(); variable
109 EXPECT_EQ(devInfos.size(), 0);
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/task/src/ |
| H A D | mock_online_task.cpp | 70 void MockOnLineTask::SetOnLineDevInfos(std::vector<MockDevInfo> devInfos) in SetOnLineDevInfos() argument
72 this->onLineDevInfos = devInfos; in SetOnLineDevInfos()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/ |
| H A D | db_status_adapter.h | 38 void NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos);
46 … bool LoadIntoCache(bool isLocal, const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | process_communication_impl.cpp | 105 DistributedDB::DeviceInfos devInfos = { in GetLocalDeviceInfos() local
108 return devInfos; in GetLocalDeviceInfos()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | process_communicator_impl.cpp | 234 DeviceInfos devInfos; in OnSessionReady() local
235 devInfos.identifier = info.uuid; in OnSessionReady()
236 sessionListener_(devInfos, errCode); in OnSessionReady()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/preprocess/ |
| H A D | preprocess_utils.cpp | 260 std::vector<AppDistributedKv::DeviceInfo> devInfos = in IsNetworkingEnabled() local
262 ZLOGI("DM remote devices count is %{public}u.", static_cast<uint32_t>(devInfos.size())); in IsNetworkingEnabled()
263 if (devInfos.empty()) { in IsNetworkingEnabled()
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/task/include/ |
| H A D | mock_online_task.h | 32 void SetOnLineDevInfos(std::vector<MockDevInfo> devInfos);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | runtime_config.cpp | 134 void RuntimeConfig::NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) in NotifyDBInfos() argument
136 RuntimeContext::GetInstance()->NotifyDBInfos(devInfos, dbInfos); in NotifyDBInfos()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | runtime_config.h | 64 … DB_API static void NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | runtime_context.h | 153 virtual void NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | runtime_context_impl.h | 138 void NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) override;
|
| H A D | runtime_context_impl.cpp | 808 void RuntimeContextImpl::NotifyDBInfos(const DeviceInfos &devInfos, const std::vector<DBInfo> &dbIn… in NotifyDBInfos() argument
812 dbStatusAdapter->NotifyDBInfos(devInfos, dbInfos); in NotifyDBInfos()
|