Classes | |
struct | ThreadResult |
Public Member Functions | |
LatencyTest (uint32_t count_per_stream, uint32_t streams, uint32_t message_size, uint32_t sender_threads, uint32_t receiver_threads) | |
LatencyResult | run () |
Private Member Functions | |
void | receiveCallback (const LatencyMessageConstPtr &msg, ros::Publisher &pub) |
void | receiveThread () |
void | sendCallback (const LatencyMessageConstPtr &msg, ros::Publisher &pub, uint32_t thread_index) |
void | sendThread (boost::barrier *b, uint32_t i) |
Private Attributes | |
uint32_t | count_per_stream_ |
uint32_t | message_size_ |
boost::mutex | mutex_ |
ros::CallbackQueue | receive_queue_ |
uint32_t | receiver_threads_ |
std::vector< boost::shared_ptr < ThreadResult > > | results_ |
boost::thread_group | send_threads_ |
uint32_t | sender_threads_ |
uint32_t | streams_ |
boost::thread_specific_ptr < ThreadResult > | thread_result_ |
perf_roscpp::intra::LatencyTest::LatencyTest | ( | uint32_t | count_per_stream, |
uint32_t | streams, | ||
uint32_t | message_size, | ||
uint32_t | sender_threads, | ||
uint32_t | receiver_threads | ||
) |
void perf_roscpp::intra::LatencyTest::receiveCallback | ( | const LatencyMessageConstPtr & | msg, |
ros::Publisher & | pub | ||
) | [private] |
void perf_roscpp::intra::LatencyTest::receiveThread | ( | ) | [private] |
void perf_roscpp::intra::LatencyTest::sendCallback | ( | const LatencyMessageConstPtr & | msg, |
ros::Publisher & | pub, | ||
uint32_t | thread_index | ||
) | [private] |
void perf_roscpp::intra::LatencyTest::sendThread | ( | boost::barrier * | b, |
uint32_t | i | ||
) | [private] |
uint32_t perf_roscpp::intra::LatencyTest::count_per_stream_ [private] |
uint32_t perf_roscpp::intra::LatencyTest::message_size_ [private] |
boost::mutex perf_roscpp::intra::LatencyTest::mutex_ [private] |
ros::CallbackQueue perf_roscpp::intra::LatencyTest::receive_queue_ [private] |
uint32_t perf_roscpp::intra::LatencyTest::receiver_threads_ [private] |
std::vector<boost::shared_ptr<ThreadResult> > perf_roscpp::intra::LatencyTest::results_ [private] |
boost::thread_group perf_roscpp::intra::LatencyTest::send_threads_ [private] |
uint32_t perf_roscpp::intra::LatencyTest::sender_threads_ [private] |
uint32_t perf_roscpp::intra::LatencyTest::streams_ [private] |
boost::thread_specific_ptr<ThreadResult> perf_roscpp::intra::LatencyTest::thread_result_ [private] |