TimingEventSourceSCU.cpp

Go to the documentation of this file.

//Copyright GSI 2012
#include <sstream>
#include <fstream>
#include <malloc.h>
#include <sys/time.h>

#include <fesa-core-gsi/RealTime/TimingEventSourceSCU.h>
#include <fesa-core-gsi/Synchronization/TimingContextSCU.h>
#include <fesa-core-gsi/Synchronization/GSICycleDescriptor.h>
#include <fesa-core-gsi/Exception/GSIException.h>
#include <fesa-core/Core/FesaDefs.h>
#include <fesa-core/Utilities/ParserElements/EventElement.h>
#include <fesa-core/Utilities/ParserElements/ParserElementDefs.h>

namespace fesaGSI
{

    TimingEventSourceSCU::TimingEventSourceSCU() :
        fesa::AbstractEventSource(fesa::TIMING_EVENT_SOURCE_NAME, fesa::TimingSource)
    {
        int status;                                     /* return status of system calls */

                /* open irq device */
                status = fileDescriptor_ = open(SCU_TIMING_DEVICE_NAME.c_str(), O_RDWR);
                if (status == -1)
                {
                        throw GSIException(__FILE__, __LINE__, FESAGSIErrorWhileConnectingToSCUTiming.c_str(),SCU_TIMING_DEVICE_NAME.c_str());
                }
    }

    TimingEventSourceSCU::~TimingEventSourceSCU()
    {
        close(fileDescriptor_);
    }

    fesa::RTEvent* TimingEventSourceSCU::wait()
    {
        // This loop is necessary in case of error on TimLib call. For errors other
        // than TimLibTIMEOUT we have to insert our own delay to avoid to loop
        // in TimLibCall very fast consuming all CPU time.
        while(true)
        {
            fesa::RTEvent* theEvent = 0;
            fesa::MultiplexingContext* context = 0;
            try
            {

                unsigned int cnt_value_irq;     /* buffer to hold data */
                int status;                                     /* return status of system calls */

                /* blocking read */
                status = read(fileDescriptor_, &cnt_value_irq, sizeof(int));
                if (status == -1)
                {
                        throw GSIException(__FILE__, __LINE__, FESAGSIErrorWhileReceivingInterrupt.c_str());
                }

                                long timestamp = cnt_value_irq;
                std::string cycleName = "AnyCycle";
                context = new TimingContextSCU(timestamp,cycleName);
                theEvent = new fesa::RTEvent("SCUTestClass::START_CYCLE#CTIM#32",context ,this);

                // Everything is fine goes out the infinite loop and fires the event
                return theEvent;
            }
            catch (fesa::FesaException& ex)//this also covers FESAGSIExceptions
            {
                if (context != 0)
                    delete context;
                if (theEvent != 0)
                    delete theEvent;

                //std::stringstream buf;
                //buf << " Event was not fired, because the following exception occured: " << ex.getMessage().c_str();
                //pLog->logError(fesa::FesaLogger::alert, fesa::FesaLogger::fwkSender) << buf.str() << std::endl;
            }
            catch (...)
            {
                if (context != 0)
                    delete context;
                if (theEvent != 0)
                    delete theEvent;

                //std::stringstream buf;
                //buf << " GSITimingEventSource.cpp: Event was not fired, because an unknown exception occured. ";
                //pLog->logError(fesa::FesaLogger::alert, fesa::FesaLogger::fwkSender) << buf.str() << std::endl;
            }
        }
    }

    void TimingEventSourceSCU::connect(boost::shared_ptr<fesa::EventElement>& eventElement)
    {
        std::string concreteEventName = eventElement->getSourceTypeSpecificData(fesa::TIMING_TAG_CONCRETE_NAME);

        // objectName are formatted like this:
        // "ClassName::BX.WCY200-CT#CTIM#202" or "ClassName::EX.SCY-MTG#LTIM#16 or ClassName::EX.SCY-MTG#LTIM-HARD#16"

        //size_t posSep0= concreteEventName.find(':');
        size_t posSep1 = concreteEventName.find('#');
        size_t posSep2 = concreteEventName.rfind('#', concreteEventName.size());
        if (posSep1 == std::string::npos || posSep2 == std::string::npos)
        {
            throw GSIException(__FILE__, __LINE__, FESAGSIErrorWrongTimingName.c_str(), concreteEventName.c_str());
        }

        //     throw GSIException(__FILE__, __LINE__, FESAGSIErrorWhileConnectingTimingEvent.c_str(),
        //                   concreteEventName.c_str());

        if (false)
        {
            throw GSIException(__FILE__, __LINE__, FESAGSIErrorWhileConnectingTimingEvent.c_str(),
                            concreteEventName.c_str());
        }

        return;
    }

}//end namespace