rpcClient.h

 
#ifndef RPCCLIENT_H
#define RPCCLIENT_H
 
#include <string>
 
#ifdef epicsExportSharedSymbols
#   define rpcClientEpicsExportSharedSymbols
#   undef epicsExportSharedSymbols
#endif
#include <pv/pvData.h>
#include <pv/valueBuilder.h>
#ifdef rpcClientEpicsExportSharedSymbols
#   define epicsExportSharedSymbols
#       undef rpcClientEpicsExportSharedSymbols
#endif
 
#include <pv/rpcService.h>
 
#include <shareLib.h>
 
#define RPCCLIENT_DEFAULT_TIMEOUT 5.0
 
namespace epics
{
 
namespace pvAccess
{
 
class epicsShareClass RPCClient
{
public:
    POINTER_DEFINITIONS(RPCClient);
 
    static shared_pointer create(const std::string & serviceName,
                                 epics::pvData::PVStructure::shared_pointer const & pvRequest = epics::pvData::PVStructure::shared_pointer());
 
    RPCClient(const std::string & serviceName,
              epics::pvData::PVStructure::shared_pointer const & pvRequest,
              const ChannelProvider::shared_pointer& provider = ChannelProvider::shared_pointer(),
              const std::string& address = std::string());
 
    ~RPCClient() {destroy();}
 
 
 
    void destroy();
 
    bool connect(double timeout = RPCCLIENT_DEFAULT_TIMEOUT);
 
    void issueConnect();
 
    bool waitConnect(double timeout = RPCCLIENT_DEFAULT_TIMEOUT);
 
    epics::pvData::PVStructure::shared_pointer request(
        epics::pvData::PVStructure::shared_pointer const & pvArgument,
        double timeout = RPCCLIENT_DEFAULT_TIMEOUT,
        bool lastRequest = false);
 
    void issueRequest(
        epics::pvData::PVStructure::shared_pointer const & pvArgument,
        bool lastRequest = false);
 
    epics::pvData::PVStructure::shared_pointer waitResponse(double timeout = RPCCLIENT_DEFAULT_TIMEOUT);
 
private:
 
    const std::string m_serviceName;
    ChannelProvider::shared_pointer m_provider;
    Channel::shared_pointer m_channel;
    ChannelRPC::shared_pointer m_rpc;
    const epics::pvData::PVStructure::shared_pointer m_pvRequest;
 
    struct RPCRequester;
    std::tr1::shared_ptr<RPCRequester> m_rpc_requester;
 
    RPCClient(const RPCClient&);
    RPCClient& operator=(const RPCClient&);
};
 
}
 
}
 
#endif