User Manual, Developers Guide and API Documentation

TrafficSpec.hpp

Go to the documentation of this file.

/*******************************************************************************
 * This file is part of openWNS (open Wireless Network Simulator)
 * _____________________________________________________________________________
 *
 * Copyright (C) 2004-2007
 * Chair of Communication Networks (ComNets)
 * Kopernikusstr. 5, D-52074 Aachen, Germany
 * phone: ++49-241-80-27910,
 * fax: ++49-241-80-22242
 * email: info@openwns.org
 * www: http://www.openwns.org
 * _____________________________________________________________________________
 *
 * openWNS is free software; you can redistribute it and/or modify it under the
 * terms of the GNU Lesser General Public License version 2 as published by the
 * Free Software Foundation;
 *
 * openWNS 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 Lesser General Public License for more
 * details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 ******************************************************************************/

#include <WNS/distribution/Distribution.hpp>
#include <WNS/pyconfig/View.hpp>
#include <WNS/pyconfig/Parser.hpp>


#ifndef WNS_MARKOVCHAIN_TRAFFICSPEC_HPP
#define WNS_MARKOVCHAIN_TRAFFICSPEC_HPP
namespace wns { namespace markovchain {

    class TrafficSpec {
    public:
        TrafficSpec()
        {
        }

        TrafficSpec(std::string _iatpdf,
                double _arg0,
                double _arg1) :
            interArrivalTimeDistribution(NULL),
            packetSizeDistribution(NULL),
            meanRate(0.0)
        {
            wns::pyconfig::Parser config;
            std::string iatDistName = convertGdfDistributionName2wns(_iatpdf, _arg0, _arg1);
            config.loadString(
                "import openwns.distribution\n"
                "packetSize = openwns.distribution.Fixed(1024)\n" // there's no better way now
                "iat = openwns.distribution." + iatDistName + "\n"
                );
                initializeGenerators(config);
        }

        TrafficSpec(const wns::pyconfig::View& pyco) :
            interArrivalTimeDistribution(NULL),
            packetSizeDistribution(NULL),
            meanRate(0.0)
        {
            initializeGenerators(pyco);
        }

        ~TrafficSpec()
        {
        }

        wns::distribution::Distribution*
        getInterArrivalTimeDistribution() const
        {
            return interArrivalTimeDistribution;
        }

        wns::distribution::Distribution*
        getPacketSizeDistribution() const
        {
            return packetSizeDistribution;
        }

        double getMeanRate() const
        {
            return meanRate; // without scaling
        }

    private:

        std::string
        stringify(double x) const
        {
            std::ostringstream o;
            o << x;
            return o.str();
        }

        std::string
        convertGdfDistributionName2wns(std::string _pdf, double _arg0, double _arg1) const
        {
            std::string DistName;
            if (_pdf == "constant") {
                DistName = "Fixed(" + stringify(_arg0) + ")";
            } else if (_pdf == "exponential") {
                DistName = "NegExp(" + stringify(_arg0) +")";
            } else if (_pdf == "uniform") {
                DistName = "Uniform(" + stringify(_arg0) + "," + stringify(_arg1) +")";
            } else { // WNS name allowed in gdf file
                DistName = _pdf + "(" + stringify(_arg0) + ")";
            }
            return DistName;
        }

        friend class MarkovContinuousTimeTrafficTest;
        friend class MarkovDiscreteTimeTrafficTest;

        void
        initializeGenerators(const wns::pyconfig::View& pyco)
        {
            wns::pyconfig::View iatConfig(pyco, "iat");
            std::string iatName = iatConfig.get<std::string>("__plugin__");
            interArrivalTimeDistribution =
                wns::distribution::DistributionFactory::creator(iatName)->create(iatConfig);
            wns::pyconfig::View packetConfig(pyco, "packetSize");
            std::string psName = packetConfig.get<std::string>("__plugin__");
            packetSizeDistribution =
                wns::distribution::DistributionFactory::creator(psName)->create(packetConfig);
            //std::cout << "iat=" << interArrivalTimeDistribution->paramString()
            //    << ", packetSize=" <<
            //    packetSizeDistribution->paramString() << std::endl;
            double meanIAT;
            meanIAT = 
                dynamic_cast<wns::distribution::IHasMean*>(interArrivalTimeDistribution)
                    ->getMean();
            assure(meanIAT>0.0,"zero meanIAT");
            meanRate =  
                dynamic_cast<wns::distribution::IHasMean*>(packetSizeDistribution)
                    ->getMean()/meanIAT;
        }

    protected:
        wns::distribution::Distribution* interArrivalTimeDistribution;
        wns::distribution::Distribution* packetSizeDistribution;
        double meanRate; // without scaling
    }; // class TrafficSpec

}//markovchain
}//wns
#endif // WNS_MARKOVCHAIN_TRAFFICSPEC_HPP

---