dsdv-routing-protocol.h

Go to the documentation of this file.

/*
 * Copyright (c) 2010 Hemanth Narra, Yufei Cheng
 *
 * SPDX-License-Identifier: GPL-2.0-only
 *
 * Author: Hemanth Narra <hemanth@ittc.ku.com>
 * Author: Yufei Cheng   <yfcheng@ittc.ku.edu>
 *
 * James P.G. Sterbenz <jpgs@ittc.ku.edu>, director
 * ResiliNets Research Group  https://resilinets.org/
 * Information and Telecommunication Technology Center (ITTC)
 * and Department of Electrical Engineering and Computer Science
 * The University of Kansas Lawrence, KS USA.
 *
 * Work supported in part by NSF FIND (Future Internet Design) Program
 * under grant CNS-0626918 (Postmodern Internet Architecture),
 * NSF grant CNS-1050226 (Multilayer Network Resilience Analysis and Experimentation on GENI),
 * US Department of Defense (DoD), and ITTC at The University of Kansas.
 */
 
#ifndef DSDV_ROUTING_PROTOCOL_H
#define DSDV_ROUTING_PROTOCOL_H
 
#include "dsdv-packet-queue.h"
#include "dsdv-packet.h"
#include "dsdv-rtable.h"
 
#include "ns3/ipv4-interface.h"
#include "ns3/ipv4-l3-protocol.h"
#include "ns3/ipv4-routing-protocol.h"
#include "ns3/node.h"
#include "ns3/output-stream-wrapper.h"
#include "ns3/random-variable-stream.h"
 
namespace ns3
{
namespace dsdv
{
 
/**
 * \ingroup dsdv
 * \brief DSDV routing protocol.
 */
class RoutingProtocol : public Ipv4RoutingProtocol
{
  public:
    /**
     * \brief Get the type ID.
     * \return the object TypeId
     */
    static TypeId GetTypeId();
    static const uint32_t DSDV_PORT;
 
    /// c-tor
    RoutingProtocol();
 
    ~RoutingProtocol() override;
    void DoDispose() override;
 
    // From Ipv4RoutingProtocol
    Ptr<Ipv4Route> RouteOutput(Ptr<Packet> p,
                               const Ipv4Header& header,
                               Ptr<NetDevice> oif,
                               Socket::SocketErrno& sockerr) override;
    /**
     * Route input packet
     * \param p The packet
     * \param header The IPv4 header
     * \param idev The device
     * \param ucb The unicast forward callback
     * \param mcb The multicast forward callback
     * \param lcb The local deliver callback
     * \param ecb The error callback
     * \returns true if successful
     */
    bool RouteInput(Ptr<const Packet> p,
                    const Ipv4Header& header,
                    Ptr<const NetDevice> idev,
                    const UnicastForwardCallback& ucb,
                    const MulticastForwardCallback& mcb,
                    const LocalDeliverCallback& lcb,
                    const ErrorCallback& ecb) override;
    void PrintRoutingTable(Ptr<OutputStreamWrapper> stream,
                           Time::Unit unit = Time::S) const override;
    void NotifyInterfaceUp(uint32_t interface) override;
    void NotifyInterfaceDown(uint32_t interface) override;
    void NotifyAddAddress(uint32_t interface, Ipv4InterfaceAddress address) override;
    void NotifyRemoveAddress(uint32_t interface, Ipv4InterfaceAddress address) override;
    void SetIpv4(Ptr<Ipv4> ipv4) override;
 
    // Methods to handle protocol parameters
    /**
     * Set enable buffer flag
     * \param f The enable buffer flag
     */
    void SetEnableBufferFlag(bool f);
    /**
     * Get enable buffer flag
     * \returns the enable buffer flag
     */
    bool GetEnableBufferFlag() const;
    /**
     * Set weighted settling time (WST) flag
     * \param f the weighted settling time (WST) flag
     */
    void SetWSTFlag(bool f);
    /**
     * Get weighted settling time (WST) flag
     * \returns the weighted settling time (WST) flag
     */
    bool GetWSTFlag() const;
    /**
     * Set enable route aggregation (RA) flag
     * \param f the enable route aggregation (RA) flag
     */
    void SetEnableRAFlag(bool f);
    /**
     * Get enable route aggregation (RA) flag
     * \returns the enable route aggregation (RA) flag
     */
    bool GetEnableRAFlag() const;
 
    /**
     * Assign a fixed random variable stream number to the random variables
     * used by this model.  Return the number of streams (possibly zero) that
     * have been assigned.
     *
     * \param stream first stream index to use
     * \return the number of stream indices assigned by this model
     */
    int64_t AssignStreams(int64_t stream);
 
  private:
    // Protocol parameters.
    /// Holdtimes is the multiplicative factor of PeriodicUpdateInterval for which the node waits
    /// since the last update before flushing a route from the routing table. If
    /// PeriodicUpdateInterval is 8s and Holdtimes is 3, the node waits for 24s since the last
    /// update to flush this route from its routing table.
    uint32_t Holdtimes;
    /// PeriodicUpdateInterval specifies the periodic time interval between which the a node
    /// broadcasts its entire routing table.
    Time m_periodicUpdateInterval;
    /// SettlingTime specifies the time for which a node waits before propagating an update.
    /// It waits for this time interval in hope of receiving an update with a better metric.
    Time m_settlingTime;
    /// Nodes IP address
    Ipv4Address m_mainAddress;
    /// IP protocol
    Ptr<Ipv4> m_ipv4;
    /// Raw socket per each IP interface, map socket -> iface address (IP + mask)
    std::map<Ptr<Socket>, Ipv4InterfaceAddress> m_socketAddresses;
    /// Loopback device used to defer route requests until a route is found
    Ptr<NetDevice> m_lo;
    /// Main Routing table for the node
    RoutingTable m_routingTable;
    /// Advertised Routing table for the node
    RoutingTable m_advRoutingTable;
    /// The maximum number of packets that we allow a routing protocol to buffer.
    uint32_t m_maxQueueLen;
    /// The maximum number of packets that we allow per destination to buffer.
    uint32_t m_maxQueuedPacketsPerDst;
    /// The maximum period of time that a routing protocol is allowed to buffer a packet for.
    Time m_maxQueueTime;
    /// A "drop front on full" queue used by the routing layer to buffer packets to which it does
    /// not have a route.
    PacketQueue m_queue;
    /// Flag that is used to enable or disable buffering
    bool EnableBuffering;
    /// Flag that is used to enable or disable Weighted Settling Time
    bool EnableWST;
    /// This is the weighted factor to determine the weighted settling time
    double m_weightedFactor;
    /// This is a flag to enable route aggregation. Route aggregation will aggregate all routes for
    /// 'RouteAggregationTime' from the time an update is received by a node and sends them as a
    /// single update .
    bool EnableRouteAggregation;
    /// Parameter that holds the route aggregation time interval
    Time m_routeAggregationTime;
    /// Unicast callback for own packets
    UnicastForwardCallback m_scb;
    /// Error callback for own packets
    ErrorCallback m_ecb;
 
  private:
    /// Start protocol operation
    void Start();
    /**
     * Queue packet until we find a route
     * \param p the packet to route
     * \param header the Ipv4Header
     * \param ucb the UnicastForwardCallback function
     * \param ecb the ErrorCallback function
     */
    void DeferredRouteOutput(Ptr<const Packet> p,
                             const Ipv4Header& header,
                             UnicastForwardCallback ucb,
                             ErrorCallback ecb);
    /// Look for any queued packets to send them out
    void LookForQueuedPackets();
    /**
     * Send packet from queue
     * \param dst - destination address to which we are sending the packet to
     * \param route - route identified for this packet
     */
    void SendPacketFromQueue(Ipv4Address dst, Ptr<Ipv4Route> route);
    /**
     * Find socket with local interface address iface
     * \param iface the interface
     * \returns the socket
     */
    Ptr<Socket> FindSocketWithInterfaceAddress(Ipv4InterfaceAddress iface) const;
 
    // Receive dsdv control packets
    /**
     * Receive and process dsdv control packet
     * \param socket the socket for receiving dsdv control packets
     */
    void RecvDsdv(Ptr<Socket> socket);
    /**
     * Send a packet
     * \param route the route
     * \param packet the packet
     * \param header the IPv4 header
     */
    void Send(Ptr<Ipv4Route> route, Ptr<const Packet> packet, const Ipv4Header& header);
 
    /**
     * Create loopback route for given header
     *
     * \param header the IP header
     * \param oif the device
     * \returns the route
     */
    Ptr<Ipv4Route> LoopbackRoute(const Ipv4Header& header, Ptr<NetDevice> oif) const;
    /**
     * Get settlingTime for a destination
     * \param dst - destination address
     * \return settlingTime for the destination if found
     */
    Time GetSettlingTime(Ipv4Address dst);
    /// Sends trigger update from a node
    void SendTriggeredUpdate();
    /// Broadcasts the entire routing table for every PeriodicUpdateInterval
    void SendPeriodicUpdate();
    /// Merge periodic updates
    void MergeTriggerPeriodicUpdates();
    /**
     * Notify that packet is dropped for some reason
     * \param packet the dropped packet
     * \param header the IPv4 header
     * \param err the error number
     */
    void Drop(Ptr<const Packet> packet, const Ipv4Header& header, Socket::SocketErrno err);
    /// Timer to trigger periodic updates from a node
    Timer m_periodicUpdateTimer;
    /// Timer used by the trigger updates in case of Weighted Settling Time is used
    Timer m_triggeredExpireTimer;
 
    /// Provides uniform random variables.
    Ptr<UniformRandomVariable> m_uniformRandomVariable;
};
 
} // namespace dsdv
} // namespace ns3
 
#endif /* DSDV_ROUTING_PROTOCOL_H */