* * *

quagga ospfd with ns-3-linux support

diff -r 28c0c7f781c1 example/dce-zebra-simple.cc

--- a/example/dce-zebra-simple.cc	Thu Mar 29 17:00:46 2012 +0200

+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000

@@ -1,114 +0,0 @@

-/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */

-/*

- * Copyright (c) 2011 UCLA

- *

- * This program is free software; you can redistribute it and/or modify

- * it under the terms of the GNU General Public License version 2 as

- * published by the Free Software Foundation;

- *

- * This program is distributed in the hope that it will be useful,

- * but WITHOUT ANY WARRANTY; without even the implied warranty of

- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

- * GNU General Public License for more details.

- *

- * You should have received a copy of the GNU General Public License

- * along with this program; if not, write to the Free Software

- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

- *

- * Author: Alexander Afanasyev <alexander.afanasyev@ucla.edu>

- */

-

-#include "ns3/network-module.h"

-#include "ns3/core-module.h"

-#include "ns3/internet-module.h"

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

-#include "ns3/dce-module.h"

-#include "ns3/quagga-helper.h"

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

-#include "../helper/ipv4-dce-routing-helper.h"

-

-using namespace ns3;

-

-NS_LOG_COMPONENT_DEFINE ("quagga");

-

-void

-procExit (std::string path, uint16_t pid, int retcode)

-{

-  std::cout << "Process exit path=" << path << " pid=" << pid << " retcode=" << retcode << std::endl;

-}

-

-// Parameters

-uint32_t nNodes = 2;

-uint32_t stopTime = 60;

-std::string netStack = "ns3";

-

-void TestDisable (Ptr<Node> node)

-{

-  NS_LOG_FUNCTION (node->GetId ());

-  

-  Ptr<Ipv4> ipv4 = node->GetObject<Ipv4> ();

-  NS_ASSERT_MSG (ipv4 != 0, "ipv4 should not be null");

-

-  // The thing I didn't know is that interface status (isUp/isDown) and device status (isLinkUp) are two totally different things.  It is possible to set interface up and down, but there is not an easy way to alter status of device. This similar to reality: it is possible to programmatically disable interface, but to actually disable a link one needs to physically cut the cable

-  ipv4->SetDown (2);

-}

-

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

-{

-  CommandLine cmd;

-  cmd.AddValue ("nNodes", "Number of Router nodes", nNodes);

-  cmd.AddValue ("stopTime", "Time to stop(seconds)", stopTime);

-  cmd.AddValue ("netStack", "What network stack", netStack);

-  cmd.Parse (argc, argv);

-

-  PointToPointHelper p2p;

-  InternetStackHelper stack;

-  Ipv4DceRoutingHelper ipv4RoutingHelper;

-  

-  stack.SetRoutingHelper (ipv4RoutingHelper);

-

-  PointToPointGridHelper grid (nNodes, nNodes, p2p);

-  grid.InstallStack (stack);

-

-  grid.AssignIpv4Addresses (

-                            Ipv4AddressHelper("10.1.0.0", "255.255.255.0"),

-                            Ipv4AddressHelper("10.2.0.0", "255.255.255.0")

-                            );

-

-  Ptr<DceManagerHelper> dceManager = CreateObject<DceManagerHelper> ();

-  dceManager->SetNetworkStack("ns3::Ns3SocketFdFactory");

-

-  QuaggaHelper quagga;

-  

-  ApplicationContainer apps;

-

-  for (int i=0; i<nNodes; i++)

-    for (int j=0; j<nNodes; j++)

-      {

-        Ptr<Node> node = grid.GetNode (i,j);

-        dceManager->Install (node);

-        quagga.EnableOspf (node);

-        quagga.EnableOspfDebug (node);

-        quagga.EnableZebraDebug (node);

-        apps.Add (quagga.Install (node));

-      }

-

-  apps.Stop (Seconds(150.0));

-

-  Simulator::ScheduleWithContext (grid.GetNode (0,0)->GetId (),

-                                  Seconds (80.0), TestDisable, grid.GetNode (0,0));

-

-  Config::Connect ("/NodeList/*/$ns3::DceManager/Exit", MakeCallback (&procExit));

-

-  // Trace routing tables 

-  Ptr<OutputStreamWrapper> routingStream = Create<OutputStreamWrapper> ("routes.log", std::ios::out);

-  ipv4RoutingHelper.PrintRoutingTableAllEvery (Seconds (10), routingStream);

-

-  Simulator::Stop (Seconds(160.0));

-  Simulator::Run ();

-  Simulator::Destroy ();

-

-  NS_LOG_INFO ("End of experiment");

-

-  return 0;

-}

diff -r 28c0c7f781c1 helper/quagga-helper.cc

--- a/helper/quagga-helper.cc	Thu Mar 29 17:00:46 2012 +0200

+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000

@@ -1,596 +0,0 @@

-/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */

-/*

- * Copyright (c) 2010 Hajime Tazaki

- *

- * This program is free software; you can redistribute it and/or modify

- * it under the terms of the GNU General Public License version 2 as

- * published by the Free Software Foundation;

- *

- * This program is distributed in the hope that it will be useful,

- * but WITHOUT ANY WARRANTY; without even the implied warranty of

- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

- * GNU General Public License for more details.

- *

- * You should have received a copy of the GNU General Public License

- * along with this program; if not, write to the Free Software

- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

- *

- * Author: Hajime Tazaki <tazaki@sfc.wide.ad.jp>

- */

-

-#include "ns3/object-factory.h"

-#include "quagga-helper.h"

-#include "ns3/names.h"

-#include "ns3/ipv4-l3-protocol.h"

-//#include "ns3/utils.h"

-#include <fstream>

-#include <map>

-#include <sys/stat.h>

-#include "ns3/log.h"

-

-NS_LOG_COMPONENT_DEFINE ("QuaggaHelper");

-

-namespace ns3 {

-

-class QuaggaConfig: public Object

-{

-private:

-  static int index;

-  std::string router_id;

-  std::map<std::string, uint32_t> *networks;

-public:

-  QuaggaConfig ()

-    : m_tdpenable (false),

-      m_zebradebug (false),

-      m_usemanualconf (false)

-  {

-    m_radvd_if = new std::vector<std::string> ();

-    m_egress_if = new std::vector<std::string> ();

-    m_haflag_if = new std::vector<std::string> ();

-  }

-  virtual ~QuaggaConfig ()

-  {

-  }

-

-  static TypeId 

-  GetTypeId (void)

-  {

-    static TypeId tid = TypeId ("ns3::QuaggaConfig")

-      .SetParent<Object> ()

-      .AddConstructor<QuaggaConfig> ()

-      ;

-    return tid;

-  }

-  TypeId 

-  GetInstanceTypeId (void) const

-  {

-    return GetTypeId ();

-  }

-

-  void

-  SetFilename (const std::string &filename)

-  {

-    m_filename = filename;

-  }

-  

-  std::string

-  GetFilename () const 

-  {

-    return m_filename;

-  }

-

-  bool m_tdpenable;

-  bool m_zebradebug;

-  bool m_usemanualconf;

-  std::vector<std::string> *m_radvd_if;

-  std::vector<std::string> *m_egress_if;

-  std::vector<std::string> *m_haflag_if;

-

-  std::string m_filename;

-

-  std::vector<uint32_t> iflist;

-

-  virtual void

-  Print (std::ostream& os) const

-  {

-    os << "hostname zebra" << std::endl

-       << "password zebra" << std::endl

-       << "log stdout" << std::endl;

-  }

-};

-std::ostream& operator << (std::ostream& os, QuaggaConfig const& config)

-{

-  config.Print (os);

-  return os;

-}

-

-class OspfConfig : public Object

-{

-private:

-  std::map<std::string, uint32_t> *networks;

-public:

-  OspfConfig ()

-    : m_ospfdebug (false)

-  {

-    networks = new std::map<std::string, uint32_t> ();

-    iflist = new std::vector<uint32_t> ();

-  }

-  ~OspfConfig ()

-  {

-    delete networks;

-    delete iflist;

-  }

-

-  bool m_ospfdebug;

-

-  static TypeId 

-  GetTypeId (void)

-  {

-    static TypeId tid = TypeId ("ns3::OspfConfig")

-      .SetParent<Object> ()

-      .AddConstructor<OspfConfig> ()

-      ;

-    return tid;

-  }

-  TypeId 

-  GetInstanceTypeId (void) const

-  {

-    return GetTypeId ();

-  }

-

-  void

-  addNetwork (Ipv4Address prefix, uint32_t plen, uint32_t area)

-  {

-    std::stringstream net;

-    net << prefix << "/" << plen;

-    networks->insert (std::map<std::string, uint32_t>::value_type (net.str (), area));

-  }

-

-  void

-  SetFilename (const std::string &filename)

-  {

-    m_filename = filename;

-  }

-  

-  std::string

-  GetFilename () const 

-  {

-    return m_filename;

-  }

-

-  virtual void

-  Print (std::ostream& os) const

-  {

-    os << "hostname zebra" << std::endl

-       << "password zebra" << std::endl

-       << "log stdout" << std::endl;

-    if (m_ospfdebug)

-      {

-        //os << "log trap errors" << std::endl;

-        os << "debug ospf event " << std::endl;

-        os << "debug ospf nsm " << std::endl;

-        os << "debug ospf ism " << std::endl;

-        os << "debug ospf packet all " << std::endl;

-      }

-

-    for (std::vector<uint32_t>::iterator i = iflist->begin (); 

-         i != iflist->end (); ++i)

-      {

-        os << "interface ns3-device" << (*i) << std::endl;

-      }

-

-    os << "router ospf " << std::endl; 

-    //    os << "  ospf router-id " << m_routerId << std::endl;

-    for (std::map<std::string, uint32_t>::iterator i = networks->begin (); 

-         i != networks->end (); ++i)

-      {

-        os << "  network " << (*i).first << " area " << (*i).second << std::endl;

-      }

-    os << "!" << std::endl;

-  }

-  std::vector<uint32_t> *iflist;

-  std::string m_filename;

-  uint32_t m_routerId;

-};

-

-

-QuaggaHelper::QuaggaHelper ()

-{

-}

-

-void 

-QuaggaHelper::SetAttribute (std::string name, const AttributeValue &value)

-{

-}

-

-// OSPF

-void

-QuaggaHelper::EnableOspf (NodeContainer nodes)

-{

-  //  for (uint32_t i = 0; i < nodes.GetN (); i++)

-  for (uint32_t i = 0; i < nodes.GetN (); i ++)

-    {

-      Ptr<OspfConfig> ospf_conf = CreateObject<OspfConfig> ();

-      nodes.Get (i)->AggregateObject (ospf_conf);

-

-      for (uint32_t j = 0; j < nodes.Get (i)->GetNDevices (); j ++)

-        {

-          // Use primary address, if multiple

-          //      Ipv4Address addr = interfaces->GetAddress (i, 0).GetLocal ();

-          // uint32_t ifindex = interfaces.Get (i).second;

-          // g_ospf_conf->iflist->insert (std::map<Ptr<Node>, uint32_t>::value_type (nodes.Get (i), ifindex));

-        }

-    }

-

-  return;

-}

-

-void

-QuaggaHelper::EnableOspfDebug (NodeContainer nodes)

-{

-  for (uint32_t i = 0; i < nodes.GetN (); i ++)

-    {

-      Ptr<OspfConfig> ospf_conf = nodes.Get (i)->GetObject<OspfConfig>();

-      if (!ospf_conf)

-        {

-          ospf_conf = new OspfConfig ();

-          nodes.Get (i)->AggregateObject (ospf_conf);

-        }

-      ospf_conf->m_ospfdebug = true;

-    }

-  return;

-}

-

-void

-QuaggaHelper::EnableTdpNina (NodeContainer nodes)

-{

-  for (uint32_t i = 0; i < nodes.GetN (); i ++)

-    {

-      Ptr<QuaggaConfig> zebra_conf = nodes.Get (i)->GetObject<QuaggaConfig>();

-      if (!zebra_conf)

-        {

-          zebra_conf = new QuaggaConfig ();

-          nodes.Get (i)->AggregateObject (zebra_conf);

-        }

-      zebra_conf->m_tdpenable = true;

-    }

-  return;

-}

-

-void

-QuaggaHelper::EnableZebraDebug (NodeContainer nodes)

-{

-  for (uint32_t i = 0; i < nodes.GetN (); i ++)

-    {

-      Ptr<QuaggaConfig> zebra_conf = nodes.Get (i)->GetObject<QuaggaConfig>();

-      if (!zebra_conf)

-        {

-          zebra_conf = new QuaggaConfig ();

-          nodes.Get (i)->AggregateObject (zebra_conf);

-        }

-      zebra_conf->m_zebradebug = true;

-    }

-  return;

-}

-

-void

-QuaggaHelper::EnableRadvd (Ptr<Node> node, const char *ifname)

-{

-  Ptr<QuaggaConfig> zebra_conf = node->GetObject<QuaggaConfig>();

-  if (!zebra_conf)

-    {

-      zebra_conf = new QuaggaConfig ();

-      node->AggregateObject (zebra_conf);

-    }

-

-  zebra_conf->m_radvd_if->push_back (std::string(ifname));

-

-  return;

-}

-

-void

-QuaggaHelper::EnableEgressIF (Ptr<Node> node, const char *ifname)

-{

-  Ptr<QuaggaConfig> zebra_conf = node->GetObject<QuaggaConfig>();

-  if (!zebra_conf)

-    {

-      zebra_conf = new QuaggaConfig ();

-      node->AggregateObject (zebra_conf);

-    }

-

-  zebra_conf->m_egress_if->push_back (std::string(ifname));

-

-  return;

-}

-

-void

-QuaggaHelper::EnableHomeAgentFlag (Ptr<Node> node, const char *ifname)

-{

-  Ptr<QuaggaConfig> zebra_conf = node->GetObject<QuaggaConfig>();

-  if (!zebra_conf)

-    {

-      zebra_conf = new QuaggaConfig ();

-      node->AggregateObject (zebra_conf);

-    }

-

-  zebra_conf->m_haflag_if->push_back (std::string(ifname));

-

-  return;

-}

-

-void

-QuaggaHelper::UseManualConfig (NodeContainer nodes)

-{

-  for (uint32_t i = 0; i < nodes.GetN (); i ++)

-    {

-      Ptr<QuaggaConfig> zebra_conf = nodes.Get (i)->GetObject<QuaggaConfig>();

-      if (!zebra_conf)

-        {

-          zebra_conf = new QuaggaConfig ();

-          nodes.Get (i)->AggregateObject (zebra_conf);

-        }

-      zebra_conf->m_usemanualconf = true;

-    }

-  return;

-}

-

-

-void

-QuaggaHelper::GenerateConfigZebra (Ptr<Node> node)

-{

-  Ptr<QuaggaConfig> zebra_conf = node->GetObject<QuaggaConfig>();

-  Ptr<Ipv4> ipv4 = node->GetObject<Ipv4> ();

-

-  if (zebra_conf->m_usemanualconf)

-    {

-      return;

-    }

-

-  NS_LOG_DEBUG ("ipv4->GetNInterfaces () = " << ipv4->GetNInterfaces ());

-

-//   for (uint32_t i = 0; i < ipv4->GetNInterfaces (); i ++)

-//     {

-//       Ipv4Address addr = ipv4->GetAddress (i, 0).GetLocal ();

-//       Ipv4Mask mask = ipv4->GetAddress (i, 0).GetMask ();

-//       Ipv4Address prefix = addr.CombineMask (mask);

-// 

-//       NS_LOG_DEBUG ("address: " << addr);

-// 

-//       if (addr.IsEqual (Ipv4Address::GetLoopback()))

-//         {

-//           continue;

-//         }

-//       

-//       zebra_conf->iflist.push_back (i);

-//     }

-

-  // config generation

-  std::stringstream conf_dir, conf_file;

-  // FIXME XXX

-  conf_dir << "files-" << node->GetId () << "";