openharmony/distributeddatamgr_datamgr_service
1
0
Fork 0
mirror of https://gitee.com/openharmony/distributeddatamgr_datamgr_service synced 2024-11-27 09:01:45 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

!2168 补充ObjectManagerTest Tdd用例

Browse Source 
Merge pull request !2168 from 郭琦11/master
This commit is contained in:
openharmony_ci 2024-08-22 11:39:17 +00:00 committed by Gitee
commit e3ded567a4
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
1 changed files with 51 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
services/distributeddataservice/service/test/object_manager_test.cpp
View File

@ -21,6 +21,7 @@
#include "executor_pool.h"
#include "object_types.h"
#include "kv_store_nb_delegate_mock.h"
#include <ipc_skeleton.h>
using namespace testing::ext;
using namespace OHOS::DistributedObject;
@ -840,4 +841,53 @@ HWTEST_F(ObjectManagerTest, PushAssets001, TestSize.Level0)
auto result = manager->PushAssets(100, appId_, sessionId_, data, deviceId_);
ASSERT_EQ(result, DistributedObject::OBJECT_SUCCESS);
}
} // namespace OHOS::Test
/**
* @tc.name: AddNotifier001
* @tc.desc: AddNotifie and DeleteNotifier test.
* @tc.type: FUNC
*/
HWTEST_F(ObjectManagerTest, AddNotifier001, TestSize.Level0)
{
auto syncManager = SequenceSyncManager::GetInstance();
std::function<void(const std::map<std::string, int32_t> &results)> func;
func = [](const std::map<std::string, int32_t> &results) {
return results;
};
auto sequenceId_ = syncManager->AddNotifier(userId_, func);
auto result = syncManager->DeleteNotifier(sequenceId_, userId_);
ASSERT_EQ(result, SequenceSyncManager::SUCCESS_USER_HAS_FINISHED);
}
/**
* @tc.name: AddNotifier002
* @tc.desc: AddNotifie and DeleteNotifier test.
* @tc.type: FUNC
*/
HWTEST_F(ObjectManagerTest, AddNotifier002, TestSize.Level0)
{
auto syncManager = SequenceSyncManager::GetInstance();
std::function<void(const std::map<std::string, int32_t> &results)> func;
func = [](const std::map<std::string, int32_t> &results) {
return results;
};
auto sequenceId = syncManager->AddNotifier(userId_, func);
ASSERT_NE(sequenceId, sequenceId_);
auto result = syncManager->DeleteNotifier(sequenceId_, userId_);
ASSERT_EQ(result, SequenceSyncManager::ERR_SID_NOT_EXIST);
}
/**
* @tc.name: BindAsset 001
* @tc.desc: BindAsset test.
* @tc.type: FUNC
*/
HWTEST_F(ObjectManagerTest, BindAsset001, TestSize.Level0)
{
auto manager = ObjectStoreManager::GetInstance();
std::string bundleName = "BindAsset";
uint32_t tokenId = IPCSkeleton::GetCallingTokenID();
auto result = manager->BindAsset(tokenId, bundleName, sessionId_, assetValue_, assetBindInfo_);
ASSERT_EQ(result, DistributedObject::OBJECT_DBSTATUS_ERROR);
}
} // namespace OHOS::Test