blob: 3e8804cea1ef500899461d82dbeb7d5ea27fbb25 [file] [log] [blame]
Alexander Afanasyev18d8bc92015-08-13 18:26:40 -07001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
3 * Copyright (c) 2011-2015 Regents of the University of California.
4 *
5 * This file is part of ndnSIM. See AUTHORS for complete list of ndnSIM authors and
6 * contributors.
7 *
8 * ndnSIM is free software: you can redistribute it and/or modify it under the terms
9 * of the GNU General Public License as published by the Free Software Foundation,
10 * either version 3 of the License, or (at your option) any later version.
11 *
12 * ndnSIM is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
13 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
14 * PURPOSE. See the GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License along with
17 * ndnSIM, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
18 **/
19
20#include "utils/tracers/ndn-app-delay-tracer.hpp"
21
22#include <boost/filesystem.hpp>
23#include <boost/test/output_test_stream.hpp>
24
25#include "../../tests-common.hpp"
26
27namespace ns3 {
28namespace ndn {
29
30const boost::filesystem::path TEST_TRACE = boost::filesystem::path(TEST_CONFIG_PATH) / "trace.txt";
31
32class AppDelayTracerFixture : public ScenarioHelperWithCleanupFixture
33{
34public:
35 AppDelayTracerFixture()
36 {
37 boost::filesystem::create_directories(TEST_CONFIG_PATH);
38
39 // setting default parameters for PointToPoint links and channels
40 Config::SetDefault("ns3::PointToPointNetDevice::DataRate", StringValue("10Mbps"));
41 Config::SetDefault("ns3::PointToPointChannel::Delay", StringValue("10ms"));
Alexander Afanasyev77f84c62018-10-08 13:37:42 -040042 Config::SetDefault("ns3::QueueBase::MaxSize", StringValue("20p"));
Alexander Afanasyev18d8bc92015-08-13 18:26:40 -070043
44 createTopology({
45 {"1", "2"},
46 {"2", "3"}
47 });
48
49 addRoutes({
50 {"1", "2", "/prefix", 1},
51 {"2", "3", "/prefix", 1}
52 });
53
54 addApps({
55 {"1", "ns3::ndn::ConsumerCbr",
56 {{"Prefix", "/prefix"}, {"Frequency", "1"}},
57 "0s", "0.9s"}, // send just one packet
58 // Second consumer will capture effect of the bug #2764
59 {"2", "ns3::ndn::ConsumerCbr",
60 {{"Prefix", "/prefix"}, {"Frequency", "1"}},
61 "2s", "100s"},
62 {"3", "ns3::ndn::Producer",
63 {{"Prefix", "/prefix"}, {"PayloadSize", "1024"}},
64 "0s", "100s"}
65 });
66 }
67
68 ~AppDelayTracerFixture()
69 {
70 boost::filesystem::remove(TEST_TRACE);
71 AppDelayTracer::Destroy(); // additional cleanup
72 }
73};
74
75BOOST_FIXTURE_TEST_SUITE(UtilsTracersNdnAppDelayTracer, AppDelayTracerFixture)
76
77BOOST_AUTO_TEST_CASE(InstallAll)
78{
79 AppDelayTracer::InstallAll(TEST_TRACE.string());
80
81 Simulator::Stop(Seconds(4));
82 Simulator::Run();
83
84 AppDelayTracer::Destroy(); // to force log to be written
85
86 std::ifstream t(TEST_TRACE.string().c_str());
87 std::stringstream buffer;
88 buffer << t.rdbuf();
89
90 BOOST_CHECK_EQUAL(buffer.str(),
Alexander Afanasyeve93e8b02018-05-08 20:10:01 -040091 R"STR(Time Node AppId SeqNo Type DelayS DelayUS RetxCount HopCount
Alexander Afanasyev0ae7eae2020-05-30 21:16:36 -0400920.0417744 1 0 0 LastDelay 0.0417744 41774.4 1 2
930.0417744 1 0 0 FullDelay 0.0417744 41774.4 1 2
942 2 0 0 LastDelay 0 0 1 1
952 2 0 0 FullDelay 0 0 1 1
963.02089 2 0 1 LastDelay 0.0208872 20887.2 1 1
973.02089 2 0 1 FullDelay 0.0208872 20887.2 1 1
Alexander Afanasyeve93e8b02018-05-08 20:10:01 -040098)STR");
Alexander Afanasyev18d8bc92015-08-13 18:26:40 -070099}
100
101BOOST_AUTO_TEST_CASE(InstallNodeContainer)
102{
103 NodeContainer nodes;
104 nodes.Add(getNode("1"));
105
106 AppDelayTracer::Install(nodes, TEST_TRACE.string());
107
108 Simulator::Stop(Seconds(4));
109 Simulator::Run();
110
111 AppDelayTracer::Destroy(); // to force log to be written
112
113 std::ifstream t(TEST_TRACE.string().c_str());
114 std::stringstream buffer;
115 buffer << t.rdbuf();
116
117 BOOST_CHECK_EQUAL(buffer.str(),
Alexander Afanasyeve93e8b02018-05-08 20:10:01 -0400118 R"STR(Time Node AppId SeqNo Type DelayS DelayUS RetxCount HopCount
Alexander Afanasyev0ae7eae2020-05-30 21:16:36 -04001190.0417744 1 0 0 LastDelay 0.0417744 41774.4 1 2
1200.0417744 1 0 0 FullDelay 0.0417744 41774.4 1 2
Alexander Afanasyeve93e8b02018-05-08 20:10:01 -0400121)STR");
Alexander Afanasyev18d8bc92015-08-13 18:26:40 -0700122}
123
124BOOST_AUTO_TEST_CASE(InstallNode)
125{
126 AppDelayTracer::Install(getNode("2"), TEST_TRACE.string());
127
128 Simulator::Stop(Seconds(4));
129 Simulator::Run();
130
131 AppDelayTracer::Destroy(); // to force log to be written
132
133 std::ifstream t(TEST_TRACE.string().c_str());
134 std::stringstream buffer;
135 buffer << t.rdbuf();
136
137 BOOST_CHECK_EQUAL(buffer.str(),
Alexander Afanasyeve93e8b02018-05-08 20:10:01 -0400138 R"STR(Time Node AppId SeqNo Type DelayS DelayUS RetxCount HopCount
Alexander Afanasyev0ae7eae2020-05-30 21:16:36 -04001392 2 0 0 LastDelay 0 0 1 1
1402 2 0 0 FullDelay 0 0 1 1
1413.02089 2 0 1 LastDelay 0.0208872 20887.2 1 1
1423.02089 2 0 1 FullDelay 0.0208872 20887.2 1 1
Alexander Afanasyeve93e8b02018-05-08 20:10:01 -0400143)STR");
Alexander Afanasyev18d8bc92015-08-13 18:26:40 -0700144}
145
146BOOST_AUTO_TEST_CASE(InstallNodeDumpStream)
147{
148 auto output = make_shared<boost::test_tools::output_test_stream>();
149 Ptr<AppDelayTracer> tracer = AppDelayTracer::Install(getNode("2"), output);
150
151 Simulator::Stop(Seconds(4));
152 Simulator::Run();
153
154 tracer = nullptr; // destroy tracer
155
156 BOOST_CHECK(output->is_equal(
Alexander Afanasyev0ae7eae2020-05-30 21:16:36 -0400157 R"STR(2 2 0 0 LastDelay 0 0 1 1
1582 2 0 0 FullDelay 0 0 1 1
1593.02089 2 0 1 LastDelay 0.0208872 20887.2 1 1
1603.02089 2 0 1 FullDelay 0.0208872 20887.2 1 1
Alexander Afanasyeve93e8b02018-05-08 20:10:01 -0400161)STR"));
Alexander Afanasyev18d8bc92015-08-13 18:26:40 -0700162}
163
164BOOST_AUTO_TEST_SUITE_END()
165
166} // namespace ndn
167} // namespace ns3