Diff: libuavcan/test/protocol/transport_stats_provider.cpp

Revision:

0:dfe6edabb8ec

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/libuavcan/test/protocol/transport_stats_provider.cpp	Sat Apr 14 10:25:32 2018 +0000
@@ -0,0 +1,86 @@
+/*
+ * Copyright (C) 2014 Pavel Kirienko <pavel.kirienko@gmail.com>
+ */
+
+#include <gtest/gtest.h>
+#include <uavcan/protocol/transport_stats_provider.hpp>
+#include "helpers.hpp"
+
+
+TEST(TransportStatsProvider, Basic)
+{
+    InterlinkedTestNodesWithSysClock nodes;
+
+    uavcan::TransportStatsProvider tsp(nodes.a);
+
+    uavcan::GlobalDataTypeRegistry::instance().reset();
+    uavcan::DefaultDataTypeRegistrator<uavcan::protocol::GetTransportStats> _reg1;
+
+    ASSERT_LE(0, tsp.start());
+
+    ServiceClientWithCollector<uavcan::protocol::GetTransportStats> tsp_cln(nodes.b);
+
+    /*
+     * First request
+     */
+    ASSERT_LE(0, tsp_cln.call(1, uavcan::protocol::GetTransportStats::Request()));
+    ASSERT_LE(0, nodes.spinBoth(uavcan::MonotonicDuration::fromMSec(10)));
+
+    ASSERT_TRUE(tsp_cln.collector.result.get());
+    ASSERT_TRUE(tsp_cln.collector.result->isSuccessful());
+    ASSERT_EQ(0, tsp_cln.collector.result->getResponse().transfer_errors);
+    ASSERT_EQ(1, tsp_cln.collector.result->getResponse().transfers_rx);
+    ASSERT_EQ(0, tsp_cln.collector.result->getResponse().transfers_tx);
+    ASSERT_EQ(1, tsp_cln.collector.result->getResponse().can_iface_stats.size());
+    ASSERT_EQ(0, tsp_cln.collector.result->getResponse().can_iface_stats[0].errors);
+    ASSERT_EQ(1, tsp_cln.collector.result->getResponse().can_iface_stats[0].frames_rx);
+    ASSERT_EQ(0, tsp_cln.collector.result->getResponse().can_iface_stats[0].frames_tx);
+
+    /*
+     * Second request
+     */
+    ASSERT_LE(0, tsp_cln.call(1, uavcan::protocol::GetTransportStats::Request()));
+    ASSERT_LE(0, nodes.spinBoth(uavcan::MonotonicDuration::fromMSec(10)));
+
+    ASSERT_TRUE(tsp_cln.collector.result.get());
+    ASSERT_EQ(0, tsp_cln.collector.result->getResponse().transfer_errors);
+    ASSERT_EQ(2, tsp_cln.collector.result->getResponse().transfers_rx);
+    ASSERT_EQ(1, tsp_cln.collector.result->getResponse().transfers_tx);
+    ASSERT_EQ(1, tsp_cln.collector.result->getResponse().can_iface_stats.size());
+    ASSERT_EQ(0, tsp_cln.collector.result->getResponse().can_iface_stats[0].errors);
+    ASSERT_EQ(2, tsp_cln.collector.result->getResponse().can_iface_stats[0].frames_rx);
+    ASSERT_EQ(6, tsp_cln.collector.result->getResponse().can_iface_stats[0].frames_tx);
+
+    /*
+     * Sending a malformed frame, it must be registered as tranfer error
+     */
+    uavcan::Frame frame(uavcan::protocol::GetTransportStats::DefaultDataTypeID, uavcan::TransferTypeServiceRequest,
+                        2, 1, 1);
+    frame.setStartOfTransfer(true);
+    frame.setEndOfTransfer(true);
+    uavcan::CanFrame can_frame;
+    ASSERT_TRUE(frame.compile(can_frame));
+    nodes.can_a.read_queue.push(can_frame);
+
+    ASSERT_LE(0, nodes.spinBoth(uavcan::MonotonicDuration::fromMSec(10)));
+
+    /*
+     * Introducing a CAN driver error
+     */
+    nodes.can_a.error_count = 72;
+
+    /*
+     * Third request
+     */
+    ASSERT_LE(0, tsp_cln.call(1, uavcan::protocol::GetTransportStats::Request()));
+    ASSERT_LE(0, nodes.spinBoth(uavcan::MonotonicDuration::fromMSec(10)));
+
+    ASSERT_TRUE(tsp_cln.collector.result.get());
+    EXPECT_EQ(1, tsp_cln.collector.result->getResponse().transfer_errors);                  // That broken frame
+    EXPECT_EQ(3, tsp_cln.collector.result->getResponse().transfers_rx);
+    EXPECT_EQ(2, tsp_cln.collector.result->getResponse().transfers_tx);
+    EXPECT_EQ(1, tsp_cln.collector.result->getResponse().can_iface_stats.size());
+    EXPECT_EQ(72, tsp_cln.collector.result->getResponse().can_iface_stats[0].errors);
+    EXPECT_EQ(4, tsp_cln.collector.result->getResponse().can_iface_stats[0].frames_rx);     // Same here
+    EXPECT_EQ(12, tsp_cln.collector.result->getResponse().can_iface_stats[0].frames_tx);
+}