Vehicle-cpp/Nav/autoware_src/autoware/utilities/sync/include/single_sync.hpp

#ifndef _SINGLE_SYNC_HEADER_
#define _SINGLE_SYNC_HEADER_
#include "ros/ros.h"
#include <boost/circular_buffer.hpp>

template<typename T1, typename T2, typename T3>
class SingleSynchronizer
{
public:
    SingleSynchronizer(const std::string sub1_topic, const std::string sub2_topic, const std::string pub1_topic, const std::string pub2_topic, const std::string req_topic, const std::string ns);
    void run();

private:
    bool buf_flag_;
    /* user var */
    boost::circular_buffer<T1> type1_ringbuf_;
    boost::circular_buffer<T2> type2_ringbuf_;
    ros::Publisher type1_pub_;
    ros::Publisher type2_pub_;
    ros::Publisher sync_time_diff_pub_;
    bool is_req_;
    T1* p_type1_buf_;
    T2* p_type2_buf_;
    ros::Subscriber type1_sub_;
    ros::Subscriber type2_sub_;
    ros::Subscriber req_sub_;
    std::string req_topic_;

    void publish_msg(T1* p_type1_buf_, T2* p_type2_buf_);
    bool publish();
    void type1_callback(const typename T1::ConstPtr& type1_msg);
    void type2_callback(const typename T2::ConstPtr& type2_msg);
    void req_callback(const typename T3::ConstPtr& req_msg);
};

#include "impl/single_sync_impl.hpp"

#endif