RollingMultiplexingDataManager.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

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

#include <fesa-core/Utilities/Lock.h>
#include <fesa-core/Exception/FesaException.h>


namespace fesa
{

RollingMultiplexingDataManager::RollingMultiplexingDataManager(int32_t depth) :
    depth_(depth)
{
}

int32_t RollingMultiplexingDataManager::findCycleIdBackward(int32_t cycleId)
{
    // lock the access to the data
    Lock lock(*mutex_);

    int32_t index = *currentPosition_ - 1;
    if (index == -1)
    {
        index = depth_ - 1;
    }

    for (int32_t i = 0; i < depth_;i++)
    {
        // update index
        index--;
        if (index == -1)
        {
            index = depth_ - 1;
        }

        if (currentIdsCol_[index] == cycleId)
        {
            return index;
        }

    }
    return -1;
}

int32_t RollingMultiplexingDataManager::findCycleStampBackward(int64_t cycleStamp)
{
    // lock the access to the data
    Lock lock(*mutex_);

    int32_t index = *currentPosition_;

    for (int32_t i = 0; i < depth_;i++)
    {
        // update index
        index--;
        if (index == -1)
            index = depth_ - 1;

        if (currentCycleStampsCol_[index] == cycleStamp)
        {
            return index;
        }

    }
    return -1;
}

//    int RollingMultiplexingDataManager::findCyleId(long cycleId)
//    {
//        // lock the access to the data
//        mutex_->lock();
//
//        int index = *currentPosition_;
//
//        for (int i = 0; i < depth_;i++)
//        {
//            // update index
//            index = (index + 1) % depth_;
//
//            if (currentIdsCol_[index] == cycleId)
//            {
//                mutex_->unlock();
//                return index;
//            }
//
//        }
//        mutex_->unlock();
//        return -1;
//    }
//
//    int RollingMultiplexingDataManager::findCyleStamp(long long cycleStamp)
//    {
//        // lock the access to the data
//        mutex_->lock();
//
//        int index = *currentPosition_;
//
//        for (int i = 0; i < depth_;i++)
//        {
//            // update index
//            index = (index + 1) % depth_;
//
//            if (currentCycleStampsCol_[index] == cycleStamp)
//            {
//                mutex_->unlock();
//                return index;
//            }
//
//        }
//
//        mutex_->unlock();
//        return -1;
//
//    }

//    int RollingMultiplexingDataManager::putCycleId(long cycleId)
//    {
//        int result = -1;
//        mutex_->lock();
//
//        if (*currentPosition_ < 0 || *currentPosition_ >= depth_)
//        {
//            mutex_->unlock();
//            return -1;
//        }
//        currentIdsCol_[*currentPosition_] = cycleId;
//        result = *currentPosition_;
//
//        mutex_->unlock();
//
//        return result;
//    }
//
//    int RollingMultiplexingDataManager::putCycleStamp(long long cycleStamp)
//    {
//        int result = -1;
//        mutex_->lock();
//
//        if (*currentPosition_ < 0 || *currentPosition_ >= depth_)
//        {
//            mutex_->unlock();
//            return -1;
//        }
//        currentCycleStampsCol_[*currentPosition_] = cycleStamp;
//
//        result = *currentPosition_;
//
//        mutex_->unlock();
//
//        return result;
//    }

int32_t RollingMultiplexingDataManager::nextPosition(int64_t cycleStamp, int32_t cycleId)
{
    int32_t result = -1;
    Lock lock(*mutex_);
    if (*currentPosition_ < 0 || *currentPosition_ >= depth_)
    {
        return -1;
    }
    currentCycleStampsCol_[*currentPosition_] = cycleStamp;
    currentIdsCol_[*currentPosition_] = cycleId;

    result = *currentPosition_;
    // move the pointer
    *currentPosition_ = (*currentPosition_ + 1) % depth_;
    return result;
}

//    std::pair<long, long long> RollingMultiplexingDataManager::getLastCycleInfo()
//    {
//        std::pair<long, long long> tmp;
//        mutex_->lock();
//        if (*currentPosition_ == 0)
//        {
//            tmp.first = currentIdsCol_[depth_ - 1];
//            tmp.second = currentCycleStampsCol_[depth_ - 1];
//        }
//        else
//        {
//            tmp.first = currentIdsCol_[*currentPosition_ - 1];
//            tmp.second = currentCycleStampsCol_[*currentPosition_ - 1];
//        }
//        mutex_->unlock();
//        return tmp;
//    }

} // fesa