QxrdDataProcessorThread Class Reference

#include <qxrddataprocessorthread.h>

Inheritance diagram for QxrdDataProcessorThread:

Collaboration diagram for QxrdDataProcessorThread:

Public Member Functions
	QxrdDataProcessorThread (QcepSettingsSaverWPtr saver, QxrdExperimentWPtr doc, QxrdAcquisitionWPtr acq, QcepAllocatorWPtr allocator, QxrdFileSaverWPtr filesaver)
	~QxrdDataProcessorThread ()
void	shutdown ()
QxrdDataProcessorPtr	dataProcessor () const
Public Member Functions inherited from QxrdThread
	QxrdThread (QObject *parent=0)
Public Member Functions inherited from QcepThread
	QcepThread (QObject *parent=0)

Protected Member Functions
void	run ()

Private Attributes
QcepAllocatorWPtr	m_Allocator
QxrdFileSaverWPtr	m_FileSaver
QxrdAcquisitionWPtr	m_Acquisition
QxrdExperimentWPtr	m_Experiment
QcepSettingsSaverWPtr	m_Saver
QxrdDataProcessorPtr	m_DataProcessor

Additional Inherited Members
Static Public Member Functions inherited from QcepThread
static void	msleep (long unsigned int)
Protected Attributes inherited from QcepThread
QMutex	m_Mutex

Detailed Description

Definition at line 13 of file qxrddataprocessorthread.h.

Constructor & Destructor Documentation

QxrdDataProcessorThread::QxrdDataProcessorThread	(	QcepSettingsSaverWPtr	saver,
		QxrdExperimentWPtr	doc,
		QxrdAcquisitionWPtr	acq,
		QcepAllocatorWPtr	allocator,
		QxrdFileSaverWPtr	filesaver
	)

Definition at line 9 of file qxrddataprocessorthread.cpp.

References DEBUG_CONSTRUCTORS, and qcepDebug().

  : QxrdThread(),
    m_Allocator(allocator),
    m_FileSaver(filesaver),
    m_Acquisition(acq),
    m_Experiment(doc),
    m_Saver(saver),
    m_DataProcessor(NULL)
{
  if (qcepDebug(DEBUG_CONSTRUCTORS)) {
    printf("QxrdDataProcessorThread::QxrdDataProcessorThread(%p)\n", this);
  }

  setObjectName("processor");
}

Here is the call graph for this function:

QxrdDataProcessorThread::~QxrdDataProcessorThread

(

)

Definition at line 29 of file qxrddataprocessorthread.cpp.

References DEBUG_CONSTRUCTORS, qcepDebug(), and shutdown().

{
  shutdown();

  if (qcepDebug(DEBUG_CONSTRUCTORS)) {
    printf("QxrdDataProcessorThread::~QxrdDataProcessorThread(%p)\n", this);
  }
}

Here is the call graph for this function:

Member Function Documentation

QxrdDataProcessorPtr QxrdDataProcessorThread::dataProcessor

(

)

const

Definition at line 81 of file qxrddataprocessorthread.cpp.

References m_DataProcessor, and QcepThread::m_Mutex.

{
  while (isRunning()) {
    {
      QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

      if (m_DataProcessor) return m_DataProcessor;
    }

    QThread::msleep(50);
  }

  return QxrdDataProcessorPtr();
}

void QxrdDataProcessorThread::run ( )

protected

Definition at line 38 of file qxrddataprocessorthread.cpp.

References DEBUG_THREADS, m_Acquisition, m_Allocator, m_DataProcessor, m_Experiment, m_FileSaver, QcepThread::m_Mutex, m_Saver, and qcepDebug().

{
  if (qcepDebug(DEBUG_THREADS)) {
    printf("Processor Thread Started\n");
  }

  QxrdDataProcessorPtr p(new QxrdDataProcessor(m_Saver,
                                               m_Experiment,
                                               m_Acquisition,
                                               m_Allocator,
                                               m_FileSaver));

  int rc = -1;

  if (p) {
    p -> initialize();

    m_Mutex.lock();
    m_DataProcessor = p;
    m_Mutex.unlock();

    rc = exec();
  }


  {
    QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);

    m_DataProcessor = QxrdDataProcessorPtr();
  }

  if (qcepDebug(DEBUG_THREADS)) {
    printf("Processor Thread Terminated with rc %d\n", rc);
  }
}

Here is the call graph for this function:

void QxrdDataProcessorThread::shutdown ( )

virtual

Implements QxrdThread.

Definition at line 74 of file qxrddataprocessorthread.cpp.

Referenced by ~QxrdDataProcessorThread().

{
  exit();

  wait();
}

Here is the caller graph for this function:

Member Data Documentation

QxrdAcquisitionWPtr QxrdDataProcessorThread::m_Acquisition

private

Definition at line 36 of file qxrddataprocessorthread.h.

Referenced by run().

QcepAllocatorWPtr QxrdDataProcessorThread::m_Allocator

private

Definition at line 34 of file qxrddataprocessorthread.h.

Referenced by run().

QxrdDataProcessorPtr QxrdDataProcessorThread::m_DataProcessor

private

Definition at line 39 of file qxrddataprocessorthread.h.

Referenced by dataProcessor(), and run().

QxrdExperimentWPtr QxrdDataProcessorThread::m_Experiment

private

Definition at line 37 of file qxrddataprocessorthread.h.

Referenced by run().

QxrdFileSaverWPtr QxrdDataProcessorThread::m_FileSaver

private

Definition at line 35 of file qxrddataprocessorthread.h.

Referenced by run().

QcepSettingsSaverWPtr QxrdDataProcessorThread::m_Saver

private

Definition at line 38 of file qxrddataprocessorthread.h.

Referenced by run().

---

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

• qxrddataprocessorthread.h (Commit a65ccc9... : jennings : 2016-03-15 14:00:18 -0500)
• qxrddataprocessorthread.cpp (Commit a65ccc9... : jennings : 2016-03-15 14:00:18 -0500)