epics::pvAccess::ca::CACMonitorQueue Class Reference

Inheritance diagram for epics::pvAccess::ca::CACMonitorQueue:

Collaboration diagram for epics::pvAccess::ca::CACMonitorQueue:

Public Member Functions
	POINTER_DEFINITIONS (CACMonitorQueue)
	CACMonitorQueue (int32 queueSize)
	~CACMonitorQueue ()
void	start ()
void	stop ()
bool	event (const PVStructurePtr &pvStructure, const MonitorElementPtr &activeElement)
MonitorElementPtr	poll ()
void	release (MonitorElementPtr const &monitorElement)

Detailed Description

Definition at line 747 of file caChannel.cpp.

Constructor & Destructor Documentation

epics::pvAccess::ca::CACMonitorQueue::CACMonitorQueue ( int32  queueSize )

inline

Definition at line 759 of file caChannel.cpp.

     : queueSize(queueSize),
       isStarted(false)
     {}

epics::pvAccess::ca::CACMonitorQueue::~CACMonitorQueue ( )

inline

Definition at line 764 of file caChannel.cpp.

     {
     }

Member Function Documentation

bool epics::pvAccess::ca::CACMonitorQueue::event ( const PVStructurePtr &  pvStructure, const MonitorElementPtr &  activeElement  )

inline

Definition at line 780 of file caChannel.cpp.

     {
         Lock guard(mutex);
         if(!isStarted) return false;
         if(monitorElementQueue.size()==queueSize) return false;
         PVStructure::shared_pointer pvs =
              getPVDataCreate()->createPVStructure(pvStructure);
         MonitorElementPtr monitorElement(new MonitorElement(pvs));
         *(monitorElement->changedBitSet) = *(activeElement->changedBitSet);
         *(monitorElement->overrunBitSet) = *(activeElement->overrunBitSet);
         monitorElementQueue.push(monitorElement);
         return true;
     }

epics::pvAccess::ca::CACMonitorQueue::POINTER_DEFINITIONS

(

CACMonitorQueue

)

MonitorElementPtr epics::pvAccess::ca::CACMonitorQueue::poll ( )

inline

Definition at line 795 of file caChannel.cpp.

     {
          Lock guard(mutex);
          if(!isStarted) return MonitorElementPtr();
          if(monitorElementQueue.empty()) return MonitorElementPtr();
          MonitorElementPtr retval = monitorElementQueue.front();
          return retval;
     }

void epics::pvAccess::ca::CACMonitorQueue::release ( MonitorElementPtr const &  monitorElement )

inline

Definition at line 803 of file caChannel.cpp.

     {
         Lock guard(mutex);
         if(!isStarted) return;
         if(monitorElementQueue.empty()) {
              string mess("CAChannelMonitor::release client error calling release ");
              throw  std::runtime_error(mess);
         }
         monitorElementQueue.pop();
     }

void epics::pvAccess::ca::CACMonitorQueue::start ( )

inline

Definition at line 767 of file caChannel.cpp.

     {
         Lock guard(mutex);
         while(!monitorElementQueue.empty()) monitorElementQueue.pop();
         isStarted = true;
     }

void epics::pvAccess::ca::CACMonitorQueue::stop ( )

inline

Definition at line 773 of file caChannel.cpp.

     {
         Lock guard(mutex);
         while(!monitorElementQueue.empty()) monitorElementQueue.pop();
         isStarted = false;
     }

---

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

• modules/pvAccess/src/ca/caChannel.cpp