cresultfilter.h

//==========================================================================
//  CRESULTFILTER.H - part of
//                     OMNeT++/OMNEST
//            Discrete System Simulation in C++
//
//==========================================================================
 
/*--------------------------------------------------------------*
  Copyright (C) 1992-2017 Andras Varga
  Copyright (C) 2006-2017 OpenSim Ltd.
 
  This file is distributed WITHOUT ANY WARRANTY. See the file
  `license' for details on this and other legal matters.
*--------------------------------------------------------------*/
 
#ifndef __OMNETPP_CRESULTFILTER_H
#define __OMNETPP_CRESULTFILTER_H
 
#include "simkerneldefs.h"
#include "cresultlistener.h"
#include "onstartup.h"
#include "globals.h"
#include "cownedobject.h"
 
namespace omnetpp {
 
class cResultFilter;
class cProperty;
 
#define Register_ResultFilter(NAME, CLASSNAME) \
  __REGISTER_CLASS_X(CLASSNAME, omnetpp::cResultFilter, "result filter", omnetpp::internal::resultFilters.getInstance()->add(new omnetpp::cResultFilterType(NAME,omnetpp::opp_typename(typeid(CLASSNAME)))) )
 
 
#define Register_ResultFilter2(NAME, CLASSNAME, DESCRIPTION) \
  __REGISTER_CLASS_X(CLASSNAME, omnetpp::cResultFilter, "result filter", omnetpp::internal::resultFilters.getInstance()->add(new omnetpp::cResultFilterType(NAME,omnetpp::opp_typename(typeid(CLASSNAME)),DESCRIPTION)) )
 
class SIM_API cResultFilter : public cResultListener
{
    public:
        struct Context {
            cComponent *component;    
            cProperty *attrsProperty; 
        };
    private:
        cComponent *component = nullptr;
        cProperty *attrsProperty = nullptr;
        cResultListener **delegates; // nullptr-terminated array
    protected:
        // methods for invoking the delegates
        void fire(cResultFilter *prev, simtime_t_cref t, bool b, cObject *details);
        void fire(cResultFilter *prev, simtime_t_cref t, intval_t l, cObject *details);
        void fire(cResultFilter *prev, simtime_t_cref t, uintval_t l, cObject *details);
        void fire(cResultFilter *prev, simtime_t_cref t, double d, cObject *details);
        void fire(cResultFilter *prev, simtime_t_cref t, const SimTime& v, cObject *details);
        void fire(cResultFilter *prev, simtime_t_cref t, const char *s, cObject *details);
        void fire(cResultFilter *prev, simtime_t_cref t, cObject *obj, cObject *details);
        virtual void callFinish(cResultFilter *prev) override;
        virtual void callEmitInitialValue() override;
        virtual void forEachChild(cVisitor *v) override;
        virtual void emitInitialValue() override;
    public:
        cResultFilter();
        ~cResultFilter();
        virtual void init(Context *ctx);
        [[deprecated]] virtual void init(cComponent *component, cProperty *attrsProperty) {} // deprecated, left for backward compatibility
        virtual cResultFilter *clone() const override;
        virtual double getInitialDoubleValue() const {return NAN;}
        virtual void addDelegate(cResultListener *delegate);
        virtual void removeDelegate(cResultListener *delegate);
        virtual bool hasDelegate(cResultListener *delegate);
        virtual int getNumDelegates() const;
        cResultListener *getDelegate(int k) const {return delegates[k];}  // unsafe
        std::vector<cResultListener*> getDelegates() const;
 
};
 
class SIM_API cNumericResultFilter : public cResultFilter
{
    protected:
        // all receiveSignal() methods either throw error or delegate here;
        // return value: whether to invoke chained listeners (true) or to swallow the value (false)
        virtual bool process(simtime_t& t, double& value, cObject *details) = 0;
    protected:
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, bool b, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, intval_t l, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, uintval_t l, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, double d, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, const SimTime& v, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, const char *s, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, cObject *obj, cObject *details) override;
};
 
class SIM_API cObjectResultFilter : public cResultFilter
{
    protected:
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, bool b, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, intval_t l, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, uintval_t l, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, double d, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, const SimTime& v, cObject *details) override;
        virtual void receiveSignal(cResultFilter *prev, simtime_t_cref t, const char *s, cObject *details) override;
};
 
class SIM_API cResultFilterType : public cNoncopyableOwnedObject
{
  private:
    std::string description;
    std::string className;
 
  public:
    cResultFilterType(const char *name, const char *className, const char *description=nullptr);
 
    cResultFilter *create() const;
 
    const char *getDescription() const {return description.c_str();}
 
    static cResultFilterType *find(const char *name);
 
    static cResultFilterType *get(const char *name);
};
 
}  // namespace omnetpp
 
#endif