User Manual, Developers Guide and API Documentation

ContextCollector.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. 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/>.
 *
 ******************************************************************************/

#ifndef WNS_PROBE_BUS_PUTDECORATOR_HPP
#define WNS_PROBE_BUS_PUTDECORATOR_HPP

#include <WNS/probe/bus/ContextProvider.hpp>
#include <WNS/probe/bus/ContextProviderCollection.hpp>
#include <WNS/probe/bus/ProbeBusRegistry.hpp>
#include <WNS/probe/bus/ProbeBus.hpp>
#include <WNS/simulator/ISimulator.hpp>

#include <WNS/osi/PDU.hpp>

#include <WNS/RefCountable.hpp>
#include <WNS/SmartPtr.hpp>

#include <boost/tuple/tuple.hpp>

#include <vector>

namespace wns { namespace probe { namespace bus {

    class ContextCollector :
        virtual public wns::RefCountable
    {
        ContextProviderCollection contextProviders_;
        wns::probe::bus::ProbeBus* probeBus_;

        template <typename Tuple, int keyIndex, int valueIndex>
        struct detail
        {
            static void fillContext(Context& c, const Tuple& tuple)
                {
                    std::string k = boost::tuples::get<keyIndex>(tuple);

                    c.insert(k, boost::tuples::get<valueIndex>(tuple));

                    detail<Tuple, keyIndex-2, valueIndex-2>::fillContext(c, tuple);
                }
        };

        template <typename Tuple>
        struct detail<Tuple, 0, 1>
        {
            static void fillContext(Context& c, const Tuple& tuple)
                {
                    std::string k = boost::tuples::get<0>(tuple);

                    c.insert(k, boost::tuples::get<1>(tuple));
                }
        };

    public:

        ContextCollector(std::string probeBusId);

        ContextCollector(ContextProviderCollection contextProviders,
                         std::string probeBusId);

        ~ContextCollector()
        {};

        bool
        hasObservers() const;

        void
        put(double value) const;

        template<typename Tuple>
        void
        put(double value, const Tuple& contextentries) const
            {
                // early return if no one is listening
                if (!probeBus_->hasObservers())
                {
                    return;
                }
                // Create vanilla Context object
                Context c;

                contextProviders_.fillContext(c);

                ContextCollector::detail<Tuple, boost::tuples::length<Tuple>::value-2, boost::tuples::length<Tuple>::value-1>::fillContext(c, contextentries);

                // determine simTime
                wns::simulator::Time t = wns::simulator::getEventScheduler()->getTime();
                probeBus_->forwardMeasurement(t, value, c);
            }

        void
        put(const wns::osi::PDUPtr&, double value) const;

        template<typename Tuple>
        void
        put(const wns::osi::PDUPtr& compound, double value, const Tuple& contextentries) const
            {
                // early return if no one is listening
                if (!probeBus_->hasObservers())
                {
                    return;
                }
                // Create vanilla Context object
                Context c;

                contextProviders_.fillContext(c, compound);

                ContextCollector::detail<Tuple, boost::tuples::length<Tuple>::value-2, boost::tuples::length<Tuple>::value-1>::fillContext(c, contextentries);

                // determine simTime
                wns::simulator::Time t = wns::simulator::getEventScheduler()->getTime();
                probeBus_->forwardMeasurement(t, value, c);
            }
    };

    typedef wns::SmartPtr<ContextCollector> ContextCollectorPtr;

}}}

#endif // NOT defined WNS_PROBE_PUTDECORATOR_HPP

---