// Copyright (c) FIRST and other WPILib contributors. // Open Source Software; you can modify and/or share it under the terms of // the WPILib BSD license file in the root directory of this project. #include "CommandTestBase.h" #include "frc2/command/InstantCommand.h" #include "frc2/command/ParallelDeadlineGroup.h" #include "frc2/command/WaitUntilCommand.h" using namespace frc2; class ParallelDeadlineGroupTest : public CommandTestBase {}; TEST_F(ParallelDeadlineGroupTest, DeadlineGroupScheduleTest) { CommandScheduler scheduler = GetScheduler(); std::unique_ptr command1Holder = std::make_unique(); std::unique_ptr command2Holder = std::make_unique(); std::unique_ptr command3Holder = std::make_unique(); MockCommand* command1 = command1Holder.get(); MockCommand* command2 = command2Holder.get(); MockCommand* command3 = command3Holder.get(); ParallelDeadlineGroup group( std::move(command1Holder), tcb::make_vector>(std::move(command2Holder), std::move(command3Holder))); EXPECT_CALL(*command1, Initialize()); EXPECT_CALL(*command1, Execute()).Times(2); EXPECT_CALL(*command1, End(false)); EXPECT_CALL(*command2, Initialize()); EXPECT_CALL(*command2, Execute()).Times(1); EXPECT_CALL(*command2, End(false)); EXPECT_CALL(*command3, Initialize()); EXPECT_CALL(*command3, Execute()).Times(2); EXPECT_CALL(*command3, End(true)); scheduler.Schedule(&group); command2->SetFinished(true); scheduler.Run(); command1->SetFinished(true); scheduler.Run(); EXPECT_FALSE(scheduler.IsScheduled(&group)); } TEST_F(ParallelDeadlineGroupTest, SequentialGroupInterruptTest) { CommandScheduler scheduler = GetScheduler(); TestSubsystem subsystem; std::unique_ptr command1Holder = std::make_unique(); std::unique_ptr command2Holder = std::make_unique(); std::unique_ptr command3Holder = std::make_unique(); MockCommand* command1 = command1Holder.get(); MockCommand* command2 = command2Holder.get(); MockCommand* command3 = command3Holder.get(); ParallelDeadlineGroup group( std::move(command1Holder), tcb::make_vector>(std::move(command2Holder), std::move(command3Holder))); EXPECT_CALL(*command1, Initialize()); EXPECT_CALL(*command1, Execute()).Times(1); EXPECT_CALL(*command1, End(true)); EXPECT_CALL(*command2, Initialize()); EXPECT_CALL(*command2, Execute()).Times(1); EXPECT_CALL(*command2, End(true)); EXPECT_CALL(*command3, Initialize()); EXPECT_CALL(*command3, Execute()).Times(1); EXPECT_CALL(*command3, End(true)); scheduler.Schedule(&group); scheduler.Run(); scheduler.Cancel(&group); scheduler.Run(); EXPECT_FALSE(scheduler.IsScheduled(&group)); } TEST_F(ParallelDeadlineGroupTest, DeadlineGroupNotScheduledCancelTest) { CommandScheduler scheduler = GetScheduler(); ParallelDeadlineGroup group{InstantCommand(), InstantCommand()}; EXPECT_NO_FATAL_FAILURE(scheduler.Cancel(&group)); } TEST_F(ParallelDeadlineGroupTest, ParallelDeadlineCopyTest) { CommandScheduler scheduler = GetScheduler(); bool finished = false; WaitUntilCommand command([&finished] { return finished; }); ParallelDeadlineGroup group(command); scheduler.Schedule(&group); scheduler.Run(); EXPECT_TRUE(scheduler.IsScheduled(&group)); finished = true; scheduler.Run(); EXPECT_FALSE(scheduler.IsScheduled(&group)); } TEST_F(ParallelDeadlineGroupTest, ParallelDeadlineRequirementTest) { CommandScheduler scheduler = GetScheduler(); TestSubsystem requirement1; TestSubsystem requirement2; TestSubsystem requirement3; TestSubsystem requirement4; InstantCommand command1([] {}, {&requirement1, &requirement2}); InstantCommand command2([] {}, {&requirement3}); InstantCommand command3([] {}, {&requirement3, &requirement4}); ParallelDeadlineGroup group(std::move(command1), std::move(command2)); scheduler.Schedule(&group); scheduler.Schedule(&command3); EXPECT_TRUE(scheduler.IsScheduled(&command3)); EXPECT_FALSE(scheduler.IsScheduled(&group)); }