inet::queueing::MultiTokenBucketMixin< T > Class Template Reference

#include <MultiTokenBucketMixin.h>

Inheritance diagram for inet::queueing::MultiTokenBucketMixin< T >:

Public Member Functions
virtual double	getNumTokens () const override
virtual void	addTokens (double numTokens) override
virtual void	removeTokens (double numTokens) override
virtual void	addTokenProductionRate (double tokenRate) override
virtual void	removeTokenProductionRate (double tokenRate) override
Public Member Functions inherited from inet::units::value< Value, Units >
	value ()
	value (const value_type &v)
template<typename OtherValue , typename OtherUnits >
	value (const value< OtherValue, OtherUnits > &v)
std::string	str () const
const value_type &	get () const
void	set (const value_type &v)
template<typename OtherValue , typename OtherUnits >
value &	operator= (const value< OtherValue, OtherUnits > &other)
template<typename OtherValue , typename OtherUnits , typename ResultValue = typename std::remove_cv<decltype(Value() + OtherValue())>::type>
value< ResultValue, Units >	operator+ (const value< OtherValue, OtherUnits > &other) const
template<typename OtherValue , typename OtherUnits >
value &	operator+= (const value< OtherValue, OtherUnits > &other)
template<typename OtherValue , typename OtherUnits >
value &	operator-= (const value< OtherValue, OtherUnits > &other)
template<typename OtherValue , typename OtherUnits , typename ResultValue = typename std::remove_cv<decltype(Value() - OtherValue())>::type>
value< ResultValue, Units >	operator- (const value< OtherValue, OtherUnits > &other) const
value	operator- () const
template<typename OtherValue , typename OtherUnits , typename ResultValue = typename std::remove_cv<decltype(Value() * OtherValue())>::type>
value< ResultValue, compose< Units, OtherUnits > >	operator* (const value< OtherValue, OtherUnits > &other) const
template<typename OtherValue >
value	operator* (OtherValue v) const
value &	operator*= (const value_type &v)
template<typename OtherValue , typename OtherUnits , typename ResultValue = typename std::remove_cv<decltype(Value() / OtherValue())>::type>
value< ResultValue, compose< Units, pow< OtherUnits, -1 > > >	operator/ (const value< OtherValue, OtherUnits > &other) const
value	operator/ (const value_type &v) const
value &	operator/= (const value_type &v)
template<typename OtherValue , typename OtherUnits >
bool	operator== (const value< OtherValue, OtherUnits > &other) const
template<typename OtherValue , typename OtherUnits >
bool	operator!= (const value< OtherValue, OtherUnits > &other) const
template<typename OtherValue , typename OtherUnits >
bool	operator< (const value< OtherValue, OtherUnits > &other) const
template<typename OtherValue , typename OtherUnits >
bool	operator<= (const value< OtherValue, OtherUnits > &other) const
template<typename OtherValue , typename OtherUnits >
bool	operator> (const value< OtherValue, OtherUnits > &other) const
template<typename OtherValue , typename OtherUnits >
bool	operator>= (const value< OtherValue, OtherUnits > &other) const
value &	operator++ ()
value	operator++ (int)
value &	operator-- ()
value	operator-- (int)
Public Member Functions inherited from inet::queueing::ITokenStorage
virtual	~ITokenStorage ()

Protected Member Functions
virtual void	initialize (int stage) override
virtual void	finish () override
virtual ITokenStorage *	getExcessTokenStorage (const char *designator)
const virtual char *	resolveDirective (char directive) const override

Protected Attributes
std::vector< TokenBucket >	tokenBuckets

Additional Inherited Members
Public Types inherited from inet::units::value< Value, Units >
typedef Value	value_type
typedef Units	unit

Member Function Documentation

addTokenProductionRate()

template<typename T >

virtual void inet::queueing::MultiTokenBucketMixin< T >::addTokenProductionRate ( double  tokenRate )

inlineoverridevirtual

Implements inet::queueing::ITokenStorage.

    {
        Enter_Method("addTokenProductionRate");
        auto &tokenBucket = tokenBuckets[0];
        EV_INFO << "Adding token production rate" << EV_FIELD(tokenRate) << EV_FIELD(tokenBucket) << EV_ENDL;
        tokenBucket.addTokenProductionRate(tokenRate);
    }

addTokens()

template<typename T >

virtual void inet::queueing::MultiTokenBucketMixin< T >::addTokens ( double  numTokens )

inlineoverridevirtual

Implements inet::queueing::ITokenStorage.

    {
        Enter_Method("addTokens");
        EV_INFO << "Adding tokens" << EV_FIELD(numTokens) << EV_FIELD(tokenBuckets) << EV_ENDL;
        T::emit(tokensChangedSignal, getNumTokens());
        tokenBuckets[0].addTokens(numTokens);
        T::emit(tokensChangedSignal, getNumTokens());
    }

finish()

template<typename T >

virtual void inet::queueing::MultiTokenBucketMixin< T >::finish ( )

inlineoverrideprotectedvirtual

    {
        T::emit(tokensChangedSignal, getNumTokens());
    }

getExcessTokenStorage()

template<typename T >

virtual ITokenStorage* inet::queueing::MultiTokenBucketMixin< T >::getExcessTokenStorage ( const char *  designator )

inlineprotectedvirtual

    {
        try {
            return &tokenBuckets[std::stoi(designator)];
        }
        catch (...) {
            const char *colon = strchr(designator, ':');
            if (colon == nullptr)
                return check_and_cast<ITokenStorage*>(T::getModuleByPath(designator));
            else {
                auto multiTokenBucketMixin = check_and_cast<MultiTokenBucketMixin<T>*>(T::getModuleByPath(designator));
                int tokenBucketIndex = std::stoi(colon + 1);
                return &multiTokenBucketMixin->tokenBuckets[tokenBucketIndex];
            }
        }
    }

getNumTokens()

template<typename T >

virtual double inet::queueing::MultiTokenBucketMixin< T >::getNumTokens ( ) const

inlineoverridevirtual

Implements inet::queueing::ITokenStorage.

    {
        double numTokens = 0;
        for (auto &tokenBucket : tokenBuckets)
            numTokens += tokenBucket.getNumTokens();
        return numTokens;
    }

initialize()

template<typename T >

virtual void inet::queueing::MultiTokenBucketMixin< T >::initialize ( int  stage )

inlineoverrideprotectedvirtual

Reimplemented in inet::queueing::TokenBucketMeterMixin< MultiTokenBucketMixin< PacketMeterBase > >, inet::queueing::MultiTokenBucketMeter, inet::queueing::TokenBucketClassifierMixin< MultiTokenBucketMixin< PacketClassifierBase > >, and inet::queueing::MultiTokenBucketClassifier.

    {
        T::initialize(stage);
        if (stage == INITSTAGE_LOCAL) {
            cValueArray *bucketConfigurations = check_and_cast<cValueArray*>(T::par("buckets").objectValue());
            tokenBuckets.resize(bucketConfigurations->size());
            for (int i = bucketConfigurations->size() - 1; i >= 0; i--) {
                cValueMap *bucketConfiguration = check_and_cast<cValueMap*>(bucketConfigurations->get(i).objectValue());
                double numTokens = bucketConfiguration->containsKey("initialNumTokens") ? bucketConfiguration->get("initialNumTokens").doubleValue() : 0;
                double maxNumTokens = bucketConfiguration->containsKey("maxNumTokens") ? bucketConfiguration->get("maxNumTokens").doubleValue() : -1;
                double tokenProductionRate = bucketConfiguration->get("tokenProductionRate");
                auto excessTokenStorage = bucketConfiguration->containsKey("excessTokenModule") ? getExcessTokenStorage(bucketConfiguration->get("excessTokenModule")) : (i < bucketConfigurations->size() - 1 ? &tokenBuckets[i + 1] : nullptr);
                tokenBuckets[i] = (TokenBucket(numTokens, maxNumTokens, tokenProductionRate, excessTokenStorage));
            }
            WATCH_VECTOR(tokenBuckets);
        }
        else if (stage == INITSTAGE_QUEUEING)
            T::emit(tokensChangedSignal, getNumTokens());
    }

removeTokenProductionRate()

template<typename T >

virtual void inet::queueing::MultiTokenBucketMixin< T >::removeTokenProductionRate ( double  tokenRate )

inlineoverridevirtual

Implements inet::queueing::ITokenStorage.

    {
        Enter_Method("removeTokenProductionRate");
        auto &tokenBucket = tokenBuckets[0];
        EV_INFO << "Removing token production rate" << EV_FIELD(tokenRate) << EV_FIELD(tokenBucket) << EV_ENDL;
        tokenBucket.removeTokenProductionRate(tokenRate);
    }

removeTokens()

template<typename T >

virtual void inet::queueing::MultiTokenBucketMixin< T >::removeTokens ( double  numTokens )

inlineoverridevirtual

Implements inet::queueing::ITokenStorage.

    {
        Enter_Method("removeTokens");
        EV_INFO << "Removing tokens" << EV_FIELD(numTokens) << EV_ENDL;
        T::emit(tokensChangedSignal, getNumTokens());
        tokenBuckets[0].removeTokens(numTokens);
        T::emit(tokensChangedSignal, getNumTokens());
    }

resolveDirective()

template<typename T >

const virtual char* inet::queueing::MultiTokenBucketMixin< T >::resolveDirective ( char  directive ) const

inlineoverrideprotectedvirtual

    {
        static std::string result;
        switch (directive) {
            case 'n': {
                std::stringstream stream;
                for (int i = 0; i < tokenBuckets.size(); i++) {
                    auto &tokenBucket = tokenBuckets[i];
                    if (i != 0)
                        stream << ", ";
                    stream << tokenBucket.getNumTokens();
                }
                result = stream.str();
                break;
            }
            default:
                return T::resolveDirective(directive);
        }
        return result.c_str();
    }

Member Data Documentation

tokenBuckets

template<typename T >

std::vector<TokenBucket> inet::queueing::MultiTokenBucketMixin< T >::tokenBuckets

protected

---

The documentation for this class was generated from the following file:

• MultiTokenBucketMixin.h