HeapRollingMultiplexingDataManager.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

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

#include <fesa-core/Utilities/Mutex.h>


namespace fesa
{

HeapRollingMultiplexingDataManager::HeapRollingMultiplexingDataManager(int32_t depth) :
    RollingMultiplexingDataManager(depth)
{

}

int32_t HeapRollingMultiplexingDataManager::computeMemorySize()
{

    int32_t memorySize = Mutex::getSize();
    // current index
    memorySize += static_cast<int32_t>(sizeof(int32_t));
    // current cycle id
    memorySize += static_cast<int32_t>(sizeof(int32_t));
    // cycles slots
    memorySize += static_cast<int32_t>(sizeof(int32_t)) * depth_;
    // cycle stamps
    memorySize += static_cast<int32_t>(sizeof(int64_t)) * depth_;

    return memorySize;
}

void HeapRollingMultiplexingDataManager::mapMemory(char* address)
{
    mutex_ = new Mutex(address);

    currentPosition_ = (int32_t*) (address + Mutex::getSize());

    *currentPosition_ = 0;

    currentId_ = (int32_t*) ((char*) currentPosition_ + sizeof(int32_t));

    *currentId_ = -1;

    currentIdsCol_ = (int32_t*) ((char*) currentId_ + sizeof(int32_t));

    currentCycleStampsCol_ = (int64_t*) ((char*) currentIdsCol_ + (sizeof(int32_t) * depth_));
}

} // fesa