AbstractMultiplexingManager.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

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

#include <fesa-core/Synchronization/AbstractMultiplexingDataManager.h>
#include <fesa-core/Synchronization/CycleDescriptor.h>


namespace fesa
{

std::map<std::string, AbstractMultiplexingManager*> AbstractMultiplexingManager::managersCol_;


AbstractMultiplexingManager::AbstractMultiplexingManager(const std::string& name,
                                                         CycleDescriptor* timingDescriptor) :
    name_(name), timingDescriptor_(timingDescriptor)
{

    managersCol_.insert(std::make_pair(name, this));
}

AbstractMultiplexingManager::~AbstractMultiplexingManager()
{
    managersCol_.erase(name_);
    if (managersCol_.size() == 0)
    {
        managersCol_.clear();
    }
}

AbstractMultiplexingManager* AbstractMultiplexingManager::getMultiplexingManager(const std::string& name)
{
    std::map<std::string, AbstractMultiplexingManager*>::iterator itr;
    itr = AbstractMultiplexingManager::managersCol_.find(name);
    if (itr == AbstractMultiplexingManager::managersCol_.end())
    {
        return NULL;
    }
    else
    {
        return itr->second;
    }
}

int32_t AbstractMultiplexingManager::getMemorySizeToAllocate()
{
    int32_t muxManagersSize_ = 0;
    for (std::map<std::string, AbstractMultiplexingManager*>::iterator itr = managersCol_.begin(); itr
             != managersCol_.end(); ++itr)
    {
        AbstractMultiplexingManager* pAbstractMultiplexingManager = (itr->second);
        AbstractMultiplexingDataManager* pCycleDataManager =
            pAbstractMultiplexingManager->getMultiplexingDataManager();
        if (pCycleDataManager)
        {

            muxManagersSize_ += pCycleDataManager->computeMemorySize();
        }
    }
    return muxManagersSize_;
}

void AbstractMultiplexingManager::mapMemory(char* p)
{
    for (std::map<std::string, AbstractMultiplexingManager*>::iterator itr = managersCol_.begin(); itr
             != managersCol_.end(); ++itr)
    {
        AbstractMultiplexingManager * pAbstractMultiplexingManager = (itr->second);
        AbstractMultiplexingDataManager* pCycleDataManager =
            pAbstractMultiplexingManager->getMultiplexingDataManager();
        if (pCycleDataManager)
        {
            pCycleDataManager->mapMemory(p);
            p += pCycleDataManager->computeMemorySize();
        }
    }
}

int32_t AbstractMultiplexingManager::getDepth()
{
    return static_cast<int32_t>(timingDescriptor_->getCycleIdsCol().size());
}

} // fesa