Classes | |
| struct | ReceiveThreadResult |
| struct | SendThreadResult |
Public Member Functions | |
| ThroughputResult | run () |
| ThroughputTest (double test_duration, uint32_t streams, uint32_t message_size, uint32_t sender_threads, uint32_t receiver_threads) | |
Private Member Functions | |
| void | callback (const roscpp::ThroughputMessageConstPtr &msg) |
| void | receiveThread (boost::barrier *all_started, boost::barrier *all_start, ros::WallTime *end_time) |
| void | sendThread (boost::barrier *all_connected) |
Private Attributes | |
| uint32_t | message_size_ |
| boost::mutex | mutex_ |
| std::vector< ros::Publisher > | pubs_ |
| ros::CallbackQueue | queue_ |
| std::vector< boost::shared_ptr < ReceiveThreadResult > > | receive_results_ |
| boost::thread_specific_ptr < ReceiveThreadResult > | receive_thread_result_ |
| boost::thread_group | receive_threads_ |
| uint32_t | receiver_threads_ |
| std::vector< boost::shared_ptr < SendThreadResult > > | send_results_ |
| boost::thread_specific_ptr < SendThreadResult > | send_thread_result_ |
| boost::thread_group | send_threads_ |
| uint32_t | sender_threads_ |
| uint32_t | streams_ |
| double | test_duration_ |
| perf_roscpp::intra::ThroughputTest::ThroughputTest | ( | double | test_duration, |
| uint32_t | streams, | ||
| uint32_t | message_size, | ||
| uint32_t | sender_threads, | ||
| uint32_t | receiver_threads | ||
| ) |
| void perf_roscpp::intra::ThroughputTest::callback | ( | const roscpp::ThroughputMessageConstPtr & | msg | ) | [private] |
| void perf_roscpp::intra::ThroughputTest::receiveThread | ( | boost::barrier * | all_started, |
| boost::barrier * | all_start, | ||
| ros::WallTime * | end_time | ||
| ) | [private] |
| void perf_roscpp::intra::ThroughputTest::sendThread | ( | boost::barrier * | all_connected | ) | [private] |
uint32_t perf_roscpp::intra::ThroughputTest::message_size_ [private] |
boost::mutex perf_roscpp::intra::ThroughputTest::mutex_ [private] |
std::vector<ros::Publisher> perf_roscpp::intra::ThroughputTest::pubs_ [private] |
std::vector<boost::shared_ptr<ReceiveThreadResult> > perf_roscpp::intra::ThroughputTest::receive_results_ [private] |
boost::thread_specific_ptr<ReceiveThreadResult> perf_roscpp::intra::ThroughputTest::receive_thread_result_ [private] |
boost::thread_group perf_roscpp::intra::ThroughputTest::receive_threads_ [private] |
uint32_t perf_roscpp::intra::ThroughputTest::receiver_threads_ [private] |
std::vector<boost::shared_ptr<SendThreadResult> > perf_roscpp::intra::ThroughputTest::send_results_ [private] |
boost::thread_specific_ptr<SendThreadResult> perf_roscpp::intra::ThroughputTest::send_thread_result_ [private] |
boost::thread_group perf_roscpp::intra::ThroughputTest::send_threads_ [private] |
uint32_t perf_roscpp::intra::ThroughputTest::sender_threads_ [private] |
uint32_t perf_roscpp::intra::ThroughputTest::streams_ [private] |
double perf_roscpp::intra::ThroughputTest::test_duration_ [private] |