rpcService.h

 
#ifndef RPCSERVICE_H
#define RPCSERVICE_H
 
#include <stdexcept>
 
#ifdef epicsExportSharedSymbols
#   define rpcServiceEpicsExportSharedSymbols
#   undef epicsExportSharedSymbols
#endif
 
#include <pv/sharedPtr.h>
#include <pv/status.h>
 
#ifdef rpcServiceEpicsExportSharedSymbols
#   define epicsExportSharedSymbols
#       undef rpcServiceEpicsExportSharedSymbols
#endif
 
#include <pv/pvAccess.h>
 
#include <shareLib.h>
 
namespace epics {
namespace pvAccess {
 
class RPCRequestException : public std::runtime_error {
public:
 
    explicit RPCRequestException(std::string const & message) :
        std::runtime_error(message), m_status(epics::pvData::Status::STATUSTYPE_ERROR)
    {}
 
    RPCRequestException(epics::pvData::Status::StatusType status, std::string const & message) :
        std::runtime_error(message), m_status(status)
    {}
 
    epics::pvData::Status::StatusType getStatus() const {
        return m_status;
    }
 
    epics::pvData::Status asStatus() const {
        return epics::pvData::Status(m_status, what());
    }
private:
    epics::pvData::Status::StatusType m_status;
};
 
class epicsShareClass RPCResponseCallback
{
public:
    POINTER_DEFINITIONS(RPCResponseCallback);
 
    virtual ~RPCResponseCallback() {};
 
    virtual void requestDone(
        epics::pvData::Status const & status,
        epics::pvData::PVStructure::shared_pointer const & result
    ) = 0;
};
 
class epicsShareClass RPCServiceAsync
{
public:
    POINTER_DEFINITIONS(RPCServiceAsync);
 
    virtual ~RPCServiceAsync() {};
 
    virtual void request(
        epics::pvData::PVStructure::shared_pointer const & args,
        RPCResponseCallback::shared_pointer const & callback
    ) = 0;
};
 
class epicsShareClass RPCService :
    public RPCServiceAsync
{
public:
    POINTER_DEFINITIONS(RPCService);
 
    virtual ~RPCService() {};
 
    virtual epics::pvData::PVStructure::shared_pointer request(
        epics::pvData::PVStructure::shared_pointer const & args
    ) = 0;
 
private:
    virtual void request(
        epics::pvData::PVStructure::shared_pointer const & args,
        RPCResponseCallback::shared_pointer const & callback
    ) OVERRIDE FINAL;
};
 
}
}
 
#endif  /* RPCSERVICE_H */