#include <gtest/gtest.h>
#include "ros/subscription_queue.h"
#include "ros/message_deserializer.h"
#include "ros/callback_queue_interface.h"
#include "ros/subscription_callback_helper.h"
#include "ros/init.h"
#include <boost/shared_array.hpp>
#include <boost/bind/bind.hpp>
#include <boost/thread.hpp>
#include "fake_message.h"

Include dependency graph for test_subscription_queue.cpp:

Functions
void	callThread (SubscriptionQueue &queue)

void	clearInCallbackCallback (SubscriptionQueue &queue)

void	clearWhileThreadIsBlockingCallback (bool done, boost::barrier barrier)

int	main (int argc, char **argv)

	TEST (SubscriptionQueue, clearCall)

	TEST (SubscriptionQueue, clearInCallback)

	TEST (SubscriptionQueue, clearThenAddAndCall)

	TEST (SubscriptionQueue, clearWhileThreadIsBlocking)

	TEST (SubscriptionQueue, concurrentCallbacks)

	TEST (SubscriptionQueue, infiniteQueue)

	TEST (SubscriptionQueue, nonConcurrentOrdering)

	TEST (SubscriptionQueue, queueSize)

void	waitForASecond ()

void	waitForBarrier (boost::barrier *bar)

Function Documentation

◆ callThread()

void callThread ( SubscriptionQueue & queue )

Definition at line 164 of file test_subscription_queue.cpp.

◆ clearInCallbackCallback()

void clearInCallbackCallback ( SubscriptionQueue & queue )

Definition at line 140 of file test_subscription_queue.cpp.

◆ clearWhileThreadIsBlockingCallback()

void clearWhileThreadIsBlockingCallback	(	bool *	done,
		boost::barrier *	barrier
	)

Definition at line 157 of file test_subscription_queue.cpp.

◆ main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 235 of file test_subscription_queue.cpp.

◆ TEST() [1/8]

TEST	(	SubscriptionQueue	,
		clearCall
	)

Definition at line 115 of file test_subscription_queue.cpp.

◆ TEST() [2/8]

TEST	(	SubscriptionQueue	,
		clearInCallback
	)

Definition at line 145 of file test_subscription_queue.cpp.

◆ TEST() [3/8]

TEST	(	SubscriptionQueue	,
		clearThenAddAndCall
	)

Definition at line 127 of file test_subscription_queue.cpp.

◆ TEST() [4/8]

TEST	(	SubscriptionQueue	,
		clearWhileThreadIsBlocking
	)

Definition at line 169 of file test_subscription_queue.cpp.

◆ TEST() [5/8]

TEST	(	SubscriptionQueue	,
		concurrentCallbacks
	)

Definition at line 193 of file test_subscription_queue.cpp.

◆ TEST() [6/8]

TEST	(	SubscriptionQueue	,
		infiniteQueue
	)

Definition at line 84 of file test_subscription_queue.cpp.

◆ TEST() [7/8]

TEST	(	SubscriptionQueue	,
		nonConcurrentOrdering
	)

Definition at line 216 of file test_subscription_queue.cpp.

◆ TEST() [8/8]

TEST	(	SubscriptionQueue	,
		queueSize
	)

Definition at line 51 of file test_subscription_queue.cpp.

◆ waitForASecond()

void waitForASecond ( )

Definition at line 211 of file test_subscription_queue.cpp.

◆ waitForBarrier()

void waitForBarrier ( boost::barrier * bar )

Definition at line 188 of file test_subscription_queue.cpp.

Functions