epics::pvDatabase::ChannelPutGetLocal Class Reference

Inheritance diagram for epics::pvDatabase::ChannelPutGetLocal:

Collaboration diagram for epics::pvDatabase::ChannelPutGetLocal:

Public Member Functions
	POINTER_DEFINITIONS (ChannelPutGetLocal)
virtual	~ChannelPutGetLocal ()
virtual void	destroy ()
virtual void	putGet (PVStructurePtr const &pvPutStructure, BitSetPtr const &putBitSet)
virtual void	getPut ()
virtual void	getGet ()
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::ChannelPutGet
	POINTER_DEFINITIONS (ChannelPutGet)
virtual	~ChannelPutGet ()
virtual void	putGet (epics::pvData::PVStructure::shared_pointer const &pvPutStructure, epics::pvData::BitSet::shared_pointer const &putBitSet)=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 ()

Static Public Member Functions
static ChannelPutGetLocalPtr	create (ChannelLocalPtr const &channelLocal, ChannelPutGetRequester::shared_pointer const &channelPutGetRequester, PVStructurePtr const &pvRequest, PVRecordPtr const &pvRecord)

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

Constructor & Destructor Documentation

epics::pvDatabase::ChannelPutGetLocal::~ChannelPutGetLocal ( )

virtual

Definition at line 654 of file channelLocal.cpp.

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

Member Function Documentation

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

{}

ChannelPutGetLocalPtr epics::pvDatabase::ChannelPutGetLocal::create ( ChannelLocalPtr const &  channelLocal, ChannelPutGetRequester::shared_pointer const &  channelPutGetRequester, PVStructurePtr const &  pvRequest, PVRecordPtr const &  pvRecord  )

static

Definition at line 606 of file channelLocal.cpp.

{
    PVCopyPtr pvPutCopy = PVCopy::create(
        pvRecord->getPVRecordStructure()->getPVStructure(),
        pvRequest,
        "putField");
    PVCopyPtr pvGetCopy = PVCopy::create(
        pvRecord->getPVRecordStructure()->getPVStructure(),
        pvRequest,
        "getField");
    if(!pvPutCopy || !pvGetCopy) {
        Status status(
            Status::STATUSTYPE_ERROR,
            "invalid pvRequest");
        ChannelPutGet::shared_pointer channelPutGet;
        channelPutGetRequester->channelPutGetConnect(
            status,
            channelPutGet,
            nullStructure,
            nullStructure);
        ChannelPutGetLocalPtr localPutGet;
        return localPutGet;
    }
    PVStructurePtr pvGetStructure = pvGetCopy->createPVStructure();
    BitSetPtr   getBitSet(new BitSet(pvGetStructure->getNumberFields()));
    ChannelPutGetLocalPtr putGet(new ChannelPutGetLocal(
        getProcess(pvRequest,true),
        channelLocal,
        channelPutGetRequester,
        pvPutCopy,
        pvGetCopy,
        pvGetStructure,
        getBitSet,
        pvRecord));
    if(pvRecord->getTraceLevel()>0)
    {
        cout << "ChannelPutGetLocal::create";
        cout << " recordName " << pvRecord->getRecordName() << endl;
    }
    channelPutGetRequester->channelPutGetConnect(
        Status::Ok, putGet, pvPutCopy->getStructure(),pvGetCopy->getStructure());
    return putGet;
}

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

inlinevirtual

Destroy this instance.

Implements epics::pvAccess::Destroyable.

Definition at line 554 of file channelLocal.cpp.

{} // DEPRECATED

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

virtual

Get a channel instance this request belongs to.

Returns

the channel instance.

Implements epics::pvAccess::ChannelRequest.

Definition at line 659 of file channelLocal.cpp.

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

void epics::pvDatabase::ChannelPutGetLocal::getGet ( )

virtual

Get the get PVStructure. The record will not be processed. Completion status is reported by calling ChannelPutGetRequester.getGetDone() callback.

Implements epics::pvAccess::ChannelPutGet.

Definition at line 735 of file channelLocal.cpp.

{
    ChannelPutGetRequester::shared_pointer requester = channelPutGetRequester.lock();
    if(!requester) return;
    PVRecordPtr pvr(pvRecord.lock());
    if(!pvr) throw std::logic_error("pvRecord is deleted");
    try {
         getBitSet->clear();
         {
             epicsGuard <PVRecord> guard(*pvr);
             pvGetCopy->updateCopySetBitSet(pvGetStructure, getBitSet);
         }
         requester->getGetDone(
             Status::Ok,getPtrSelf(),pvGetStructure,getBitSet);
         if(pvr->getTraceLevel()>1)
         {
             cout << "ChannelPutGetLocal::getGet" << endl;
         }
    } catch(std::exception& ex) {
        Status status = Status(Status::STATUSTYPE_FATAL, ex.what());
        PVStructurePtr pvPutStructure;
        BitSetPtr putBitSet;
        requester->getGetDone(status,getPtrSelf(),pvGetStructure,getBitSet);
    }
}

void epics::pvDatabase::ChannelPutGetLocal::getPut ( )

virtual

Get the put PVStructure. The record will not be processed. Completion status is reported by calling ChannelPutGetRequester.getPutDone() callback.

Implements epics::pvAccess::ChannelPutGet.

Definition at line 708 of file channelLocal.cpp.

{
    ChannelPutGetRequester::shared_pointer requester = channelPutGetRequester.lock();
    if(!requester) return;
    PVRecordPtr pvr(pvRecord.lock());
    if(!pvr) throw std::logic_error("pvRecord is deleted");
    try {
        PVStructurePtr pvPutStructure = pvPutCopy->createPVStructure();
        BitSetPtr putBitSet(new BitSet(pvPutStructure->getNumberFields()));
        {
            epicsGuard <PVRecord> guard(*pvr);
            pvPutCopy->initCopy(pvPutStructure, putBitSet);
        }
        requester->getPutDone(
            Status::Ok,getPtrSelf(),pvPutStructure,putBitSet);
        if(pvr->getTraceLevel()>1)
        {
            cout << "ChannelPutGetLocal::getPut" << endl;
        }
    } catch(std::exception& ex) {
        Status status = Status(Status::STATUSTYPE_FATAL, ex.what());
        PVStructurePtr pvPutStructure;
        BitSetPtr putBitSet;
        requester->getPutDone(status,getPtrSelf(),pvGetStructure,getBitSet);
    }
}

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

{}

void epics::pvDatabase::ChannelPutGetLocal::lock ( )

virtual

Reimplemented from epics::pvAccess::Lockable.

Definition at line 665 of file channelLocal.cpp.

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

epics::pvDatabase::ChannelPutGetLocal::POINTER_DEFINITIONS

(

ChannelPutGetLocal

)

void epics::pvDatabase::ChannelPutGetLocal::putGet ( PVStructurePtr const &  pvPutStructure, BitSetPtr const &  putBitSet  )

virtual

Definition at line 679 of file channelLocal.cpp.

{
    ChannelPutGetRequester::shared_pointer requester = channelPutGetRequester.lock();
    if(!requester) return;
    PVRecordPtr pvr(pvRecord.lock());
    if(!pvr) throw std::logic_error("pvRecord is deleted");
    try {
        {
            epicsGuard <PVRecord> guard(*pvr);
            pvr->beginGroupPut();
            pvPutCopy->updateMaster(pvPutStructure, putBitSet);
            if(callProcess) pvr->process();
            getBitSet->clear();
            pvGetCopy->updateCopySetBitSet(pvGetStructure, getBitSet);
            pvr->endGroupPut();
        }
        requester->putGetDone(
            Status::Ok,getPtrSelf(),pvGetStructure,getBitSet);
        if(pvr->getTraceLevel()>1)
        {
            cout << "ChannelPutGetLocal::putGet" << endl;
        }
    } catch(std::exception& ex) {
        Status status = Status(Status::STATUSTYPE_FATAL, ex.what());
        requester->putGetDone(status,getPtrSelf(),pvGetStructure,getBitSet);
    }
}

void epics::pvDatabase::ChannelPutGetLocal::unlock ( )

virtual

Reimplemented from epics::pvAccess::Lockable.

Definition at line 671 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