epics::pvDatabase::ChannelRPCLocal Class Reference

Inheritance diagram for epics::pvDatabase::ChannelRPCLocal:

Collaboration diagram for epics::pvDatabase::ChannelRPCLocal:

Public Member Functions
	POINTER_DEFINITIONS (ChannelRPCLocal)
virtual void	destroy ()
	ChannelRPCLocal (ChannelLocalPtr const &channelLocal, ChannelRPCRequester::shared_pointer const &channelRPCRequester, RPCServiceAsync::shared_pointer const &service, PVRecordPtr const &pvRecord)
virtual	~ChannelRPCLocal ()
void	processRequest (RPCService::shared_pointer const &service, PVStructurePtr const &pvArgument)
virtual void	requestDone (Status const &status, PVStructurePtr const &result)
void	processRequest (RPCServiceAsync::shared_pointer const &service, PVStructurePtr const &pvArgument)
virtual void	request (PVStructurePtr const &pvArgument)
virtual Channel::shared_pointer	getChannel ()
virtual void	cancel ()
virtual void	lock ()
virtual void	unlock ()
virtual void	lastRequest ()
Public Member Functions inherited from epics::pvAccess::ChannelRPC
	POINTER_DEFINITIONS (ChannelRPC)
virtual	~ChannelRPC ()
virtual void	request (epics::pvData::PVStructure::shared_pointer const &pvArgument)=0
Public Member Functions inherited from epics::pvAccess::ChannelRequest
	POINTER_DEFINITIONS (ChannelRequest)
	ChannelRequest ()
virtual	~ChannelRequest ()
Public Member Functions inherited from epics::pvAccess::Destroyable
	POINTER_DEFINITIONS (Destroyable)
Public Member Functions inherited from epics::pvAccess::Lockable
	POINTER_DEFINITIONS (Lockable)
virtual	~Lockable ()
Public Member Functions inherited from epics::pvAccess::RPCResponseCallback
	POINTER_DEFINITIONS (RPCResponseCallback)
virtual	~RPCResponseCallback ()
virtual void	requestDone (epics::pvData::Status const &status, epics::pvData::PVStructure::shared_pointer const &result)=0

Static Public Member Functions
static ChannelRPCLocalPtr	create (ChannelLocalPtr const &channelLocal, ChannelRPCRequester::shared_pointer const &channelRPCRequester, PVStructurePtr const &pvRequest, PVRecordPtr const &pvRecord)

Additional Inherited Members
Public Types inherited from epics::pvAccess::ChannelRPC
typedef ChannelRPCRequester	requester_type
Static Public Attributes inherited from epics::pvAccess::ChannelRequest
static size_t	num_instances
Protected Member Functions inherited from epics::pvAccess::Destroyable
virtual	~Destroyable ()

Detailed Description

Definition at line 762 of file channelLocal.cpp.

Constructor & Destructor Documentation

epics::pvDatabase::ChannelRPCLocal::ChannelRPCLocal ( ChannelLocalPtr const &  channelLocal, ChannelRPCRequester::shared_pointer const &  channelRPCRequester, RPCServiceAsync::shared_pointer const &  service, PVRecordPtr const &  pvRecord  )

inline

Definition at line 776 of file channelLocal.cpp.

                                      :
        channelLocal(channelLocal),
        channelRPCRequester(channelRPCRequester),
        service(service),
        pvRecord(pvRecord)
    {
    }

epics::pvDatabase::ChannelRPCLocal::~ChannelRPCLocal ( )

virtual

Definition at line 851 of file channelLocal.cpp.

{
//cout << "~ChannelRPCLocal()\n";
}

Member Function Documentation

virtual void epics::pvDatabase::ChannelRPCLocal::cancel ( )

inlinevirtual

Cancel any pending request. Completion will be reported via request's response callback:

• if cancel() request is issued after the request was already complete, request success/failure completion will be reported and cancel() request ignored.
• if the request was actually canceled, cancellation completion is reported.

Implements epics::pvAccess::ChannelRequest.

Definition at line 805 of file channelLocal.cpp.

{}

ChannelRPCLocalPtr epics::pvDatabase::ChannelRPCLocal::create ( ChannelLocalPtr const &  channelLocal, ChannelRPCRequester::shared_pointer const &  channelRPCRequester, PVStructurePtr const &  pvRequest, PVRecordPtr const &  pvRecord  )

static

Definition at line 820 of file channelLocal.cpp.

{
    RPCServiceAsync::shared_pointer service = pvRecord->getService(pvRequest);
    if (!service)
    {
        Status status(Status::STATUSTYPE_ERROR,
            "ChannelRPC not supported");
            channelRPCRequester->channelRPCConnect(status,ChannelRPCLocalPtr());
        return ChannelRPCLocalPtr();
    }

    if (!channelRPCRequester)
        throw std::invalid_argument("channelRPCRequester == null");

    // TODO use std::make_shared
    ChannelRPCLocalPtr rpc(
        new ChannelRPCLocal(channelLocal, channelRPCRequester, service, pvRecord)
    );
    channelRPCRequester->channelRPCConnect(Status::Ok, rpc);
    if(pvRecord->getTraceLevel()>0)
    {
        cout << "ChannelRPCLocal::create";
        cout << " recordName " << pvRecord->getRecordName() << endl;
    }
    return rpc;
}

virtual void epics::pvDatabase::ChannelRPCLocal::destroy ( )

inlinevirtual

Destroy this instance.

Implements epics::pvAccess::Destroyable.

Definition at line 769 of file channelLocal.cpp.

{} // DEPRECATED

std::tr1::shared_ptr< Channel > epics::pvDatabase::ChannelRPCLocal::getChannel ( )

virtual

Get a channel instance this request belongs to.

Returns

the channel instance.

Implements epics::pvAccess::ChannelRequest.

Definition at line 856 of file channelLocal.cpp.

{
   ChannelLocalPtr channel(channelLocal.lock());
   return channel;
}

virtual void epics::pvDatabase::ChannelRPCLocal::lastRequest ( )

inlinevirtual

Announce next request as last request. When last request will be completed (regardless of completion status) the remote and local instance will be destroyed.

Implements epics::pvAccess::ChannelRequest.

Definition at line 808 of file channelLocal.cpp.

{}

virtual void epics::pvDatabase::ChannelRPCLocal::lock ( )

inlinevirtual

Reimplemented from epics::pvAccess::Lockable.

Definition at line 806 of file channelLocal.cpp.

{}

epics::pvDatabase::ChannelRPCLocal::POINTER_DEFINITIONS

(

ChannelRPCLocal

)

void epics::pvDatabase::ChannelRPCLocal::processRequest	(	RPCService::shared_pointer const &	service,
		PVStructurePtr const &	pvArgument
	)

Definition at line 863 of file channelLocal.cpp.

{
    PVStructurePtr result;
    Status status = Status::Ok;
    bool ok = true;
    try
    {
        result = service->request(pvArgument);
    }
    catch (RPCRequestException& rre)
    {
        status = Status(rre.getStatus(), rre.what());
        ok = false;
    }
    catch (std::exception& ex)
    {
        status = Status(Status::STATUSTYPE_FATAL, ex.what());
        ok = false;
    }
    catch (...)
    {
        // handle user unexpected errors
        status = Status(Status::STATUSTYPE_FATAL, "Unexpected exception caught while calling RPCService.request(PVStructure).");
        ok = false;
    }

    // check null result
    if (ok && !result)
    {
        status = Status(Status::STATUSTYPE_FATAL, "RPCService.request(PVStructure) returned null.");
    }
    ChannelRPCRequester::shared_pointer requester = channelRPCRequester.lock();
    if(requester) requester->requestDone(status, getPtrSelf(), result);
}

void epics::pvDatabase::ChannelRPCLocal::processRequest	(	RPCServiceAsync::shared_pointer const &	service,
		PVStructurePtr const &	pvArgument
	)

Definition at line 900 of file channelLocal.cpp.

{
    try
    {
        service->request(pvArgument, getPtrSelf());
    }
    catch (std::exception& ex)
    {
        // handle user unexpected errors
        Status errorStatus(Status::STATUSTYPE_FATAL, ex.what());
        ChannelRPCRequester::shared_pointer requester = channelRPCRequester.lock();
        if(requester) requester->requestDone(errorStatus, getPtrSelf(), PVStructurePtr());
    }
    catch (...)
    {
        // handle user unexpected errors
        Status errorStatus(Status::STATUSTYPE_FATAL,
                           "Unexpected exception caught while calling RPCServiceAsync.request(PVStructure, RPCResponseCallback).");
        ChannelRPCRequester::shared_pointer requester = channelRPCRequester.lock();
        if(requester) requester->requestDone(errorStatus, shared_from_this(), PVStructurePtr());
    }

    // we wait for callback to be called
}

void epics::pvDatabase::ChannelRPCLocal::request ( PVStructurePtr const &  pvArgument )

virtual

Definition at line 928 of file channelLocal.cpp.

{
    PVRecordPtr pvr(pvRecord.lock());
    if(pvr && pvr->getTraceLevel()>0) {
        cout << "ChannelRPCLocal::request " << pvr->getRecordName() << endl;
    }
    RPCService::shared_pointer rpcService =
            std::tr1::dynamic_pointer_cast<RPCService>(service);
    if (rpcService)
    {
        processRequest(rpcService, pvArgument);
        return;
    }

    RPCServiceAsync::shared_pointer rpcServiceAsync =
            std::tr1::dynamic_pointer_cast<RPCServiceAsync>(service);
    if (rpcServiceAsync)
    {
         processRequest(rpcServiceAsync, pvArgument);
         return;
    }
}

virtual void epics::pvDatabase::ChannelRPCLocal::requestDone ( Status const &  status, PVStructurePtr const &  result  )

inlinevirtual

Definition at line 792 of file channelLocal.cpp.

    {
        ChannelRPCRequester::shared_pointer requester = channelRPCRequester.lock();
        if(!requester) return;
        requester->requestDone(status, getPtrSelf(), result);
    }

virtual void epics::pvDatabase::ChannelRPCLocal::unlock ( )

inlinevirtual

Reimplemented from epics::pvAccess::Lockable.

Definition at line 807 of file channelLocal.cpp.

{}

---

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

• modules/pvDatabase/src/pvAccess/channelLocal.cpp