#include <gtest/gtest.h>
#include "ros/subscription_queue.h"
#include "ros/message_deserializer.h"
#include "ros/message.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.hpp>
#include <boost/thread.hpp>
Go to the source code of this file.
Classes | |
class | FakeMessage |
class | FakeSubHelper |
Typedefs | |
typedef boost::shared_ptr < FakeSubHelper > | FakeSubHelperPtr |
Functions | |
void | callThread (SubscriptionQueue &queue) |
void | clearInCallbackCallback (SubscriptionQueue &queue) |
void | clearWhileThreadIsBlockingCallback (bool *done, boost::barrier *barrier) |
int | main (int argc, char **argv) |
TEST (SubscriptionQueue, nonConcurrentOrdering) | |
TEST (SubscriptionQueue, concurrentCallbacks) | |
TEST (SubscriptionQueue, clearWhileThreadIsBlocking) | |
TEST (SubscriptionQueue, clearInCallback) | |
TEST (SubscriptionQueue, clearThenAddAndCall) | |
TEST (SubscriptionQueue, clearCall) | |
TEST (SubscriptionQueue, infiniteQueue) | |
TEST (SubscriptionQueue, queueSize) | |
void | waitForASecond () |
void | waitForBarrier (boost::barrier *bar) |
typedef boost::shared_ptr<FakeSubHelper> FakeSubHelperPtr |
Definition at line 97 of file test_subscription_queue.cpp.
void callThread | ( | SubscriptionQueue & | queue | ) |
Definition at line 212 of file test_subscription_queue.cpp.
void clearInCallbackCallback | ( | SubscriptionQueue & | queue | ) |
Definition at line 188 of file test_subscription_queue.cpp.
void clearWhileThreadIsBlockingCallback | ( | bool * | done, | |
boost::barrier * | barrier | |||
) |
Definition at line 205 of file test_subscription_queue.cpp.
int main | ( | int | argc, | |
char ** | argv | |||
) |
Definition at line 283 of file test_subscription_queue.cpp.
TEST | ( | SubscriptionQueue | , | |
nonConcurrentOrdering | ||||
) |
Definition at line 264 of file test_subscription_queue.cpp.
TEST | ( | SubscriptionQueue | , | |
concurrentCallbacks | ||||
) |
Definition at line 241 of file test_subscription_queue.cpp.
TEST | ( | SubscriptionQueue | , | |
clearWhileThreadIsBlocking | ||||
) |
Definition at line 217 of file test_subscription_queue.cpp.
TEST | ( | SubscriptionQueue | , | |
clearInCallback | ||||
) |
Definition at line 193 of file test_subscription_queue.cpp.
TEST | ( | SubscriptionQueue | , | |
clearThenAddAndCall | ||||
) |
Definition at line 175 of file test_subscription_queue.cpp.
TEST | ( | SubscriptionQueue | , | |
clearCall | ||||
) |
Definition at line 163 of file test_subscription_queue.cpp.
TEST | ( | SubscriptionQueue | , | |
infiniteQueue | ||||
) |
Definition at line 132 of file test_subscription_queue.cpp.
TEST | ( | SubscriptionQueue | , | |
queueSize | ||||
) |
Definition at line 99 of file test_subscription_queue.cpp.
void waitForASecond | ( | ) |
Definition at line 259 of file test_subscription_queue.cpp.
void waitForBarrier | ( | boost::barrier * | bar | ) |
Definition at line 236 of file test_subscription_queue.cpp.