Home
last modified time | relevance | path

Searched refs:devicesMap (Results 1 – 18 of 18) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_relational_sync_test.cpp229 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonf1fa0da10302()
248 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonf1fa0da10402()
267 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonf1fa0da10502()
286 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonf1fa0da10602()
308 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonf1fa0da10702()
327 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonf1fa0da10802()
352 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonf1fa0da10902()
382 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonf1fa0da10a02()
409 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonf1fa0da10b02()
923 for (const auto &itDev : devicesMap) { in __anonf1fa0da12402()
[all …]
H A Ddistributeddb_interfaces_relational_test.cpp1253 [&devices](const std::map<std::string, std::vector<TableStatus>> &devicesMap) { in __anonc71ddc450302() argument
1254 EXPECT_EQ(devicesMap.size(), devices.size()); in __anonc71ddc450302()
1255 EXPECT_EQ(devicesMap.at(DEVICE_B)[0].status, OK); in __anonc71ddc450302()
1308 [&devices](const std::map<std::string, std::vector<TableStatus>> &devicesMap) { in TestRemoveDeviceDataWithCallback() argument
1309 ASSERT_EQ(devicesMap.size(), devices.size()); in TestRemoveDeviceDataWithCallback()
1310 EXPECT_EQ(devicesMap.at(DEVICE_B)[0].status, OK); in TestRemoveDeviceDataWithCallback()
1593 [&devices](const std::map<std::string, std::vector<TableStatus>> &devicesMap) { in ProcessSync() argument
1594 EXPECT_EQ(devicesMap.size(), devices.size()); in ProcessSync()
1595 EXPECT_EQ(devicesMap.at(DEVICE_B)[0].status, OK); in ProcessSync()
1617 EXPECT_EQ(devicesMap.size(), devices.size()); in ProcessSync()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dkvdb_pragma.h58 const std::function<void(const std::map<std::string, int> &devicesMap)> &onComplete,
70 const std::function<void(const std::map<std::string, int> &devicesMap)> &onComplete,
83 std::function<void(const std::map<std::string, int> &devicesMap)> onComplete_;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_relational_syncer.cpp81 …Param.onComplete = [this, subSyncId, syncId, param](const std::map<std::string, int> &devicesMap) { in GenerateEachSyncTask() argument
82 DoOnSubSyncComplete(subSyncId, syncId, param, devicesMap); in GenerateEachSyncTask()
101 const SyncParma &param, const std::map<std::string, int> &devicesMap) in DoOnSubSyncComplete() argument
108 for (const auto &item : devicesMap) { in DoOnSubSyncComplete()
H A Dsingle_ver_relational_syncer.h49 const SyncParma &param, const std::map<std::string, int> &devicesMap);
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/
H A Dkv_store_nb_delegate_mock.h62 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
78 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
85 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
88 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
H A Dkv_store_nb_delegate_mock.cpp127 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, in Sync()
196 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, in Sync()
219 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, in SubscribeRemoteQuery()
226 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, in UnSubscribeRemoteQuery()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_nb_delegate_impl.h87 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
132 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
145 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
150 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
194 … const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete) const;
H A Dkv_store_nb_delegate_impl.cpp546 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, in Sync()
571 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, in Sync()
921 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete) const in OnSyncComplete()
966 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, in SubscribeRemoteQuery()
990 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, in UnSubscribeRemoteQuery()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/
H A Dkv_store_nb_delegate.h152 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
203 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
220 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
225 const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete,
H A Dstore_types.h195 …sCallback = std::function<void(const std::map<std::string, std::vector<TableStatus>> &devicesMap)>;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_relational_multi_user_test.cpp202 const std::map<std::string, std::vector<TableStatus>> &devicesMap) { in CheckSyncTest() argument
203 statusMap = devicesMap; in CheckSyncTest()
221 const std::map<std::string, std::vector<TableStatus>> &devicesMap) { in CheckSyncTest() argument
222 LOGE("call back devicesMap.size = %d", devicesMap.size()); in CheckSyncTest()
223 statusMap2 = devicesMap; in CheckSyncTest()
280 const std::map<std::string, std::vector<TableStatus>> &devicesMap) { in CheckSyncResult() argument
281 statusMap = devicesMap; in CheckSyncResult()
H A Ddistributeddb_relational_ver_p2p_sync_test.cpp336 const std::map<std::string, std::vector<TableStatus>> &devicesMap) { in BlockSync() argument
337 statusMap = devicesMap; in BlockSync()
1144 const std::map<std::string, std::vector<TableStatus>> &devicesMap) { in __anond45d0a2b0602() argument
1145 statusMap = devicesMap; in __anond45d0a2b0602()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dsync_able_kvdb_connection.h66 … const std::function<void(const std::map<std::string, int> &devicesMap)> &onComplete, bool wait);
H A Dsync_able_kvdb_connection.cpp173 const std::function<void(const std::map<std::string, int> &devicesMap)> &onComplete, bool wait) in OnSyncComplete()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include/
H A Disyncer.h40 std::function<void(const std::map<std::string, int> &devicesMap)> onComplete;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dsingle_store_impl.cpp918 auto complete = [observer](const std::map<std::string, DistributedDB::DBStatus> &devicesMap) { in DoClientSync() argument
923 for (auto &[key, dbStatus] : devicesMap) { in DoClientSync()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_manager.cpp891 [this, sequenceId](const std::map<std::string, DistributedDB::DBStatus> &devicesMap) { in SyncOnStore() argument
894 for (auto &item : devicesMap) { in SyncOnStore()