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 test_roscpp::LatencyMessageConstPtr &msg, ros::Publisher &pub)
void	receiveThread ()
void	sendCallback (const test_roscpp::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_

Detailed Description

Definition at line 333 of file intra.cpp.

Constructor & Destructor Documentation

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
	)

Definition at line 369 of file intra.cpp.

void perf_roscpp::intra::LatencyTest::receiveCallback	(	const test_roscpp::LatencyMessageConstPtr &	msg,
		ros::Publisher &	pub
	)		`[private]`

Definition at line 378 of file intra.cpp.

void perf_roscpp::intra::LatencyTest::receiveThread ( ) [private]

LatencyResult perf_roscpp::intra::LatencyTest::run ( )

Definition at line 476 of file intra.cpp.

void perf_roscpp::intra::LatencyTest::sendCallback	(	const test_roscpp::LatencyMessageConstPtr &	msg,
		ros::Publisher &	pub,
		uint32_t	thread_index
	)		`[private]`