User Manual, Developers Guide and API Documentation

TimeSeriesProbeBus.cpp

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. 16, 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/probe/bus/TimeSeriesProbeBus.hpp>
#include <WNS/simulator/ISimulator.hpp>
#include <WNS/Ttos.hpp>

#include <fstream>
#include <iomanip>

using namespace wns::probe::bus;

STATIC_FACTORY_REGISTER_WITH_CREATOR(
    TimeSeriesProbeBus,
    wns::probe::bus::ProbeBus,
    "TimeSeriesProbeBus",
    wns::PyConfigViewCreator);

TimeSeriesProbeBus::TimeSeriesProbeBus(const wns::pyconfig::View& pyco):
    filename(pyco.get<std::string>("outputFilename")),
    firstWrite(true),
    timePrecision(pyco.get<int>("timePrecision")),
    valuePrecision(pyco.get<int>("valuePrecision")),
    format((pyco.get<std::string>("format")=="scientific") ? formatScientific : formatFixed),
    name(pyco.get<std::string>("name")),
    desc(pyco.get<std::string>("description")),
    prefix("#")
{
    wns::pyconfig::View pycoRoot = wns::simulator::getConfiguration();
    outputPath = pycoRoot.get<std::string>("outputDir");

    for (int ii = 0; ii < pyco.len("contextKeys"); ++ii)
    {
        contextKeys.push_back(pyco.get<std::string>("contextKeys", ii));
    }
}

TimeSeriesProbeBus::~TimeSeriesProbeBus()
{
}

bool
TimeSeriesProbeBus::accepts(const wns::simulator::Time&, const IContext&)
{
    return true;
}

void
TimeSeriesProbeBus::onMeasurement(const wns::simulator::Time& _time,
                               const double& _value,
                               const IContext& _context)
{
    LogEntry entry;
    entry.value = _value;
    entry.time  = _time;

    for(std::vector<std::string>::const_iterator it = contextKeys.begin();
        it != contextKeys.end();
        ++it)
    {
        if(_context.knows(*it))
        {
            if(_context.isInt(*it))
            {
                entry.context.push_back(wns::Ttos(_context.getInt(*it)));
            }
            else if(_context.isString(*it))
            {
                entry.context.push_back(_context.getString(*it));
            }
        }
    }

    // Store value for later output
    logQueue.push_back(entry);
}

void
TimeSeriesProbeBus::output()
{
    std::ofstream out((outputPath + "/" + filename).c_str(),
                      (firstWrite ? std::ios::out : (std::ios::out |  std::ios::app)));

    if (firstWrite)
    {
        firstWrite = false;
        out<<prefix<<"  PROBE RESULTS (THIS IS A MAGIC LINE)" << std::endl;
        out<<prefix<<" ---------------------------------------------------------------------------" << std::endl;
        out<<prefix<<" Evaluation: TimeSeries" << std::endl;
        out<<prefix<<" ---------------------------------------------------------------------------" << std::endl;
        out<<prefix<<"  Name: " << name << std::endl;
        out<<prefix<<"  Description: " << desc << std::endl;
        if(not contextKeys.empty())
        {
            out<<prefix<<"  ContextKeys:";
            for(std::vector<std::string>::const_iterator it = contextKeys.begin();
                it != contextKeys.end();
                ++it)
            {
                out << " " << (*it);
            }
            out << std::endl;
        }
        out<<prefix<<" ---------------------------------------------------------------------------" << std::endl;
    }

    out << (format == formatFixed ? std::setiosflags(std::ios::fixed) : std::setiosflags(std::ios::scientific))
        << std::resetiosflags(std::ios::right)
        << std::setiosflags(std::ios::left);

    assure(out, "I/O Error: Can't dump TimeSeriesProbeBus log file");
    while (!logQueue.empty())
        {
            LogEntry entry = logQueue.front();
            logQueue.pop_front();
            out << std::setprecision(timePrecision) << entry.time
                << " " << std::setprecision(valuePrecision) << entry.value;
            for(std::vector<std::string>::const_iterator it = entry.context.begin();
                it != entry.context.end();
                ++it)
            {
                out << " " << (*it);
            }
            out << std::endl;
            assure(out, "I/O Error: Can't dump TimeSeriesProbeBus log file");
        }
}

---