Possible bug in CSMA bridge implementation (incomplete routing tables autopopulation)

neko neko

unread,

Apr 19, 2015, 2:31:14 AM4/19/15

to ns-3-...@googlegroups.com

The full source code follows. It creates a network of bunch of nodes, tied up with CSMA bridges. The model use simple routing (the one that initializes on calling Ipv4GlobalRoutingHelper::PopulateRoutingTables ()). I already tried to run the very similar network model before (the same hosts were just tied together with bus CSMA basic network, the one created with CsmaHelper, no bridges) and it worked perfectly, with routing tables being populated each time. After I redesigned the model to use CSMA bridges instead, most of the routing tables of my host are containing only localhost's and their own network's routes. But, for reason unknown, some of the hosts sometimes have routes to some network beyond their own. Anyway, the model now doesn't work as it should, despite I verified my code dozen of times against official ns3 bridging example, which is, by the way, work too (though, in this example there are only 2 bridges and one router, so it actually doesn't need routing autopopulation)

Or may be I did something wrong? I would really apreciated some assistance asap, I need to submit this piece of work by monday.

#include <iostream>

#include <fstream>

#include "ns3/core-module.h"

#include "ns3/network-module.h"

#include "ns3/csma-module.h"

#include "ns3/bridge-module.h"

#include "ns3/internet-module.h"

#include "ns3/point-to-point-module.h"

#include "ns3/applications-module.h"

#include "ns3/ipv4-global-routing-helper.h"

#include "ns3/flow-monitor.h"

#include "ns3/flow-monitor-helper.h"

#include "ns3/netanim-module.h"

#include "ns3/log.h"

#include <string.h>

using namespace ns3;

using namespace std;

NS_LOG_COMPONENT_DEFINE ("Datacenter_model");

int main(int argc, char *argv[])

{

bool verbose = false;

bool with_ECMP = false;

string ECMP_str="";

string ttype = "focused";

CommandLine cmd;

cmd.AddValue ("ttype", "Connectons\' distribution to simulate", ttype);

cmd.AddValue ("with_ECMP", "Connectons\' distribution to simulate", with_ECMP);

cmd.AddValue ("verbose", "Tell echo applications to log if true", verbose);

if (with_ECMP)

{

ECMP_str="-with_ECMP";

}

cmd.Parse (argc, argv);

if (verbose)

{

LogComponentEnableAll(LOG_LEVEL_ERROR);

// LogComponentEnableAll(LOG_LEVEL_INFO);

}

LogComponentEnable ("Datacenter_model", LOG_LEVEL_INFO);

/* Configuration. */

NS_LOG_INFO ("Create nodes.");

/* Build nodes. */

NodeContainer nodes_row1_cl1;

NodeContainer nodes_row2_cl1;

NodeContainer sw_Ag_cl1;

NodeContainer sw_lnk_Ag_to_cl1;

NodeContainer nodes_row1_cl2;

NodeContainer nodes_row2_cl2;

NodeContainer sw_Ag_cl2;

NodeContainer sw_lnk_Ag_to_cl2;

NodeContainer sw_Core;

NodeContainer sw_lnk_Core_to_Ag;

NodeContainer ether_switches;

/* Build switches binding the network together. */

/*sw0 - row1 cl1; sw1 - row2 cl1; sw2 - ag cl1; sw3 - row1 cl2; sw4 - row2 cl2; sw5 - ag cl2; sw6 - core*/

ether_switches.Create (7);

/* Build cluster #1 nodes and groups. */

sw_Ag_cl1.Create (1);

nodes_row1_cl1.Create (3);

nodes_row2_cl1.Create (3);

sw_lnk_Ag_to_cl1.Add (nodes_row1_cl1.Get (2));

sw_lnk_Ag_to_cl1.Add (nodes_row2_cl1.Get (2));

sw_lnk_Ag_to_cl1.Add (sw_Ag_cl1.Get (0));

/* Build cluster #2 nodes and groups. */

sw_Ag_cl2.Create (1);

nodes_row1_cl2.Create (3);

nodes_row2_cl2.Create (3);

sw_lnk_Ag_to_cl2.Add (nodes_row1_cl2.Get (2));

sw_lnk_Ag_to_cl2.Add (nodes_row2_cl2.Get (2));

sw_lnk_Ag_to_cl2.Add (sw_Ag_cl2.Get (0));

/* Build core network nodes and groups. */

sw_Core.Create (1);

sw_lnk_Core_to_Ag.Add (sw_Core.Get (0));

sw_lnk_Core_to_Ag.Add (sw_Ag_cl1.Get (0));

sw_lnk_Core_to_Ag.Add (sw_Ag_cl2.Get (0));

NS_LOG_INFO ("Build Topology");

/* Build links. */

CsmaHelper csma;

csma.SetChannelAttribute ("DataRate", StringValue ("1Mbps"));

csma.SetChannelAttribute ("Delay", TimeValue (NanoSeconds (500)));

NetDeviceContainer netdevs_nodes_row1_cl1;

NetDeviceContainer netdevs_nodes_row2_cl1;

NetDeviceContainer netdevs_Ag_cl1;

NetDeviceContainer netdevs_nodes_row1_cl2;

NetDeviceContainer netdevs_nodes_row2_cl2;

NetDeviceContainer netdevs_Ag_cl2;

NetDeviceContainer netdevs_Core;

NetDeviceContainer switchDevices1;

NetDeviceContainer switchDevices2;

NetDeviceContainer switchDevices3;

NetDeviceContainer switchDevices4;

NetDeviceContainer switchDevices5;

NetDeviceContainer switchDevices6;

NetDeviceContainer switchDevices7;

//-----------------------

// Create csma links, from each terminal to the switch

BridgeHelper bridge;

for (int i = 0; i < 3; i++)

{

NetDeviceContainer link = csma.Install (NodeContainer (nodes_row1_cl1.Get (i), ether_switches.Get(0)));

netdevs_nodes_row1_cl1.Add (link.Get (0));

switchDevices1.Add (link.Get (1));

}

// Create the bridge netdevice, which will do the packet switching

bridge.Install (ether_switches.Get(0), switchDevices1);

// Create csma links, from each terminal to the switch

for (int i = 0; i < 3; i++)

{

NetDeviceContainer link = csma.Install (NodeContainer (nodes_row2_cl1.Get (i), ether_switches.Get(1)));

netdevs_nodes_row2_cl1.Add (link.Get (0));

switchDevices2.Add (link.Get (1));

}

// Create the bridge netdevice, which will do the packet switching

bridge.Install (ether_switches.Get(1), switchDevices2);

// Create csma links, from each terminal to the switch

for (int i = 0; i < 3; i++)

{

NetDeviceContainer link = csma.Install (NodeContainer (sw_lnk_Ag_to_cl1.Get (i), ether_switches.Get(2)));

netdevs_Ag_cl1.Add (link.Get (0));

switchDevices3.Add (link.Get (1));

}

// Create the bridge netdevice, which will do the packet switching

bridge.Install (ether_switches.Get(2), switchDevices3);

//--------------------------

// Create csma links, from each terminal to the switch

for (int i = 0; i < 3; i++)

{

NetDeviceContainer link = csma.Install (NodeContainer (nodes_row1_cl2.Get (i), ether_switches.Get(3)));

netdevs_nodes_row1_cl2.Add (link.Get (0));

switchDevices4.Add (link.Get (1));

}

// Create the bridge netdevice, which will do the packet switching

bridge.Install (ether_switches.Get(3), switchDevices4);

// Create csma links, from each terminal to the switch

for (int i = 0; i < 3; i++)

{

NetDeviceContainer link = csma.Install (NodeContainer (nodes_row2_cl2.Get (i), ether_switches.Get(4)));

netdevs_nodes_row2_cl2.Add (link.Get (0));

switchDevices5.Add (link.Get (1));

}

// Create the bridge netdevice, which will do the packet switching

bridge.Install (ether_switches.Get(4), switchDevices5);

// Create csma links, from each terminal to the switch

for (int i = 0; i < 3; i++)

{

NetDeviceContainer link = csma.Install (NodeContainer (sw_lnk_Ag_to_cl2.Get (i), ether_switches.Get(5)));

netdevs_Ag_cl2.Add (link.Get (0));

switchDevices6.Add (link.Get (1));

}

// Create the bridge netdevice, which will do the packet switching

bridge.Install (ether_switches.Get(5), switchDevices6);

//--------------------------

csma.SetChannelAttribute ("DataRate", StringValue ("1.5Mbps"));

// Create csma links, from each terminal to the switch

for (int i = 0; i < 3; i++)

{

NetDeviceContainer link = csma.Install (NodeContainer (sw_lnk_Core_to_Ag.Get (i), ether_switches.Get(6)));

netdevs_Core.Add (link.Get (0));

switchDevices7.Add (link.Get (1));

}

// Create the bridge netdevice, which will do the packet switching

bridge.Install (ether_switches.Get(6), switchDevices7);

//--------------------------

/* Install the IP stack. */

InternetStackHelper stack;

stack.Install (nodes_row1_cl1);

stack.Install (nodes_row2_cl1);

stack.Install (sw_Ag_cl1);

stack.Install (nodes_row1_cl2);

stack.Install (nodes_row2_cl2);

stack.Install (sw_Ag_cl2);

stack.Install (sw_Core);

/* Assign IP addresses. */

Ipv4AddressHelper ipv4_address;

Ipv4InterfaceContainer ipv4_nodes_row1_cl1;

Ipv4InterfaceContainer ipv4_nodes_row2_cl1;

Ipv4InterfaceContainer ipv4_Ag_cl1;

Ipv4InterfaceContainer ipv4_nodes_row1_cl2;

Ipv4InterfaceContainer ipv4_nodes_row2_cl2;

Ipv4InterfaceContainer ipv4_Ag_cl2;

Ipv4InterfaceContainer ipv4_Core;

ipv4_address.SetBase ("10.0.1.0", "255.255.255.0");

ipv4_nodes_row1_cl1 = ipv4_address.Assign (netdevs_nodes_row1_cl1);

ipv4_address.SetBase ("10.0.2.0", "255.255.255.0");

ipv4_nodes_row2_cl1 = ipv4_address.Assign (netdevs_nodes_row2_cl1);

ipv4_address.SetBase ("10.1.1.0", "255.255.255.0");

ipv4_Ag_cl1 = ipv4_address.Assign (netdevs_Ag_cl1);

ipv4_address.SetBase ("10.0.3.0", "255.255.255.0");

ipv4_nodes_row1_cl2 = ipv4_address.Assign (netdevs_nodes_row1_cl2);

ipv4_address.SetBase ("10.0.4.0", "255.255.255.0");

ipv4_nodes_row2_cl2 = ipv4_address.Assign (netdevs_nodes_row2_cl2);

ipv4_address.SetBase ("10.2.1.0", "255.255.255.0");

ipv4_Ag_cl2 = ipv4_address.Assign (netdevs_Ag_cl2);

ipv4_address.SetBase ("192.168.1.0", "255.255.255.0");

ipv4_Core = ipv4_address.Assign (netdevs_Core);

/* Generate Route. */

Ipv4GlobalRoutingHelper::PopulateRoutingTables ();

//Ipv4GlobalRoutingHelper::RecomputeRoutingTables ();

//Ipv4GlobalRouting::RandomEcmpRouting

/* Generate TCP streams. */

if (ttype == "mixed")

{

/* Create a TCP stream destination. */

Address LocalAddress (InetSocketAddress (Ipv4Address::GetAny (), 50000));

PacketSinkHelper packetSinkHelper ("ns3::TcpSocketFactory", LocalAddress);

ApplicationContainer recvapp;

recvapp.Add (packetSinkHelper.Install (nodes_row1_cl1.Get (0)));

recvapp.Add (packetSinkHelper.Install (nodes_row2_cl1.Get (0)));

recvapp.Add (packetSinkHelper.Install (nodes_row1_cl2.Get (0)));

recvapp.Add (packetSinkHelper.Install (nodes_row2_cl2.Get (0)));

recvapp.Start (Seconds (0.3));

recvapp.Stop (Seconds (152.0));

/* Create TCP streams' sources. */

OnOffHelper onOffHelper ("ns3::TcpSocketFactory", Address ());

// onOffHelper.SetAttribute ("DataRate",StringValue ("5Mbps")); uncomment to control bitrate and packet size of TCP stream generators

// onOffHelper.SetAttribute ("PacketSize",UintegerValue(512));

onOffHelper.SetAttribute ("OnTime", StringValue ("ns3::ConstantRandomVariable[Constant=1]"));

onOffHelper.SetAttribute ("OffTime", StringValue ("ns3::ConstantRandomVariable[Constant=0]"));

ApplicationContainer sendapp;

Ptr<Ipv4> ipv4_temp;

Ipv4InterfaceAddress iaddr_temp;

Ipv4Address remote_ip_addr;

/* Create TCP streams from cluster #1 to cluster #2. */

ipv4_temp = nodes_row1_cl2.Get (0)->GetObject<Ipv4>();

iaddr_temp = ipv4_temp->GetAddress (1,0);

remote_ip_addr = iaddr_temp.GetLocal ();

onOffHelper.SetAttribute ("Remote", AddressValue ((InetSocketAddress (remote_ip_addr, 50000))));

sendapp.Add (onOffHelper.Install (nodes_row1_cl1.Get (1)));

ipv4_temp = nodes_row2_cl2.Get (0)->GetObject<Ipv4>();

iaddr_temp = ipv4_temp->GetAddress (1,0);

remote_ip_addr = iaddr_temp.GetLocal ();

onOffHelper.SetAttribute ("Remote", AddressValue ((InetSocketAddress (remote_ip_addr, 50000))));

sendapp.Add (onOffHelper.Install (nodes_row2_cl1.Get (1)));

/* Create TCP streams from cluster #2 to cluster #1. */

ipv4_temp = nodes_row1_cl1.Get (0)->GetObject<Ipv4>();

iaddr_temp = ipv4_temp->GetAddress (1,0);

remote_ip_addr = iaddr_temp.GetLocal ();

onOffHelper.SetAttribute ("Remote", AddressValue ((InetSocketAddress (remote_ip_addr, 50000))));

sendapp.Add (onOffHelper.Install (nodes_row1_cl2.Get (1)));

ipv4_temp = nodes_row2_cl1.Get (0)->GetObject<Ipv4>();

iaddr_temp = ipv4_temp->GetAddress (1,0);

remote_ip_addr = iaddr_temp.GetLocal ();

onOffHelper.SetAttribute ("Remote", AddressValue ((InetSocketAddress (remote_ip_addr, 50000))));

sendapp.Add (onOffHelper.Install (nodes_row2_cl2.Get (1)));

sendapp.Start (Seconds (0.3));

sendapp.Stop (Seconds (152.0));

}

else

if (ttype == "focused")

{

/* Create a TCP stream destination. */

Address LocalAddress (InetSocketAddress (Ipv4Address::GetAny (), 50000));

PacketSinkHelper packetSinkHelper ("ns3::TcpSocketFactory", LocalAddress);

ApplicationContainer recvapp = packetSinkHelper.Install (nodes_row1_cl1.Get (0));

recvapp.Start (Seconds (0.3));

recvapp.Stop (Seconds (152.0));

/* Create TCP streams' sources. */

OnOffHelper onOffHelper ("ns3::TcpSocketFactory", Address ());

// onOffHelper.SetAttribute ("DataRate",StringValue ("5Mbps")); uncomment to control bitrate and packet size of TCP stream generators

// onOffHelper.SetAttribute ("PacketSize",UintegerValue(512));

onOffHelper.SetAttribute ("OnTime", StringValue ("ns3::ConstantRandomVariable[Constant=1]"));

onOffHelper.SetAttribute ("OffTime", StringValue ("ns3::ConstantRandomVariable[Constant=0]"));

Ptr<Ipv4> ipv4_temp = nodes_row1_cl1.Get (0)->GetObject<Ipv4>();

Ipv4InterfaceAddress iaddr_temp = ipv4_temp->GetAddress (1,0);

Ipv4Address remote_ip_addr = iaddr_temp.GetLocal ();

ApplicationContainer sendapp;

AddressValue remoteAddress (InetSocketAddress (remote_ip_addr, 50000));