| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | user_delegate.cpp | 54 std::set<std::string> users; in GetLocalUsers() local
55 deviceUser_.Compute(deviceId, [&users](const auto &key, auto &value) { in GetLocalUsers()
59 for (const auto &user : userMetaData.users) { in GetLocalUsers()
64 users.emplace(std::to_string(user)); in GetLocalUsers()
68 return users; in GetLocalUsers()
83 deviceUser_.Compute(deviceId, [&userStatus](const auto &key, auto &users) { in GetUsers()
84 if (users.empty()) { in GetUsers()
87 for (const auto &user : userMetaData.users) { in GetUsers()
88 users[user.id] = user.isActive; in GetUsers()
91 for (const auto [key, value] : users) { in GetUsers()
122 std::vector<int> users; InitLocalUserMeta() local
[all...] |
| H A D | auth_delegate.cpp | 37 bool IsUserActive(const std::vector<UserStatus> &users, int32_t userId);
65 bool AuthHandlerStub::IsUserActive(const std::vector<UserStatus> &users, int32_t userId) in IsUserActive() argument
67 for (const auto &user : users) { in IsUserActive()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/ |
| H A D | account_delegate_default_impl.cpp | 39 bool AccountDelegateDefaultImpl::QueryUsers(std::vector<int> &users) in QueryUsers() argument
42 users = {0}; // default user in QueryUsers()
46 bool AccountDelegateDefaultImpl::QueryForegroundUsers(std::vector<int> &users) in QueryForegroundUsers() argument
49 users = {0}; // default user in QueryForegroundUsers()
|
| H A D | account_delegate_default_impl.h | 26 bool QueryUsers(std::vector<int> &users) override;
27 bool QueryForegroundUsers(std::vector<int> &users) override;
|
| H A D | account_delegate_normal_impl.cpp | 69 bool AccountDelegateNormalImpl::QueryUsers(std::vector<int> &users) in QueryUsers() argument
71 users = {0}; // default user in QueryUsers()
72 return AccountSA::OsAccountManager::QueryActiveOsAccountIds(users) == 0; in QueryUsers()
75 bool AccountDelegateNormalImpl::QueryForegroundUsers(std::vector<int> &users) in QueryForegroundUsers() argument
82 users.push_back(account.localId); in QueryForegroundUsers()
|
| H A D | account_delegate_normal_impl.h | 31 bool QueryUsers(std::vector<int> &users) override;
32 bool QueryForegroundUsers(std::vector<int> &users) override;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| H A D | user_meta_data.cpp | 25 ret = SetValue(node[GET_NAME(users)], users) && ret;
in Marshal()
34 ret = GetValue(node, GET_NAME(users), users) && ret;
in Unmarshal()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/test/ |
| H A D | account_delegate_test.cpp | 210 * @tc.desc: query users
217 std::vector<int32_t> users; in HWTEST_F() local
218 AccountDelegate::GetInstance()->QueryUsers(users); in HWTEST_F()
219 EXPECT_GT(users.size(), 0); in HWTEST_F()
224 * @tc.desc: query users
254 * @tc.desc: query foreground users
261 std::vector<int32_t> users; in HWTEST_F() local
262 EXPECT_TRUE(AccountDelegate::GetInstance()->QueryForegroundUsers(users)); in HWTEST_F()
265 EXPECT_EQ(accounts.size(), users.size()); in HWTEST_F()
266 for (int i = 0; i < users in HWTEST_F()
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/test/unittest/ |
| H A D | session_manager_test.cpp | 81 userMetaData.users = { status };
in SetUpTestCase()
83 userMetaData.users.emplace_back(status);
in SetUpTestCase()
151 std::vector<std::string> users;
in HWTEST_F() local
155 recvHandler->ParseHeadData(data.get(), routeHeadSize, parseSize, users);
in HWTEST_F()
157 ASSERT_EQ(users.size(), 0);
in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_kv_syncer_test.cpp | 82 g_CloudSyncoption.users.push_back(USER_ID); in SetUpTestCase()
171 std::set<std::string> userSet(option.users.begin(), option.users.end()); in BlockSync()
575 * @tc.desc: Test sync data with multiple users.
587 syncOption.users.push_back(USER_ID); in HWTEST_F()
588 syncOption.users.push_back(USER_ID_2); in HWTEST_F()
640 syncOption.users.push_back(USER_ID); in HWTEST_F()
641 syncOption.users.push_back(USER_ID_2); in HWTEST_F()
649 syncOption.users.clear(); in HWTEST_F()
650 syncOption.users in HWTEST_F()
[all...] |
| H A D | distributeddb_cloud_kv_test.cpp | 69 bool CheckUserSyncInfo(const vector<std::string> users, const vector<DBStatus> userStatus,
90 g_CloudSyncoption.users.push_back(USER_ID); in SetUpTestCase()
177 std::set<std::string> userSet(option.users.begin(), option.users.end()); in BlockSync()
273 std::set<std::string> userSet(option.users.begin(), option.users.end()); in SyncAndGetProcessInfo()
293 bool DistributedDBCloudKvTest::CheckUserSyncInfo(const vector<std::string> users, const vector<DBStatus> userStatus, in CheckUserSyncInfo() argument
298 if ((idx >= users.size()) || (idx >= userStatus.size()) || (idx >= userExpectInfo.size())) { in CheckUserSyncInfo()
302 if (user.compare(0, user.length(), users[idx]) != 0) { in CheckUserSyncInfo()
626 option.users in HWTEST_F()
[all...] |
| H A D | distributeddb_cloud_kvstore_test.cpp | 69 bool CheckUserSyncInfo(const vector<std::string> users, const vector<DBStatus> userStatus,
90 g_CloudSyncoption.users.push_back(USER_ID); in SetUpTestCase()
177 std::set<std::string> userSet(option.users.begin(), option.users.end()); in BlockSync()
273 std::set<std::string> userSet(option.users.begin(), option.users.end()); in SyncAndGetProcessInfo()
293 bool DistributedDBCloudKvStoreTest::CheckUserSyncInfo(const vector<std::string> users, in CheckUserSyncInfo() argument
298 if ((idx >= users.size()) || (idx >= userStatus.size()) || (idx >= userExpectInfo.size())) { in CheckUserSyncInfo()
302 if (user.compare(0, user.length(), users[idx]) != 0) { in CheckUserSyncInfo()
374 option.users in HWTEST_F()
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/account/ |
| H A D | account_delegate.h | 66 API_EXPORT virtual bool QueryUsers(std::vector<int> &users) = 0;
67 API_EXPORT virtual bool QueryForegroundUsers(std::vector<int> &users) = 0;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | cloud_service_impl.cpp | 366 std::vector<int32_t> users; in DoKvCloudSync() local
368 users.emplace_back(userId); in DoKvCloudSync()
370 Account::GetInstance()->QueryForegroundUsers(users); in DoKvCloudSync()
372 for (auto user : users) { in DoKvCloudSync()
403 std::vector<int32_t> users; in NotifyDataChange() local
405 users.emplace_back(userId); in NotifyDataChange()
407 Account::GetInstance()->QueryForegroundUsers(users); in NotifyDataChange()
409 for (auto user : users) { in NotifyDataChange()
632 std::vector<int> users; in OnInitialize() local
633 Account::GetInstance()->QueryUsers(users); in OnInitialize()
691 std::vector<int32_t> users; OnReady() local
709 std::vector<int32_t> users; Offline() local
865 std::vector<int32_t> users; GenTask() local
975 std::vector<int32_t> users; GetSchema() local
[all...] |
| H A D | sync_manager.cpp | 521 const std::vector<int32_t> &users, const Database &schemaDatabase)
529 for (auto &activeUser : users) {
572 std::vector<int32_t> users{};
575 AccountDelegate::GetInstance()->QueryForegroundUsers(users);
577 users.push_back(user);
579 if (!users.empty()) {
580 info.user = users[0];
590 std::map<uint32_t, GeneralStore::BindInfo> bindInfos = GetBindInfos(meta, users, dbMeta);
591 if (mustBind && bindInfos.size() != users.size()) {
829 std::vector<int32_t> users;
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | process_communicator_impl.cpp | 244 const uint8_t *data, uint32_t dataLen, uint32_t &headLen, std::vector<std::string> &users) in CheckAndGetDataHeadInfo()
256 auto ret = handler->ParseHeadData(data, dataLen, headLen, users); in CheckAndGetDataHeadInfo()
261 if (users.empty()) { in CheckAndGetDataHeadInfo()
265 ZLOGD("ok, result:%{public}zu, user:%{public}s", users.size(), users.front().c_str()); in CheckAndGetDataHeadInfo()
243 CheckAndGetDataHeadInfo( const uint8_t *data, uint32_t dataLen, uint32_t &headLen, std::vector<std::string> &users) CheckAndGetDataHeadInfo() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/communicator/ |
| H A D | route_head_handler.h | 29 const uint8_t *data, uint32_t totalLen, uint32_t &headSize, std::vector<std::string> &users) = 0;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/ |
| H A D | user_meta_data.h | 37 std::vector<UserStatus> users;
member in OHOS::DistributedData::final
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer_extend.cpp | 485 std::vector<std::string> users; in GenerateCompensatedSync() local
486 int errCode = storageProxy_->GetCompensatedSyncQuery(syncQuery, users); in GenerateCompensatedSync()
495 taskInfo.users.clear(); in GenerateCompensatedSync()
498 auto it = std::find(users.begin(), users.end(), user); in GenerateCompensatedSync()
499 if (it != users.end()) { in GenerateCompensatedSync()
500 taskInfo.users.push_back(user); in GenerateCompensatedSync()
847 cloudTaskInfos_[beMergeTask].users); in TryMergeTask()
906 std::set<std::string> users; in SwapTwoTaskAndCopyTable() local
907 users in SwapTwoTaskAndCopyTable()
[all...] |
| H A D | process_notifier.h | 26 const std::vector<std::string> &users);
|
| H A D | process_notifier.cpp | 33 const std::vector<std::string> &devices, const std::vector<std::string> &users) in Init()
37 for (const auto &user : users) { in Init()
32 Init(const std::vector<std::string> &tableName, const std::vector<std::string> &devices, const std::vector<std::string> &users) Init() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/ |
| H A D | session_manager.cpp | 47 auto users = UserDelegate::GetInstance().GetRemoteUserStatus(targetDeviceId);
in GetSession() local
68 for (const auto &user : users) {
in GetSession()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 563 std::set<std::string> userSet(option.users.begin(), option.users.end()); in FillSyncInfo()
564 info.users = std::vector<std::string>(userSet.begin(), userSet.end()); in FillSyncInfo()
573 if (option.users.empty()) { in CheckSyncOption()
587 for (const auto &user : option.users) { in CheckSyncOption()
|
| /foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/ |
| H A D | RdbstorePredicatesJoinJsunit.test.js | 74 const users = [
83 users.forEach((user) => {
|
| /foundation/distributeddatamgr/relational_store/test/js/rdb/unittest/src/ |
| H A D | RdbstorePredicatesJoinJsunit.test.js | 70 const users = [
79 users.forEach((user) => {
|