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] |