mrpt_local_obstacles_node.cpp

Go to the documentation of this file.

/***********************************************************************************
 * Revised BSD License *
 * Copyright (c) 2014-2015, Jose-Luis Blanco <jlblanco@ual.es> *
 * 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 the Vienna University of Technology 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 Markus Bader 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. *
 ***********************************************************************************/

#include <ros/ros.h>

#include <sensor_msgs/LaserScan.h>
#include <sensor_msgs/PointCloud.h>
#include <nav_msgs/Odometry.h>

#include <tf/transform_listener.h>

#include <mrpt_bridge/pose.h>
#include <mrpt_bridge/laser_scan.h>
#include <mrpt_bridge/point_cloud.h>

#include <map>

#include <mrpt/version.h>
#include <mrpt/obs/CSensoryFrame.h>
#include <mrpt/maps/CSimplePointsMap.h>
#include <mrpt/maps/COccupancyGridMap2D.h>
#include <mrpt/obs/CObservation2DRangeScan.h>
using namespace mrpt::maps;
using namespace mrpt::obs;

#include <mrpt/system/string_utils.h>
#include <mrpt/utils/CTimeLogger.h>
#include <mrpt/utils/CConfigFile.h>
#include <mrpt/gui/CDisplayWindow3D.h>
#include <mrpt/opengl/CGridPlaneXY.h>
#include <mrpt/opengl/CPointCloud.h>
#include <mrpt/opengl/stock_objects.h>

// The ROS node
class LocalObstaclesNode
{
   private:
        struct TAuxInitializer
        {
                TAuxInitializer(int argc, char** argv)
                {
                        ros::init(argc, argv, "mrpt_local_obstacles_node");
                }
        };

        mrpt::utils::CTimeLogger m_profiler;

        TAuxInitializer m_auxinit;  
        ros::NodeHandle m_nh;  
        ros::NodeHandle m_localn;  
        bool m_show_gui;
        std::string m_frameid_reference;  
        std::string m_frameid_robot;  
        std::string
                m_topic_local_map_pointcloud;  
        std::string m_source_topics_2dscan;  
        double m_time_window;  

        double m_publish_period;  


        ros::Timer m_timer_publish;

        // Sensor data:
        struct TInfoPerTimeStep
        {
                CObservation::Ptr observation;
                mrpt::poses::CPose3D robot_pose;
        };
        typedef std::multimap<double, TInfoPerTimeStep> TListObservations;
        TListObservations m_hist_obs;  

        boost::mutex m_hist_obs_mtx;

        CSimplePointsMap m_localmap_pts;
        // COccupancyGridMap2D m_localmap_grid;

        mrpt::gui::CDisplayWindow3D::Ptr m_gui_win;

        ros::Publisher m_pub_local_map_pointcloud;
        std::vector<ros::Subscriber>
                m_subs_2dlaser;  
        tf::TransformListener m_tf_listener;  

        template <typename CALLBACK_METHOD_TYPE>
        size_t subscribeToMultipleTopics(
                const std::string& lstTopics, std::vector<ros::Subscriber>& subs,
                CALLBACK_METHOD_TYPE cb)
        {
                std::vector<std::string> lstSources;
                mrpt::system::tokenize(lstTopics, " ,\t\n", lstSources);
                subs.resize(lstSources.size());
                for (size_t i = 0; i < lstSources.size(); i++)
                        subs[i] = m_nh.subscribe(lstSources[i], 1, cb, this);
                return lstSources.size();
        }

        void onNewSensor_Laser2D(const sensor_msgs::LaserScanConstPtr& scan)
        {
                mrpt::utils::CTimeLoggerEntry tle(m_profiler, "onNewSensor_Laser2D");

                // Get the relative position of the sensor wrt the robot:
                tf::StampedTransform sensorOnRobot;
                try
                {
                        mrpt::utils::CTimeLoggerEntry tle2(
                                m_profiler, "onNewSensor_Laser2D.lookupTransform_sensor");
                        m_tf_listener.lookupTransform(
                                m_frameid_robot, scan->header.frame_id, ros::Time(0),
                                sensorOnRobot);
                }
                catch (tf::TransformException& ex)
                {
                        ROS_ERROR("%s", ex.what());
                        return;
                }

                // Convert data to MRPT format:
                mrpt::poses::CPose3D sensorOnRobot_mrpt;
                mrpt_bridge::convert(sensorOnRobot, sensorOnRobot_mrpt);
                // In MRPT, CObservation2DRangeScan holds both: sensor data + relative
                // pose:
                CObservation2DRangeScan::Ptr obsScan =
                        mrpt::make_aligned_shared<CObservation2DRangeScan>();
                mrpt_bridge::convert(*scan, sensorOnRobot_mrpt, *obsScan);

                ROS_DEBUG(
                        "[onNewSensor_Laser2D] %u rays, sensor pose on robot %s",
                        static_cast<unsigned int>(obsScan->scan.size()),
                        sensorOnRobot_mrpt.asString().c_str());

                // Get sensor timestamp:
                const double timestamp = scan->header.stamp.toSec();

                // Get robot pose at that time in the reference frame, typ: /odom ->
                // /base_link
                mrpt::poses::CPose3D robotPose;
                try
                {
                        mrpt::utils::CTimeLoggerEntry tle3(
                                m_profiler, "onNewSensor_Laser2D.lookupTransform_robot");
                        tf::StampedTransform tx;

                        try
                        {
                                m_tf_listener.lookupTransform(
                                        m_frameid_reference, m_frameid_robot, scan->header.stamp,
                                        tx);
                        }
                        catch (tf::ExtrapolationException&)
                        {
                                // if we need a "too much " recent robot pose,be happy with the
                                // latest one:
                                m_tf_listener.lookupTransform(
                                        m_frameid_reference, m_frameid_robot, ros::Time(0), tx);
                        }
                        mrpt_bridge::convert(tx, robotPose);
                        ROS_DEBUG(
                                "[onNewSensor_Laser2D] robot pose %s",
                                robotPose.asString().c_str());
                }
                catch (tf::TransformException& ex)
                {
                        ROS_ERROR("%s", ex.what());
                        return;
                }

                // Insert into the observation history:
                TInfoPerTimeStep ipt;
                ipt.observation = obsScan;
                ipt.robot_pose = robotPose;

                m_hist_obs_mtx.lock();
                m_hist_obs.insert(
                        m_hist_obs.end(), TListObservations::value_type(timestamp, ipt));
                m_hist_obs_mtx.unlock();

        }  // end onNewSensor_Laser2D

        void onDoPublish(const ros::TimerEvent&)
        {
                mrpt::utils::CTimeLoggerEntry tle(m_profiler, "onDoPublish");

                // Purge old observations & latch a local copy:
                TListObservations obs;
                {
                        mrpt::utils::CTimeLoggerEntry tle(
                                m_profiler, "onDoPublish.removingOld");
                        m_hist_obs_mtx.lock();

                        // Purge old obs:
                        if (!m_hist_obs.empty())
                        {
                                const double last_time = m_hist_obs.rbegin()->first;
                                TListObservations::iterator it_first_valid =
                                        m_hist_obs.lower_bound(last_time - m_time_window);
                                const size_t nToRemove =
                                        std::distance(m_hist_obs.begin(), it_first_valid);
                                ROS_DEBUG(
                                        "[onDoPublish] Removing %u old entries, last_time=%lf",
                                        static_cast<unsigned int>(nToRemove), last_time);
                                m_hist_obs.erase(m_hist_obs.begin(), it_first_valid);
                        }
                        // Local copy in this thread:
                        obs = m_hist_obs;
                        m_hist_obs_mtx.unlock();
                }

                ROS_DEBUG(
                        "Building local map with %u observations.",
                        static_cast<unsigned int>(obs.size()));
                if (obs.empty()) return;

                // Build local map(s):
                // -----------------------------------------------
                m_localmap_pts.clear();
                mrpt::poses::CPose3D curRobotPose;
                {
                        mrpt::utils::CTimeLoggerEntry tle2(
                                m_profiler, "onDoPublish.buildLocalMap");

                        // Get the latest robot pose in the reference frame (typ: /odom ->
                        // /base_link)
                        // so we can build the local map RELATIVE to it:
                        try
                        {
                                tf::StampedTransform tx;
                                m_tf_listener.lookupTransform(
                                        m_frameid_reference, m_frameid_robot, ros::Time(0), tx);
                                mrpt_bridge::convert(tx, curRobotPose);
                                ROS_DEBUG(
                                        "[onDoPublish] Building local map relative to latest robot "
                                        "pose: %s",
                                        curRobotPose.asString().c_str());
                        }
                        catch (tf::TransformException& ex)
                        {
                                ROS_ERROR("%s", ex.what());
                                return;
                        }

                        // For each observation: compute relative robot pose & insert obs
                        // into map:
                        for (TListObservations::const_iterator it = obs.begin();
                                 it != obs.end(); ++it)
                        {
                                const TInfoPerTimeStep& ipt = it->second;

                                // Relative pose in the past:
                                mrpt::poses::CPose3D relPose(mrpt::poses::UNINITIALIZED_POSE);
                                relPose.inverseComposeFrom(ipt.robot_pose, curRobotPose);

                                // Insert obs:
                                m_localmap_pts.insertObservationPtr(ipt.observation, &relPose);

                        }  // end for
                }

                // Publish them:
                if (m_pub_local_map_pointcloud.getNumSubscribers() > 0)
                {
                        sensor_msgs::PointCloudPtr msg_pts =
                                sensor_msgs::PointCloudPtr(new sensor_msgs::PointCloud);
                        msg_pts->header.frame_id = m_frameid_robot;
                        msg_pts->header.stamp = ros::Time(obs.rbegin()->first);
                        mrpt_bridge::point_cloud::mrpt2ros(
                                m_localmap_pts, msg_pts->header, *msg_pts);
                        m_pub_local_map_pointcloud.publish(msg_pts);
                }

                // Show gui:
                if (m_show_gui)
                {
                        if (!m_gui_win)
                        {
                                m_gui_win = mrpt::gui::CDisplayWindow3D::Create(
                                        "LocalObstaclesNode", 800, 600);
                                mrpt::opengl::COpenGLScene::Ptr& scene =
                                        m_gui_win->get3DSceneAndLock();
                                scene->insert(
                                        mrpt::make_aligned_shared<mrpt::opengl::CGridPlaneXY>());
                                scene->insert(
                                        mrpt::opengl::stock_objects::CornerXYZSimple(1.0, 4.0));

                                mrpt::opengl::CSetOfObjects::Ptr gl_obs =
                                        mrpt::make_aligned_shared<mrpt::opengl::CSetOfObjects>();
                                gl_obs->setName("obstacles");
                                scene->insert(gl_obs);

                                mrpt::opengl::CPointCloud::Ptr gl_pts =
                                        mrpt::make_aligned_shared<mrpt::opengl::CPointCloud>();
                                gl_pts->setName("points");
                                gl_pts->setPointSize(2.0);
                                gl_pts->setColor_u8(mrpt::utils::TColor(0x0000ff));
                                scene->insert(gl_pts);

                                m_gui_win->unlockAccess3DScene();
                        }

                        mrpt::opengl::COpenGLScene::Ptr& scene =
                                m_gui_win->get3DSceneAndLock();
                        mrpt::opengl::CSetOfObjects::Ptr gl_obs =
                                std::dynamic_pointer_cast<mrpt::opengl::CSetOfObjects>(
                                        scene->getByName("obstacles"));
                        ROS_ASSERT(!!gl_obs);
                        gl_obs->clear();

                        mrpt::opengl::CPointCloud::Ptr gl_pts =
                                std::dynamic_pointer_cast<mrpt::opengl::CPointCloud>(
                                        scene->getByName("points"));

                        for (TListObservations::const_iterator it = obs.begin();
                                 it != obs.end(); ++it)
                        {
                                const TInfoPerTimeStep& ipt = it->second;
                                // Relative pose in the past:
                                mrpt::poses::CPose3D relPose(mrpt::poses::UNINITIALIZED_POSE);
                                relPose.inverseComposeFrom(ipt.robot_pose, curRobotPose);

                                mrpt::opengl::CSetOfObjects::Ptr gl_axis =
                                        mrpt::opengl::stock_objects::CornerXYZSimple(0.9, 2.0);
                                gl_axis->setPose(relPose);
                                gl_obs->insert(gl_axis);
                        }  // end for

                        gl_pts->loadFromPointsMap(&m_localmap_pts);

                        m_gui_win->unlockAccess3DScene();
                        m_gui_win->repaint();
                }

        }  // onDoPublish

   public:
        LocalObstaclesNode(int argc, char** argv)
                : m_auxinit(argc, argv),
                  m_nh(),
                  m_localn("~"),
                  m_show_gui(true),
                  m_frameid_reference("odom"),
                  m_frameid_robot("base_link"),
                  m_topic_local_map_pointcloud("local_map_pointcloud"),
                  m_source_topics_2dscan("scan,laser1"),
                  m_time_window(0.2),
                  m_publish_period(0.05)
        {
                // Load params:
                m_localn.param("show_gui", m_show_gui, m_show_gui);
                m_localn.param(
                        "frameid_reference", m_frameid_reference, m_frameid_reference);
                m_localn.param("frameid_robot", m_frameid_robot, m_frameid_robot);
                m_localn.param(
                        "topic_local_map_pointcloud", m_topic_local_map_pointcloud,
                        m_topic_local_map_pointcloud);
                m_localn.param(
                        "source_topics_2dscan", m_source_topics_2dscan,
                        m_source_topics_2dscan);
                m_localn.param("time_window", m_time_window, m_time_window);
                m_localn.param("publish_period", m_publish_period, m_publish_period);

                ROS_ASSERT(m_time_window > m_publish_period);
                ROS_ASSERT(m_publish_period > 0);

                // Init ROS publishers:
                m_pub_local_map_pointcloud = m_nh.advertise<sensor_msgs::PointCloud>(
                        m_topic_local_map_pointcloud, 10);

                // Init ROS subs:
                // Subscribe to one or more laser sources:
                size_t nSubsTotal = 0;
                nSubsTotal += this->subscribeToMultipleTopics(
                        m_source_topics_2dscan, m_subs_2dlaser,
                        &LocalObstaclesNode::onNewSensor_Laser2D);

                ROS_INFO(
                        "Total number of sensor subscriptions: %u\n",
                        static_cast<unsigned int>(nSubsTotal));
                ROS_ASSERT_MSG(
                        nSubsTotal > 0,
                        "*Error* It is mandatory to set at least one source topic for "
                        "sensory information!");

                // Local map params:
                m_localmap_pts.insertionOptions.minDistBetweenLaserPoints = 0;
                m_localmap_pts.insertionOptions.also_interpolate = false;

                // Init timers:
                m_timer_publish = m_nh.createTimer(
                        ros::Duration(m_publish_period), &LocalObstaclesNode::onDoPublish,
                        this);

        }  // end ctor

};  // end class

int main(int argc, char** argv)
{
        LocalObstaclesNode the_node(argc, argv);
        ros::spin();
        return 0;
}