fly316/PX4-Autopilot
7
0
Fork 0
mirror of https://gitee.com/mirrors_PX4/PX4-Autopilot.git synced 2026-07-17 17:10:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

Added checks for the subscriber test

Browse Source
This commit is contained in:
Pavel Kirienko
2014-03-09 18:02:28 +04:00
parent 2c2d7605a7
commit 31e169db4a
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libuavcan/test/subscriber.cpp
+9
View File
@@ -86,7 +86,9 @@ TEST(Subscriber, Basic)
typedef SubscriptionListener<uavcan::mavlink::Message> Listener;
uavcan::Subscriber<uavcan::mavlink::Message, Listener::ExtendedBinder> sub_extended(sch, poolmgr);
uavcan::Subscriber<uavcan::mavlink::Message, Listener::ExtendedBinder> sub_extended2(sch, poolmgr); // Not used
uavcan::Subscriber<uavcan::mavlink::Message, Listener::SimpleBinder> sub_simple(sch, poolmgr);
uavcan::Subscriber<uavcan::mavlink::Message, Listener::SimpleBinder> sub_simple2(sch, poolmgr); // Not used
// Null binder - will fail
ASSERT_EQ(-1, sub_extended.start(Listener::ExtendedBinder(NULL, NULL)));
@@ -131,7 +133,12 @@ TEST(Subscriber, Basic)
* Reception
*/
ASSERT_EQ(1, sub_extended.start(listener.bindExtended()));
ASSERT_EQ(1, sub_extended2.start(listener.bindExtended()));
ASSERT_EQ(1, sub_simple.start(listener.bindSimple()));
ASSERT_EQ(1, sub_simple2.start(listener.bindSimple()));
sub_extended2.stop(); // These are not used - making sure they aren't receiving anything
sub_simple2.stop();
for (unsigned int i = 0; i < rx_frames.size(); i++)
{
@@ -144,6 +151,7 @@ TEST(Subscriber, Basic)
/*
* Validation
*/
ASSERT_EQ(listener.extended.size(), rx_frames.size());
for (unsigned int i = 0; i < rx_frames.size(); i++)
{
const Listener::ReceivedDataStructureCopy s = listener.extended.at(i);
@@ -154,6 +162,7 @@ TEST(Subscriber, Basic)
ASSERT_EQ(rx_frames[i].getMonotonicTimestamp(), s.ts_monotonic);
}
ASSERT_EQ(listener.simple.size(), rx_frames.size());
for (unsigned int i = 0; i < rx_frames.size(); i++)
{
ASSERT_TRUE(listener.simple.at(i) == expected_msg);