cwatch.h Source File¶

API: cwatch.h Source File
API
//==========================================================================
//  CWATCH.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_CWATCH_H
#define __OMNETPP_CWATCH_H
 
#include <iostream>
#include <sstream>
#include <functional>
#include "cownedobject.h"
#include "cclassdescriptor.h"
#include "cdynamicdescriptor.h"
 
namespace omnetpp {
 
class cWatchBase;
class SIM_API cWatchProxyDescriptor : public cClassDescriptor {
  protected:
    cWatchBase *watch;
    cClassDescriptor *targetDesc;
 
  public:
    cWatchProxyDescriptor(cWatchBase *watch, cClassDescriptor *targetDesc) :
      cClassDescriptor(targetDesc ? targetDesc->getName() : "none"),
      watch(watch), targetDesc(targetDesc) { }
 
    void setTargetDescriptor(cClassDescriptor *desc) { targetDesc = desc; setName(desc ? desc->getName() : "none"); }
 
    virtual const char **getPropertyNames() const override;
    virtual const char *getProperty(const char *propertyname) const override;
    virtual int getFieldCount() const override;
    virtual const char *getFieldName(int field) const override;
    virtual unsigned int getFieldTypeFlags(int field) const override;
    virtual const char *getFieldTypeString(int field) const override;
    virtual const char *getFieldStructName(int field) const override;
    virtual const char **getFieldPropertyNames(int field) const override;
    virtual const char *getFieldProperty(int field, const char *propertyname) const override;
    virtual std::string getValueAsString(any_ptr object) const override;
    virtual void setValueAsString(any_ptr object, const char *value) const override;
    virtual std::string getFieldValueAsString(any_ptr object, int field, int i) const override;
    virtual void setFieldValueAsString(any_ptr object, int field, int i, const char *value) const override;
    virtual cValue getFieldValue(any_ptr object, int field, int i) const override;
    virtual void setFieldValue(any_ptr object, int field, int i, const cValue& value) const override;
    virtual any_ptr getFieldStructValuePointer(any_ptr object, int field, int i) const override;
    virtual void setFieldStructValuePointer(any_ptr object, int field, int i, any_ptr ptr) const override;
    virtual int getFieldArraySize(any_ptr object, int field) const override;
    virtual void setFieldArraySize(any_ptr object, int field, int size) const override;
    virtual std::string getFieldArrayIndexString(any_ptr object, int field, int arrayIndex) const override;
};
class SIM_API cWatchBase : public cNoncopyableOwnedObject
{
  protected:
    mutable cWatchProxyDescriptor *proxyDesc = nullptr;
 
  protected:
    void forEachChildOf(cObject *obj, cVisitor *visitor);
 
  public:
    cWatchBase(const char *name) : cNoncopyableOwnedObject(name) {}
    ~cWatchBase();
 
    virtual std::string str() const override;
    virtual any_ptr getValuePointer() const = 0;
};
 
template<typename T>
class cWatch : public cWatchBase
{
  private:
    const T& r;
 
  public:
    cWatch(const char *name, const T& x) : cWatchBase(name), r(x) {}
    virtual const char *getClassName() const override {return getDescriptor()->getFullName();}
 
    virtual void forEachChild(cVisitor *visitor) override {
        if constexpr (std::is_base_of_v<cObject, T>)
            forEachChildOf(const_cast<T*>(&r), visitor);
    }
 
    virtual any_ptr getValuePointer() const override {
        if constexpr (std::is_base_of_v<cObject, T>)
            return toAnyPtr(&r);
        else
            return any_ptr(&r);
    }
 
    virtual cClassDescriptor *getDescriptor() const override {
        if (proxyDesc == nullptr) {
            cClassDescriptor *targetDesc;
            if constexpr (std::is_base_of_v<cObject, T>)
                targetDesc = r.getDescriptor();
            else
                targetDesc = omnetpp::ensureDescriptor<T>();
            auto *nonconst_this = const_cast<cWatch*>(this);
            proxyDesc = new cWatchProxyDescriptor(nonconst_this, targetDesc);
            nonconst_this->take(proxyDesc);
        }
        return proxyDesc;
    }
};
template<typename T>
class cPointerWatch : public cWatchBase
{
  private:
    T *& p;
    std::string declTypeName;
 
  public:
    cPointerWatch(const char *name, T *& x) : cWatchBase(name), p(x),
        declTypeName(std::string(opp_typename(typeid(T))) + " *") {}
 
    virtual const char *getClassName() const override {return declTypeName.c_str();}
 
    virtual void forEachChild(cVisitor *visitor) override {
        if constexpr (std::is_base_of_v<cObject, std::remove_const_t<T>>)
            if (p) forEachChildOf(const_cast<cObject*>(static_cast<const cObject*>(p)), visitor);
    }
 
    virtual any_ptr getValuePointer() const override {
        if constexpr (std::is_base_of_v<cObject, std::remove_const_t<T>>)
            return toAnyPtr(static_cast<const cObject*>(p));
        else
            return any_ptr(p);
    }
 
    virtual cClassDescriptor *getDescriptor() const override {
        if (proxyDesc == nullptr) {
            cClassDescriptor *targetDesc;
            if constexpr (std::is_base_of_v<cObject, std::remove_const_t<T>>)
                targetDesc = p ? p->getDescriptor() : nullptr;
            else
                targetDesc = omnetpp::ensureDescriptor<std::remove_const_t<T>>();
            auto *nonconst_this = const_cast<cPointerWatch*>(this);
            proxyDesc = new cWatchProxyDescriptor(nonconst_this, targetDesc);
            nonconst_this->take(proxyDesc);
        }
        else if constexpr (std::is_base_of_v<cObject, std::remove_const_t<T>>) {
            // watched pointer may now point to a different object, update descriptor
            proxyDesc->setTargetDescriptor(p ? p->getDescriptor() : nullptr);
        }
        return proxyDesc;
    }
};
 
 
template<typename T>
inline cWatchBase *createWatch(const char *varname, T& d) {
    return new cWatch<T>(varname, d);
}
 
template<typename T>
inline cWatchBase *createWatch(const char *varname, T *& p) {
    return new cPointerWatch<T>(varname, p);
}
template<typename T>
class cComputedWatch : public cWatchBase
{
  private:
    std::function<T()> fn;
    mutable T cachedValue;
 
  public:
    cComputedWatch(const char *name, std::function<T()> f)
        : cWatchBase(name), fn(f), cachedValue(f()) {}
 
    virtual const char *getClassName() const override {
        return getDescriptor()->getFullName();
    }
 
    virtual any_ptr getValuePointer() const override {
        cachedValue = fn();
        return any_ptr(&cachedValue);
    }
 
    virtual cClassDescriptor *getDescriptor() const override {
        if (proxyDesc == nullptr) {
            cClassDescriptor *targetDesc = omnetpp::ensureDescriptor<T>();
            auto *nonconst_this = const_cast<cComputedWatch*>(this);
            proxyDesc = new cWatchProxyDescriptor(nonconst_this, targetDesc);
            nonconst_this->take(proxyDesc);
        }
        return proxyDesc;
    }
};
 
template<typename F>
inline cWatchBase *createLambdaWatch(const char *name, F&& fn) {
    using T = std::invoke_result_t<F>;
    return new cComputedWatch<T>(name, std::function<T()>(std::forward<F>(fn)));
}
#define WATCH(variable)  omnetpp::createWatch(#variable,(variable))
 
// Obsolete aliases to WATCH()
#define WATCH_RW(variable)         WATCH(variable)
#define WATCH_OBJ(variable)        WATCH(variable)
#define WATCH_PTR(variable)        WATCH(variable)
#define WATCH_VECTOR(variable)     WATCH(variable)
#define WATCH_PTRVECTOR(variable)  WATCH(variable)
#define WATCH_LIST(variable)       WATCH(variable)
#define WATCH_PTRLIST(variable)    WATCH(variable)
#define WATCH_SET(variable)        WATCH(variable)
#define WATCH_PTRSET(variable)     WATCH(variable)
#define WATCH_MAP(variable)        WATCH(variable)
#define WATCH_PTRMAP(variable)     WATCH(variable)
#define WATCH_EXPR(name, expression)  omnetpp::createLambdaWatch(name, [this]() { return (expression); })
#define WATCH_LAMBDA(name, lambdaFunction)  omnetpp::createLambdaWatch(name, lambdaFunction)
 
}  // namespace omnetpp
 
 
#endif
 
 