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

!909 修改dschedcontinuestatetest用例异常 beta1

Browse Source 
Merge pull request !909 from 师皓杰/OpenHarmony-5.0-Beta1
This commit is contained in:
openharmony_ci 2024-05-21 10:58:22 +00:00 committed by Gitee
commit 9371b49450
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
5 changed files with 100 additions and 91 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
services/dtbschedmgr/test/unittest/adapter/mmi_adapter_test.cpp
View File

@ -24,6 +24,10 @@ using namespace testing::ext;
namespace OHOS {
namespace DistributedSchedule {
namespace {
const int32_t WAITTIME = 1000;
}
void MMIAdapterTest::SetUpTestCase()
{
DTEST_LOG << "MMIAdapterTest::SetUpTestCase" << std::endl;
@ -37,12 +41,14 @@ void MMIAdapterTest::TearDownTestCase()
void MMIAdapterTest::TearDown()
{
DTEST_LOG << "MMIAdapterTest::TearDown" << std::endl;
usleep(WAITTIME);
MMIAdapter::GetInstance().UnInit();
}
void MMIAdapterTest::SetUp()
{
DTEST_LOG << "MMIAdapterTest::SetUp" << std::endl;
usleep(WAITTIME);
MMIAdapter::GetInstance().Init();
}

9
services/dtbschedmgr/test/unittest/continue/dsched_continue_manager_test.cpp
View File

@ -30,6 +30,7 @@ namespace {
const std::string REMOTE_DEVICEID = "remotedeviceid";
const std::string CONTINUETYPE = "continueType";
constexpr int32_t MISSION_ID = 1;
const int32_t WAITTIME = 2000;
const std::string BUNDLE_NAME = "com.ohos.permissionmanager";
}
@ -45,11 +46,13 @@ void DSchedContinueManagerTest::TearDownTestCase()
void DSchedContinueManagerTest::TearDown()
{
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueManagerTest::TearDown" << std::endl;
}
void DSchedContinueManagerTest::SetUp()
{
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueManagerTest::SetUp" << std::endl;
}
@ -277,8 +280,7 @@ HWTEST_F(DSchedContinueManagerTest, HandleNotifyCompleteContinuation_001, TestSi
DSchedContinueManager::GetInstance().HandleNotifyCompleteContinuation(devId, missionId, false);
DSchedContinueInfo info;
std::shared_ptr<DSchedContinue> ptr = nullptr;
DSchedContinueManager::GetInstance().continues_[info] = ptr;
DSchedContinueManager::GetInstance().continues_[info] = nullptr;
DSchedContinueManager::GetInstance().HandleNotifyCompleteContinuation(devId, missionId, false);
bool ret = DSchedContinueManager::GetInstance().continues_.empty();
EXPECT_EQ(ret, false);
@ -321,7 +323,6 @@ HWTEST_F(DSchedContinueManagerTest, OnContinueEnd_001, TestSize.Level3)
ret = DSchedContinueManager::GetInstance().OnContinueEnd(info);
EXPECT_EQ(ret, ERR_OK);
DSchedContinueManager::GetInstance().UnInit();
DTEST_LOG << "DSchedContinueManagerTest OnContinueEnd_001 end" << std::endl;
}
@ -335,7 +336,6 @@ HWTEST_F(DSchedContinueManagerTest, HandleContinueEnd_001, TestSize.Level3)
DTEST_LOG << "DSchedContinueManagerTest HandleContinueEnd_001 begin" << std::endl;
DSchedContinueInfo info(LOCAL_DEVICEID, "sourceBundleName", REMOTE_DEVICEID, "sinkBundleName",
"continueType");
DSchedContinueManager::GetInstance().UnInit();
DSchedContinueManager::GetInstance().RemoveTimeout(info);
DSchedContinueManager::GetInstance().Init();
@ -351,7 +351,6 @@ HWTEST_F(DSchedContinueManagerTest, HandleContinueEnd_001, TestSize.Level3)
DSchedContinueManager::GetInstance().continues_[info] = ptr;
DSchedContinueManager::GetInstance().HandleContinueEnd(info);
EXPECT_EQ(DSchedContinueManager::GetInstance().cntSource_, 0);
DSchedContinueManager::GetInstance().UnInit();
DTEST_LOG << "DSchedContinueManagerTest HandleContinueEnd_001 end" << std::endl;
}
}

136
services/dtbschedmgr/test/unittest/continue/dsched_continue_state_test.cpp
View File

@ -24,7 +24,9 @@ using namespace testing::ext;
namespace OHOS {
namespace DistributedSchedule {
namespace {
const int32_t WAITTIME = 2000;
}
//DSchedContinueDataStateTest
void DSchedContinueDataStateTest::SetUpTestCase()
{
@ -38,7 +40,7 @@ void DSchedContinueDataStateTest::TearDownTestCase()
void DSchedContinueDataStateTest::TearDown()
{
dataStateTest_ = nullptr;
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueDataStateTest::TearDown" << std::endl;
}
@ -48,6 +50,7 @@ void DSchedContinueDataStateTest::SetUp()
std::shared_ptr<DSchedContinueStateMachine> stateMachine = std::make_shared<DSchedContinueStateMachine>(dContinue);
dataStateTest_ = std::make_shared<DSchedContinueDataState>(stateMachine);
DTEST_LOG << "DSchedContinueDataStateTest::SetUp" << std::endl;
usleep(WAITTIME);
}
std::shared_ptr<DSchedContinue> DSchedContinueDataStateTest::CreateObject()
@ -75,7 +78,7 @@ void DSchedContinueSinkEndStateTest::TearDownTestCase()
void DSchedContinueSinkEndStateTest::TearDown()
{
sinkEndStateTest_ = nullptr;
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueSinkEndStateTest::TearDown" << std::endl;
}
@ -85,6 +88,7 @@ void DSchedContinueSinkEndStateTest::SetUp()
std::shared_ptr<DSchedContinueStateMachine> stateMachine = std::make_shared<DSchedContinueStateMachine>(dContinue);
sinkEndStateTest_ = std::make_shared<DSchedContinueSinkEndState>(stateMachine);
DTEST_LOG << "DSchedContinueSinkEndStateTest::SetUp" << std::endl;
usleep(WAITTIME);
}
std::shared_ptr<DSchedContinue> DSchedContinueSinkEndStateTest::CreateObject()
@ -112,7 +116,7 @@ void DSchedContinueSinkStartStateTest::TearDownTestCase()
void DSchedContinueSinkStartStateTest::TearDown()
{
sinkStartStateTest_ = nullptr;
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueSinkStartStateTest::TearDown" << std::endl;
}
@ -122,6 +126,7 @@ void DSchedContinueSinkStartStateTest::SetUp()
std::shared_ptr<DSchedContinueStateMachine> stateMachine = std::make_shared<DSchedContinueStateMachine>(dContinue);
sinkStartStateTest_ = std::make_shared<DSchedContinueSinkStartState>(stateMachine);
DTEST_LOG << "DSchedContinueSinkStartStateTest::SetUp" << std::endl;
usleep(WAITTIME);
}
std::shared_ptr<DSchedContinue> DSchedContinueSinkStartStateTest::CreateObject()
@ -149,7 +154,7 @@ void DSchedContinueSinkWaitEndStateTest::TearDownTestCase()
void DSchedContinueSinkWaitEndStateTest::TearDown()
{
sinkWaitEndTest_ = nullptr;
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest::TearDown" << std::endl;
}
@ -160,6 +165,7 @@ void DSchedContinueSinkWaitEndStateTest::SetUp()
std::make_shared<DSchedContinueStateMachine>(dContinue);
sinkWaitEndTest_ = std::make_shared<DSchedContinueSinkWaitEndState>(stateMachine);
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest::SetUp" << std::endl;
usleep(WAITTIME);
}
std::shared_ptr<DSchedContinue> DSchedContinueSinkWaitEndStateTest::CreateObject()
@ -187,7 +193,7 @@ void DSchedContinueAbilityStateTest::TearDownTestCase()
void DSchedContinueAbilityStateTest::TearDown()
{
abilityStateTest_ = nullptr;
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueAbilityStateTest::TearDown" << std::endl;
}
@ -198,6 +204,7 @@ void DSchedContinueAbilityStateTest::SetUp()
std::make_shared<DSchedContinueStateMachine>(dContinue);
abilityStateTest_ = std::make_shared<DSchedContinueAbilityState>(stateMachine);
DTEST_LOG << "DSchedContinueAbilityStateTest::SetUp" << std::endl;
usleep(WAITTIME);
}
std::shared_ptr<DSchedContinue> DSchedContinueAbilityStateTest::CreateObject()
@ -225,7 +232,7 @@ void DSchedContinueEndStateTest::TearDownTestCase()
void DSchedContinueEndStateTest::TearDown()
{
srcEndStateTest_ = nullptr;
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueEndStateTest::TearDown" << std::endl;
}
@ -236,6 +243,7 @@ void DSchedContinueEndStateTest::SetUp()
std::make_shared<DSchedContinueStateMachine>(dContinue);
srcEndStateTest_ = std::make_shared<DSchedContinueEndState>(stateMachine);
DTEST_LOG << "DSchedContinueEndStateTest::SetUp" << std::endl;
usleep(WAITTIME);
}
std::shared_ptr<DSchedContinue> DSchedContinueEndStateTest::CreateObject()
@ -263,7 +271,7 @@ void DSchedContinueSourceStartStateTest::TearDownTestCase()
void DSchedContinueSourceStartStateTest::TearDown()
{
srcStartStateTest_ == nullptr;
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueSourceStartStateTest::TearDown" << std::endl;
}
@ -274,6 +282,7 @@ void DSchedContinueSourceStartStateTest::SetUp()
std::make_shared<DSchedContinueStateMachine>(dContinue);
srcStartStateTest_ = std::make_shared<DSchedContinueSourceStartState>(stateMachine);
DTEST_LOG << "DSchedContinueSourceStartStateTest::SetUp" << std::endl;
usleep(WAITTIME);
}
std::shared_ptr<DSchedContinue> DSchedContinueSourceStartStateTest::CreateObject()
@ -301,7 +310,7 @@ void DSchedContinueWaitEndStateTest::TearDownTestCase()
void DSchedContinueWaitEndStateTest::TearDown()
{
srcWaitEndTest_ = nullptr;
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueWaitEndStateTest::TearDown" << std::endl;
}
@ -312,6 +321,7 @@ void DSchedContinueWaitEndStateTest::SetUp()
std::make_shared<DSchedContinueStateMachine>(dContinue);
srcWaitEndTest_ = std::make_shared<DSchedContinueWaitEndState>(stateMachine);
DTEST_LOG << "DSchedContinueWaitEndStateTest::SetUp" << std::endl;
usleep(WAITTIME);
}
std::shared_ptr<DSchedContinue> DSchedContinueWaitEndStateTest::CreateObject()
@ -339,6 +349,7 @@ void DSchedContinueStateMachineTest::TearDownTestCase()
void DSchedContinueStateMachineTest::TearDown()
{
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueStateMachineTest::TearDown" << std::endl;
}
@ -347,6 +358,7 @@ void DSchedContinueStateMachineTest::SetUp()
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
stateMachineTest_ = std::make_shared<DSchedContinueStateMachine>(dContinue);
DTEST_LOG << "DSchedContinueStateMachineTest::SetUp" << std::endl;
usleep(WAITTIME);
}
std::shared_ptr<DSchedContinue> DSchedContinueStateMachineTest::CreateObject()
@ -369,7 +381,6 @@ std::shared_ptr<DSchedContinue> DSchedContinueStateMachineTest::CreateObject()
HWTEST_F(DSchedContinueDataStateTest, SinkExecuteTest001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueDataStateTest SinkExecuteTest001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -377,7 +388,7 @@ HWTEST_F(DSchedContinueDataStateTest, SinkExecuteTest001, TestSize.Level3)
delete event;
}
};
int32_t ret = dataStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = dataStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, CONTINUE_STATE_MACHINE_INVALID_STATE);
DTEST_LOG << "DSchedContinueDataStateTest SinkExecuteTest001 end" << std::endl;
}
@ -390,7 +401,6 @@ HWTEST_F(DSchedContinueDataStateTest, SinkExecuteTest001, TestSize.Level3)
HWTEST_F(DSchedContinueDataStateTest, SinkExecuteTest002, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueDataStateTest SinkExecuteTest002 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(DSCHED_CONTINUE_DATA_EVENT);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -398,7 +408,7 @@ HWTEST_F(DSchedContinueDataStateTest, SinkExecuteTest002, TestSize.Level3)
delete event;
}
};
int32_t ret = dataStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = dataStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueDataStateTest SinkExecuteTest002 end" << std::endl;
}
@ -424,7 +434,6 @@ HWTEST_F(DSchedContinueDataStateTest, SinkGetStateType001, TestSize.Level3)
HWTEST_F(DSchedContinueDataStateTest, SinkDoContinueDataTask001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueDataStateTest SinkDoContinueDataTask001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -432,7 +441,7 @@ HWTEST_F(DSchedContinueDataStateTest, SinkDoContinueDataTask001, TestSize.Level3
delete event;
}
};
int32_t ret = dataStateTest_->DoContinueDataTask(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = dataStateTest_->DoContinueDataTask(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, DSCHED_CONTINUE_DATA_STATE);
DTEST_LOG << "DSchedContinueDataStateTest SinkDoContinueDataTask001 end" << std::endl;
}
@ -445,7 +454,6 @@ HWTEST_F(DSchedContinueDataStateTest, SinkDoContinueDataTask001, TestSize.Level3
HWTEST_F(DSchedContinueDataStateTest, SinkDoContinueEndTask001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueDataStateTest SinkDoContinueEndTask001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -453,7 +461,7 @@ HWTEST_F(DSchedContinueDataStateTest, SinkDoContinueEndTask001, TestSize.Level3)
delete event;
}
};
int32_t ret = dataStateTest_->DoContinueEndTask(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = dataStateTest_->DoContinueEndTask(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueDataStateTest SinkDoContinueEndTask001 end" << std::endl;
}
@ -466,7 +474,6 @@ HWTEST_F(DSchedContinueDataStateTest, SinkDoContinueEndTask001, TestSize.Level3)
HWTEST_F(DSchedContinueSinkEndStateTest, TestSinkExecute001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkEndStateTest SinkExecuteTest001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -474,7 +481,7 @@ HWTEST_F(DSchedContinueSinkEndStateTest, TestSinkExecute001, TestSize.Level3)
delete event;
}
};
int32_t ret = sinkEndStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = sinkEndStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, CONTINUE_STATE_MACHINE_INVALID_STATE);
DTEST_LOG << "DSchedContinueSinkEndStateTest TestSinkExecute001 end" << std::endl;
}
@ -487,7 +494,6 @@ HWTEST_F(DSchedContinueSinkEndStateTest, TestSinkExecute001, TestSize.Level3)
HWTEST_F(DSchedContinueSinkEndStateTest, TestSinkExecute002, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkEndStateTest SinkExecuteTest001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(DSCHED_CONTINUE_END_EVENT);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -495,7 +501,7 @@ HWTEST_F(DSchedContinueSinkEndStateTest, TestSinkExecute002, TestSize.Level3)
delete event;
}
};
int32_t ret = sinkEndStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = sinkEndStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueSinkEndStateTest TestSinkExecute002 end" << std::endl;
}
@ -521,7 +527,6 @@ HWTEST_F(DSchedContinueSinkEndStateTest, TestSinkGetStateType001, TestSize.Level
HWTEST_F(DSchedContinueSinkEndStateTest, TestSinkDoContinueEndTask001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkEndStateTest TestSinkDoContinueEndTask001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -529,7 +534,7 @@ HWTEST_F(DSchedContinueSinkEndStateTest, TestSinkDoContinueEndTask001, TestSize.
delete event;
}
};
int32_t ret = sinkEndStateTest_->DoContinueEndTask(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = sinkEndStateTest_->DoContinueEndTask(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueSinkEndStateTest TestSinkDoContinueEndTask001 end" << std::endl;
}
@ -542,7 +547,6 @@ HWTEST_F(DSchedContinueSinkEndStateTest, TestSinkDoContinueEndTask001, TestSize.
HWTEST_F(DSchedContinueSinkStartStateTest, SinkExecuteTest_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkExecuteTest_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -550,7 +554,7 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkExecuteTest_001, TestSize.Level3)
delete event;
}
};
int32_t ret = sinkStartStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = sinkStartStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, CONTINUE_STATE_MACHINE_INVALID_STATE);
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkExecuteTest_001 end" << std::endl;
}
@ -563,7 +567,6 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkExecuteTest_001, TestSize.Level3)
HWTEST_F(DSchedContinueSinkStartStateTest, SinkExecuteTest_002, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkExecuteTest_002 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(DSCHED_CONTINUE_REQ_PULL_EVENT);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -571,7 +574,7 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkExecuteTest_002, TestSize.Level3)
delete event;
}
};
int32_t ret = sinkStartStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = sinkStartStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkExecuteTest_002 end" << std::endl;
}
@ -597,7 +600,6 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkGetStateTypeTest_001, TestSize.Le
HWTEST_F(DSchedContinueSinkStartStateTest, SinkDoContinuePullReqTaskTest_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkDoContinuePullReqTaskTest_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -605,7 +607,7 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkDoContinuePullReqTaskTest_001, Te
delete event;
}
};
int32_t ret = sinkStartStateTest_->DoContinuePullReqTask(dContinue,
int32_t ret = sinkStartStateTest_->DoContinuePullReqTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkDoContinuePullReqTaskTest_001 end" << std::endl;
@ -619,7 +621,6 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkDoContinuePullReqTaskTest_001, Te
HWTEST_F(DSchedContinueSinkStartStateTest, SinkDoContinueAbilityTaskTest_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkDoContinueAbilityTaskTest_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -627,7 +628,7 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkDoContinueAbilityTaskTest_001, Te
delete event;
}
};
int32_t ret = sinkStartStateTest_->DoContinueAbilityTask(dContinue,
int32_t ret = sinkStartStateTest_->DoContinueAbilityTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkDoContinueAbilityTaskTest_001 end" << std::endl;
@ -641,7 +642,6 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkDoContinueAbilityTaskTest_001, Te
HWTEST_F(DSchedContinueSinkStartStateTest, SinkDoContinueEndTaskTest_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkDoContinueEndTaskTest_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -649,7 +649,7 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkDoContinueEndTaskTest_001, TestSi
delete event;
}
};
int32_t ret = sinkStartStateTest_->DoContinueEndTask(dContinue,
int32_t ret = sinkStartStateTest_->DoContinueEndTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueSinkStartStateTest SinkDoContinueEndTaskTest_001 end" << std::endl;
@ -663,7 +663,6 @@ HWTEST_F(DSchedContinueSinkStartStateTest, SinkDoContinueEndTaskTest_001, TestSi
HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkExecute001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest SinkExecute001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -671,7 +670,7 @@ HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkExecute001, TestSize.Level3)
delete event;
}
};
int32_t ret = sinkWaitEndTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = sinkWaitEndTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, CONTINUE_STATE_MACHINE_INVALID_STATE);
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest SinkExecute001 end" << std::endl;
}
@ -684,7 +683,6 @@ HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkExecute001, TestSize.Level3)
HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkExecute002, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest SinkExecute002 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(DSCHED_CONTINUE_COMPLETE_EVENT);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -692,7 +690,7 @@ HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkExecute002, TestSize.Level3)
delete event;
}
};
int32_t ret = sinkWaitEndTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = sinkWaitEndTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest SinkExecute002 end" << std::endl;
}
@ -719,7 +717,6 @@ HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkGetStateType001, TestSize.Level
HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkDoNotifyCompleteTask001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest SinkDoNotifyCompleteTask001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -727,7 +724,7 @@ HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkDoNotifyCompleteTask001, TestSi
delete event;
}
};
int32_t ret = sinkWaitEndTest_->DoNotifyCompleteTask(dContinue,
int32_t ret = sinkWaitEndTest_->DoNotifyCompleteTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest SinkDoNotifyCompleteTask001 end" << std::endl;
@ -741,7 +738,6 @@ HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkDoNotifyCompleteTask001, TestSi
HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkDoContinueEndTask001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest SinkDoContinueEndTask001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -749,7 +745,7 @@ HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkDoContinueEndTask001, TestSize.
delete event;
}
};
int32_t ret = sinkWaitEndTest_->DoContinueEndTask(dContinue,
int32_t ret = sinkWaitEndTest_->DoContinueEndTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueSinkWaitEndStateTest SinkDoContinueEndTask001 end" << std::endl;
@ -763,7 +759,6 @@ HWTEST_F(DSchedContinueSinkWaitEndStateTest, SinkDoContinueEndTask001, TestSize.
HWTEST_F(DSchedContinueAbilityStateTest, SrcExecuteTest001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueAbilityStateTest SrcExecuteTest001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -771,7 +766,7 @@ HWTEST_F(DSchedContinueAbilityStateTest, SrcExecuteTest001, TestSize.Level3)
delete event;
}
};
int32_t ret = abilityStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = abilityStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, CONTINUE_STATE_MACHINE_INVALID_STATE);
DTEST_LOG << "DSchedContinueAbilityStateTest SrcExecuteTest001 end" << std::endl;
}
@ -784,7 +779,6 @@ HWTEST_F(DSchedContinueAbilityStateTest, SrcExecuteTest001, TestSize.Level3)
HWTEST_F(DSchedContinueAbilityStateTest, SrcExecuteTest002, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueAbilityStateTest SrcExecuteTest002 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(DSHCED_CONTINUE_SEND_DATA_EVENT);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -792,7 +786,7 @@ HWTEST_F(DSchedContinueAbilityStateTest, SrcExecuteTest002, TestSize.Level3)
delete event;
}
};
int32_t ret = abilityStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = abilityStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueAbilityStateTest SrcExecuteTest002 end" << std::endl;
}
@ -818,7 +812,6 @@ HWTEST_F(DSchedContinueAbilityStateTest, SrcGetStateType001, TestSize.Level3)
HWTEST_F(DSchedContinueAbilityStateTest, SrcDoContinueSendTask001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueAbilityStateTest SrcDoContinueSendTask001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -826,7 +819,7 @@ HWTEST_F(DSchedContinueAbilityStateTest, SrcDoContinueSendTask001, TestSize.Leve
delete event;
}
};
int32_t ret = abilityStateTest_->DoContinueSendTask(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = abilityStateTest_->DoContinueSendTask(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueAbilityStateTest SrcDoContinueSendTask001 end" << std::endl;
}
@ -839,7 +832,6 @@ HWTEST_F(DSchedContinueAbilityStateTest, SrcDoContinueSendTask001, TestSize.Leve
HWTEST_F(DSchedContinueAbilityStateTest, SrcDoContinueEndTask001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueAbilityStateTest SrcDoContinueEndTask001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -847,7 +839,7 @@ HWTEST_F(DSchedContinueAbilityStateTest, SrcDoContinueEndTask001, TestSize.Level
delete event;
}
};
int32_t ret = abilityStateTest_->DoContinueEndTask(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = abilityStateTest_->DoContinueEndTask(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueAbilityStateTest SrcDoContinueEndTask001 end" << std::endl;
}
@ -860,7 +852,6 @@ HWTEST_F(DSchedContinueAbilityStateTest, SrcDoContinueEndTask001, TestSize.Level
HWTEST_F(DSchedContinueEndStateTest, SrcExecuteTest001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueEndStateTest SrcExecuteTest001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -868,7 +859,7 @@ HWTEST_F(DSchedContinueEndStateTest, SrcExecuteTest001, TestSize.Level3)
delete event;
}
};
int32_t ret = srcEndStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = srcEndStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, CONTINUE_STATE_MACHINE_INVALID_STATE);
DTEST_LOG << "DSchedContinueEndStateTest SrcExecuteTest001 end" << std::endl;
}
@ -881,7 +872,6 @@ HWTEST_F(DSchedContinueEndStateTest, SrcExecuteTest001, TestSize.Level3)
HWTEST_F(DSchedContinueEndStateTest, SrcExecuteTest002, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueEndStateTest SrcExecuteTest002 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(DSCHED_CONTINUE_END_EVENT);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -889,7 +879,7 @@ HWTEST_F(DSchedContinueEndStateTest, SrcExecuteTest002, TestSize.Level3)
delete event;
}
};
int32_t ret = srcEndStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = srcEndStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueEndStateTest SrcExecuteTest002 end" << std::endl;
}
@ -915,7 +905,6 @@ HWTEST_F(DSchedContinueEndStateTest, SrcGetStateTypeTest001, TestSize.Level3)
HWTEST_F(DSchedContinueEndStateTest, SrcDoContinueEndTaskTest001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueEndStateTest SrcDoContinueEndTaskTest001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -923,7 +912,7 @@ HWTEST_F(DSchedContinueEndStateTest, SrcDoContinueEndTaskTest001, TestSize.Level
delete event;
}
};
int32_t ret = srcEndStateTest_->DoContinueEndTask(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = srcEndStateTest_->DoContinueEndTask(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueEndStateTest SrcDoContinueEndTaskTest001 end" << std::endl;
}
@ -936,7 +925,6 @@ HWTEST_F(DSchedContinueEndStateTest, SrcDoContinueEndTaskTest001, TestSize.Level
HWTEST_F(DSchedContinueSourceStartStateTest, SrcExecuteTest_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcExecuteTest_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -944,7 +932,7 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcExecuteTest_001, TestSize.Level3
delete event;
}
};
int32_t ret = srcStartStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = srcStartStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, CONTINUE_STATE_MACHINE_INVALID_STATE);
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcExecuteTest_001 end" << std::endl;
}
@ -957,7 +945,6 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcExecuteTest_001, TestSize.Level3
HWTEST_F(DSchedContinueSourceStartStateTest, SrcExecuteTest_002, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcExecuteTest_002 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(DSHCED_CONTINUE_REQ_PUSH_EVENT);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -965,7 +952,7 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcExecuteTest_002, TestSize.Level3
delete event;
}
};
int32_t ret = srcStartStateTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = srcStartStateTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcExecuteTest_002 end" << std::endl;
}
@ -991,7 +978,6 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcGetStateTypeTest_001, TestSize.L
HWTEST_F(DSchedContinueSourceStartStateTest, SrcDoContinuePushReqTaskTest_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcDoContinuePushReqTaskTest_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -999,7 +985,7 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcDoContinuePushReqTaskTest_001, T
delete event;
}
};
int32_t ret = srcStartStateTest_->DoContinuePushReqTask(dContinue,
int32_t ret = srcStartStateTest_->DoContinuePushReqTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcDoContinuePushReqTaskTest_001 end" << std::endl;
@ -1013,7 +999,6 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcDoContinuePushReqTaskTest_001, T
HWTEST_F(DSchedContinueSourceStartStateTest, SrcDoContinueAbilityTaskTest_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcDoContinueAbilityTaskTest_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -1021,7 +1006,7 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcDoContinueAbilityTaskTest_001, T
delete event;
}
};
int32_t ret = srcStartStateTest_->DoContinueAbilityTask(dContinue,
int32_t ret = srcStartStateTest_->DoContinueAbilityTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcDoContinueAbilityTaskTest_001 end" << std::endl;
@ -1035,7 +1020,6 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcDoContinueAbilityTaskTest_001, T
HWTEST_F(DSchedContinueSourceStartStateTest, SrcDoContinueEndTaskTest_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcDoContinueEndTaskTest_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -1043,7 +1027,7 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcDoContinueEndTaskTest_001, TestS
delete event;
}
};
int32_t ret = srcStartStateTest_->DoContinueEndTask(dContinue,
int32_t ret = srcStartStateTest_->DoContinueEndTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueSourceStartStateTest SrcDoContinueEndTaskTest_001 end" << std::endl;
@ -1057,7 +1041,6 @@ HWTEST_F(DSchedContinueSourceStartStateTest, SrcDoContinueEndTaskTest_001, TestS
HWTEST_F(DSchedContinueWaitEndStateTest, SrcExecute_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueWaitEndStateTest SrcExecute_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -1065,7 +1048,7 @@ HWTEST_F(DSchedContinueWaitEndStateTest, SrcExecute_001, TestSize.Level3)
delete event;
}
};
int32_t ret = srcWaitEndTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = srcWaitEndTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, CONTINUE_STATE_MACHINE_INVALID_STATE);
DTEST_LOG << "DSchedContinueWaitEndStateTest SrcExecute_001 end" << std::endl;
}
@ -1078,7 +1061,6 @@ HWTEST_F(DSchedContinueWaitEndStateTest, SrcExecute_001, TestSize.Level3)
HWTEST_F(DSchedContinueWaitEndStateTest, SrcExecute_002, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueWaitEndStateTest SrcExecute_002 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(DSCHED_CONTINUE_COMPLETE_EVENT);
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -1086,7 +1068,7 @@ HWTEST_F(DSchedContinueWaitEndStateTest, SrcExecute_002, TestSize.Level3)
delete event;
}
};
int32_t ret = srcWaitEndTest_->Execute(dContinue, AppExecFwk::InnerEvent::Pointer(event, destructor));
int32_t ret = srcWaitEndTest_->Execute(nullptr, AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueWaitEndStateTest SrcExecute_002 end" << std::endl;
}
@ -1112,7 +1094,6 @@ HWTEST_F(DSchedContinueWaitEndStateTest, SrcGetStateType_001, TestSize.Level3)
HWTEST_F(DSchedContinueWaitEndStateTest, SrcDoNotifyCompleteTask_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueWaitEndStateTest SrcDoNotifyCompleteTask_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -1120,7 +1101,7 @@ HWTEST_F(DSchedContinueWaitEndStateTest, SrcDoNotifyCompleteTask_001, TestSize.L
delete event;
}
};
int32_t ret = srcWaitEndTest_->DoNotifyCompleteTask(dContinue,
int32_t ret = srcWaitEndTest_->DoNotifyCompleteTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueWaitEndStateTest SrcDoNotifyCompleteTask_001 end" << std::endl;
@ -1134,7 +1115,6 @@ HWTEST_F(DSchedContinueWaitEndStateTest, SrcDoNotifyCompleteTask_001, TestSize.L
HWTEST_F(DSchedContinueWaitEndStateTest, SrcDoContinueEndTask_001, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueWaitEndStateTest SrcDoContinueEndTask_001 begin" << std::endl;
std::shared_ptr<DSchedContinue> dContinue = CreateObject();
AppExecFwk::InnerEvent *event = new AppExecFwk::InnerEvent();
event->innerEventId_ = static_cast<uint32_t>(-1);;
auto destructor = [](AppExecFwk::InnerEvent *event) {
@ -1142,7 +1122,7 @@ HWTEST_F(DSchedContinueWaitEndStateTest, SrcDoContinueEndTask_001, TestSize.Leve
delete event;
}
};
int32_t ret = srcWaitEndTest_->DoContinueEndTask(dContinue,
int32_t ret = srcWaitEndTest_->DoContinueEndTask(nullptr,
AppExecFwk::InnerEvent::Pointer(event, destructor));
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueWaitEndStateTest SrcDoContinueEndTask_001 end" << std::endl;
@ -1192,15 +1172,7 @@ HWTEST_F(DSchedContinueStateMachineTest, UpdateState_002, TestSize.Level3)
{
DTEST_LOG << "DSchedContinueStateMachineTest UpdateState_002 begin" << std::endl;
DSchedContinueStateType stateType = DSCHED_CONTINUE_ABILITY_STATE;
int32_t subServiceType = 0;
int32_t direction = 0;
sptr<IRemoteObject> callback = nullptr;
DSchedContinueInfo continueInfo;
std::shared_ptr<DSchedContinue> dContinue = std::make_shared<DSchedContinue>(subServiceType, direction,
callback, continueInfo);
dContinue->Init();
auto stateMachine = std::make_shared<DSchedContinueStateMachine>(dContinue);
stateMachineTest_->currentState_ = std::make_shared<DSchedContinueDataState>(stateMachine);
stateMachineTest_->currentState_ = stateMachineTest_->CreateState(stateType);
stateMachineTest_->UpdateState(stateType);
EXPECT_NE(stateMachineTest_->currentState_, nullptr);
DTEST_LOG << "DSchedContinueStateMachineTest UpdateState_002 end" << std::endl;

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

@ -26,6 +26,9 @@ using namespace testing::ext;
namespace OHOS {
namespace DistributedSchedule {
namespace {
const int32_t WAITTIME = 2000;
}
void DSchedContinueTest::SetUpTestCase()
{
DTEST_LOG << "DSchedContinueTest::SetUpTestCase" << std::endl;
@ -39,11 +42,13 @@ void DSchedContinueTest::TearDownTestCase()
void DSchedContinueTest::TearDown()
{
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueTest::TearDown" << std::endl;
}
void DSchedContinueTest::SetUp()
{
usleep(WAITTIME);
DTEST_LOG << "DSchedContinueTest::SetUp" << std::endl;
}
@ -76,6 +81,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_001_1, TestSize.Level0)
ret = conti->PostStartTask(wantParams);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_001_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -107,6 +113,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_002_1, TestSize.Level0)
ret = conti->PostCotinueAbilityTask(appVersion);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_002_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -148,6 +155,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_003_1, TestSize.Level0)
ret = conti->PostReplyTask(cmd);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_003_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -187,10 +195,8 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_004_1, TestSize.Level0)
ret = conti->PostContinueSendTask(want, callerUid, status, accessToken);
EXPECT_EQ(ret, ERR_OK);
status = INVALID_PARAMETERS_ERR;
ret = conti->PostContinueSendTask(want, callerUid, status, accessToken);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_004_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -226,6 +232,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_005_1, TestSize.Level0)
ret = conti->PostContinueDataTask(cmd);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_005_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -271,6 +278,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_006_1, TestSize.Level0)
ret = conti->PostNotifyCompleteTask(ERR_OK);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_006_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -302,6 +310,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_007_1, TestSize.Level0)
ret = conti->PostContinueEndTask(result);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_007_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -326,6 +335,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_008_1, TestSize.Level0)
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_008_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -351,6 +361,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_009_1, TestSize.Level0)
int32_t ret = conti->PackStartCmd(cmd, wantParams);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_009_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -375,6 +386,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0010_1, TestSize.Level0)
int32_t ret = conti->ExecuteContinueAbility(appVersion);
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0010_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -397,6 +409,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0011_1, TestSize.Level0)
int32_t ret = conti->GetMissionIdByBundleName();
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0011_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -419,6 +432,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0012_1, TestSize.Level0)
int32_t ret = conti->CheckContinueAbilityPermission();
EXPECT_EQ(ret, NO_MISSION_INFO_FOR_MISSION_ID);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0012_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -441,6 +455,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0013_1, TestSize.Level0)
int32_t ret = conti->ExecuteContinueReply();
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0013_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -464,6 +479,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0014_1, TestSize.Level0)
int32_t ret = conti->ExecuteContinueSend(data);
EXPECT_EQ(ret, INVALID_REMOTE_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0014_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -487,6 +503,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0015_1, TestSize.Level0)
int32_t ret = conti->SetWantForContinuation(want);
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0015_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -515,6 +532,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0016_1, TestSize.Level0)
int32_t ret = conti->PackDataCmd(cmd, want, abilityInfo, callerInfo, accountInfo);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0016_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -539,6 +557,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0017_1, TestSize.Level0)
int32_t ret = conti->ExecuteContinueData(cmd);
EXPECT_EQ(ret, INVALID_REMOTE_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0017_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -562,6 +581,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0018_1, TestSize.Level0)
int32_t ret = conti->ExecuteNotifyComplete(result);
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0018_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -589,6 +609,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0019_1, TestSize.Level0)
int32_t ret = conti->PackReplyCmd(cmd, replyCmd, appVersion, result, "");
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0019_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -613,6 +634,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0020_1, TestSize.Level0)
int32_t ret = conti->ExecuteContinueEnd(result);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0020_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -636,6 +658,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0021_1, TestSize.Level0)
int32_t ret = conti->ExecuteContinueError(result);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0021_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -661,6 +684,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0022_1, TestSize.Level0)
int32_t ret = conti->PackEndCmd(cmd, result);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0022_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -684,6 +708,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0023_1, TestSize.Level0)
int32_t ret = conti->SendCommand(cmd);
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0023_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -707,6 +732,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0024_1, TestSize.Level0)
bool ret = conti->GetLocalDeviceId(localDeviceId);
EXPECT_EQ(ret, true);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0024_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -729,6 +755,7 @@ HWTEST_F(DSchedContinueTest, DSchedContinueTest_0025_1, TestSize.Level0)
int32_t ret = conti->CheckDeviceIdFromRemote("", "", "");
EXPECT_EQ(ret, false);
DTEST_LOG << "DSchedContinueTest DSchedContinueTest_0025_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -752,6 +779,7 @@ HWTEST_F(DSchedContinueTest, WaitAbilityStateInitialTest_0026_1, TestSize.Level0
bool ret = conti->WaitAbilityStateInitial(persistentId);
EXPECT_FALSE(ret);
DTEST_LOG << "DSchedContinueTest WaitAbilityStateInitialTest_0026_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -778,6 +806,7 @@ HWTEST_F(DSchedContinueTest, StartAbilityTest_0027_1, TestSize.Level0)
int32_t ret = conti->StartAbility(want, 0);
EXPECT_NE(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest StartAbilityTest_0027_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -801,6 +830,7 @@ HWTEST_F(DSchedContinueTest, QuerySinkAbilityNameTest_0028_1, TestSize.Level0)
std::string sinkBundleName = conti->QuerySinkAbilityName();
EXPECT_TRUE(sinkBundleName.empty());
DTEST_LOG << "DSchedContinueTest QuerySinkAbilityNameTest_0028_1 end" << std::endl;
usleep(WAITTIME);
}
/**
@ -823,6 +853,7 @@ HWTEST_F(DSchedContinueTest, QuickStartAbilityTest_0029_1, TestSize.Level0)
int32_t ret = conti->QuickStartAbility();
EXPECT_EQ(ret, INVALID_PARAMETERS_ERR);
DTEST_LOG << "DSchedContinueTest QuickStartAbilityTest_0029_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
/**
@ -849,6 +880,7 @@ HWTEST_F(DSchedContinueTest, UpdateWantForContinueTypeTest_0030_1, TestSize.Leve
int32_t ret = conti->UpdateWantForContinueType(want);
EXPECT_EQ(ret, ERR_OK);
DTEST_LOG << "DSchedContinueTest UpdateWantForContinueTypeTest_0030_1 end ret:" << ret << std::endl;
usleep(WAITTIME);
}
}
}

2
services/dtbschedmgr/test/unittest/switch_status_dependency_test.cpp
View File

@ -80,7 +80,7 @@ HWTEST_F(SwitchStatusDependencyTest, IsCreateDataShareHelper_001, TestSize.Level
SwitchStatusDependency::GetInstance().GetSwitchStatus(key, defaultValue));
key = CONTINUE_SWITCH_STATUS_KEY;
defaultValue = CONTINUE_SWITCH_OFF;
EXPECT_EQ(CONTINUE_SWITCH_ON,
EXPECT_EQ(CONTINUE_SWITCH_OFF,
SwitchStatusDependency::GetInstance().GetSwitchStatus(key, defaultValue));
DTEST_LOG << "SwitchStatusDependencyTest IsCreateDataShareHelper_001 end" << std::endl;
}