#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.