A Discrete-Event Network Simulator
API
ipv4-rip-test.cc
Go to the documentation of this file.
1/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/*
3 * Copyright (c) 2016 Universita' di Firenze
4 *
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License version 2 as
7 * published by the Free Software Foundation;
8 *
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
13 *
14 * You should have received a copy of the GNU General Public License
15 * along with this program; if not, write to the Free Software
16 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17 *
18 * Author: Tommaso Pecorella <tommaso.pecorella@unifi.it>
19 */
20
21#include "ns3/test.h"
22#include "ns3/socket-factory.h"
23#include "ns3/udp-socket-factory.h"
24#include "ns3/simulator.h"
25#include "ns3/simple-channel.h"
26#include "ns3/simple-net-device.h"
27#include "ns3/socket.h"
28#include "ns3/boolean.h"
29#include "ns3/enum.h"
30
31#include "ns3/log.h"
32#include "ns3/node.h"
33#include "ns3/inet-socket-address.h"
34
35#include "ns3/internet-stack-helper.h"
36#include "ns3/ipv4-address-helper.h"
37#include "ns3/ipv4-l3-protocol.h"
38#include "ns3/icmpv4-l4-protocol.h"
39#include "ns3/udp-l4-protocol.h"
40#include "ns3/rip.h"
41#include "ns3/rip-helper.h"
42#include "ns3/node-container.h"
43#include "ns3/ipv4-static-routing.h"
44
45#include <string>
46#include <limits>
47
48using namespace ns3;
49
56class Ipv4RipTest : public TestCase
57{
58 Ptr<Packet> m_receivedPacket;
59
65 void DoSendData (Ptr<Socket> socket, std::string to);
71 void SendData (Ptr<Socket> socket, std::string to);
72
73public:
74 virtual void DoRun (void);
75 Ipv4RipTest ();
76
81 void ReceivePkt (Ptr<Socket> socket);
82};
83
84Ipv4RipTest::Ipv4RipTest ()
85 : TestCase ("RIP")
86{
87}
88
89void Ipv4RipTest::ReceivePkt (Ptr<Socket> socket)
90{
91 uint32_t availableData;
92 availableData = socket->GetRxAvailable ();
93 m_receivedPacket = socket->Recv (std::numeric_limits<uint32_t>::max (), 0);
94 NS_TEST_ASSERT_MSG_EQ (availableData, m_receivedPacket->GetSize (), "Received Packet size is not equal to the Rx buffer size");
95 //cast availableData to void, to suppress 'availableData' set but not used
96 //compiler warning
97 (void) availableData;
98}
99
100void
101Ipv4RipTest::DoSendData (Ptr<Socket> socket, std::string to)
102{
103 Address realTo = InetSocketAddress (Ipv4Address (to.c_str ()), 1234);
104 NS_TEST_EXPECT_MSG_EQ (socket->SendTo (Create<Packet> (123), 0, realTo),
105 123, "100");
106}
107
108void
109Ipv4RipTest::SendData (Ptr<Socket> socket, std::string to)
110{
111 m_receivedPacket = Create<Packet> ();
112 Simulator::ScheduleWithContext (socket->GetNode ()->GetId (), Seconds (60),
113 &Ipv4RipTest::DoSendData, this, socket, to);
114 Simulator::Stop (Seconds (66));
115 Simulator::Run ();
116}
117
118void
119Ipv4RipTest::DoRun (void)
120{
121 // Create topology
122
123 Ptr<Node> txNode = CreateObject<Node> ();
124 Ptr<Node> rxNode = CreateObject<Node> ();
125 Ptr<Node> routerA = CreateObject<Node> ();
126 Ptr<Node> routerB = CreateObject<Node> ();
127 Ptr<Node> routerC = CreateObject<Node> ();
128
129 NodeContainer nodes (txNode, rxNode);
130 NodeContainer routers (routerA, routerB, routerC);
131 NodeContainer all (nodes, routers);
132
133 RipHelper ripRouting;
134 InternetStackHelper internetRouters;
135 internetRouters.SetRoutingHelper (ripRouting);
136 internetRouters.Install (routers);
137
138 InternetStackHelper internetNodes;
139 internetNodes.Install (nodes);
140
141 NetDeviceContainer net1;
142 NetDeviceContainer net2;
143 NetDeviceContainer net3;
144 NetDeviceContainer net4;
145
146 // Sender Node
147 Ptr<SimpleNetDevice> txDev;
148 {
149 txDev = CreateObject<SimpleNetDevice> ();
150 txDev->SetAddress (Mac48Address ("00:00:00:00:00:01"));
151 txNode->AddDevice (txDev);
152 }
153 net1.Add (txDev);
154
155 // Router A
156 Ptr<SimpleNetDevice> fwDev1routerA, fwDev2routerA;
157 { // first interface
158 fwDev1routerA = CreateObject<SimpleNetDevice> ();
159 fwDev1routerA->SetAddress (Mac48Address ("00:00:00:00:00:02"));
160 routerA->AddDevice (fwDev1routerA);
161 }
162 net1.Add (fwDev1routerA);
163
164 { // second interface
165 fwDev2routerA = CreateObject<SimpleNetDevice> ();
166 fwDev2routerA->SetAddress (Mac48Address ("00:00:00:00:00:03"));
167 routerA->AddDevice (fwDev2routerA);
168 }
169 net2.Add (fwDev2routerA);
170
171 // Router B
172 Ptr<SimpleNetDevice> fwDev1routerB, fwDev2routerB;
173 { // first interface
174 fwDev1routerB = CreateObject<SimpleNetDevice> ();
175 fwDev1routerB->SetAddress (Mac48Address ("00:00:00:00:00:04"));
176 routerB->AddDevice (fwDev1routerB);
177 }
178 net2.Add (fwDev1routerB);
179
180 { // second interface
181 fwDev2routerB = CreateObject<SimpleNetDevice> ();
182 fwDev2routerB->SetAddress (Mac48Address ("00:00:00:00:00:05"));
183 routerB->AddDevice (fwDev2routerB);
184 }
185 net3.Add (fwDev2routerB);
186
187 // Router C
188 Ptr<SimpleNetDevice> fwDev1routerC, fwDev2routerC;
189 { // first interface
190 fwDev1routerC = CreateObject<SimpleNetDevice> ();
191 fwDev1routerC->SetAddress (Mac48Address ("00:00:00:00:00:06"));
192 routerC->AddDevice (fwDev1routerC);
193 }
194 net3.Add (fwDev1routerC);
195
196 { // second interface
197 fwDev2routerC = CreateObject<SimpleNetDevice> ();
198 fwDev2routerC->SetAddress (Mac48Address ("00:00:00:00:00:07"));
199 routerC->AddDevice (fwDev2routerC);
200 }
201 net4.Add (fwDev2routerC);
202
203 // Rx node
204 Ptr<SimpleNetDevice> rxDev;
205 { // first interface
206 rxDev = CreateObject<SimpleNetDevice> ();
207 rxDev->SetAddress (Mac48Address ("00:00:00:00:00:08"));
208 rxNode->AddDevice (rxDev);
209 }
210 net4.Add (rxDev);
211
212 // link the channels
213 Ptr<SimpleChannel> channel1 = CreateObject<SimpleChannel> ();
214 txDev->SetChannel (channel1);
215 fwDev1routerA->SetChannel (channel1);
216
217 Ptr<SimpleChannel> channel2 = CreateObject<SimpleChannel> ();
218 fwDev2routerA->SetChannel (channel2);
219 fwDev1routerB->SetChannel (channel2);
220
221 Ptr<SimpleChannel> channel3 = CreateObject<SimpleChannel> ();
222 fwDev2routerB->SetChannel (channel3);
223 fwDev1routerC->SetChannel (channel3);
224
225 Ptr<SimpleChannel> channel4 = CreateObject<SimpleChannel> ();
226 fwDev2routerC->SetChannel (channel4);
227 rxDev->SetChannel (channel4);
228
229 // Setup IPv4 addresses and forwarding
230 Ipv4AddressHelper ipv4;
231
232 ipv4.SetBase (Ipv4Address ("10.0.1.0"), Ipv4Mask ("255.255.255.0"));
233 Ipv4InterfaceContainer iic1 = ipv4.Assign (net1);
234
235 ipv4.SetBase (Ipv4Address ("192.168.0.0"), Ipv4Mask ("255.255.255.0"));
236 Ipv4InterfaceContainer iic2 = ipv4.Assign (net2);
237
238 ipv4.SetBase (Ipv4Address ("192.168.1.0"), Ipv4Mask ("255.255.255.0"));
239 Ipv4InterfaceContainer iic3 = ipv4.Assign (net3);
240
241 ipv4.SetBase (Ipv4Address ("10.0.2.0"), Ipv4Mask ("255.255.255.0"));
242 Ipv4InterfaceContainer iic4 = ipv4.Assign (net4);
243
244 Ptr<Ipv4StaticRouting> staticRouting;
245 staticRouting = Ipv4RoutingHelper::GetRouting <Ipv4StaticRouting> (txNode->GetObject<Ipv4> ()->GetRoutingProtocol ());
246 staticRouting->SetDefaultRoute ("10.0.1.2", 1 );
247 staticRouting = Ipv4RoutingHelper::GetRouting <Ipv4StaticRouting> (rxNode->GetObject<Ipv4> ()->GetRoutingProtocol ());
248 staticRouting->SetDefaultRoute ("10.0.2.1", 1 );
249
250 // Create the UDP sockets
251 Ptr<SocketFactory> rxSocketFactory = rxNode->GetObject<UdpSocketFactory> ();
252 Ptr<Socket> rxSocket = rxSocketFactory->CreateSocket ();
253 NS_TEST_EXPECT_MSG_EQ (rxSocket->Bind (InetSocketAddress (Ipv4Address ("10.0.2.2"), 1234)), 0, "trivial");
254 rxSocket->SetRecvCallback (MakeCallback (&Ipv4RipTest::ReceivePkt, this));
255
256 Ptr<SocketFactory> txSocketFactory = txNode->GetObject<UdpSocketFactory> ();
257 Ptr<Socket> txSocket = txSocketFactory->CreateSocket ();
258 txSocket->SetAllowBroadcast (true);
259
260 // ------ Now the tests ------------
261
262 // Unicast test
263 SendData (txSocket, "10.0.2.2");
264 NS_TEST_EXPECT_MSG_EQ (m_receivedPacket->GetSize (), 123, "IPv4 RIP should work.");
265
266 m_receivedPacket->RemoveAllByteTags ();
267
268 Simulator::Destroy ();
269}
270
271
278class Ipv4RipCountToInfinityTest : public TestCase
279{
280 Ptr<Packet> m_receivedPacket;
281
287 void DoSendData (Ptr<Socket> socket, std::string to);
293 void SendData (Ptr<Socket> socket, std::string to);
294
295public:
296 virtual void DoRun (void);
297 Ipv4RipCountToInfinityTest ();
298
303 void ReceivePkt (Ptr<Socket> socket);
304};
305
306Ipv4RipCountToInfinityTest::Ipv4RipCountToInfinityTest ()
307 : TestCase ("RIP counting to infinity")
308{
309}
310
311void Ipv4RipCountToInfinityTest::ReceivePkt (Ptr<Socket> socket)
312{
313 uint32_t availableData;
314 availableData = socket->GetRxAvailable ();
315 m_receivedPacket = socket->Recv (std::numeric_limits<uint32_t>::max (), 0);
316 NS_TEST_ASSERT_MSG_EQ (availableData, m_receivedPacket->GetSize (), "Received Packet size is not equal to the Rx buffer size");
317 //cast availableData to void, to suppress 'availableData' set but not used
318 //compiler warning
319 (void) availableData;
320}
321
322void
323Ipv4RipCountToInfinityTest::DoSendData (Ptr<Socket> socket, std::string to)
324{
325 Address realTo = InetSocketAddress (Ipv4Address (to.c_str ()), 1234);
326 NS_TEST_EXPECT_MSG_EQ (socket->SendTo (Create<Packet> (123), 0, realTo),
327 123, "100");
328}
329
330void
331Ipv4RipCountToInfinityTest::SendData (Ptr<Socket> socket, std::string to)
332{
333 m_receivedPacket = Create<Packet> ();
334 Simulator::ScheduleWithContext (socket->GetNode ()->GetId (), Seconds (60),
335 &Ipv4RipCountToInfinityTest::DoSendData, this, socket, to);
336 Simulator::Stop (Seconds (66));
337 Simulator::Run ();
338}
339
340void
341Ipv4RipCountToInfinityTest::DoRun (void)
342{
343 // Create topology
344
345 Ptr<Node> txNode = CreateObject<Node> ();
346 Ptr<Node> rxNode = CreateObject<Node> ();
347 Ptr<Node> routerA = CreateObject<Node> ();
348 Ptr<Node> routerB = CreateObject<Node> ();
349 Ptr<Node> routerC = CreateObject<Node> ();
350
351 NodeContainer nodes (txNode, rxNode);
352 NodeContainer routers (routerA, routerB, routerC);
353 NodeContainer all (nodes, routers);
354
355 RipHelper ripNgRouting;
356 // Change the router's interface metric to 10, must not send packets (count to infinity)
357 // note: Interface 0 is the loopback.
358 ripNgRouting.SetInterfaceMetric (routerA, 2, 10);
359 ripNgRouting.SetInterfaceMetric (routerB, 1, 10);
360 ripNgRouting.SetInterfaceMetric (routerB, 2, 10);
361 ripNgRouting.SetInterfaceMetric (routerC, 1, 10);
362
363 InternetStackHelper internetv6routers;
364 internetv6routers.SetRoutingHelper (ripNgRouting);
365 internetv6routers.Install (routers);
366
367 InternetStackHelper internetv6nodes;
368 internetv6nodes.Install (nodes);
369
370 NetDeviceContainer net1;
371 NetDeviceContainer net2;
372 NetDeviceContainer net3;
373 NetDeviceContainer net4;
374
375 // Sender Node
376 Ptr<SimpleNetDevice> txDev;
377 {
378 txDev = CreateObject<SimpleNetDevice> ();
379 txDev->SetAddress (Mac48Address ("00:00:00:00:00:01"));
380 txNode->AddDevice (txDev);
381 }
382 net1.Add (txDev);
383
384 // Router A
385 Ptr<SimpleNetDevice> fwDev1routerA, fwDev2routerA;
386 { // first interface
387 fwDev1routerA = CreateObject<SimpleNetDevice> ();
388 fwDev1routerA->SetAddress (Mac48Address ("00:00:00:00:00:02"));
389 routerA->AddDevice (fwDev1routerA);
390 }
391 net1.Add (fwDev1routerA);
392
393 { // second interface
394 fwDev2routerA = CreateObject<SimpleNetDevice> ();
395 fwDev2routerA->SetAddress (Mac48Address ("00:00:00:00:00:03"));
396 routerA->AddDevice (fwDev2routerA);
397 }
398 net2.Add (fwDev2routerA);
399
400 // Router B
401 Ptr<SimpleNetDevice> fwDev1routerB, fwDev2routerB;
402 { // first interface
403 fwDev1routerB = CreateObject<SimpleNetDevice> ();
404 fwDev1routerB->SetAddress (Mac48Address ("00:00:00:00:00:04"));
405 routerB->AddDevice (fwDev1routerB);
406 }
407 net2.Add (fwDev1routerB);
408
409 { // second interface
410 fwDev2routerB = CreateObject<SimpleNetDevice> ();
411 fwDev2routerB->SetAddress (Mac48Address ("00:00:00:00:00:05"));
412 routerB->AddDevice (fwDev2routerB);
413 }
414 net3.Add (fwDev2routerB);
415
416 // Router C
417 Ptr<SimpleNetDevice> fwDev1routerC, fwDev2routerC;
418 { // first interface
419 fwDev1routerC = CreateObject<SimpleNetDevice> ();
420 fwDev1routerC->SetAddress (Mac48Address ("00:00:00:00:00:06"));
421 routerC->AddDevice (fwDev1routerC);
422 }
423 net3.Add (fwDev1routerC);
424
425 { // second interface
426 fwDev2routerC = CreateObject<SimpleNetDevice> ();
427 fwDev2routerC->SetAddress (Mac48Address ("00:00:00:00:00:07"));
428 routerC->AddDevice (fwDev2routerC);
429 }
430 net4.Add (fwDev2routerC);
431
432 // Rx node
433 Ptr<SimpleNetDevice> rxDev;
434 { // first interface
435 rxDev = CreateObject<SimpleNetDevice> ();
436 rxDev->SetAddress (Mac48Address ("00:00:00:00:00:08"));
437 rxNode->AddDevice (rxDev);
438 }
439 net4.Add (rxDev);
440
441 // link the channels
442 Ptr<SimpleChannel> channel1 = CreateObject<SimpleChannel> ();
443 txDev->SetChannel (channel1);
444 fwDev1routerA->SetChannel (channel1);
445
446 Ptr<SimpleChannel> channel2 = CreateObject<SimpleChannel> ();
447 fwDev2routerA->SetChannel (channel2);
448 fwDev1routerB->SetChannel (channel2);
449
450 Ptr<SimpleChannel> channel3 = CreateObject<SimpleChannel> ();
451 fwDev2routerB->SetChannel (channel3);
452 fwDev1routerC->SetChannel (channel3);
453
454 Ptr<SimpleChannel> channel4 = CreateObject<SimpleChannel> ();
455 fwDev2routerC->SetChannel (channel4);
456 rxDev->SetChannel (channel4);
457
458 // Setup IPv4 addresses and forwarding
459 Ipv4AddressHelper ipv4;
460
461 ipv4.SetBase (Ipv4Address ("10.0.1.0"), Ipv4Mask ("255.255.255.0"));
462 Ipv4InterfaceContainer iic1 = ipv4.Assign (net1);
463
464 ipv4.SetBase (Ipv4Address ("192.168.0.0"), Ipv4Mask ("255.255.255.0"));
465 Ipv4InterfaceContainer iic2 = ipv4.Assign (net2);
466
467 ipv4.SetBase (Ipv4Address ("192.168.1.0"), Ipv4Mask ("255.255.255.0"));
468 Ipv4InterfaceContainer iic3 = ipv4.Assign (net3);
469
470 ipv4.SetBase (Ipv4Address ("10.0.2.0"), Ipv4Mask ("255.255.255.0"));
471 Ipv4InterfaceContainer iic4 = ipv4.Assign (net4);
472
473 Ptr<Ipv4StaticRouting> staticRouting;
474 staticRouting = Ipv4RoutingHelper::GetRouting <Ipv4StaticRouting> (txNode->GetObject<Ipv4> ()->GetRoutingProtocol ());
475 staticRouting->SetDefaultRoute ("10.0.1.2", 1 );
476 staticRouting = Ipv4RoutingHelper::GetRouting <Ipv4StaticRouting> (rxNode->GetObject<Ipv4> ()->GetRoutingProtocol ());
477 staticRouting->SetDefaultRoute ("10.0.2.1", 1 );
478
479
480 // Create the UDP sockets
481 Ptr<SocketFactory> rxSocketFactory = rxNode->GetObject<UdpSocketFactory> ();
482 Ptr<Socket> rxSocket = rxSocketFactory->CreateSocket ();
483 NS_TEST_EXPECT_MSG_EQ (rxSocket->Bind (InetSocketAddress (Ipv4Address ("10.0.2.2"), 1234)), 0, "trivial");
484 rxSocket->SetRecvCallback (MakeCallback (&Ipv4RipCountToInfinityTest::ReceivePkt, this));
485
486 Ptr<SocketFactory> txSocketFactory = txNode->GetObject<UdpSocketFactory> ();
487 Ptr<Socket> txSocket = txSocketFactory->CreateSocket ();
488 txSocket->SetAllowBroadcast (true);
489
490 // ------ Now the tests ------------
491
492 SendData (txSocket, "10.0.2.2");
493 NS_TEST_EXPECT_MSG_EQ (m_receivedPacket->GetSize (), 0, "RIP counting to infinity.");
494
495 Simulator::Destroy ();
496}
497
498
505class Ipv4RipSplitHorizonStrategyTest : public TestCase
506{
507 Rip::SplitHorizonType_e m_setStrategy;
508 Rip::SplitHorizonType_e m_detectedStrategy;
509
510public:
511 virtual void DoRun (void);
512
517 Ipv4RipSplitHorizonStrategyTest (Rip::SplitHorizonType_e strategy);
518
523 void ReceivePktProbe (Ptr<Socket> socket);
524};
525
526Ipv4RipSplitHorizonStrategyTest::Ipv4RipSplitHorizonStrategyTest (Rip::SplitHorizonType_e strategy)
527 : TestCase ("RIP Split Horizon strategy")
528{
529 m_setStrategy = strategy;
530}
531
532void Ipv4RipSplitHorizonStrategyTest::ReceivePktProbe (Ptr<Socket> socket)
533{
534 uint32_t availableData;
535 availableData = socket->GetRxAvailable ();
536 Address srcAddr;
537 Ptr<Packet> receivedPacketProbe = socket->RecvFrom (std::numeric_limits<uint32_t>::max (), 0, srcAddr);
538 NS_TEST_ASSERT_MSG_EQ (availableData, receivedPacketProbe->GetSize (), "Received Packet size is not equal to the Rx buffer size");
539 Ipv4Address senderAddress = InetSocketAddress::ConvertFrom (srcAddr).GetIpv4 ();
540
541 if (senderAddress == "192.168.0.2")
542 {
543 RipHeader hdr;
544 receivedPacketProbe->RemoveHeader (hdr);
545
546 std::list<RipRte> rtes = hdr.GetRteList ();
547
548 // validate the RTEs before processing
549 for (std::list<RipRte>::iterator iter = rtes.begin ();
550 iter != rtes.end (); iter++)
551 {
552 if (iter->GetPrefix () == "10.0.1.0")
553 {
554 bool correct = false;
555 if (iter->GetRouteMetric () == 16)
556 {
557 correct = true;
558 m_detectedStrategy = Rip::POISON_REVERSE;
559 }
560 else if (iter->GetRouteMetric () == 2)
561 {
562 correct = true;
563 m_detectedStrategy = Rip::NO_SPLIT_HORIZON;
564 }
565 NS_TEST_EXPECT_MSG_EQ (correct, true, "RIP: unexpected metric value: " << iter->GetRouteMetric ());
566 }
567 }
568 }
569
570 //cast availableData to void, to suppress 'availableData' set but not used
571 //compiler warning
572 (void) availableData;
573}
574
575void
576Ipv4RipSplitHorizonStrategyTest::DoRun (void)
577{
578 // Create topology
579
580 Ptr<Node> fakeNode = CreateObject<Node> ();
581 Ptr<Node> listener = CreateObject<Node> ();
582
583 Ptr<Node> routerA = CreateObject<Node> ();
584 Ptr<Node> routerB = CreateObject<Node> ();
585
586 NodeContainer listeners (listener, fakeNode);
587 NodeContainer routers (routerA, routerB);
588 NodeContainer all (routers, listeners);
589
590 RipHelper ripNgRouting;
591 ripNgRouting.Set ("SplitHorizon", EnumValue (m_setStrategy));
592
593 InternetStackHelper internetRouters;
594 internetRouters.SetRoutingHelper (ripNgRouting);
595 internetRouters.Install (routers);
596
597 InternetStackHelper internetNodes;
598 internetNodes.Install (listeners);
599
600 NetDeviceContainer net0;
601 NetDeviceContainer net1;
602
603 // Fake Node
604 Ptr<SimpleNetDevice> silentDev;
605 {
606 silentDev = CreateObject<SimpleNetDevice> ();
607 silentDev->SetAddress (Mac48Address ("00:00:00:00:00:01"));
608 fakeNode->AddDevice (silentDev);
609 }
610 net0.Add (silentDev);
611
612 // Router A
613 Ptr<SimpleNetDevice> silentDevRouterA, fwDevRouterA;
614 { // silent interface
615 silentDevRouterA = CreateObject<SimpleNetDevice> ();
616 silentDevRouterA->SetAddress (Mac48Address ("00:00:00:00:00:02"));
617 routerA->AddDevice (silentDevRouterA);
618 }
619 net0.Add (silentDevRouterA);
620
621 { // first interface
622 fwDevRouterA = CreateObject<SimpleNetDevice> ();
623 fwDevRouterA->SetAddress (Mac48Address ("00:00:00:00:00:03"));
624 routerA->AddDevice (fwDevRouterA);
625 }
626 net1.Add (fwDevRouterA);
627
628 // Router B
629 Ptr<SimpleNetDevice> fwDevRouterB;
630 { // first interface
631 fwDevRouterB = CreateObject<SimpleNetDevice> ();
632 fwDevRouterB->SetAddress (Mac48Address ("00:00:00:00:00:04"));
633 routerB->AddDevice (fwDevRouterB);
634 }
635 net1.Add (fwDevRouterB);
636
637 // listener A
638 Ptr<SimpleNetDevice> listenerDev;
639 {
640 listenerDev = CreateObject<SimpleNetDevice> ();
641 listenerDev->SetAddress (Mac48Address ("00:00:00:00:00:05"));
642 listener->AddDevice (listenerDev);
643 }
644 net1.Add (listenerDev);
645
646 // link the channels
647 Ptr<SimpleChannel> channel0 = CreateObject<SimpleChannel> ();
648 silentDev->SetChannel (channel0);
649 silentDevRouterA->SetChannel (channel0);
650
651 Ptr<SimpleChannel> channel1 = CreateObject<SimpleChannel> ();
652 fwDevRouterA->SetChannel (channel1);
653 fwDevRouterB->SetChannel (channel1);
654 listenerDev->SetChannel (channel1);
655
656 // Setup IPv6 addresses and forwarding
657 Ipv4AddressHelper ipv4;
658
659 ipv4.SetBase (Ipv4Address ("10.0.1.0"), Ipv4Mask ("255.255.255.0"));
660 Ipv4InterfaceContainer iic0 = ipv4.Assign (net0);
661
662 ipv4.SetBase (Ipv4Address ("192.168.0.0"), Ipv4Mask ("255.255.255.0"));
663 Ipv4InterfaceContainer iic1 = ipv4.Assign (net1);
664
665 // Create the UDP sockets
666 Ptr<SocketFactory> rxSocketFactory = listener->GetObject<UdpSocketFactory> ();
667 Ptr<Socket> rxSocket = rxSocketFactory->CreateSocket ();
668 rxSocket->BindToNetDevice (listenerDev);
669 NS_TEST_EXPECT_MSG_EQ (rxSocket->Bind (InetSocketAddress (Ipv4Address ("224.0.0.9"), 520)), 0, "trivial");
670 rxSocket->SetRecvCallback (MakeCallback (&Ipv4RipSplitHorizonStrategyTest::ReceivePktProbe, this));
671
672 // ------ Now the tests ------------
673
674 // If the strategy is Split Horizon, then no packet will be received.
675 m_detectedStrategy = Rip::SPLIT_HORIZON;
676
677 Simulator::Stop (Seconds (66));
678 Simulator::Run ();
679 NS_TEST_EXPECT_MSG_EQ (m_detectedStrategy, m_setStrategy, "RIP counting to infinity.");
680
681 Simulator::Destroy ();
682}
683
684
691class Ipv4RipTestSuite : public TestSuite
692{
693public:
694 Ipv4RipTestSuite () : TestSuite ("ipv4-rip", UNIT)
695 {
696 AddTestCase (new Ipv4RipTest, TestCase::QUICK);
697 AddTestCase (new Ipv4RipCountToInfinityTest, TestCase::QUICK);
698 AddTestCase (new Ipv4RipSplitHorizonStrategyTest (Rip::POISON_REVERSE), TestCase::QUICK);
699 AddTestCase (new Ipv4RipSplitHorizonStrategyTest (Rip::SPLIT_HORIZON), TestCase::QUICK);
700 AddTestCase (new Ipv4RipSplitHorizonStrategyTest (Rip::NO_SPLIT_HORIZON), TestCase::QUICK);
701 }
702};
703
704static Ipv4RipTestSuite g_ipv4ripTestSuite;
max
#define max(a, b)
Definition: 80211b.c:43
Ipv4RipCountToInfinityTest
IPv4 RIP count to infinity Test.
Definition: ipv4-rip-test.cc:279
Ipv4RipCountToInfinityTest::ReceivePkt
void ReceivePkt(Ptr< Socket > socket)
Receive data.
Definition: ipv4-rip-test.cc:311
Ipv4RipCountToInfinityTest::DoRun
virtual void DoRun(void)
Implementation to actually run this TestCase.
Definition: ipv4-rip-test.cc:341
Ipv4RipCountToInfinityTest::DoSendData
void DoSendData(Ptr< Socket > socket, std::string to)
Send data.
Definition: ipv4-rip-test.cc:323
Ipv4RipCountToInfinityTest::SendData
void SendData(Ptr< Socket > socket, std::string to)
Send data.
Definition: ipv4-rip-test.cc:331
Ipv4RipCountToInfinityTest::m_receivedPacket
Ptr< Packet > m_receivedPacket
Received packet.
Definition: ipv4-rip-test.cc:280
Ipv4RipSplitHorizonStrategyTest
IPv4 RIP SplitHorizon strategy Test.
Definition: ipv4-rip-test.cc:506
Ipv4RipSplitHorizonStrategyTest::DoRun
virtual void DoRun(void)
Implementation to actually run this TestCase.
Definition: ipv4-rip-test.cc:576
Ipv4RipSplitHorizonStrategyTest::ReceivePktProbe
void ReceivePktProbe(Ptr< Socket > socket)
Receive data.
Definition: ipv4-rip-test.cc:532
Ipv4RipSplitHorizonStrategyTest::m_detectedStrategy
Rip::SplitHorizonType_e m_detectedStrategy
Strategy detected.
Definition: ipv4-rip-test.cc:508
Ipv4RipSplitHorizonStrategyTest::Ipv4RipSplitHorizonStrategyTest
Ipv4RipSplitHorizonStrategyTest(Rip::SplitHorizonType_e strategy)
Constructor.
Definition: ipv4-rip-test.cc:526
Ipv4RipSplitHorizonStrategyTest::m_setStrategy
Rip::SplitHorizonType_e m_setStrategy
Strategy set.
Definition: ipv4-rip-test.cc:507
Ipv4RipTest
IPv4 RIP Test.
Definition: ipv4-rip-test.cc:57
Ipv4RipTest::SendData
void SendData(Ptr< Socket > socket, std::string to)
Send data.
Definition: ipv4-rip-test.cc:109
Ipv4RipTest::ReceivePkt
void ReceivePkt(Ptr< Socket > socket)
Receive data.
Definition: ipv4-rip-test.cc:89
Ipv4RipTest::DoRun
virtual void DoRun(void)
Implementation to actually run this TestCase.
Definition: ipv4-rip-test.cc:119
Ipv4RipTest::m_receivedPacket
Ptr< Packet > m_receivedPacket
Received packet.
Definition: ipv4-rip-test.cc:58
Ipv4RipTest::DoSendData
void DoSendData(Ptr< Socket > socket, std::string to)
Send data.
Definition: ipv4-rip-test.cc:101
Ipv4RipTestSuite
IPv4 RIP TestSuite.
Definition: ipv4-rip-test.cc:692
ns3::Address
a polymophic address class
Definition: address.h:91
ns3::EnumValue
Hold variables of type enum.
Definition: enum.h:55
ns3::InetSocketAddress
an Inet address class
Definition: inet-socket-address.h:41
ns3::InternetStackHelper
aggregate IP/TCP/UDP functionality to existing Nodes.
Definition: internet-stack-helper.h:88
ns3::InternetStackHelper::Install
void Install(std::string nodeName) const
Aggregate implementations of the ns3::Ipv4, ns3::Ipv6, ns3::Udp, and ns3::Tcp classes onto the provid...
Definition: internet-stack-helper.cc:359
ns3::InternetStackHelper::SetRoutingHelper
void SetRoutingHelper(const Ipv4RoutingHelper &routing)
Definition: internet-stack-helper.cc:175
ns3::Ipv4AddressHelper
A helper class to make life easier while doing simple IPv4 address assignment in scripts.
Definition: ipv4-address-helper.h:48
ns3::Ipv4AddressHelper::SetBase
void SetBase(Ipv4Address network, Ipv4Mask mask, Ipv4Address base="0.0.0.1")
Set the base network number, network mask and base address.
Definition: ipv4-address-helper.cc:64
ns3::Ipv4AddressHelper::Assign
Ipv4InterfaceContainer Assign(const NetDeviceContainer &c)
Assign IP addresses to the net devices specified in the container based on the current network prefix...
Definition: ipv4-address-helper.cc:135
ns3::Ipv4Address
Ipv4 addresses are stored in host order in this class.
Definition: ipv4-address.h:41
ns3::Ipv4
Access to the IPv4 forwarding table, interfaces, and configuration.
Definition: ipv4.h:77
ns3::Ipv4::GetRoutingProtocol
virtual Ptr< Ipv4RoutingProtocol > GetRoutingProtocol(void) const =0
Get the routing protocol to be used by this Ipv4 stack.
ns3::Ipv4InterfaceContainer
holds a vector of std::pair of Ptr<Ipv4> and interface index.
Definition: ipv4-interface-container.h:55
ns3::Ipv4Mask
a class to represent an Ipv4 address mask
Definition: ipv4-address.h:256
ns3::Mac48Address
an EUI-48 address
Definition: mac48-address.h:44
ns3::NetDeviceContainer
holds a vector of ns3::NetDevice pointers
Definition: net-device-container.h:42
ns3::NetDeviceContainer::Add
void Add(NetDeviceContainer other)
Append the contents of another NetDeviceContainer to the end of this container.
Definition: net-device-container.cc:67
ns3::NodeContainer
keep track of a set of node pointers.
Definition: node-container.h:39
ns3::Node::GetId
uint32_t GetId(void) const
Definition: node.cc:109
ns3::Node::AddDevice
uint32_t AddDevice(Ptr< NetDevice > device)
Associate a NetDevice to this node.
Definition: node.cc:130
ns3::Object::GetObject
Ptr< T > GetObject(void) const
Get a pointer to the requested aggregated Object.
Definition: object.h:470
ns3::Packet::RemoveAllByteTags
void RemoveAllByteTags(void)
Remove all byte tags stored in this packet.
Definition: packet.cc:371
ns3::Packet::RemoveHeader
uint32_t RemoveHeader(Header &header)
Deserialize and remove the header from the internal buffer.
Definition: packet.cc:280
ns3::Packet::GetSize
uint32_t GetSize(void) const
Returns the the size in bytes of the packet (including the zero-filled initial payload).
Definition: packet.h:856
ns3::RipHeader
RipHeader - see RFC 2453
Definition: rip-header.h:158
ns3::RipHeader::GetRteList
std::list< RipRte > GetRteList(void) const
Get the list of the RTEs included in the message.
Definition: rip-header.cc:272
ns3::RipHelper
Helper class that adds RIP routing to nodes.
Definition: rip-helper.h:41
ns3::RipHelper::Set
void Set(std::string name, const AttributeValue &value)
Definition: rip-helper.cc:81
ns3::RipHelper::SetInterfaceMetric
void SetInterfaceMetric(Ptr< Node > node, uint32_t interface, uint8_t metric)
Set a metric for an interface.
Definition: rip-helper.cc:176
ns3::Rip::SplitHorizonType_e
SplitHorizonType_e
Split Horizon strategy type.
Definition: rip.h:202
ns3::Socket::RecvFrom
virtual Ptr< Packet > RecvFrom(uint32_t maxSize, uint32_t flags, Address &fromAddress)=0
Read a single packet from the socket and retrieve the sender address.
ns3::Socket::GetNode
virtual Ptr< Node > GetNode(void) const =0
Return the node this socket is associated with.
ns3::Socket::GetRxAvailable
virtual uint32_t GetRxAvailable(void) const =0
Return number of bytes which can be returned from one or multiple calls to Recv.
ns3::Socket::Recv
virtual Ptr< Packet > Recv(uint32_t maxSize, uint32_t flags)=0
Read data from the socket.
ns3::Socket::SendTo
virtual int SendTo(Ptr< Packet > p, uint32_t flags, const Address &toAddress)=0
Send data to a specified peer.
ns3::TestCase
encapsulates test code
Definition: test.h:994
ns3::TestCase::AddTestCase
void AddTestCase(TestCase *testCase, TestDuration duration=QUICK)
Add an individual child TestCase to this test suite.
Definition: test.cc:299
ns3::TestSuite
A suite of tests to run.
Definition: test.h:1188
ns3::TestSuite::UNIT
@ UNIT
This test suite implements a Unit Test.
Definition: test.h:1197
ns3::UdpSocketFactory
API to create UDP socket instances.
Definition: udp-socket-factory.h:42
uint32_t
NS_TEST_ASSERT_MSG_EQ
#define NS_TEST_ASSERT_MSG_EQ(actual, limit, msg)
Test that an actual and expected (limit) value are equal and report and abort if not.
Definition: test.h:141
NS_TEST_EXPECT_MSG_EQ
#define NS_TEST_EXPECT_MSG_EQ(actual, limit, msg)
Test that an actual and expected (limit) value are equal and report if not.
Definition: test.h:240
ns3::Seconds
Time Seconds(double value)
Construct a Time in the indicated unit.
Definition: nstime.h:1244
g_ipv4ripTestSuite
static Ipv4RipTestSuite g_ipv4ripTestSuite
Static variable for test initialization.
Definition: ipv4-rip-test.cc:704
first.nodes
nodes
Definition: first.py:32
ns3
Every class exported by the ns3 library is enclosed in the ns3 namespace.
ns3::MakeCallback
Callback< R, Ts... > MakeCallback(R(T::*memPtr)(Ts...), OBJ objPtr)
Build Callbacks for class method members which take varying numbers of arguments and potentially retu...
Definition: callback.h:1648