plan_execution.cpp

Go to the documentation of this file.

/*********************************************************************
 * Software License Agreement (BSD License)
 *
 *  Copyright (c) 2012, Willow Garage, Inc.
 *  All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions
 *  are met:
 *
 *   * Redistributions of source code must retain the above copyright
 *     notice, this list of conditions and the following disclaimer.
 *   * Redistributions in binary form must reproduce the above
 *     copyright notice, this list of conditions and the following
 *     disclaimer in the documentation and/or other materials provided
 *     with the distribution.
 *   * Neither the name of Willow Garage nor the names of its
 *     contributors may be used to endorse or promote products derived
 *     from this software without specific prior written permission.
 *
 *  THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 *  "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 *  LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
 *  FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
 *  COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
 *  INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
 *  BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
 *  LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
 *  CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 *  LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
 *  ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 *  POSSIBILITY OF SUCH DAMAGE.
 *********************************************************************/
 
/* Author: Ioan Sucan */
 
#include <moveit/plan_execution/plan_execution.hpp>
#include <moveit/robot_state/conversions.hpp>
#include <moveit/trajectory_processing/trajectory_tools.hpp>
#include <moveit/collision_detection/collision_tools.hpp>
#include <moveit/utils/message_checks.hpp>
#include <moveit/utils/moveit_error_code.hpp>
#include <boost/algorithm/string/join.hpp>
#include <rclcpp/logger.hpp>
#include <rclcpp/logging.hpp>
#include <rclcpp/node.hpp>
#include <rclcpp/parameter_value.hpp>
#include <rclcpp/rate.hpp>
#include <rclcpp/utilities.hpp>
#include <moveit/utils/logger.hpp>
 
// #include <dynamic_reconfigure/server.h>
// #include <moveit_ros_planning/PlanExecutionDynamicReconfigureConfig.hpp>
 
namespace plan_execution
{
 
// class PlanExecution::DynamicReconfigureImpl
// {
// public:
//   DynamicReconfigureImpl(PlanExecution* owner)
//     : owner_(owner)  //, dynamic_reconfigure_server_(ros::NodeHandle("~/plan_execution"))
//   {
//     // dynamic_reconfigure_server_.setCallback(
//     //     [this](const auto& config, uint32_t level) { dynamicReconfigureCallback(config, level); });
//   }
//
// private:
//   // void dynamicReconfigureCallback(const PlanExecutionDynamicReconfigureConfig& config, uint32_t level)
//   // {
//   //   owner_->setMaxReplanAttempts(config.max_replan_attempts);
//   //   owner_->setTrajectoryStateRecordingFrequency(config.record_trajectory_state_frequency);
//   // }
//
//   PlanExecution* owner_;
//   // dynamic_reconfigure::Server<PlanExecutionDynamicReconfigureConfig> dynamic_reconfigure_server_;
// };
}  // namespace plan_execution
 
plan_execution::PlanExecution::PlanExecution(
    const rclcpp::Node::SharedPtr& node, const planning_scene_monitor::PlanningSceneMonitorPtr& planning_scene_monitor,
    const trajectory_execution_manager::TrajectoryExecutionManagerPtr& trajectory_execution)
  : node_(node)
  , planning_scene_monitor_(planning_scene_monitor)
  , trajectory_execution_manager_(trajectory_execution)
  , logger_(moveit::getLogger("moveit.ros.plan_execution"))
{
  if (!trajectory_execution_manager_)
  {
    trajectory_execution_manager_ = std::make_shared<trajectory_execution_manager::TrajectoryExecutionManager>(
        node_, planning_scene_monitor_->getRobotModel(), planning_scene_monitor_->getStateMonitor());
  }
 
  default_max_replan_attempts_ = 5;
 
  new_scene_update_ = false;
 
  // we want to be notified when new information is available
  planning_scene_monitor_->addUpdateCallback(
      [this](const planning_scene_monitor::PlanningSceneMonitor::SceneUpdateType update_type) {
        planningSceneUpdatedCallback(update_type);
      });
 
  // start the dynamic-reconfigure server
  // reconfigure_impl_ = new DynamicReconfigureImpl(this);
}
plan_execution::PlanExecution::PlanExecution( {…}
 
plan_execution::PlanExecution::~PlanExecution()
{
  // delete reconfigure_impl_;
}
plan_execution::PlanExecution::~PlanExecution() {…}
 
void plan_execution::PlanExecution::stop()
{
  preempt_.request();
}
void plan_execution::PlanExecution::stop() {…}
 
void plan_execution::PlanExecution::planAndExecute(ExecutableMotionPlan& plan, const Options& opt)
{
  plan.planning_scene_monitor = planning_scene_monitor_;
  plan.planning_scene = planning_scene_monitor_->getPlanningScene();
  planAndExecuteHelper(plan, opt);
}
void plan_execution::PlanExecution::planAndExecute(ExecutableMotionPlan& plan, const Options& opt) {…}
 
void plan_execution::PlanExecution::planAndExecute(ExecutableMotionPlan& plan,
                                                   const moveit_msgs::msg::PlanningScene& scene_diff,
                                                   const Options& opt)
{
  if (moveit::core::isEmpty(scene_diff))
  {
    planAndExecute(plan, opt);
  }
  else
  {
    plan.planning_scene_monitor = planning_scene_monitor_;
    {
      planning_scene_monitor::LockedPlanningSceneRO lscene(planning_scene_monitor_);  // lock the scene so that it does
                                                                                      // not modify the world
                                                                                      // representation while diff() is
                                                                                      // called
      plan.planning_scene = lscene->diff(scene_diff);
    }
    planAndExecuteHelper(plan, opt);
  }
}
void plan_execution::PlanExecution::planAndExecute(ExecutableMotionPlan& plan, {…}
 
void plan_execution::PlanExecution::planAndExecuteHelper(ExecutableMotionPlan& plan, const Options& opt)
{
  // perform initial configuration steps & various checks
  preempt_.checkAndClear();  // clear any previous preempt_ request
 
  bool preempt_requested = false;
 
  // run the actual motion plan & execution
  unsigned int max_replan_attempts =
      opt.replan ? (opt.replan_attemps > 0 ? opt.replan_attemps : default_max_replan_attempts_) : 1;
  unsigned int replan_attempts = 0;
  bool previously_solved = false;
 
  // run a planning loop for at most the maximum replanning attempts;
  // re-planning is executed only in case of known types of failures (e.g., environment changed)
  do
  {
    replan_attempts++;
    RCLCPP_INFO(logger_, "Planning attempt %u of at most %u", replan_attempts, max_replan_attempts);
 
    if (opt.before_plan_callback_)
      opt.before_plan_callback_();
 
    new_scene_update_ = false;  // we clear any scene updates to be evaluated because we are about to compute a new
                                // plan, which should consider most recent updates already
 
    // if we never had a solved plan, or there is no specified way of fixing plans, just call the planner; otherwise,
    // try to repair the plan we previously had;
    bool solved =
        (!previously_solved || !opt.repair_plan_callback_) ?
            opt.plan_callback(plan) :
            opt.repair_plan_callback_(plan, trajectory_execution_manager_->getCurrentExpectedTrajectoryIndex());
 
    preempt_requested = preempt_.checkAndClear();
    if (preempt_requested)
      break;
 
    // if planning fails in a manner that is not recoverable, we exit the loop,
    // otherwise, we attempt to continue, if replanning attempts are left
    if (plan.error_code.val == moveit_msgs::msg::MoveItErrorCodes::PLANNING_FAILED ||
        plan.error_code.val == moveit_msgs::msg::MoveItErrorCodes::INVALID_MOTION_PLAN ||
        plan.error_code.val == moveit_msgs::msg::MoveItErrorCodes::UNABLE_TO_AQUIRE_SENSOR_DATA)
    {
      if (plan.error_code.val == moveit_msgs::msg::MoveItErrorCodes::UNABLE_TO_AQUIRE_SENSOR_DATA &&
          opt.replan_delay > 0.0)
      {
        auto replan_delay_seconds = std::chrono::duration<double>(opt.replan_delay);
        rclcpp::sleep_for(std::chrono::duration_cast<std::chrono::nanoseconds>(replan_delay_seconds));
      }
      continue;
    }
 
    // abort if no plan was found
    if (solved)
    {
      previously_solved = true;
    }
    else
    {
      break;
    }
 
    if (plan.error_code.val == moveit_msgs::msg::MoveItErrorCodes::SUCCESS)
    {
      if (opt.before_execution_callback_)
        opt.before_execution_callback_();
 
      preempt_requested = preempt_.checkAndClear();
      if (preempt_requested)
        break;
 
      // execute the trajectory, and monitor its execution
      plan.error_code = executeAndMonitor(plan, false);
    }
 
    if (plan.error_code.val == moveit_msgs::msg::MoveItErrorCodes::PREEMPTED)
      preempt_requested = true;
 
    // if execution succeeded or failed in a manner that we do not consider recoverable, we exit the loop (with failure)
    if (plan.error_code.val != moveit_msgs::msg::MoveItErrorCodes::MOTION_PLAN_INVALIDATED_BY_ENVIRONMENT_CHANGE)
    {
      break;
    }
    else
    {
      // otherwise, we wait (if needed)
      if (opt.replan_delay > 0.0)
      {
        RCLCPP_INFO(logger_, "Waiting for a %lf seconds before attempting a new plan ...", opt.replan_delay);
        auto replan_delay_seconds = std::chrono::duration<double>(opt.replan_delay);
        rclcpp::sleep_for(std::chrono::duration_cast<std::chrono::nanoseconds>(replan_delay_seconds));
        RCLCPP_INFO(logger_, "Done waiting");
      }
    }
 
    preempt_requested = preempt_.checkAndClear();
    if (preempt_requested)
      break;
 
  } while (replan_attempts < max_replan_attempts);
 
  if (preempt_requested)
  {
    RCLCPP_DEBUG(logger_, "PlanExecution was preempted");
    plan.error_code.val = moveit_msgs::msg::MoveItErrorCodes::PREEMPTED;
  }
 
  if (opt.done_callback_)
    opt.done_callback_();
 
  if (plan.error_code.val == moveit_msgs::msg::MoveItErrorCodes::SUCCESS)
  {
    RCLCPP_DEBUG(logger_, "PlanExecution finished successfully.");
  }
  else
  {
    RCLCPP_DEBUG(logger_, "PlanExecution terminating with error code %d - '%s'", plan.error_code.val,
                 moveit::core::errorCodeToString(plan.error_code).c_str());
  }
}
 
bool plan_execution::PlanExecution::isRemainingPathValid(const ExecutableMotionPlan& plan,
                                                         const std::pair<int, int>& path_segment)
{
  if (path_segment.first >= 0 &&
      plan.plan_components[path_segment.first].trajectory_monitoring)  // If path_segment.second <= 0, the function
                                                                       // will fallback to check the entire trajectory
  {
    planning_scene_monitor::LockedPlanningSceneRO lscene(plan.planning_scene_monitor);  // lock the scene so that it
                                                                                        // does not modify the world
                                                                                        // representation while
                                                                                        // isStateValid() is called
    const robot_trajectory::RobotTrajectory& t = *plan.plan_components[path_segment.first].trajectory;
    const collision_detection::AllowedCollisionMatrix* acm =
        plan.plan_components[path_segment.first].allowed_collision_matrix.get();
    std::size_t wpc = t.getWayPointCount();
    collision_detection::CollisionRequest req;
    req.group_name = t.getGroupName();
    req.pad_environment_collisions = false;
    moveit::core::RobotState state = plan.planning_scene->getCurrentState();
    std::map<std::string, const moveit::core::AttachedBody*> current_attached_objects, waypoint_attached_objects;
    state.getAttachedBodies(current_attached_objects);
    waypoint_attached_objects = plan_components_attached_objects_[path_segment.first];
    for (std::size_t i = std::max(path_segment.second - 1, 0); i < wpc; ++i)
    {
      collision_detection::CollisionResult res;
      state = t.getWayPoint(i);
      if (plan_components_attached_objects_[path_segment.first].empty())
      {
        state.getAttachedBodies(waypoint_attached_objects);
      }
 
      // If sample state has attached objects that are not in the current state, remove them from the sample state
      for (const auto& [name, object] : waypoint_attached_objects)
      {
        if (current_attached_objects.find(name) == current_attached_objects.end())
        {
          RCLCPP_DEBUG(logger_, "Attached object '%s' is not in the current scene. Removing it.", name.c_str());
          state.clearAttachedBody(name);
        }
      }
 
      // If current state has attached objects that are not in the sample state, add them to the sample state
      for (const auto& [name, object] : current_attached_objects)
      {
        if (waypoint_attached_objects.find(name) == waypoint_attached_objects.end())
        {
          RCLCPP_DEBUG(logger_, "Attached object '%s' is not in the robot state. Adding it.", name.c_str());
          state.attachBody(std::make_unique<moveit::core::AttachedBody>(*object));
        }
      }
 
      if (acm)
      {
        plan.planning_scene->checkCollision(req, res, state, *acm);
      }
      else
      {
        plan.planning_scene->checkCollision(req, res, state);
      }
 
      if (res.collision || !plan.planning_scene->isStateFeasible(state, false))
      {
        RCLCPP_INFO(logger_, "Trajectory component '%s' is invalid for waypoint %ld out of %ld",
                    plan.plan_components[path_segment.first].description.c_str(), i, wpc);
 
        // call the same functions again, in verbose mode, to show what issues have been detected
        plan.planning_scene->isStateFeasible(state, true);
        req.verbose = true;
        res.clear();
        if (acm)
        {
          plan.planning_scene->checkCollision(req, res, state, *acm);
        }
        else
        {
          plan.planning_scene->checkCollision(req, res, state);
        }
        return false;
      }
    }
  }
  return true;
}
 
moveit_msgs::msg::MoveItErrorCodes plan_execution::PlanExecution::executeAndMonitor(ExecutableMotionPlan& plan,
                                                                                    bool reset_preempted)
{
  if (reset_preempted)
    preempt_.checkAndClear();
 
  if (!plan.planning_scene_monitor)
    plan.planning_scene_monitor = planning_scene_monitor_;
  if (!plan.planning_scene)
    plan.planning_scene = planning_scene_monitor_->getPlanningScene();
 
  moveit_msgs::msg::MoveItErrorCodes result;
 
  // try to execute the trajectory
  execution_complete_ = true;
 
  if (!trajectory_execution_manager_)
  {
    RCLCPP_ERROR(logger_, "No trajectory execution manager");
    result.val = moveit_msgs::msg::MoveItErrorCodes::CONTROL_FAILED;
    return result;
  }
 
  if (plan.plan_components.empty())
  {
    result.val = moveit_msgs::msg::MoveItErrorCodes::SUCCESS;
    return result;
  }
 
  execution_complete_ = false;
 
  // push the trajectories we have slated for execution to the trajectory execution manager
  int prev = -1;
  for (size_t component_idx = 0; component_idx < plan.plan_components.size(); ++component_idx)
  {
    // \todo should this be in trajectory_execution ? Maybe. Then that will have to use kinematic_trajectory too;
    // splitting trajectories for controllers becomes interesting: tied to groups instead of joints. this could cause
    // some problems
    // in the meantime we do a hack:
 
    bool unwound = false;
    for (int prev_component = component_idx - 1; prev_component >= 0; --prev_component)
    {
      // Search backward for a previous component having the same group.
      // If the group is the same, unwind this component based on the last waypoint of the previous one.
      if (plan.plan_components.at(prev_component).trajectory &&
          plan.plan_components.at(prev_component).trajectory->getGroup() ==
              plan.plan_components.at(prev_component).trajectory->getGroup() &&
          !plan.plan_components.at(prev_component).trajectory->empty())
      {
        plan.plan_components.at(component_idx)
            .trajectory->unwind(plan.plan_components.at(prev_component).trajectory->getLastWayPoint());
        unwound = true;
        // Break so each component is only unwound once
        break;
      }
    }
 
    if (!unwound)
    {
      // unwind the path to execute based on the current state of the system
      if (prev < 0)
      {
        plan.plan_components[component_idx].trajectory->unwind(
            plan.planning_scene_monitor && plan.planning_scene_monitor->getStateMonitor() ?
                *plan.planning_scene_monitor->getStateMonitor()->getCurrentState() :
                plan.planning_scene->getCurrentState());
      }
      else
      {
        plan.plan_components[component_idx].trajectory->unwind(plan.plan_components[prev].trajectory->getLastWayPoint());
      }
    }
 
    if (plan.plan_components[component_idx].trajectory && !plan.plan_components[component_idx].trajectory->empty())
      prev = component_idx;
 
    // convert to message, pass along
    moveit_msgs::msg::RobotTrajectory msg;
    plan.plan_components[component_idx].trajectory->getRobotTrajectoryMsg(msg);
    if (!trajectory_execution_manager_->push(msg, plan.plan_components[component_idx].controller_name))
    {
      RCLCPP_ERROR(logger_, "Apparently trajectory initialization failed");
      execution_complete_ = true;
      result.val = moveit_msgs::msg::MoveItErrorCodes::CONTROL_FAILED;
      return result;
    }
  }
 
  if (!trajectory_monitor_ && planning_scene_monitor_->getStateMonitor())
  {
    // Pass current value of reconfigurable parameter plan_execution/record_trajectory_state_frequency
    double sampling_frequency = 0.0;
    node_->get_parameter_or("plan_execution.record_trajectory_state_frequency", sampling_frequency, 0.0);
    trajectory_monitor_ = std::make_shared<planning_scene_monitor::TrajectoryMonitor>(
        planning_scene_monitor_->getStateMonitor(), sampling_frequency);
  }
 
  // start recording trajectory states
  if (trajectory_monitor_)
    trajectory_monitor_->startTrajectoryMonitor();
 
  // start a trajectory execution thread
  trajectory_execution_manager_->execute(
      [this](const moveit_controller_manager::ExecutionStatus& status) { doneWithTrajectoryExecution(status); },
      [this, &plan](std::size_t index) { successfulTrajectorySegmentExecution(plan, index); });
  // wait for path to be done, while checking that the path does not become invalid
  rclcpp::WallRate r(100);
  path_became_invalid_ = false;
  bool preempt_requested = false;
 
  // Check that attached objects remain consistent throughout the trajectory and store them.
  // This avoids querying the scene for attached objects at each waypoint whenever possible.
  // If a change in attached objects is detected, they will be queried at each waypoint.
  plan_components_attached_objects_.clear();
  plan_components_attached_objects_.reserve(plan.plan_components.size());
  for (const auto& component : plan.plan_components)
  {
    const auto& trajectory = component.trajectory;
    std::map<std::string, const moveit::core::AttachedBody*> trajectory_attached_objects;
    if (trajectory)
    {
      std::map<std::string, const moveit::core::AttachedBody*> attached_objects;
      trajectory->getWayPoint(0).getAttachedBodies(trajectory_attached_objects);
      for (std::size_t i = 1; i < trajectory->getWayPointCount(); ++i)
      {
        trajectory->getWayPoint(i).getAttachedBodies(attached_objects);
        if (attached_objects != trajectory_attached_objects)
        {
          trajectory_attached_objects.clear();
          break;
        }
      }
    }
    plan_components_attached_objects_.push_back(trajectory_attached_objects);
  }
 
  while (rclcpp::ok() && !execution_complete_ && !path_became_invalid_)
  {
    r.sleep();
    // check the path if there was an environment update in the meantime
    if (new_scene_update_)
    {
      new_scene_update_ = false;
      std::pair<int, int> current_index = trajectory_execution_manager_->getCurrentExpectedTrajectoryIndex();
      if (!isRemainingPathValid(plan, current_index))
      {
        RCLCPP_INFO(logger_, "Trajectory component '%s' is invalid after scene update",
                    plan.plan_components[current_index.first].description.c_str());
        path_became_invalid_ = true;
        break;
      }
    }
 
    preempt_requested = preempt_.checkAndClear();
    if (preempt_requested)
      break;
  }
 
  // stop execution if needed
  if (preempt_requested)
  {
    RCLCPP_INFO(logger_, "Stopping execution due to preempt request");
    trajectory_execution_manager_->stopExecution();
  }
  else if (path_became_invalid_)
  {
    RCLCPP_INFO(logger_, "Stopping execution because the path to execute became invalid"
                         "(probably the environment changed)");
    trajectory_execution_manager_->stopExecution();
  }
  else if (!execution_complete_)
  {
    RCLCPP_WARN(logger_, "Stopping execution due to unknown reason."
                         "Possibly the node is about to shut down.");
    trajectory_execution_manager_->stopExecution();
  }
 
  // stop recording trajectory states
  if (trajectory_monitor_)
  {
    trajectory_monitor_->stopTrajectoryMonitor();
    plan.executed_trajectory =
        std::make_shared<robot_trajectory::RobotTrajectory>(planning_scene_monitor_->getRobotModel(), "");
    trajectory_monitor_->swapTrajectory(*plan.executed_trajectory);
  }
 
  // decide return value
  if (path_became_invalid_)
  {
    result.val = moveit_msgs::msg::MoveItErrorCodes::MOTION_PLAN_INVALIDATED_BY_ENVIRONMENT_CHANGE;
  }
  else
  {
    if (preempt_requested)
    {
      result.val = moveit_msgs::msg::MoveItErrorCodes::PREEMPTED;
    }
    else
    {
      if (trajectory_execution_manager_->getLastExecutionStatus() ==
          moveit_controller_manager::ExecutionStatus::SUCCEEDED)
      {
        result.val = moveit_msgs::msg::MoveItErrorCodes::SUCCESS;
      }
      else if (trajectory_execution_manager_->getLastExecutionStatus() ==
               moveit_controller_manager::ExecutionStatus::TIMED_OUT)
      {
        result.val = moveit_msgs::msg::MoveItErrorCodes::TIMED_OUT;
      }
      else
      {
        result.val = moveit_msgs::msg::MoveItErrorCodes::CONTROL_FAILED;
      }
    }
  }
  return result;
}
moveit_msgs::msg::MoveItErrorCodes plan_execution::PlanExecution::executeAndMonitor(ExecutableMotionPlan& plan, {…}
 
void plan_execution::PlanExecution::planningSceneUpdatedCallback(
    const planning_scene_monitor::PlanningSceneMonitor::SceneUpdateType update_type)
{
  if (update_type & (planning_scene_monitor::PlanningSceneMonitor::UPDATE_GEOMETRY |
                     planning_scene_monitor::PlanningSceneMonitor::UPDATE_TRANSFORMS))
    new_scene_update_ = true;
}
 
void plan_execution::PlanExecution::doneWithTrajectoryExecution(
    const moveit_controller_manager::ExecutionStatus& /*status*/)
{
  execution_complete_ = true;
}
 
void plan_execution::PlanExecution::successfulTrajectorySegmentExecution(const ExecutableMotionPlan& plan,
                                                                         std::size_t index)
{
  if (plan.plan_components.empty())
  {
    RCLCPP_WARN(logger_, "Length of provided motion plan is zero.");
    return;
  }
 
  // if any side-effects are associated to the trajectory part that just completed, execute them
  RCLCPP_DEBUG(logger_, "Completed '%s'", plan.plan_components[index].description.c_str());
  if (plan.plan_components[index].effect_on_success)
  {
    if (!plan.plan_components[index].effect_on_success(&plan))
    {
      // execution of side-effect failed
      RCLCPP_ERROR(logger_, "Execution of path-completion side-effect failed. Preempting.");
      preempt_.request();
      return;
    }
  }
 
  // if there is a next trajectory, check it for validity, before we start execution
  ++index;
  if (index < plan.plan_components.size() && plan.plan_components[index].trajectory &&
      !plan.plan_components[index].trajectory->empty())
  {
    std::pair<int, int> next_index(static_cast<int>(index), 0);
    if (!isRemainingPathValid(plan, next_index))
    {
      RCLCPP_INFO(logger_, "Upcoming trajectory component '%s' is invalid",
                  plan.plan_components[next_index.first].description.c_str());
      path_became_invalid_ = true;
    }
  }
}