RollingMultiplexingDataManager.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef ROLLING_MULTIPLEXING_DATA_MANAGER_H_
#define ROLLING_MULTIPLEXING_DATA_MANAGER_H_

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

namespace fesa
{

class RollingMultiplexingDataManager : public MultiplexingDataManager
{
  public:

    RollingMultiplexingDataManager(int32_t depth);

    virtual int32_t computeMemorySize() = 0;

    virtual void mapMemory(char* address) = 0;

    int32_t findCycleIdBackward(int32_t cycleId);

    int32_t findCycleStampBackward(int64_t cycleStamp);

    //            /*!
    //             * \brief This method finds the cycleId, passed by argument, starting from the first position
    //             * \param cycleId the CycleID we are searching for
    //             * \return the corresponding slot, -1 if not found
    //             */
    //            int findCyleId(long cycleId);
    //
    //            /*!
    //             * \brief This method finds the cycleId, passed by argument, starting from the first position
    //             * \param cycleStamp the cycleStamp we are searching for
    //             * \return the corresponding slot, -1 if not found
    //             */
    //            int findCyleStamp(long long cycleStamp);

    //            /*!
    //             * \brief This method puts the cycleId passed by argument into the currentPosition
    //             * \param cycleId the CycleID we want to put
    //             * \return the slot where the ID was put, -1 on error
    //             */
    //            int putCycleId(long cycleId);
    //
    //            /*!
    //             * \brief This method puts the cycleStamp passed by argument into the currentPosition
    //             * \param cycleStamp the cycleStamp we want to put
    //             * \return the slot where the stamp was put, -1 on error
    //             */
    //            int putCycleStamp(long long cycleStamp);
    int64_t getCycleStamp(int32_t position);

    int32_t nextPosition(int64_t cycleStamp, int32_t cycleId);
    int32_t getCurrentPosition();

    int32_t getDepth();

    int32_t getCurrentCycleId();

    //            std::pair<long, long long> getLastCycleInfo();

    /*
     * \brief This method sets the cycle ID of the current slot
     * \param cycleId the CycleID we want to put
     * \return the current cycle ID
     */
    void setCurrentCycleId(int32_t cycleId);

  protected:

    int32_t* currentIdsCol_;

    int64_t* currentCycleStampsCol_;

    int32_t depth_;

    int32_t* currentId_;

    AbstractMutex* mutex_;

    int32_t* currentPosition_;

};

inline int32_t RollingMultiplexingDataManager::getDepth()
{
    return depth_;
}

inline int32_t RollingMultiplexingDataManager::getCurrentCycleId()
{
    return *currentId_;
}
inline void RollingMultiplexingDataManager::setCurrentCycleId(int32_t currentId)
{
    *currentId_ = currentId;
}
inline int32_t RollingMultiplexingDataManager::getCurrentPosition()
{
    return *currentPosition_;
}

inline int64_t RollingMultiplexingDataManager::getCycleStamp(int32_t position)
{
    return *(currentCycleStampsCol_ + position);
}

} // fesa

#endif // ROLLING_MULTIPLEXING_DATA_MANAGER_H_