rpcService.h

Go to the documentation of this file.

#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 epicsShareClass 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 */