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 
48 using namespace ns3;
49 
56 class 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 
73 public:
74  virtual void DoRun (void);
75  Ipv4RipTest ();
76 
81  void ReceivePkt (Ptr<Socket> socket);
82 };
83 
84 Ipv4RipTest::Ipv4RipTest ()
85  : TestCase ("RIP")
86 {
87 }
88 
89 void 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 
100 void
101 Ipv4RipTest::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 
108 void
109 Ipv4RipTest::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 
118 void
119 Ipv4RipTest::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 
278 class 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 
295 public:
296  virtual void DoRun (void);
297  Ipv4RipCountToInfinityTest ();
298 
303  void ReceivePkt (Ptr<Socket> socket);
304 };
305 
306 Ipv4RipCountToInfinityTest::Ipv4RipCountToInfinityTest ()
307  : TestCase ("RIP counting to infinity")
308 {
309 }
310 
311 void 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 
322 void
323 Ipv4RipCountToInfinityTest::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 
330 void
331 Ipv4RipCountToInfinityTest::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 
340 void
341 Ipv4RipCountToInfinityTest::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 
505 class Ipv4RipSplitHorizonStrategyTest : public TestCase
506 {
507  Rip::SplitHorizonType_e m_setStrategy;
508  Rip::SplitHorizonType_e m_detectedStrategy;
509 
510 public:
511  virtual void DoRun (void);
512 
517  Ipv4RipSplitHorizonStrategyTest (Rip::SplitHorizonType_e strategy);
518 
523  void ReceivePktProbe (Ptr<Socket> socket);
524 };
525 
526 Ipv4RipSplitHorizonStrategyTest::Ipv4RipSplitHorizonStrategyTest (Rip::SplitHorizonType_e strategy)
527  : TestCase ("RIP Split Horizon strategy")
528 {
529  m_setStrategy = strategy;
530 }
531 
532 void 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 
575 void
576 Ipv4RipSplitHorizonStrategyTest::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 
691 class Ipv4RipTestSuite : public TestSuite
692 {
693 public:
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 
704 static 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::Recv
virtual Ptr< Packet > Recv(uint32_t maxSize, uint32_t flags)=0
Read data from the socket.
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::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::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
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