flow-monitor.h

Go to the documentation of this file.

//
// Copyright (c) 2009 INESC Porto
//
// 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: Gustavo J. A. M. Carneiro  <gjc@inescporto.pt> <gjcarneiro@gmail.com>
//
 
#ifndef FLOW_MONITOR_H
#define FLOW_MONITOR_H
 
#include "flow-classifier.h"
#include "flow-probe.h"
 
#include "ns3/event-id.h"
#include "ns3/histogram.h"
#include "ns3/nstime.h"
#include "ns3/object.h"
#include "ns3/ptr.h"
 
#include <map>
#include <vector>
 
namespace ns3
{
 
/**
 * \defgroup flow-monitor Flow Monitor
 * \brief  Collect and store performance data from a simulation
 */
 
/**
 * \ingroup flow-monitor
 * \brief An object that monitors and reports back packet flows observed during a simulation
 *
 * The FlowMonitor class is responsible for coordinating efforts
 * regarding probes, and collects end-to-end flow statistics.
 *
 */
class FlowMonitor : public Object
{
  public:
    /// \brief Structure that represents the measured metrics of an individual packet flow
    struct FlowStats
    {
        /// Contains the absolute time when the first packet in the flow
        /// was transmitted, i.e. the time when the flow transmission
        /// starts
        Time timeFirstTxPacket;
 
        /// Contains the absolute time when the first packet in the flow
        /// was received by an end node, i.e. the time when the flow
        /// reception starts
        Time timeFirstRxPacket;
 
        /// Contains the absolute time when the last packet in the flow
        /// was transmitted, i.e. the time when the flow transmission
        /// ends
        Time timeLastTxPacket;
 
        /// Contains the absolute time when the last packet in the flow
        /// was received, i.e. the time when the flow reception ends
        Time timeLastRxPacket;
 
        /// Contains the sum of all end-to-end delays for all received
        /// packets of the flow.
        Time delaySum; // delayCount == rxPackets
 
        /// Contains the sum of all end-to-end delay jitter (delay
        /// variation) values for all received packets of the flow.  Here
        /// we define _jitter_ of a packet as the delay variation
        /// relatively to the last packet of the stream,
        /// i.e. \f$Jitter\left\{P_N\right\} = \left|Delay\left\{P_N\right\} -
        /// Delay\left\{P_{N-1}\right\}\right|\f$. This definition is in accordance with the
        /// Type-P-One-way-ipdv as defined in IETF \RFC{3393}.
        Time jitterSum; // jitterCount == rxPackets - 1
 
        /// Contains the last measured delay of a packet
        /// It is stored to measure the packet's Jitter
        Time lastDelay;
 
        /// Total number of transmitted bytes for the flow
        uint64_t txBytes;
        /// Total number of received bytes for the flow
        uint64_t rxBytes;
        /// Total number of transmitted packets for the flow
        uint32_t txPackets;
        /// Total number of received packets for the flow
        uint32_t rxPackets;
 
        /// Total number of packets that are assumed to be lost,
        /// i.e. those that were transmitted but have not been reportedly
        /// received or forwarded for a long time.  By default, packets
        /// missing for a period of over 10 seconds are assumed to be
        /// lost, although this value can be easily configured in runtime
        uint32_t lostPackets;
 
        /// Contains the number of times a packet has been reportedly
        /// forwarded, summed for all received packets in the flow
        uint32_t timesForwarded;
 
        /// Histogram of the packet delays
        Histogram delayHistogram;
        /// Histogram of the packet jitters
        Histogram jitterHistogram;
        /// Histogram of the packet sizes
        Histogram packetSizeHistogram;
 
        /// This attribute also tracks the number of lost packets and
        /// bytes, but discriminates the losses by a _reason code_.  This
        /// reason code is usually an enumeration defined by the concrete
        /// FlowProbe class, and for each reason code there may be a
        /// vector entry indexed by that code and whose value is the
        /// number of packets or bytes lost due to this reason.  For
        /// instance, in the Ipv4FlowProbe case the following reasons are
        /// currently defined: DROP_NO_ROUTE (no IPv4 route found for a
        /// packet), DROP_TTL_EXPIRE (a packet was dropped due to an IPv4
        /// TTL field decremented and reaching zero), and
        /// DROP_BAD_CHECKSUM (a packet had bad IPv4 header checksum and
        /// had to be dropped).
        std::vector<uint32_t>
            packetsDropped; // packetsDropped[reasonCode] => number of dropped packets
 
        /// This attribute also tracks the number of lost bytes.  See also
        /// comment in attribute packetsDropped.
        std::vector<uint64_t> bytesDropped;   // bytesDropped[reasonCode] => number of dropped bytes
        Histogram flowInterruptionsHistogram; //!< histogram of durations of flow interruptions
    };
 
    // --- basic methods ---
    /**
     * \brief Get the type ID.
     * \return the object TypeId
     */
    static TypeId GetTypeId();
    TypeId GetInstanceTypeId() const override;
    FlowMonitor();
 
    /// Add a FlowClassifier to be used by the flow monitor.
    /// \param classifier the FlowClassifier
    void AddFlowClassifier(Ptr<FlowClassifier> classifier);
 
    /// Set the time, counting from the current time, from which to start monitoring flows.
    /// This method overwrites any previous calls to Start()
    /// \param time delta time to start
    void Start(const Time& time);
    /// Set the time, counting from the current time, from which to stop monitoring flows.
    /// This method overwrites any previous calls to Stop()
    /// \param time delta time to stop
    void Stop(const Time& time);
    /// Begin monitoring flows *right now*
    void StartRightNow();
    /// End monitoring flows *right now*
    void StopRightNow();
 
    // --- methods to be used by the FlowMonitorProbe's only ---
    /// Register a new FlowProbe that will begin monitoring and report
    /// events to this monitor.  This method is normally only used by
    /// FlowProbe implementations.
    /// \param probe the probe to add
    void AddProbe(Ptr<FlowProbe> probe);
 
    /// FlowProbe implementations are supposed to call this method to
    /// report that a new packet was transmitted (but keep in mind the
    /// distinction between a new packet entering the system and a
    /// packet that is already known and is only being forwarded).
    /// \param probe the reporting probe
    /// \param flowId flow identification
    /// \param packetId Packet ID
    /// \param packetSize packet size
    void ReportFirstTx(Ptr<FlowProbe> probe,
                       FlowId flowId,
                       FlowPacketId packetId,
                       uint32_t packetSize);
    /// FlowProbe implementations are supposed to call this method to
    /// report that a known packet is being forwarded.
    /// \param probe the reporting probe
    /// \param flowId flow identification
    /// \param packetId Packet ID
    /// \param packetSize packet size
    void ReportForwarding(Ptr<FlowProbe> probe,
                          FlowId flowId,
                          FlowPacketId packetId,
                          uint32_t packetSize);
    /// FlowProbe implementations are supposed to call this method to
    /// report that a known packet is being received.
    /// \param probe the reporting probe
    /// \param flowId flow identification
    /// \param packetId Packet ID
    /// \param packetSize packet size
    void ReportLastRx(Ptr<FlowProbe> probe,
                      FlowId flowId,
                      FlowPacketId packetId,
                      uint32_t packetSize);
    /// FlowProbe implementations are supposed to call this method to
    /// report that a known packet is being dropped due to some reason.
    /// \param probe the reporting probe
    /// \param flowId flow identification
    /// \param packetId Packet ID
    /// \param packetSize packet size
    /// \param reasonCode drop reason code
    void ReportDrop(Ptr<FlowProbe> probe,
                    FlowId flowId,
                    FlowPacketId packetId,
                    uint32_t packetSize,
                    uint32_t reasonCode);
 
    /// Check right now for packets that appear to be lost
    void CheckForLostPackets();
 
    /// Check right now for packets that appear to be lost, considering
    /// packets as lost if not seen in the network for a time larger
    /// than maxDelay
    /// \param maxDelay the max delay for a packet
    void CheckForLostPackets(Time maxDelay);
 
    // --- methods to get the results ---
 
    /// Container: FlowId, FlowStats
    typedef std::map<FlowId, FlowStats> FlowStatsContainer;
    /// Container Iterator: FlowId, FlowStats
    typedef std::map<FlowId, FlowStats>::iterator FlowStatsContainerI;
    /// Container Const Iterator: FlowId, FlowStats
    typedef std::map<FlowId, FlowStats>::const_iterator FlowStatsContainerCI;
    /// Container: FlowProbe
    typedef std::vector<Ptr<FlowProbe>> FlowProbeContainer;
    /// Container Iterator: FlowProbe
    typedef std::vector<Ptr<FlowProbe>>::iterator FlowProbeContainerI;
    /// Container Const Iterator: FlowProbe
    typedef std::vector<Ptr<FlowProbe>>::const_iterator FlowProbeContainerCI;
 
    /// Retrieve all collected the flow statistics.  Note, if the
    /// FlowMonitor has not stopped monitoring yet, you should call
    /// CheckForLostPackets() to make sure all possibly lost packets are
    /// accounted for.
    /// \returns the flows statistics
    const FlowStatsContainer& GetFlowStats() const;
 
    /// Get a list of all FlowProbe's associated with this FlowMonitor
    /// \returns a list of all the probes
    const FlowProbeContainer& GetAllProbes() const;
 
    /// Serializes the results to an std::ostream in XML format
    /// \param os the output stream
    /// \param indent number of spaces to use as base indentation level
    /// \param enableHistograms if true, include also the histograms in the output
    /// \param enableProbes if true, include also the per-probe/flow pair statistics in the output
    void SerializeToXmlStream(std::ostream& os,
                              uint16_t indent,
                              bool enableHistograms,
                              bool enableProbes);
 
    /// Same as SerializeToXmlStream, but returns the output as a std::string
    /// \param indent number of spaces to use as base indentation level
    /// \param enableHistograms if true, include also the histograms in the output
    /// \param enableProbes if true, include also the per-probe/flow pair statistics in the output
    /// \return the XML output as string
    std::string SerializeToXmlString(uint16_t indent, bool enableHistograms, bool enableProbes);
 
    /// Same as SerializeToXmlStream, but writes to a file instead
    /// \param fileName name or path of the output file that will be created
    /// \param enableHistograms if true, include also the histograms in the output
    /// \param enableProbes if true, include also the per-probe/flow pair statistics in the output
    void SerializeToXmlFile(std::string fileName, bool enableHistograms, bool enableProbes);
 
    /// Reset all the statistics
    void ResetAllStats();
 
  protected:
    void NotifyConstructionCompleted() override;
    void DoDispose() override;
 
  private:
    /// Structure to represent a single tracked packet data
    struct TrackedPacket
    {
        Time firstSeenTime;      //!< absolute time when the packet was first seen by a probe
        Time lastSeenTime;       //!< absolute time when the packet was last seen by a probe
        uint32_t timesForwarded; //!< number of times the packet was reportedly forwarded
    };
 
    /// FlowId --> FlowStats
    FlowStatsContainer m_flowStats;
 
    /// (FlowId,PacketId) --> TrackedPacket
    typedef std::map<std::pair<FlowId, FlowPacketId>, TrackedPacket> TrackedPacketMap;
    TrackedPacketMap m_trackedPackets; //!< Tracked packets
    Time m_maxPerHopDelay;             //!< Minimum per-hop delay
    FlowProbeContainer m_flowProbes;   //!< all the FlowProbes
 
    // note: this is needed only for serialization
    std::list<Ptr<FlowClassifier>> m_classifiers; //!< the FlowClassifiers
 
    EventId m_startEvent;               //!< Start event
    EventId m_stopEvent;                //!< Stop event
    bool m_enabled;                     //!< FlowMon is enabled
    double m_delayBinWidth;             //!< Delay bin width (for histograms)
    double m_jitterBinWidth;            //!< Jitter bin width (for histograms)
    double m_packetSizeBinWidth;        //!< packet size bin width (for histograms)
    double m_flowInterruptionsBinWidth; //!< Flow interruptions bin width (for histograms)
    Time m_flowInterruptionsMinTime;    //!< Flow interruptions minimum time
 
    /// Get the stats for a given flow
    /// \param flowId the Flow identification
    /// \returns the stats of the flow
    FlowStats& GetStatsForFlow(FlowId flowId);
 
    /// Periodic function to check for lost packets and prune statistics
    void PeriodicCheckForLostPackets();
};
 
} // namespace ns3
 
#endif /* FLOW_MONITOR_H */