topic_statistic_frequency.cpp

Go to the documentation of this file.

#include <map>
#include <string>
 
#include <ros/ros.h>
#include <gtest/gtest.h>
#include <rosgraph_msgs/TopicStatistics.h>
#include <boost/thread.hpp>
#include <std_msgs/Int8MultiArray.h>
 
class Aggregator {
public:
  std::map<std::string, ros::Duration> topic_period_mean_map_;
 
  void cb(const rosgraph_msgs::TopicStatistics& msg) {
    topic_period_mean_map_[msg.topic] = msg.period_mean;
  }
 
  bool frequencyAcceptable(const std::string& topic, float expected) {
    float errorMargin = 0.1;
    float foundFreq = 1.f / topic_period_mean_map_[topic].toSec();
    return std::fabs(foundFreq - expected) / expected <= errorMargin;
  }
};
 
void assertEventuallyHasTopic(const Aggregator& agg, const std::string& topic) {
  ros::Duration timeout(5.0);
  auto start = ros::Time::now();
  while (ros::Time::now() - start < timeout && !agg.topic_period_mean_map_.count(topic)) {
    ros::Duration(0.5).sleep();
  }
  ASSERT_EQ(agg.topic_period_mean_map_.count(topic), 1u);
}
 
TEST(TopicStatisticFrequency, statisticFrequency)
{
  ros::NodeHandle nh;
  Aggregator agg;
  ros::Subscriber stat_sub = nh.subscribe("/statistics", 1, &Aggregator::cb, &agg);
 
  ros::AsyncSpinner spinner(4);
  spinner.start();
 
  ros::Duration(5.0).sleep();
 
  assertEventuallyHasTopic(agg, "/very_fast_chatter");
  assertEventuallyHasTopic(agg, "/fast_chatter");
  assertEventuallyHasTopic(agg, "/slow_chatter");
  assertEventuallyHasTopic(agg, "/very_slow_chatter");
 
  ros::shutdown();
 
  ASSERT_TRUE(agg.frequencyAcceptable("/very_fast_chatter", 171));
  ASSERT_TRUE(agg.frequencyAcceptable("/fast_chatter", 53));
  ASSERT_TRUE(agg.frequencyAcceptable("/slow_chatter", 18));
  ASSERT_TRUE(agg.frequencyAcceptable("/very_slow_chatter", 0.8));
}
 
 
int main(int argc, char** argv)
{
  testing::InitGoogleTest(&argc, argv);
  ros::init(argc, argv, "topic_statistic_frequency");
  ros::NodeHandle nh;
  return RUN_ALL_TESTS();
}