#include <qcepintegrateddataqueue.h>

Inheritance diagram for QcepIntegratedDataQueue:

Collaboration diagram for QcepIntegratedDataQueue:

Public Member Functions
	QcepIntegratedDataQueue (QString name)

	~QcepIntegratedDataQueue ()

QcepIntegratedDataPtr	dequeue ()

void	enqueue (QcepIntegratedDataPtr data)

int	size () const

QcepIntegratedDataPtr	operator[] (int n)

void	deallocate ()

Private Attributes
QReadWriteLock	m_Lock

QQueue< QcepIntegratedDataPtr >	m_Queue

QString	m_Name

int	m_Debug

Detailed Description

Definition at line 10 of file qcepintegrateddataqueue.h.

Constructor & Destructor Documentation

QcepIntegratedDataQueue::QcepIntegratedDataQueue ( QString name )

Definition at line 6 of file qcepintegrateddataqueue.cpp.

                                                              :
   m_Name(name)
 {
 }

QcepIntegratedDataQueue::~QcepIntegratedDataQueue ( )

Definition at line 11 of file qcepintegrateddataqueue.cpp.

References deallocate(), DEBUG_QUEUES, g_Application, HEXARG, m_Name, m_Queue, QcepApplication::printMessage(), and qcepDebug().

 {
   if (g_Application && qcepDebug(DEBUG_QUEUES)) {
     g_Application->printMessage(tr("QcepIntegratedDataQueue::~QcepIntegratedDataQueue(%1) %2 begin [contains %3]")
                       .arg(m_Name).HEXARG(this).arg(m_Queue.size()));
   }
 
   deallocate();
 
   if (g_Application && qcepDebug(DEBUG_QUEUES)) {
     g_Application->printMessage(tr("QcepIntegratedDataQueue::~QcepIntegratedDataQueue(%1) %2 end [contains %3]")
                       .arg(m_Name).HEXARG(this).arg(m_Queue.size()));
   }
 }

Here is the call graph for this function:

Member Function Documentation

void QcepIntegratedDataQueue::deallocate ( )

Definition at line 85 of file qcepintegrateddataqueue.cpp.

References DEBUG_QUEUES, g_Application, HEXARG, m_Queue, QcepApplication::printMessage(), and qcepDebug().

Referenced by ~QcepIntegratedDataQueue().

 {
   while (!m_Queue.isEmpty()) {
     QcepIntegratedDataPtr img = m_Queue.dequeue();
     if (g_Application && qcepDebug(DEBUG_QUEUES)) {
       g_Application->printMessage(tr("Deallocate %1").HEXARG(img.data()));
     }
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

QcepIntegratedDataPtr QcepIntegratedDataQueue::dequeue ( )

Definition at line 26 of file qcepintegrateddataqueue.cpp.

References DEBUG_QUEUES, g_Application, HEXARG, m_Lock, m_Name, m_Queue, QcepApplication::printMessage(), and qcepDebug().

 {
   QWriteLocker lock(&m_Lock);
 
   if (m_Queue.isEmpty()) {
     if (g_Application && qcepDebug(DEBUG_QUEUES)) {
       g_Application->printMessage(tr("QcepIntegratedDataQueue::dequeue() = NULL from %1").arg(m_Name));
     }
 
     return QcepIntegratedDataPtr(NULL);
   } else {
     QcepIntegratedDataPtr res = m_Queue.dequeue();
 
     if (g_Application && qcepDebug(DEBUG_QUEUES)) {
       g_Application->printMessage(tr("QcepIntegratedDataQueue::dequeue() = %1 from %2, leaving %3")
                         .HEXARG(res.data()).arg(m_Name).arg(m_Queue.size()));
     }
 
     return res;
   }
 }

Here is the call graph for this function:

void QcepIntegratedDataQueue::enqueue ( QcepIntegratedDataPtr data )

Definition at line 48 of file qcepintegrateddataqueue.cpp.

References DEBUG_QUEUES, g_Application, HEXARG, m_Lock, m_Name, m_Queue, QcepApplication::printMessage(), and qcepDebug().

 {
   QWriteLocker lock(&m_Lock);
 
   if (g_Application && qcepDebug(DEBUG_QUEUES)) {
     g_Application->printMessage(tr("QcepIntegratedDataQueue::enqueue(%1) into %2, starting with %3")
                       .HEXARG(data.data()).arg(m_Name).arg(m_Queue.size()));
   }
 
   if (data) {
     m_Queue.enqueue(data);
   }
 }

Here is the call graph for this function:

QcepIntegratedDataPtr QcepIntegratedDataQueue::operator[] ( int n )

Definition at line 74 of file qcepintegrateddataqueue.cpp.

References m_Lock, and m_Queue.

 {
   QReadLocker lock(&m_Lock);
 
   if (n < 0 || n >= m_Queue.size()) {
     return QcepIntegratedDataPtr(NULL);
   } else {
     return m_Queue[n];
   }
 }

int QcepIntegratedDataQueue::size ( ) const

Definition at line 62 of file qcepintegrateddataqueue.cpp.

References DEBUG_QUEUES, g_Application, m_Lock, m_Name, m_Queue, QcepApplication::printMessage(), and qcepDebug().

 {
   QReadLocker lock(&m_Lock);
 
   if (g_Application && qcepDebug(DEBUG_QUEUES)) {
     g_Application->printMessage(tr("QcepIntegratedDataQueue::size() = %1 for %2")
                       .arg(m_Queue.size()).arg(m_Name));
   }
 
   return m_Queue.size();
 }