openharmony/ability_dmsfwk
1
0
Fork 0
mirror of https://gitee.com/openharmony/ability_dmsfwk synced 2024-11-22 22:09:58 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

codecheck

Browse Source 
Signed-off-by: MisterE <smart_e@126.com>
This commit is contained in:
MisterE 2024-11-19 15:15:25 +08:00
commit bbe7526243
2 changed files with 74 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
services/dtbschedmgr/test/BUILD.gn
View File

@ -34,6 +34,7 @@ config("test_config") {
"${distributed_service}/dtbschedmgr/include/continue/state/sink_state",
"${distributed_service}/dtbschedmgr/include/distributedWant",
"${distributed_service}/dtbschedmgr/include/softbus_adapter/transport",
"${distributed_service}/dtbschedmgr/include/mission",
"${distributed_service}/dtbschedmgr/test/unittest",
"${dms_path}/common/include",
"${dms_path}/interfaces/innerkits/distributed_event/include",

73
services/dtbschedmgr/test/unittest/continue/dsched_continue_test.cpp
View File

@ -20,6 +20,7 @@
#include "dtbschedmgr_log.h"
#include "softbus_error_code.h"
#include "test_log.h"
#include "distributed_bm_storage.h"
using namespace testing;
using namespace testing::ext;
@ -30,6 +31,14 @@ namespace DistributedSchedule {
namespace {
const std::string BASEDIR = "/data/service/el1/public/database/DistributedSchedule";
const std::string BUNDLEMAME_1 = "bundleName";
const std::string CONTINUE_TYPE1 = "continueType1";
const std::string CONTINUE_TYPE2 = "continueType2";
const std::string CONTINUE_TYPE1_QUICK = "continueType1_ContinueQuickStart";
const std::string MODULE_NAME1 = "moduleName1";
const std::string MODULE_NAME2 = "moduleName2";
const std::string MODULE_NAME3 = "moduleName3";
const std::string ABILITY_NAME_SAME_AS_CONTINUE_TYPE = CONTINUE_TYPE1;
const std::string ABILITY_NAME_DIFF_AS_CONTINUE_TYPE = "ability";
const int32_t WAITTIME = 2000;
const uint32_t DSCHED_BUFFER_SIZE = 1024;
}
@ -602,6 +611,70 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0017_1, TestSize.Level0)
usleep(WAITTIME);
}
HWTEST_F(DSchedContinueTest, DSchedContinueTest_0017_2, TestSize.Level0)
{
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0017_2 begin" << std::endl;
std::string deviceId = "123";
std::string bundleName = "test";
int32_t subType = CONTINUE_PULL;
int32_t direction = CONTINUE_SINK;
sptr<IRemoteObject> callback = nullptr;
auto info = DSchedContinueInfo(deviceId, bundleName, deviceId, bundleName, "");
auto conti = std::make_shared<DSchedContinue>(subType, direction, callback, info);
conti->Init();
auto cmd = std::make_shared<DSchedContinueDataCmd>();
EXPECT_CALL(*dmsStoreMock, GetLocalDeviceId(_)).WillOnce(Return(true));
// no continueType, diff module
cmd->continueType_ = CONTINUE_TYPE1;
cmd->want_.SetElementName("", BUNDLEMAME_1, ABILITY_NAME_SAME_AS_CONTINUE_TYPE, MODULE_NAME2);
int32_t ret = conti->UpdateElementInfo(cmd);
EXPECT_EQ(ret, CAN_NOT_FOUND_MODULE_ERR);
// no continueType, same module
cmd->continueType_ = CONTINUE_TYPE1;
cmd->want_.SetElementName("", BUNDLEMAME_1, ABILITY_NAME_SAME_AS_CONTINUE_TYPE, MODULE_NAME1);
ret = conti->UpdateElementInfo(cmd);
EXPECT_EQ(ret, ERR_OK);
// no continueType with quick start, same module
cmd->continueType_ = CONTINUE_TYPE1_QUICK;
cmd->want_.SetElementName("", BUNDLEMAME_1, ABILITY_NAME_SAME_AS_CONTINUE_TYPE, MODULE_NAME1);
ret = conti->UpdateElementInfo(cmd);
EXPECT_EQ(ret, ERR_OK);
// has continueType, same module
cmd->continueType_ = CONTINUE_TYPE2;
cmd->want_.SetElementName("", BUNDLEMAME_1, ABILITY_NAME_DIFF_AS_CONTINUE_TYPE, MODULE_NAME2);
ret = conti->UpdateElementInfo(cmd);
EXPECT_EQ(ret, ERR_OK);
// has continueType, diff module
cmd->continueType_ = CONTINUE_TYPE2;
cmd->want_.SetElementName("", BUNDLEMAME_1, ABILITY_NAME_DIFF_AS_CONTINUE_TYPE, MODULE_NAME1);
ret = conti->UpdateElementInfo(cmd);
EXPECT_EQ(ret, ERR_OK);
// has continueType, no module
cmd->continueType_ = CONTINUE_TYPE2;
cmd->want_.SetElementName("", BUNDLEMAME_1, ABILITY_NAME_DIFF_AS_CONTINUE_TYPE, MODULE_NAME3);
ret = conti->UpdateElementInfo(cmd);
EXPECT_EQ(ret, CAN_NOT_FOUND_MODULE_ERR);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0017_2 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
bool DmsBmStorage::GetDistributedBundleInfo(const std::string &networkId, const std::string &bundleName,
DmsBundleInfo &distributeBundleInfo)
{
DmsAbilityInfo info2;
info2.continueType = {CONTINUE_TYPE2};
info2.moduleName = MODULE_NAME2;
info2.abilityName = ABILITY_NAME_DIFF_AS_CONTINUE_TYPE;
distributeBundleInfo.dmsAbilityInfos.push_back(info2);
DmsAbilityInfo info1;
info1.continueType = {CONTINUE_TYPE1};
info1.moduleName = MODULE_NAME1;
info1.abilityName = ABILITY_NAME_SAME_AS_CONTINUE_TYPE;
distributeBundleInfo.dmsAbilityInfos.push_back(info1);
return true;
}
/**
* @tc.name: DSchedContinueTest_0018_1
* @tc.desc: ExecuteNotifyComplete