FieldValue.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/DataStore/FieldValue.h>


namespace fesa
{

FieldValue<char[]>::FieldValue(DataIntegrity dataIntegrity, uint32_t size)
{

    phase_ = P1;
    toBeSync_ = false;
    pendingChanged_ = false;
    offset_[0] = sizeof(FieldValue<char[]> );

    if (dataIntegrity == DoubleBuffered)
    {
        offset_[1] = static_cast<uint32_t>(sizeof(FieldValue<char[]>)) + static_cast<uint32_t>(sizeof(char)) * (size + 1);
    }
    else
    {
        offset_[1] = offset_[0];
    }

}

char* FieldValue<char[]>::pendingBuffer(char* pFV)
{
    return (this->phase_ == this->P1) ? pFV + offset_[0] : pFV + offset_[1];
}

char* FieldValue<char[]>::activeBuffer(char* pFV)
{
    return (this->phase_ == this->P1) ? pFV + offset_[1] : pFV + offset_[0];
}

/************************ END SPECIALIZATION FOR STRING ****************************/

FieldValue<char *[]>::FieldValue(DataIntegrity dataIntegrity, uint32_t size)
{

    phase_ = P1;
    toBeSync_ = false;
    pendingChanged_ = false;
    currentSize_[0] = size;
    currentSize_[1] = size;
    offset_[0] = 0;

    if (dataIntegrity == DoubleBuffered)
    {
        offset_[1] = 1;
        isSingleBuffer_ = false;
    }
    else
    {
        offset_[1] = 0;
        isSingleBuffer_ = true;
    }

}

uint32_t FieldValue<char *[]>::pendingBuffer()
{


    if (this->phase_ == this->P1)
    {
        return offset_[1];
    }
    else
    {
        return offset_[0];
    }
}

uint32_t FieldValue<char *[]>::activeBuffer()
{

    if (this->phase_ == this->P1)
    {
        return offset_[0];
    }
    else
    {
        return offset_[1];
    }
}

uint32_t FieldValue<char* []>::getPendingCurrentSize()
{
    // In case of single buffer dimension is get from position 0 else it's driven by the phase
    if (isSingleBuffer_)
        return currentSize_[0];
    else
        return (this->phase_ == this->P1) ? currentSize_[0] : currentSize_[1];
}

uint32_t FieldValue<char* []>::getActiveCurrentSize()
{
    // In case of single buffer dimension is get from position 0 else it's driven by the phase
    if (isSingleBuffer_)
        return currentSize_[0];
    else
        return (this->phase_ == this->P1) ? currentSize_[1] : currentSize_[0];
}

void FieldValue<char* []>::setPendingCurrentSize(uint32_t currentSize)
{
    // In case of single buffer dimension is written in position 0 else it's driven by the phase
    if (isSingleBuffer_ || this->phase_ == this->P1)
    {
        currentSize_[0] = currentSize;
    }
    else
    {
        currentSize_[1] = currentSize;
    }
}

void FieldValue<char* []>::setActiveCurrentSize(uint32_t currentSize)
{
    // In case of single buffer dimension is written in position 0 else it's driven by the phase
    if (isSingleBuffer_ || this->phase_ == this->P2)
    {
        currentSize_[0] = currentSize;
    }
    else
    {
        currentSize_[1] = currentSize;
    }
}

} // fesa