openharmony/ability_dmsfwk
1
0
Fork 0
mirror of https://gitee.com/openharmony/ability_dmsfwk synced 2024-11-23 06:20:07 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

add service ut

Browse Source 
Signed-off-by: 师皓杰 <shihaojie10@huawei.com>
This commit is contained in:
师皓杰 2024-11-19 16:51:02 +08:00
parent 917bf8d784
commit 504e222a18
3 changed files with 165 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

99
services/dtbschedmgr/test/unittest/distributed_sched_service_second_test.cpp
View File

@ -1617,5 +1617,104 @@ HWTEST_F(DistributedSchedServiceSecondTest, NotifyDSchedEventResultFromRemote_00
EXPECT_EQ(ret, ERR_OK); EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DistributedSchedServiceSecondTest NotifyDSchedEventResultFromRemote_001 end" << std::endl; DTEST_LOG << "DistributedSchedServiceSecondTest NotifyDSchedEventResultFromRemote_001 end" << std::endl;
} }
/**
* @tc.name: ContinueLocalMission_001
* @tc.desc: ContinueLocalMission
* @tc.type: FUNC
*/
HWTEST_F(DistributedSchedServiceSecondTest, ContinueLocalMission_001, TestSize.Level3)
{
DTEST_LOG << "DistributedSchedServiceSecondTest ContinueLocalMission_001 start" << std::endl;
std::string dstDeviceId;
int32_t missionId = 0;
OHOS::AAFwk::WantParams wantParams;
DistributedSchedService::GetInstance().dschedContinuation_ = nullptr;
int32_t ret = DistributedSchedService::GetInstance().ContinueLocalMission(
dstDeviceId, missionId, nullptr, wantParams);
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
ret = DistributedSchedService::GetInstance().ContinueAbilityWithTimeout(
dstDeviceId, missionId, nullptr, 0);
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DistributedSchedService::GetInstance().NotifyDSchedEventCallbackResult(FOREGROUND);
ret = DistributedSchedService::GetInstance().NotifyContinuationResultFromRemote(
FOREGROUND, true, dstDeviceId);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DistributedSchedServiceSecondTest ContinueLocalMission_001 end" << std::endl;
}
/**
* @tc.name: GetContinueInfo_001
* @tc.desc: GetContinueInfo
* @tc.type: FUNC
*/
HWTEST_F(DistributedSchedServiceSecondTest, GetContinueInfo_001, TestSize.Level3)
{
DTEST_LOG << "DistributedSchedServiceSecondTest GetContinueInfo_001 start" << std::endl;
std::string dstNetworkId;
std::string srcNetworkId;
DistributedSchedService::GetInstance().dschedContinuation_ = nullptr;
int32_t ret = DistributedSchedService::GetInstance().GetContinueInfo(dstNetworkId, srcNetworkId);
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DistributedSchedService::GetInstance().dschedContinuation_ = std::make_shared<DSchedContinuation>();
ret = DistributedSchedService::GetInstance().GetContinueInfo(dstNetworkId, srcNetworkId);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DistributedSchedServiceSecondTest GetContinueInfo_001 end" << std::endl;
}
/**
* @tc.name: GetDSchedEventInfo_001
* @tc.desc: GetDSchedEventInfo
* @tc.type: FUNC
*/
HWTEST_F(DistributedSchedServiceSecondTest, GetDSchedEventInfo_001, TestSize.Level3)
{
DTEST_LOG << "DistributedSchedServiceSecondTest GetDSchedEventInfo_001 start" << std::endl;
std::vector<EventNotify> events;
int32_t ret = DistributedSchedService::GetInstance().GetDSchedEventInfo(DMS_CONTINUE, events);
EXPECT_EQ(ret, ERR_OK);
ret = DistributedSchedService::GetInstance().GetDSchedEventInfo(DMS_ALL, events);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DistributedSchedServiceSecondTest GetDSchedEventInfo_001 end" << std::endl;
}
/**
* @tc.name: RegisterDSchedEventListener_001
* @tc.desc: RegisterDSchedEventListener
* @tc.type: FUNC
*/
HWTEST_F(DistributedSchedServiceSecondTest, RegisterDSchedEventListener_001, TestSize.Level3)
{
DTEST_LOG << "DistributedSchedServiceSecondTest RegisterDSchedEventListener_001 start" << std::endl;
DistributedSchedService::GetInstance().dschedContinuation_ = nullptr;
DistributedSchedService::GetInstance().collaborateCbMgr_ = nullptr;
int32_t ret = DistributedSchedService::GetInstance().RegisterDSchedEventListener(DMS_CONTINUE, nullptr);
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
ret = DistributedSchedService::GetInstance().UnRegisterDSchedEventListener(DMS_CONTINUE, nullptr);
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DistributedSchedService::GetInstance().dschedContinuation_ = std::make_shared<DSchedContinuation>();
ret = DistributedSchedService::GetInstance().RegisterDSchedEventListener(DMS_CONTINUE, nullptr);
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
ret = DistributedSchedService::GetInstance().UnRegisterDSchedEventListener(DMS_CONTINUE, nullptr);
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DistributedSchedService::GetInstance().collaborateCbMgr_ = std::make_shared<DSchedCollaborationCallbackMgr>();
DistributedSchedService::GetInstance().collaborateCbMgr_->Init();
auto callback = GetDSchedService();
ret = DistributedSchedService::GetInstance().RegisterDSchedEventListener(DMS_COLLABORATION, callback);
EXPECT_EQ(ret, ERR_OK);
ret = DistributedSchedService::GetInstance().UnRegisterDSchedEventListener(DMS_COLLABORATION, callback);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DistributedSchedServiceSecondTest RegisterDSchedEventListener_001 end" << std::endl;
}
} }
} }

62
services/dtbschedmgr/test/unittest/dtbschedmgr_device_info_storage_test.cpp
View File

@ -444,12 +444,70 @@ HWTEST_F(DtbschedmgrDeviceInfoStorageTest, GetNetworkIdList_001, TestSize.Level3
std::string netWorkId = "netWorkId"; std::string netWorkId = "netWorkId";
devices = DtbschedmgrDeviceInfoStorage::GetInstance().GetNetworkIdList(); devices = DtbschedmgrDeviceInfoStorage::GetInstance().GetNetworkIdList();
EXPECT_EQ(devices.empty(), true); EXPECT_EQ(devices.empty(), true);
std::shared_ptr<DmsDeviceInfo> deviceInfo = std::make_shared<DmsDeviceInfo>("deviceName", 0, "netWorkId"); std::shared_ptr<DmsDeviceInfo> deviceInfo = nullptr;
DtbschedmgrDeviceInfoStorage::GetInstance().remoteDevices_[netWorkId] = deviceInfo;
devices = DtbschedmgrDeviceInfoStorage::GetInstance().GetNetworkIdList();
EXPECT_EQ(devices.empty(), true);
deviceInfo = std::make_shared<DmsDeviceInfo>("deviceName", 0, "netWorkId");
DtbschedmgrDeviceInfoStorage::GetInstance().remoteDevices_[netWorkId] = deviceInfo; DtbschedmgrDeviceInfoStorage::GetInstance().remoteDevices_[netWorkId] = deviceInfo;
devices = DtbschedmgrDeviceInfoStorage::GetInstance().GetNetworkIdList(); devices = DtbschedmgrDeviceInfoStorage::GetInstance().GetNetworkIdList();
EXPECT_EQ(devices.empty(), false); EXPECT_EQ(devices.empty(), false);
DTEST_LOG << "DtbschedmgrDeviceInfoStorageTest GetNetworkIdList_001 end" << std::endl; DTEST_LOG << "DtbschedmgrDeviceInfoStorageTest GetNetworkIdList_001 end" << std::endl;
} }
/**
* @tc.name: InitNetworkIdManager_001
* @tc.desc: test InitNetworkIdManager
* @tc.type: FUNC
*/
HWTEST_F(DtbschedmgrDeviceInfoStorageTest, InitNetworkIdManager_001, TestSize.Level3)
{
DTEST_LOG << "DtbschedmgrDeviceInfoStorageTest InitNetworkIdManager_001 start" << std::endl;
bool ret = DtbschedmgrDeviceInfoStorage::GetInstance().InitNetworkIdManager(nullptr);
EXPECT_EQ(ret, false);
DTEST_LOG << "DtbschedmgrDeviceInfoStorageTest InitNetworkIdManager_001 end" << std::endl;
}
/**
* @tc.name: RegisterUuidNetworkIdMap_001
* @tc.desc: test RegisterUuidNetworkIdMap
* @tc.type: FUNC
*/
HWTEST_F(DtbschedmgrDeviceInfoStorageTest, RegisterUuidNetworkIdMap_001, TestSize.Level3)
{
DTEST_LOG << "DtbschedmgrDeviceInfoStorageTest RegisterUuidNetworkIdMap_001 start" << std::endl;
std::string networkId = "networkId";
EXPECT_NO_FATAL_FAILURE(DtbschedmgrDeviceInfoStorage::GetInstance().RegisterUuidNetworkIdMap(networkId));
EXPECT_NO_FATAL_FAILURE(DtbschedmgrDeviceInfoStorage::GetInstance().UnregisterUuidNetworkIdMap(networkId));
EXPECT_NO_FATAL_FAILURE(DtbschedmgrDeviceInfoStorage::GetInstance().DeviceOnlineNotify(nullptr));
networkId = "";
EXPECT_NO_FATAL_FAILURE(DtbschedmgrDeviceInfoStorage::GetInstance().DeviceOfflineNotify(networkId));
DTEST_LOG << "DtbschedmgrDeviceInfoStorageTest RegisterUuidNetworkIdMap_001 end" << std::endl;
}
/**
* @tc.name: GetDeviceName_002
* @tc.desc: test GetDeviceName
* @tc.type: FUNC
*/
HWTEST_F(DtbschedmgrDeviceInfoStorageTest, GetDeviceName_002, TestSize.Level3)
{
DTEST_LOG << "DtbschedmgrDeviceInfoStorageTest GetDeviceName_002 start" << std::endl;
DtbschedmgrDeviceInfoStorage::GetInstance().remoteDevices_.clear();
std::string netWorkId = "netWorkId";
std::shared_ptr<DmsDeviceInfo> deviceInfo = nullptr;
DtbschedmgrDeviceInfoStorage::GetInstance().remoteDevices_[netWorkId] = deviceInfo;
std::string str = DtbschedmgrDeviceInfoStorage::GetInstance().GetDeviceName(netWorkId);
EXPECT_EQ(str, "");
DtbschedmgrDeviceInfoStorage::GetInstance().remoteDevices_.clear();
deviceInfo = std::make_shared<DmsDeviceInfo>("deviceName", 0, "netWorkId");
DtbschedmgrDeviceInfoStorage::GetInstance().remoteDevices_[netWorkId] = deviceInfo;
str = DtbschedmgrDeviceInfoStorage::GetInstance().GetDeviceName(netWorkId);
EXPECT_EQ(str, "deviceName");
DTEST_LOG << "DtbschedmgrDeviceInfoStorageTest GetDeviceName_002 end" << std::endl;
}
} // namespace DistributedSchedule } // namespace DistributedSchedule
} // namespace OHOS } // namespace OHOS

6
services/dtbschedmgr/test/unittest/mission/dms_continue_manager_test.cpp
View File

@ -23,6 +23,7 @@
#include "mission/dms_continue_recv_manager.h" #include "mission/dms_continue_recv_manager.h"
#undef private #undef private
#include "multi_user_manager.h" #include "multi_user_manager.h"
#include "softbus_adapter/softbus_adapter.h"
#include "test_log.h" #include "test_log.h"
using namespace testing; using namespace testing;
@ -49,6 +50,11 @@ constexpr int32_t DBMS_RETRY_MAX_TIME = 5;
constexpr uint8_t DMS_FOCUSED_TYPE = 0x00; constexpr uint8_t DMS_FOCUSED_TYPE = 0x00;
} }
int32_t SoftbusAdapter::SendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer)
{
return CAN_NOT_FOUND_ABILITY_ERR;
}
void DMSContinueManagerTest::SetUpTestCase() void DMSContinueManagerTest::SetUpTestCase()
{ {
} }