| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_test.cpp | 42 onlines.onlineDevices.insert(target); in HandleConnectChange()
46 onlines.onlineDevices.erase(target); in HandleConnectChange()
185 EXPECT_EQ(onlineForAA.onlineDevices.size(), static_cast<size_t>(0));
192 EXPECT_EQ(onlineForAA.onlineDevices.size(), static_cast<size_t>(0));
203 EXPECT_EQ(onlineForAA.onlineDevices.size(), static_cast<size_t>(0));
204 EXPECT_EQ(onlineForBB.onlineDevices.size(), static_cast<size_t>(0));
211 EXPECT_EQ(onlineForAA.onlineDevices.size(), static_cast<size_t>(0));
212 EXPECT_EQ(onlineForBB.onlineDevices.size(), static_cast<size_t>(0));
422 onlineForEE.onlineDevices.clear(); in TestRemoteRestart()
429 while (onlineForEE.onlineDevices.size() != 1 && reTryTimes > 0) { in TestRemoteRestart()
[all …]
|
| H A D | distributeddb_communicator_common.h | 36 std::set<std::string> onlineDevices; member
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_distributed/src/database_manage/ |
| H A D | medialibrary_sync_operation.cpp | 265 vector<string> onlineDevices; in SyncPullTable() local
266 GetOnlineDevices(syncOpts.bundleName, devices, onlineDevices); in SyncPullTable()
267 if (onlineDevices.size() == 0) { in SyncPullTable()
272 predicate.InDevices(onlineDevices); in SyncPullTable()
376 vector<string> onlineDevices; in SyncPushTable() local
377 GetOnlineDevices(syncOpts.bundleName, devices, onlineDevices); in SyncPushTable()
378 if (onlineDevices.size() == 0) { in SyncPushTable()
382 predicate.InDevices(onlineDevices); in SyncPushTable()
403 vector<string> &onlineDevices) in GetOnlineDevices() argument
418 onlineDevices.push_back(device); in GetOnlineDevices()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/br/optimization/ |
| H A D | auth_session_test2.cpp | 83 NodeBasicInfo *onlineDevices = nullptr; in WaitDeviceOnline() local
85 ret = GetAllNodeDeviceInfo(pkgName, &onlineDevices, &onlineNum); in WaitDeviceOnline()
88 FreeNodeInfo(onlineDevices); in WaitDeviceOnline()
94 networkIdSet_.insert(string(onlineDevices[i].networkId)); in WaitDeviceOnline()
95 cout << "online idex " << i << " : " << string(onlineDevices[i].networkId) << endl; in WaitDeviceOnline()
97 FreeNodeInfo(onlineDevices); in WaitDeviceOnline()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/br/file/ |
| H A D | proxy_session_file_test.cpp | 109 NodeBasicInfo *onlineDevices = nullptr; in WaitDeviceOnline() local
111 ret = GetAllNodeDeviceInfo(pkgName, &onlineDevices, &onlineNum); in WaitDeviceOnline()
114 FreeNodeInfo(onlineDevices); in WaitDeviceOnline()
120 networkIdSet_.insert(string(onlineDevices[i].networkId)); in WaitDeviceOnline()
121 cout << "online idex " << i << " : " << string(onlineDevices[i].networkId) << endl; in WaitDeviceOnline()
123 FreeNodeInfo(onlineDevices); in WaitDeviceOnline()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/distributed_stream/ |
| H A D | distributed_stream_test.cpp | 190 NodeBasicInfo *onlineDevices = nullptr; in SetUpTestCase() local
192 int ret = GetAllNodeDeviceInfo(TEST_PKG_NAME.c_str(), &onlineDevices, &onlineNum); in SetUpTestCase()
197 networkIdSet_.insert(string(onlineDevices[i].networkId)); in SetUpTestCase()
198 cout << "online index " << i << " : " << string(onlineDevices[i].networkId) << endl; in SetUpTestCase()
200 FreeNodeInfo(onlineDevices); in SetUpTestCase()
|
| /ohos5.0/foundation/deviceprofile/device_info_manager/old/services/core/src/dbstorage/ |
| H A D | device_profile_storage.cpp | 341 std::vector<std::string> onlineDevices = GetOnlineDevices(); in CheckTrustDeviceList() local
343 auto iter = find(onlineDevices.begin(), onlineDevices.end(), deviceId); in CheckTrustDeviceList()
344 if (iter != onlineDevices.end()) { in CheckTrustDeviceList()
|
| H A D | device_profile_storage_manager.cpp | 476 std::list<std::shared_ptr<DeviceInfo>> onlineDevices; in CheckSyncOption() local
477 DpDeviceManager::GetInstance().GetDeviceList(onlineDevices); in CheckSyncOption()
479 for (const auto& onlineDevice : onlineDevices) { in CheckSyncOption()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator_aggregator.cpp | 337 std::set<std::string> onlineDevices; in GetOnlineDevices() local
339 onlineDevices.insert(item.first); in GetOnlineDevices()
341 return onlineDevices; in GetOnlineDevices()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_distributed/include/database_manage/ |
| H A D | medialibrary_sync_operation.h | 75 std::vector<std::string> &onlineDevices);
|