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 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_ |
Definition at line 43 of file intra.cpp.
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 ThroughputMessageConstPtr & | msg | ) | [private] |
void perf_roscpp::intra::ThroughputTest::receiveThread | ( | boost::barrier * | all_started, | |
boost::barrier * | all_start, | |||
ros::WallTime * | end_time | |||
) | [private] |
ThroughputResult perf_roscpp::intra::ThroughputTest::run | ( | ) |
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] |
ros::CallbackQueue perf_roscpp::intra::ThroughputTest::queue_ [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] |