Attachment #713 for bug #779

View | Details | Raw Unified | Return to bug 779
Collapse All | Expand All




}

Ptr<NixVector>
Ipv4NixVectorRouting::GetNixVector (Ptr<Node> source, Ipv4Address dest, Ptr<NetDevice> oif)
{
  NS_LOG_FUNCTION_NOARGS ();


      // otherwise proceed as normal 
      // and build the nix vector
      std::vector< Ptr<Node> > parentVector;

      BFS (NodeList::GetNNodes (), source, destNode, parentVector, oif);

      if (BuildNixVector (parentVector, source->GetId (), destNode->GetId (), nixVector))
        {

      NS_LOG_LOGIC ("Nix-vector not in cache, build: ");
      // Build the nix-vector, given this node and the
      // dest IP address
      nixVectorInCache = GetNixVector (m_node, header.GetDestination (), oif);

      // cache it
      m_nixCache.insert (NixMap_t::value_type (header.GetDestination (), nixVectorInCache));

      uint32_t numberOfBits = nixVectorForPacket->BitCount (m_totalNeighbors);
      uint32_t nodeIndex = nixVectorForPacket->ExtractNeighborIndex (numberOfBits);

      // Search here in a cache for this node index 
      // and look for a Ipv4Route
      // need to do the next 3 lines.
      rtentry = GetIpv4RouteInCache (header.GetDestination ());

      if (!rtentry || !(rtentry->GetOutputDevice () == oif))
        {
          // not in cache or a different specified output
          // device is to be used

          // first, make sure we erase existing (incorrect)
          // rtentry from the map
          if (rtentry)
            {
              m_ipv4RouteCache.erase(header.GetDestination ());
            }

          NS_LOG_LOGIC ("Ipv4Route not in cache, build: ");
          Ipv4Address gatewayIp;
          uint32_t index = FindNetDeviceForNixIndex (nodeIndex, gatewayIp);
          int32_t interfaceIndex = 0;

          if (!oif)
            {
              interfaceIndex = (m_ipv4)->GetInterfaceForDevice(m_node->GetDevice(index));
            }
          else
            {
              interfaceIndex = (m_ipv4)->GetInterfaceForDevice(oif);
            }

          NS_ASSERT_MSG (interfaceIndex != -1, "Interface index not found for device");

          Ipv4InterfaceAddress ifAddr = m_ipv4->GetAddress (interfaceIndex, 0);

          // start filling in the Ipv4Route info


          rtentry->SetGateway (gatewayIp);
          rtentry->SetDestination (header.GetDestination ());

          if (!oif)
            {
              rtentry->SetOutputDevice (m_ipv4->GetNetDevice (interfaceIndex));
            }
          else
            {
              rtentry->SetOutputDevice (oif);
            }

          sockerr = Socket::ERROR_NOTERROR;


  // Get the nix-vector from the packet
  Ptr<NixVector> nixVector = p->GetNixVector();

  // If nixVector isn't in packet, something went wrong
  NS_ASSERT (nixVector);

  // Get the interface number that we go out of, by extracting
  // from the nix-vector
  if (m_totalNeighbors == 0)
    {
      m_totalNeighbors = FindTotalNeighbors ();
    }
  uint32_t numberOfBits = nixVector->BitCount (m_totalNeighbors);
  uint32_t nodeIndex = nixVector->ExtractNeighborIndex (numberOfBits);

  rtentry = GetIpv4RouteInCache (header.GetDestination ());
  // not in cache
  if (!rtentry)
    {
      NS_LOG_LOGIC ("Ipv4Route not in cache, build: ");
      Ipv4Address gatewayIp;
      uint32_t index = FindNetDeviceForNixIndex (nodeIndex, gatewayIp);
      uint32_t interfaceIndex = (m_ipv4)->GetInterfaceForDevice(m_node->GetDevice(index));
      Ipv4InterfaceAddress ifAddr = m_ipv4->GetAddress (interfaceIndex, 0);

      // start filling in the Ipv4Route info
      rtentry = Create<Ipv4Route> ();
      rtentry->SetSource (ifAddr.GetLocal ());

      rtentry->SetGateway (gatewayIp);
      rtentry->SetDestination (header.GetDestination ());
      rtentry->SetOutputDevice (m_ipv4->GetNetDevice (interfaceIndex));

      // add rtentry to cache
      m_ipv4RouteCache.insert(Ipv4RouteMap_t::value_type(header.GetDestination (), rtentry));
    }
          NS_LOG_LOGIC ("RouteInput(): Nix-vector not in cache, build: ");

  NS_LOG_LOGIC ("At Node " << m_node->GetId() << ", Extracting " << numberOfBits << 
                       " bits from Nix-vector: " << nixVector << " : " << *nixVector);
          nixVectorInCache = GetNixVector (m_node, header.GetDestination ());
        }

  // call the unicast callback
  // local deliver is handled by Ipv4StaticRoutingImpl
  // so this code is never even called if the packet is
  // destined for this node.
  ucb (rtentry, p, header);

  return true;
          m_nixCache.insert(NixMap_t::value_type(header.GetDestination (), nixVectorInCache));

          // create a new nix vector to be used, 
          // we want to keep the cached version clean
          Ptr<NixVector> nixVectorForPacket;
          nixVectorForPacket = CreateObject<NixVector> ();
          nixVectorForPacket = nixVectorInCache->Copy(); 

          // Get the interface number that we go out of, by extracting
          // from the nix-vector
          if (m_totalNeighbors == 0)
            {
              m_totalNeighbors = FindTotalNeighbors ();
            }
          uint32_t numberOfBits = nixVectorForPacket->BitCount (m_totalNeighbors);
          uint32_t nodeIndex = nixVectorForPacket->ExtractNeighborIndex (numberOfBits);

          rtentry = GetIpv4RouteInCache (header.GetDestination ());
          // not in cache
          if (!rtentry)
            {
              NS_LOG_LOGIC ("Ipv4Route not in cache, build: ");
              Ipv4Address gatewayIp;
              uint32_t index = FindNetDeviceForNixIndex (nodeIndex, gatewayIp);

              uint32_t interfaceIndex = (m_ipv4)->GetInterfaceForDevice(m_node->GetDevice(index));
              Ipv4InterfaceAddress ifAddr = m_ipv4->GetAddress (interfaceIndex, 0);

              // start filling in the Ipv4Route info
              rtentry = Create<Ipv4Route> ();
              rtentry->SetSource (ifAddr.GetLocal ());

              rtentry->SetGateway (Ipv4Address(gatewayIp));
              rtentry->SetDestination (header.GetDestination ());
              rtentry->SetOutputDevice (m_ipv4->GetNetDevice (interfaceIndex));

              // add rtentry to cache
              m_ipv4RouteCache.insert(Ipv4RouteMap_t::value_type(header.GetDestination (), rtentry));
            }

          NS_LOG_LOGIC ("Nix-vector contents: " << *nixVectorInCache << " : Remaining bits: " << nixVectorForPacket->GetRemainingBits());

          // Add  nix-vector in the packet class 
          // have to copy the packet first b/c 
          // it is const
          Ptr<Packet> newPacket = Create<Packet> ();
          newPacket = p->Copy();

          NS_LOG_LOGIC ("Adding Nix-vector to packet: " << *nixVectorForPacket);
          newPacket->SetNixVector(nixVectorForPacket);

          // call the unicast callback
          // local deliver is handled by Ipv4StaticRoutingImpl
          // so this code is never even called if the packet is
          // destined for this node.
          ucb (rtentry, newPacket, header);
          return true;
        }
      else // path doesn't exist
        {
          NS_LOG_ERROR ("No path to the dest: " << header.GetDestination ());
          return false;
        }
    }
  else
    {
      // Get the interface number that we go out of, by extracting
      // from the nix-vector
      if (m_totalNeighbors == 0)
        {
          m_totalNeighbors = FindTotalNeighbors ();
        }
      uint32_t numberOfBits = nixVector->BitCount (m_totalNeighbors);
      uint32_t nodeIndex = nixVector->ExtractNeighborIndex (numberOfBits);

      rtentry = GetIpv4RouteInCache (header.GetDestination ());
      // not in cache
      if (!rtentry)
        {
          NS_LOG_LOGIC ("Ipv4Route not in cache, build: ");
          Ipv4Address gatewayIp;
          uint32_t index = FindNetDeviceForNixIndex (nodeIndex, gatewayIp);
          uint32_t interfaceIndex = (m_ipv4)->GetInterfaceForDevice(m_node->GetDevice(index));
          Ipv4InterfaceAddress ifAddr = m_ipv4->GetAddress (interfaceIndex, 0);

          // start filling in the Ipv4Route info
          rtentry = Create<Ipv4Route> ();
          rtentry->SetSource (ifAddr.GetLocal ());

          rtentry->SetGateway (gatewayIp);
          rtentry->SetDestination (header.GetDestination ());
          rtentry->SetOutputDevice (m_ipv4->GetNetDevice (interfaceIndex));

          // add rtentry to cache
          m_ipv4RouteCache.insert(Ipv4RouteMap_t::value_type(header.GetDestination (), rtentry));
        }

      NS_LOG_LOGIC ("At Node " << m_node->GetId() << ", Extracting " << numberOfBits << 
                           " bits from Nix-vector: " << nixVector << " : " << *nixVector);

      // call the unicast callback
      // local deliver is handled by Ipv4StaticRoutingImpl
      // so this code is never even called if the packet is
      // destined for this node.
      ucb (rtentry, p, header);

      return true;
    }
}

// virtual functions from Ipv4RoutingProtocol 

}

bool
Ipv4NixVectorRouting::BFS (uint32_t numberOfNodes, Ptr<Node> source, 
                           Ptr<Node> dest, std::vector< Ptr<Node> > & parentVector,
                           Ptr<NetDevice> oif)
{
  NS_LOG_FUNCTION_NOARGS ();


          return true;
        }

      // if this is the first iteration of the loop and a 
      // specific output interface was given, make sure 
      // we go this way
      if (currNode == source && oif)
        {
          // Get a net device from the node
          // as well as the channel, and figure
          // out the adjacent net device
          Ptr<NetDevice> localNetDevice = currNode->GetDevice (i);

          // make sure that we can go this way
          if (ipv4)
            {
              uint32_t interfaceIndex = (ipv4)->GetInterfaceForDevice(oif);
              if (!(ipv4->IsUp (interfaceIndex)))
                {
                  NS_LOG_LOGIC ("Ipv4Interface is down");
                  return false;
                }
            }
          if (!(oif->IsLinkUp ()))
            {
              NS_LOG_LOGIC ("Link is down.");
              return false;
            }
          Ptr<Channel> channel = oif->GetChannel ();
          if (channel == 0)
            { 
              return false;
            }

          // this function takes in the local net dev, and channnel, and
          // writes to the netDeviceContainer the adjacent net devs
          NetDeviceContainer netDeviceContainer;
          GetAdjacentNetDevices (oif, channel, netDeviceContainer);

          // Finally we can get the adjacent nodes
          // and scan through them.  We push them

                }
            }
        }
      else
        {
          // Iterate over the current node's adjacent vertices
          // and push them into the queue
          for (uint32_t i = 0; i < (currNode->GetNDevices ()); i++)
            {
              // Get a net device from the node
              // as well as the channel, and figure
              // out the adjacent net device
              Ptr<NetDevice> localNetDevice = currNode->GetDevice (i);

              // make sure that we can go this way
              if (ipv4)
                {
                  uint32_t interfaceIndex = (ipv4)->GetInterfaceForDevice(currNode->GetDevice(i));
                  if (!(ipv4->IsUp (interfaceIndex)))
                    {
                      NS_LOG_LOGIC ("Ipv4Interface is down");
                      continue;
                    }
                }
                if (!(localNetDevice->IsLinkUp ()))
                  {
                    NS_LOG_LOGIC ("Link is down.");
                    continue;
                  }
              Ptr<Channel> channel = localNetDevice->GetChannel ();
              if (channel == 0)
                { 
                  continue;
                }

              // this function takes in the local net dev, and channnel, and
              // writes to the netDeviceContainer the adjacent net devs
              NetDeviceContainer netDeviceContainer;
              GetAdjacentNetDevices (localNetDevice, channel, netDeviceContainer);

              // Finally we can get the adjacent nodes
              // and scan through them.  We push them
              // to the greyNode queue, if they aren't 
              // already there.
              for (NetDeviceContainer::Iterator iter = netDeviceContainer.Begin (); iter != netDeviceContainer.End (); iter++)
                {
                  Ptr<Node> remoteNode = (*iter)->GetNode ();

                  // check to see if this node has been pushed before
                  // by checking to see if it has a parent
                  // if it doesn't (null or 0), then set its parent and 
                  // push to the queue
                  if (parentVector.at (remoteNode->GetId ()) == 0)
                    {
                      parentVector.at (remoteNode->GetId ()) = currNode;
                      greyNodeList.push (remoteNode);
                    }
                }
            }
        }

      // Pop off the head grey node.  We have all its children.
      // It is now black.




    void ResetTotalNeighbors (void);

    /*  takes in the source node and dest IP and calls GetNodeByIp, 
     *  BFS, accounting for any output interface specified, and finally 
     *  BuildNixVector to return the built nix-vector */
    Ptr<NixVector> GetNixVector (Ptr<Node>, Ipv4Address, Ptr<NetDevice>);

    /* checks the cache based on dest IP for the nix-vector */
    Ptr<NixVector> GetNixVectorInCache (Ipv4Address);

    bool BFS (uint32_t numberOfNodes, 
             Ptr<Node> source, 
             Ptr<Node> dest, 
             std::vector< Ptr<Node> > & parentVector,
             Ptr<NetDevice> oif);

    void DoDispose (void);


Return to bug 779