SubscriptionCycle.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/RDADeviceServer/SubscriptionCycle.h>

#include <fesa-core/Synchronization/MultiplexingContext.h>


namespace fesa
{

SubscriptionCycle::SubscriptionCycle()
{
}

SubscriptionCycle::~SubscriptionCycle()
{
}

void SubscriptionCycle::addCycle(const std::string& cycle)
{
    CyclesItr itr = cycles_.find(cycle);
    if(itr != cycles_.end())
    {
        //increment the refCounter for this cycle
        uint32_t refCount = (*itr).second +1;
        (*itr).second = refCount;
    }
    else
    {
        cycles_[cycle] = 1;
    }
}

void SubscriptionCycle::removeCycle(const std::string& cycle)
{
    CyclesItr itr = cycles_.find(cycle);
    if ((*itr).second == 1)
        cycles_.erase(itr);
    else
    {
        //decrement the refCounter for this cycle
        uint32_t refCount = (*itr).second -1;
        (*itr).second = refCount;
    }
}

void SubscriptionCycle::matchContext(MultiplexingContext& ctxt, std::vector<std::string>& validCycles)
{
    CyclesItr itr = cycles_.begin();
    CyclesItr itrEnd = cycles_.end();
    // just in case...
    validCycles.clear();

    for(; itr != itrEnd; ++itr)
    {
        const std::string& cs = (*itr).first;
        if (ctxt.match(cs))
        {
            validCycles.push_back(cs);
        }
    }
}

void SubscriptionCycle::printDebugState(std::stringstream& str, int32_t tabNb)
{
    std::string tabs;
    for (int32_t i=0; i<tabNb;++i)
        tabs.append("\t");
    CyclesItr itr = cycles_.begin();
    CyclesItr itrEnd = cycles_.end();
    for(; itr != itrEnd; ++itr)
    {
        str << tabs << " cycle: " << (*itr).first << " . refcount: " << (*itr).second << "\n";
    }
}

} // fesa