AbstractMsgQueue.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/Core/AbstractMsgQueue.h>

#include <fesa-core/Exception/FesaException.h>
#include <cmw-log/Logger.h>

namespace
{

CMW::Log::Logger& logger = CMW::Log::LoggerFactory::getLogger("FESA.FWK.fesa-core.Utilities.ConfigData");

} // namespace

namespace fesa
{

AbstractMsgQueue::AbstractMsgQueue(const std::string& name, MQ_TYPE type, uint32_t queuelength) :
    queueName_(name), queueType_(type), queueLength_(queuelength)
{
    if (queuelength > constants_.msg_num_max_)
    {
        throw FesaException(__FILE__, __LINE__, FesaErrorQueueLengthExceeded.c_str(), "Creating", name.c_str());
    }
    std::ostringstream traceStringStream;
    traceStringStream << "Creating the MessageQueue: '" << queueName_ << "' of length " << queueLength_ ;
    LOG_TRACE_IF(logger, traceStringStream.str());
}

uint32_t AbstractMsgQueue::isFull()
{
    uint32_t curMsgCount = getCurrentMsgCount();
    if (curMsgCount == queueLength_)
    {
        return curMsgCount;
    }
    else
    {
        return 0;
    }
}

AbstractMsgQueue::~AbstractMsgQueue()
{
}

uint32_t AbstractMsgQueue::isAlmostFull()
{
    uint32_t curMsgCount = getCurrentMsgCount();
    uint32_t diff = queueLength_ - curMsgCount;
    if ((diff <= constants_.queue_diag_slots) && (diff > 0))
    {
        return curMsgCount;
    }
    else
    {
        return 0;
    }
}

void AbstractMsgQueue::checkState(uint32_t msgPrio)
{
    if (isFull())
    {
        throw FesaException(__FILE__, __LINE__, FesaErrorQueueFull.c_str(), "completly",
                            "No place even for DIAG msg", queueName_.c_str());
    }
    else if (isAlmostFull() && (msgPrio != HIGH_MQ_PRIO))
    {
        throw FesaException(__FILE__, __LINE__, FesaErrorQueueFull.c_str(), "almost", "Only DIAG msg are allowed",
                            queueName_.c_str());
    }
}

} // fesa