epics::pvAccess::RPCClient::RPCRequester Struct Reference

Inheritance diagram for epics::pvAccess::RPCClient::RPCRequester:

Collaboration diagram for epics::pvAccess::RPCClient::RPCRequester:

Public Member Functions
	POINTER_DEFINITIONS (RPCRequester)
	RPCRequester ()
virtual	~RPCRequester ()
virtual std::string	getRequesterName ()
virtual void	channelRPCConnect (const pvd::Status &status, ChannelRPC::shared_pointer const &operation)
virtual void	requestDone (const pvd::Status &status, ChannelRPC::shared_pointer const &operation, pvd::PVStructure::shared_pointer const &pvResponse)
virtual void	channelDisconnect (bool destroy)
Public Member Functions inherited from epics::pvAccess::ChannelRPCRequester
	POINTER_DEFINITIONS (ChannelRPCRequester)
virtual	~ChannelRPCRequester ()
virtual void	requestDone (const epics::pvData::Status &status, ChannelRPC::shared_pointer const &operation, epics::pvData::PVStructure::shared_pointer const &pvResponse)=0
Public Member Functions inherited from epics::pvAccess::ChannelBaseRequester
	POINTER_DEFINITIONS (ChannelBaseRequester)
	ChannelBaseRequester ()
virtual	~ChannelBaseRequester ()

Public Attributes
pvd::Mutex	mutex
ChannelRPC::shared_pointer	op
pvd::Status	conn_status
pvd::Status	resp_status
epics::pvData::PVStructure::shared_pointer	next_args
epics::pvData::PVStructure::shared_pointer	last_data
epicsEvent	event
bool	inprogress
bool	last

Additional Inherited Members
Public Types inherited from epics::pvAccess::ChannelRPCRequester
typedef ChannelRPC	operation_type
Static Public Attributes inherited from epics::pvAccess::ChannelBaseRequester
static size_t	num_instances

Detailed Description

Definition at line 34 of file rpcClient.cpp.

Constructor & Destructor Documentation

epics::pvAccess::RPCClient::RPCRequester::RPCRequester ( )

inline

Definition at line 45 of file rpcClient.cpp.

        :conn_status(pvd::Status::error("Never connected"))
        ,resp_status(pvd::Status::error("Never connected"))
        ,inprogress(false)
        ,last(false)
    {}

virtual epics::pvAccess::RPCClient::RPCRequester::~RPCRequester ( )

inlinevirtual

Definition at line 51 of file rpcClient.cpp.

{}

Member Function Documentation

virtual void epics::pvAccess::RPCClient::RPCRequester::channelDisconnect ( bool  destroy )

inlinevirtual

Notification when underlying Channel becomes DISCONNECTED or DESTORYED

(re)connection is notified through a sub-class *Connect() method.

Any in-progress get()/put()/request()/start() is implicitly cancel()'d or stop()'d before this method is called.

Ownership of any PVStructures passed to completion callbacks (eg. ChannelGetRequester::getDone() ) is returned the operation

Parameters

destroy

true for final disconnect.

Reimplemented from epics::pvAccess::ChannelBaseRequester.

Definition at line 103 of file rpcClient.cpp.

    {
        TRACE("destroy="<<destroy);
        {
            pvd::Lock L(mutex);
            resp_status = conn_status = pvd::Status::error("Connection lost");
            last_data.reset();
            next_args.reset();
            inprogress = false;
        }
        event.signal();
    }

virtual void epics::pvAccess::RPCClient::RPCRequester::channelRPCConnect ( const pvd::Status &  status, ChannelRPC::shared_pointer const &  operation  )

inlinevirtual

RPC creation request satisfied.

Must check status.isOk().

On Success, a non-NULL 'operation' is provided. This is the same pointer which was, or will be, returned from Channel::createChannelRPC().

It is allowed to call ChannelRPC::request() from within this method.

Implements epics::pvAccess::ChannelRPCRequester.

Definition at line 55 of file rpcClient.cpp.

    {
        bool lastreq, inprog;
        pvd::PVStructure::shared_pointer args;
        {
            pvd::Lock L(mutex);
            TRACE("status="<<status);
            op = operation;
            conn_status = status;
            args.swap(next_args);
            lastreq = last;
            inprog = inprogress;
            if(inprog && args)
                TRACE("request deferred: "<<args);
        }
        if(inprog && args) {
            TRACE("request deferred: "<<args);
            if(lastreq)
                operation->lastRequest();
            operation->request(args);
        }
        event.signal();
    }

virtual std::string epics::pvAccess::RPCClient::RPCRequester::getRequesterName ( )

inlinevirtual

Definition at line 53 of file rpcClient.cpp.

{ return "RPCClient::RPCRequester"; }

epics::pvAccess::RPCClient::RPCRequester::POINTER_DEFINITIONS

(

RPCRequester

)

virtual void epics::pvAccess::RPCClient::RPCRequester::requestDone ( const pvd::Status &  status, ChannelRPC::shared_pointer const &  operation, pvd::PVStructure::shared_pointer const &  pvResponse  )

inlinevirtual

Definition at line 81 of file rpcClient.cpp.

    {
        TRACE("status="<<status<<" response:\n"<<pvResponse<<"\n");
        {
            pvd::Lock L(mutex);
            if(!inprogress) {
                std::cerr<<"pva provider give RPC requestDone() when no request in progress\n";
            } else {
                resp_status = status;
                last_data = pvResponse;
                if(resp_status.isSuccess() && !last_data) {
                    resp_status = pvd::Status::error("No reply data");
                }
                inprogress = false;
            }
        }
        event.signal();
    }

Member Data Documentation

pvd::Status epics::pvAccess::RPCClient::RPCRequester::conn_status

Definition at line 40 of file rpcClient.cpp.

epicsEvent epics::pvAccess::RPCClient::RPCRequester::event

Definition at line 42 of file rpcClient.cpp.

bool epics::pvAccess::RPCClient::RPCRequester::inprogress

Definition at line 43 of file rpcClient.cpp.

bool epics::pvAccess::RPCClient::RPCRequester::last

Definition at line 43 of file rpcClient.cpp.

epics::pvData::PVStructure::shared_pointer epics::pvAccess::RPCClient::RPCRequester::last_data

Definition at line 41 of file rpcClient.cpp.

pvd::Mutex epics::pvAccess::RPCClient::RPCRequester::mutex

Definition at line 38 of file rpcClient.cpp.

epics::pvData::PVStructure::shared_pointer epics::pvAccess::RPCClient::RPCRequester::next_args

Definition at line 41 of file rpcClient.cpp.

ChannelRPC::shared_pointer epics::pvAccess::RPCClient::RPCRequester::op

Definition at line 39 of file rpcClient.cpp.

pvd::Status epics::pvAccess::RPCClient::RPCRequester::resp_status

Definition at line 40 of file rpcClient.cpp.

---

The documentation for this struct was generated from the following file:

• modules/pvAccess/src/rpcClient/rpcClient.cpp