#include "unit.hpp"#include "corba_mqueue_test.hpp"#include <transports/corba/corba.h>#include <rtt/InputPort.hpp>#include <rtt/OutputPort.hpp>#include <rtt/TaskContext.hpp>#include <transports/corba/TaskContextServer.hpp>#include <transports/corba/TaskContextProxy.hpp>#include <string>#include <iostream>#include <transports/corba/DataFlowI.h>#include <rtt/transports/corba/RemotePorts.hpp>#include <rtt/transports/mqueue/MQLib.hpp>#include <rtt/transports/corba/CorbaConnPolicy.hpp>#include <cstdlib>

Go to the source code of this file.
Classes | |
| class | CorbaMQueueIPCTest |
Defines | |
| #define | ASSERT_PORT_SIGNALLING(code, read_port) |
| #define | wait_for(cond, times) |
| #define | wait_for_equal(a, b, times) |
Functions | |
| BOOST_AUTO_TEST_CASE (testPortConnections) | |
Variables | |
| bool | wait_for_helper |
| #define ASSERT_PORT_SIGNALLING | ( | code, | |||
| read_port | ) |
signalled_port = 0; \
code; \
usleep(100000); \
BOOST_CHECK( read_port == signalled_port );
Definition at line 110 of file corba_mqueue_ipc_test.cpp.
| #define wait_for | ( | cond, | |||
| times | ) |
wait = 0; \
while( (wait_for_helper = !(cond)) && wait++ != times ) \
usleep(100000); \
if (wait_for_helper) BOOST_CHECK( cond );
Definition at line 117 of file corba_mqueue_ipc_test.cpp.
| #define wait_for_equal | ( | a, | |||
| b, | |||||
| times | ) |
wait = 0; \
while( (wait_for_helper = ((a) != (b))) && wait++ != times ) \
usleep(100000); \
if (wait_for_helper) BOOST_CHECK_EQUAL( a, b );
Definition at line 123 of file corba_mqueue_ipc_test.cpp.
| BOOST_AUTO_TEST_CASE | ( | testPortConnections | ) |
Definition at line 194 of file corba_mqueue_ipc_test.cpp.
| bool wait_for_helper |
Definition at line 116 of file corba_mqueue_ipc_test.cpp.