processRecord.h

Go to the documentation of this file.

/* processRecord.h */
#ifndef PROCESSRECORD_H
#define PROCESSRECORD_H

#include <map>
#include <epicsThread.h>
#include <pv/event.h>
#include <pv/channelProviderLocal.h>

#include <shareLib.h>

namespace epics { namespace pvDatabase {

typedef std::tr1::shared_ptr<epicsThread> EpicsThreadPtr;

class ProcessRecord;
typedef std::tr1::shared_ptr<ProcessRecord> ProcessRecordPtr;

class epicsShareClass ProcessRecord :
    public PVRecord,
    public epicsThreadRunable
{
public:
    POINTER_DEFINITIONS(ProcessRecord);
    static ProcessRecordPtr create(
        std::string const & recordName,double delay);
    virtual bool init();
    virtual void process();
    virtual void run();
    void startThread();
    void stop();
private:
    ProcessRecord(
        std::string const & recordName,
        epics::pvData::PVStructurePtr const & pvStructure,double delay);
    double delay;
    EpicsThreadPtr thread;
    epics::pvData::Event runStop;
    epics::pvData::Event runReturn;
    PVDatabasePtr pvDatabase;
    PVRecordMap pvRecordMap;
    epics::pvData::PVStringPtr pvCommand;
    epics::pvData::PVStringPtr pvRecordName;
    epics::pvData::PVStringPtr pvResult;
    epics::pvData::Mutex mutex;
};

}}

#endif  /* PROCESSRECORD_H */