epics::pvDatabase::ChannelProcessLocal Class Reference

Inheritance diagram for epics::pvDatabase::ChannelProcessLocal:

Collaboration diagram for epics::pvDatabase::ChannelProcessLocal:

Public Member Functions
	POINTER_DEFINITIONS (ChannelProcessLocal)
virtual	~ChannelProcessLocal ()
virtual void	destroy ()
virtual void	process ()
virtual std::tr1::shared_ptr< Channel >	getChannel ()
virtual void	cancel ()
virtual void	lock ()
virtual void	unlock ()
virtual void	lastRequest ()
Public Member Functions inherited from epics::pvAccess::ChannelProcess
	POINTER_DEFINITIONS (ChannelProcess)
virtual	~ChannelProcess ()
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 ()

Static Public Member Functions
static ChannelProcessLocalPtr	create (ChannelLocalPtr const &channelLocal, ChannelProcessRequester::shared_pointer const &channelProcessRequester, PVStructurePtr const &pvRequest, PVRecordPtr const &pvRecord)

Additional Inherited Members
Public Types inherited from epics::pvAccess::ChannelProcess
typedef ChannelProcessRequester	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 76 of file channelLocal.cpp.

Constructor & Destructor Documentation

epics::pvDatabase::ChannelProcessLocal::~ChannelProcessLocal ( )

virtual

Definition at line 157 of file channelLocal.cpp.

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

Member Function Documentation

virtual void epics::pvDatabase::ChannelProcessLocal::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 91 of file channelLocal.cpp.

{}

ChannelProcessLocalPtr epics::pvDatabase::ChannelProcessLocal::create ( ChannelLocalPtr const &  channelLocal, ChannelProcessRequester::shared_pointer const &  channelProcessRequester, PVStructurePtr const &  pvRequest, PVRecordPtr const &  pvRecord  )

static

Definition at line 119 of file channelLocal.cpp.

{
    PVFieldPtr pvField;
    PVStructurePtr pvOptions;
    int nProcess = 1;
    if(pvRequest) pvField = pvRequest->getSubField("record._options");
    if(pvField) {
        pvOptions = static_pointer_cast<PVStructure>(pvField);
        pvField = pvOptions->getSubField("nProcess");
        if(pvField) {
            PVStringPtr pvString = pvOptions->getSubField<PVString>("nProcess");
            if(pvString) {
                int size=0;
                std::stringstream ss;
                ss << pvString->get();
                ss >> size;
                nProcess = size;
            }
        }
    }
    ChannelProcessLocalPtr process(new ChannelProcessLocal(
        channelLocal,
        channelProcessRequester,
        pvRecord,
        nProcess));
    if(pvRecord->getTraceLevel()>0)
    {
        cout << "ChannelProcessLocal::create";
        cout << " recordName " << pvRecord->getRecordName() << endl;
    }
    channelProcessRequester->channelProcessConnect(Status::Ok, process);
    return process;
}

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

inlinevirtual

Destroy this instance.

Implements epics::pvAccess::Destroyable.

Definition at line 83 of file channelLocal.cpp.

{} // DEPRECATED

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

virtual

Get a channel instance this request belongs to.

Returns

the channel instance.

Implements epics::pvAccess::ChannelRequest.

Definition at line 162 of file channelLocal.cpp.

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

virtual void epics::pvDatabase::ChannelProcessLocal::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 94 of file channelLocal.cpp.

{}

void epics::pvDatabase::ChannelProcessLocal::lock ( )

virtual

Reimplemented from epics::pvAccess::Lockable.

Definition at line 168 of file channelLocal.cpp.

{
    PVRecordPtr pvr(pvRecord.lock());
    if(!pvr) throw std::logic_error("pvRecord is deleted");
    pvr->lock();
}

epics::pvDatabase::ChannelProcessLocal::POINTER_DEFINITIONS

(

ChannelProcessLocal

)

void epics::pvDatabase::ChannelProcessLocal::process ( )

virtual

Issue a process request. Completion status is reported by calling ChannelProcessRequester.processDone() callback.

Implements epics::pvAccess::ChannelProcess.

Definition at line 181 of file channelLocal.cpp.

{
    ChannelProcessRequester::shared_pointer requester = channelProcessRequester.lock();
    if(!requester) return;
    PVRecordPtr pvr(pvRecord.lock());
    if(!pvr) throw std::logic_error("pvRecord is deleted");
    if(pvr->getTraceLevel()>1)
    {
        cout << "ChannelProcessLocal::process";
        cout << " nProcess " << nProcess << endl;
    }
    try {
        for(int i=0; i< nProcess; i++) {
            epicsGuard <PVRecord> guard(*pvr);
            pvr->beginGroupPut();
            pvr->process();
            pvr->endGroupPut();
        }
        requester->processDone(Status::Ok,getPtrSelf());
    } catch(std::exception& ex) {
        Status status = Status(Status::STATUSTYPE_FATAL, ex.what());
        requester->processDone(status,getPtrSelf());
    }
}

void epics::pvDatabase::ChannelProcessLocal::unlock ( )

virtual

Reimplemented from epics::pvAccess::Lockable.

Definition at line 174 of file channelLocal.cpp.

{
    PVRecordPtr pvr(pvRecord.lock());
    if(!pvr) throw std::logic_error("pvRecord is deleted");
    pvr->unlock();
}

---

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

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