GSIErrorCollectionField.cpp

Go to the documentation of this file.

//Copyright GSI 2012
#include <fesa-core-gsi/DataStore/GSIErrorCollectionField.h>
#include <fesa-core/Utilities/Lock.h>

#include <cmw-log/Logger.h>

#include <sstream>//to convert the error code to string
#include <sys/time.h>

namespace
{

CMW::Log::Logger& logger = CMW::Log::LoggerFactory::getLogger("FESA.FWK.fesa-core-gsi.DataStore.GSIErrorCollectionField");

} // namespace

namespace fesaGSI
{
        GSIErrorCollectionField::GSIErrorCollectionField(const std::string& fieldName, bool multiplexed, fesa::DataStore* pDataStore, bool persistent, int size)
        : fesa::AcqFieldStructArray<GSI_ERROR> (fieldName, multiplexed, pDataStore, persistent, size, fesa::SingleBuffered)
        {
                index_ = 0;
        }

        GSIErrorCollectionField::~GSIErrorCollectionField()
        {
        }

        void GSIErrorCollectionField::addError(long error_code, std::string& ErrorMessage, fesa::MultiplexingContext* context, fesa::AbstractDevice* pDev)
        {
                unsigned int index;
                {//usage of fesa::lock to automatically release lock after this block
                        fesa::Lock lock(mutexIndex_);

                        //we use this field-array as rolling buffer
                        index_= index_ % maxSize_;
                        index = index_;
                }

                //The cell we want to overwrite
                GSI_ERROR* temp = const_cast<GSI_ERROR*>(getCell(index,context));

                for(unsigned int x=0;x<MAX_ERROR_MESSAGE_LENGTH && x< ErrorMessage.size();x++)
                        temp->error_string[x]= ErrorMessage[x];

                std::string cycleName= context->getCycleName();
                for(unsigned int x=0;x<MAX_CYCLE_NAME_LENGTH && x< cycleName.size();x++)
                        temp->error_cycle_name[x]= cycleName[x];

                temp->error_code = error_code;

                //for logging we as well need the error-code as string
                std::string error_code_as_string;
                std::stringstream tempStream;
                tempStream << error_code;
                tempStream >> error_code_as_string;

                //get timestamp as char-array (only for fesa, syslog automatically adds stamps)
        time_t ltime;
        struct tm *Tm;

        ltime=time(NULL);
        Tm=localtime(&ltime);

        char temp_stamp[MAX_TIMESTAMP_LENGTH];
        sprintf(temp_stamp,"[%d] %d %d %d, %d:%d:%d",
                Tm->tm_wday, /* Mon - Sun */
                Tm->tm_mday,
                Tm->tm_mon+1,
                Tm->tm_year+1900,
                Tm->tm_hour,
                Tm->tm_min,
                Tm->tm_sec);

                for(unsigned int x=0;x<MAX_TIMESTAMP_LENGTH;x++)
                        temp->error_timestamp[x]= temp_stamp[x];

        //log the error
        std::ostringstream message;
        message << "Error at: [Device]: " << pDev->getName() << " [Cycle:]" << context->getCycleName()
                        << " [Error Code:] " << error_code_as_string << " [Error Message:] " << ErrorMessage;
                LOG_ERROR_IF(logger, message.str());

                setCell(temp, index, context);
                index_++;
        }

} // namespace end