diff --git a/nav2_controller/src/controller_server.cpp b/nav2_controller/src/controller_server.cpp index 447d8534819..a7f6bee27cf 100644 --- a/nav2_controller/src/controller_server.cpp +++ b/nav2_controller/src/controller_server.cpp @@ -480,10 +480,15 @@ void ControllerServer::computeControl() } if (action_server_->is_cancel_requested()) { - RCLCPP_INFO(get_logger(), "Goal was canceled. Stopping the robot."); - action_server_->terminate_all(); - publishZeroVelocity(); - return; + if (controllers_[current_controller_]->cancel()) { + RCLCPP_INFO(get_logger(), "Cancellation was successful. Stopping the robot."); + action_server_->terminate_all(); + publishZeroVelocity(); + return; + } else { + RCLCPP_INFO_THROTTLE( + get_logger(), *get_clock(), 1000, "Waiting for the controller to finish cancellation"); + } } // Don't compute a trajectory until costmap is valid (after clear costmap) diff --git a/nav2_core/include/nav2_core/controller.hpp b/nav2_core/include/nav2_core/controller.hpp index dab79176e94..b01381a0414 100644 --- a/nav2_core/include/nav2_core/controller.hpp +++ b/nav2_core/include/nav2_core/controller.hpp @@ -116,6 +116,16 @@ class Controller const geometry_msgs::msg::Twist & velocity, nav2_core::GoalChecker * goal_checker) = 0; + /** + * @brief Cancel the current control action + * @return True if the cancellation was successful. If false is returned, computeVelocityCommands + * will be called until cancel returns true. + */ + virtual bool cancel() + { + return true; + } + /** * @brief Limits the maximum linear speed of the robot. * @param speed_limit expressed in absolute value (in m/s) diff --git a/nav2_regulated_pure_pursuit_controller/include/nav2_regulated_pure_pursuit_controller/parameter_handler.hpp b/nav2_regulated_pure_pursuit_controller/include/nav2_regulated_pure_pursuit_controller/parameter_handler.hpp index 8962003d446..3975b8df4ff 100644 --- a/nav2_regulated_pure_pursuit_controller/include/nav2_regulated_pure_pursuit_controller/parameter_handler.hpp +++ b/nav2_regulated_pure_pursuit_controller/include/nav2_regulated_pure_pursuit_controller/parameter_handler.hpp @@ -53,6 +53,7 @@ struct Parameters double curvature_lookahead_dist; bool use_rotate_to_heading; double max_angular_accel; + double cancel_deceleration; double rotate_to_heading_min_angle; bool allow_reversing; double max_robot_pose_search_dist; diff --git a/nav2_regulated_pure_pursuit_controller/include/nav2_regulated_pure_pursuit_controller/regulated_pure_pursuit_controller.hpp b/nav2_regulated_pure_pursuit_controller/include/nav2_regulated_pure_pursuit_controller/regulated_pure_pursuit_controller.hpp index 7b28ca9720e..689dc3237cf 100644 --- a/nav2_regulated_pure_pursuit_controller/include/nav2_regulated_pure_pursuit_controller/regulated_pure_pursuit_controller.hpp +++ b/nav2_regulated_pure_pursuit_controller/include/nav2_regulated_pure_pursuit_controller/regulated_pure_pursuit_controller.hpp @@ -96,6 +96,8 @@ class RegulatedPurePursuitController : public nav2_core::Controller const geometry_msgs::msg::Twist & velocity, nav2_core::GoalChecker * /*goal_checker*/) override; + bool cancel() override; + /** * @brief nav2_core setPlan - Sets the global plan * @param path The global plan @@ -111,6 +113,8 @@ class RegulatedPurePursuitController : public nav2_core::Controller */ void setSpeedLimit(const double & speed_limit, const bool & percentage) override; + void reset() override; + protected: /** * @brief Get lookahead distance @@ -206,6 +210,8 @@ class RegulatedPurePursuitController : public nav2_core::Controller Parameters * params_; double goal_dist_tol_; double control_duration_; + bool cancelling_ = false; + bool finished_cancelling_ = false; std::shared_ptr> global_path_pub_; std::shared_ptr> diff --git a/nav2_regulated_pure_pursuit_controller/src/parameter_handler.cpp b/nav2_regulated_pure_pursuit_controller/src/parameter_handler.cpp index 92187376632..f3848b1fee3 100644 --- a/nav2_regulated_pure_pursuit_controller/src/parameter_handler.cpp +++ b/nav2_regulated_pure_pursuit_controller/src/parameter_handler.cpp @@ -85,6 +85,8 @@ ParameterHandler::ParameterHandler( node, plugin_name_ + ".rotate_to_heading_min_angle", rclcpp::ParameterValue(0.785)); declare_parameter_if_not_declared( node, plugin_name_ + ".max_angular_accel", rclcpp::ParameterValue(3.2)); + declare_parameter_if_not_declared( + node, plugin_name_ + ".cancel_deceleration", rclcpp::ParameterValue(3.2)); declare_parameter_if_not_declared( node, plugin_name_ + ".allow_reversing", rclcpp::ParameterValue(false)); declare_parameter_if_not_declared( @@ -151,6 +153,7 @@ ParameterHandler::ParameterHandler( node->get_parameter( plugin_name_ + ".rotate_to_heading_min_angle", params_.rotate_to_heading_min_angle); node->get_parameter(plugin_name_ + ".max_angular_accel", params_.max_angular_accel); + node->get_parameter(plugin_name_ + ".cancel_deceleration", params_.cancel_deceleration); node->get_parameter(plugin_name_ + ".allow_reversing", params_.allow_reversing); node->get_parameter( plugin_name_ + ".max_robot_pose_search_dist", @@ -241,6 +244,8 @@ ParameterHandler::dynamicParametersCallback( params_.regulated_linear_scaling_min_speed = parameter.as_double(); } else if (name == plugin_name_ + ".max_angular_accel") { params_.max_angular_accel = parameter.as_double(); + } else if (name == plugin_name_ + ".cancel_deceleration") { + params_.cancel_deceleration = parameter.as_double(); } else if (name == plugin_name_ + ".rotate_to_heading_min_angle") { params_.rotate_to_heading_min_angle = parameter.as_double(); } diff --git a/nav2_regulated_pure_pursuit_controller/src/regulated_pure_pursuit_controller.cpp b/nav2_regulated_pure_pursuit_controller/src/regulated_pure_pursuit_controller.cpp index 0ecab5b0017..e006b64a37d 100644 --- a/nav2_regulated_pure_pursuit_controller/src/regulated_pure_pursuit_controller.cpp +++ b/nav2_regulated_pure_pursuit_controller/src/regulated_pure_pursuit_controller.cpp @@ -225,6 +225,23 @@ geometry_msgs::msg::TwistStamped RegulatedPurePursuitController::computeVelocity collision_checker_->costAtPose(pose.pose.position.x, pose.pose.position.y), transformed_plan, linear_vel, sign); + if (cancelling_) { + const double & dt = control_duration_; + linear_vel = speed.linear.x - x_vel_sign * dt * params_->cancel_deceleration; + + if (x_vel_sign > 0) { + if (linear_vel <= 0) { + linear_vel = 0; + finished_cancelling_ = true; + } + } else { + if (linear_vel >= 0) { + linear_vel = 0; + finished_cancelling_ = true; + } + } + } + // Apply curvature to angular velocity after constraining linear velocity angular_vel = linear_vel * lookahead_curvature; } @@ -245,6 +262,12 @@ geometry_msgs::msg::TwistStamped RegulatedPurePursuitController::computeVelocity return cmd_vel; } +bool RegulatedPurePursuitController::cancel() +{ + cancelling_ = true; + return finished_cancelling_; +} + bool RegulatedPurePursuitController::shouldRotateToPath( const geometry_msgs::msg::PoseStamped & carrot_pose, double & angle_to_path) { @@ -401,6 +424,12 @@ void RegulatedPurePursuitController::setSpeedLimit( } } +void RegulatedPurePursuitController::reset() +{ + cancelling_ = false; + finished_cancelling_ = false; +} + double RegulatedPurePursuitController::findVelocitySignChange( const nav_msgs::msg::Path & transformed_plan) {