#include <qxrdacquisitionextrainputs.h>

Inheritance diagram for QxrdAcquisitionExtraInputs:

Collaboration diagram for QxrdAcquisitionExtraInputs:

Public Slots
void	prepareForAcquisition (QxrdAcquisitionParameterPackWPtr parms)

void	initiate ()

void	reinitiate ()

void	acquire ()

void	logToImage (QcepInt16ImageDataPtr img)

void	finish ()

void	timerDone ()

void	appendChannel (int ch=-1)

void	removeChannel (int ch=-1)

QVector< double >	evaluateChannels ()

double	evaluateChannel (int ch)

QVector< double >	readChannel (int ch)

QVector< double >	readXChannel ()

double	averageChannel (int ch)

double	sumChannel (int ch)

QVector< QxrdAcquisitionExtraInputsChannelPtr >	channels () const

QxrdAcquisitionExtraInputsChannelPtr	channel (int chan) const

Public Slots inherited from QcepObject
virtual void	printLine (QString line)

virtual QString	settingsScript ()

QString	scriptValueLiteral (QVariant v)

Signals
void	newDataAvailable ()

void	channelCountChanged ()

Public Member Functions
	QxrdAcquisitionExtraInputs (QcepSettingsSaverWPtr saver, QxrdExperimentWPtr doc, QxrdAcquisitionWPtr acq)

void	initialize ()

virtual	~QxrdAcquisitionExtraInputs ()

void	setNIDAQPlugin (QxrdNIDAQPluginInterfacePtr nidaqPlugin)

QxrdNIDAQPluginInterfacePtr	nidaqPlugin () const

void	readSettings (QSettings *settings, QString section)

void	writeSettings (QSettings *settings, QString section)

void	printMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const

void	criticalMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const

void	statusMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const

Public Member Functions inherited from QcepObject
	QcepObject (QString name, QcepObject *parent)

virtual	~QcepObject ()

QString	get_Name () const

void	set_Name (QString name)

Properties
bool	enabled

bool	skipping

double	sampleRate

double	acquireDelay

double	exposureTime

QString	deviceName

Properties inherited from QcepObject
QString	name

Private Attributes
QMutex	m_Mutex

QxrdExperimentWPtr	m_Experiment

QxrdAcquisitionWPtr	m_Acquisition

QcepSettingsSaverWPtr	m_Saver

QVector< QxrdAcquisitionExtraInputsChannelPtr >	m_Channels

QxrdNIDAQPluginInterfacePtr	m_NIDAQPlugin

QVector< QVector< double > >	m_ChannelData

Additional Inherited Members
Static Public Member Functions inherited from QcepObject
static int	allocatedObjects ()

static int	deletedObjects ()

static QSet< QcepObject * >	allocatedObjectsSet ()

static QString	addSlashes (QString str)

Detailed Description

Definition at line 19 of file qxrdacquisitionextrainputs.h.

Constructor & Destructor Documentation

QxrdAcquisitionExtraInputs::QxrdAcquisitionExtraInputs	(	QcepSettingsSaverWPtr	saver,
		QxrdExperimentWPtr	doc,
		QxrdAcquisitionWPtr	acq
	)

explicit

Definition at line 13 of file qxrdacquisitionextrainputs.cpp.

References DEBUG_CONSTRUCTORS, m_Acquisition, m_NIDAQPlugin, qcepDebug(), reinitiate(), and QcepDoubleProperty::valueChanged().

                                                                                                                                    :
   QcepObject("extraInputs", NULL),
   m_Enabled(QcepSettingsSaverPtr(), this, "enabled", 0, "Extra Inputs Enabled?"),
   m_Skipping(QcepSettingsSaverPtr(), this, "skipping", 0, "Skipping initial readout?"),
   m_SampleRate(saver, this, "sampleRate", 1000.0, "Sampling Rate for Extra Inputs"),
   m_AcquireDelay(saver, this, "acquireDelay", 0.107, "Delay between exposure end and Image available in QXRD"),
   m_ExposureTime(QcepSettingsSaverPtr(), this, "exposureTime", 0.107, "Exposure time (in seconds)"),
   m_DeviceName(saver, this, "deviceName", "", "NI-DAQ Device Name"),
   m_Experiment(doc),
   m_Acquisition(acq),
   m_Saver(saver),
   m_Channels(),
   m_NIDAQPlugin()
 {
   if (qcepDebug(DEBUG_CONSTRUCTORS)) {
     printf("QxrdAcquisitionExtraInputs::QxrdAcquisitionExtraInputs(%p)\n", this);
   }
 
   QxrdAcquisitionPtr acqp(m_Acquisition);
 
   if (acqp) {
     m_NIDAQPlugin = acqp->nidaqPlugin();
   }
 
   connect(prop_SampleRate(), &QcepDoubleProperty::valueChanged,
           this, &QxrdAcquisitionExtraInputs::reinitiate);
 
   if (acqp) {
     connect(acqp->prop_ExposureTime(), &QcepDoubleProperty::valueChanged,
             this, &QxrdAcquisitionExtraInputs::reinitiate);
   }
 }

Here is the call graph for this function:

QxrdAcquisitionExtraInputs::~QxrdAcquisitionExtraInputs ( )

virtual

Definition at line 50 of file qxrdacquisitionextrainputs.cpp.

References DEBUG_CONSTRUCTORS, and qcepDebug().

 {
 #ifndef QT_NO_DEBUG
   printf("Deleting acquisition extra inputs\n");
 #endif
 
   if (qcepDebug(DEBUG_CONSTRUCTORS)) {
     printf("QxrdAcquisitionExtraInputs::~QxrdAcquisitionExtraInputs(%p)\n", this);
   }
 }

Here is the call graph for this function:

Member Function Documentation

void QxrdAcquisitionExtraInputs::acquire ( )

slot

Definition at line 260 of file qxrdacquisitionextrainputs.cpp.

References evaluateChannel(), m_Acquisition, m_Channels, m_NIDAQPlugin, and newDataAvailable().

 {
   if (get_Enabled()) {
     if (!get_Skipping()) {
       QxrdAcquisitionPtr acq(m_Acquisition);
 
       if (acq && m_NIDAQPlugin) {
         m_NIDAQPlugin->readContinuousInput();
       }
 
       foreach (QxrdAcquisitionExtraInputsChannelPtr chanp, m_Channels) {
         if (chanp && chanp->get_Enabled()) {
           chanp -> set_Value(
                 chanp -> evaluateChannel());
 
           if (acq && chanp->get_Triggered()) {
             acq->set_Triggered(true);
           }
         }
       }
 
       emit newDataAvailable();
     }
   }
 }

Here is the call graph for this function:

void QxrdAcquisitionExtraInputs::appendChannel ( int ch = -1 )

slot

Definition at line 227 of file qxrdacquisitionextrainputs.cpp.

References channelCountChanged(), m_Channels, m_Experiment, m_Saver, reinitiate(), and QxrdAcquisitionExtraInputsChannel::reinitiateNeeded().

Referenced by readSettings().

 {
   QxrdAcquisitionExtraInputsChannel *chan = 0;
   int n = (ch < 0 ? m_Channels.size() : ch+1);
 
   m_Channels.insert(n,
                     QxrdAcquisitionExtraInputsChannelPtr(
                         chan = new QxrdAcquisitionExtraInputsChannel(n, m_Saver, m_Experiment, sharedFromThis())));
 
   connect(chan, &QxrdAcquisitionExtraInputsChannel::reinitiateNeeded, this, &QxrdAcquisitionExtraInputs::reinitiate);
 
   QcepSettingsSaverPtr saver(m_Saver);
 
   if (saver) {
       saver->changed();
   }
 
   emit channelCountChanged();
 }

Here is the call graph for this function:

Here is the caller graph for this function:

double QxrdAcquisitionExtraInputs::averageChannel ( int ch )

slot

Definition at line 366 of file qxrdacquisitionextrainputs.cpp.

References channel().

 {
   QxrdAcquisitionExtraInputsChannelPtr chanp = channel(ch);
 
   if (chanp) {
     return chanp->averageChannel();
   } else {
     return 0;
   }
 }

Here is the call graph for this function:

QxrdAcquisitionExtraInputsChannelPtr QxrdAcquisitionExtraInputs::channel ( int chan ) const

slot

Definition at line 222 of file qxrdacquisitionextrainputs.cpp.

References m_Channels.

Referenced by averageChannel(), evaluateChannel(), evaluateChannels(), readChannel(), readSettings(), readXChannel(), and writeSettings().

 {
   return m_Channels.value(chan);
 }

Here is the caller graph for this function:

void QxrdAcquisitionExtraInputs::channelCountChanged ( )

signal

Referenced by appendChannel(), QxrdAcquisition::initialize(), and removeChannel().

Here is the caller graph for this function:

QVector< QxrdAcquisitionExtraInputsChannelPtr > QxrdAcquisitionExtraInputs::channels ( ) const

slot

Definition at line 217 of file qxrdacquisitionextrainputs.cpp.

References m_Channels.

 {
   return m_Channels;
 }

void QxrdAcquisitionExtraInputs::criticalMessage	(	QString	msg,
		QDateTime	ts = `QDateTime::currentDateTime()`
	)		const

virtual

Reimplemented from QcepObject.

Definition at line 133 of file qxrdacquisitionextrainputs.cpp.

References m_Acquisition.

 {
   QxrdAcquisitionPtr acq(m_Acquisition);
 
   if (acq) {
     acq->criticalMessage(msg, ts);
   }
 }

double QxrdAcquisitionExtraInputs::evaluateChannel ( int ch )

slot

Definition at line 325 of file qxrdacquisitionextrainputs.cpp.

References channel().

Referenced by acquire().

 {
   QxrdAcquisitionExtraInputsChannelPtr chanp = channel(ch);
 
   if (chanp) {
     return chanp->evaluateChannel();
   } else {
     return 0;
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

QVector< double > QxrdAcquisitionExtraInputs::evaluateChannels ( )

slot

Definition at line 304 of file qxrdacquisitionextrainputs.cpp.

References channel(), DEBUG_EXTRAINPUTS, m_Channels, printMessage(), and qcepDebug().

Referenced by logToImage().

 {
   QVector<double> res;
 
   for(int i=0; i<m_Channels.count(); i++) {
     QxrdAcquisitionExtraInputsChannelPtr chanp = channel(i);
 
     if (chanp && chanp->get_Enabled()) {
       double val = chanp->evaluateChannel();
 
       if (qcepDebug(DEBUG_EXTRAINPUTS)) {
         printMessage(tr("QxrdAcquisitionExtraInputs::evaluateChannels [%1] = %2").arg(i).arg(val));
       }
 
       res.append(val);
     }
   }
 
   return res;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdAcquisitionExtraInputs::finish ( )

slot

Definition at line 293 of file qxrdacquisitionextrainputs.cpp.

References m_Acquisition, and m_NIDAQPlugin.

 {
   QxrdAcquisitionPtr acq(m_Acquisition);
 
   if (acq && m_NIDAQPlugin) {
     m_NIDAQPlugin->finishContinuousInput();
   }
 
   set_Enabled(false);
 }

void QxrdAcquisitionExtraInputs::initialize ( )

Definition at line 46 of file qxrdacquisitionextrainputs.cpp.

47 {

48 }

void QxrdAcquisitionExtraInputs::initiate ( )

slot

Definition at line 158 of file qxrdacquisitionextrainputs.cpp.

References m_Acquisition, m_Channels, m_NIDAQPlugin, and timerDone().

Referenced by prepareForAcquisition(), readSettings(), and reinitiate().

 {
   QxrdAcquisitionPtr acq(m_Acquisition);
 
   if (acq && m_NIDAQPlugin) {
     QStringList uniqueChannels;
     QVector<double> channelMinimum, channelMaximum;
 
     foreach (QxrdAcquisitionExtraInputsChannelPtr chanp, m_Channels) {
       if (chanp && chanp->get_Enabled()) {
         QString channame = chanp->get_ChannelName();
         double chanmin = chanp->get_Min();
         double chanmax = chanp->get_Max();
 
         int physChan = uniqueChannels.indexOf(channame);
 
         if (physChan < 0) {
           uniqueChannels.append(channame);
           physChan = uniqueChannels.count() - 1;
           channelMinimum.append(chanmin);
           channelMaximum.append(chanmax);
         } else {
           channelMinimum[physChan] = qMin(channelMinimum[physChan], chanmin);
           channelMaximum[physChan] = qMin(channelMaximum[physChan], chanmax);
         }
 
         chanp->set_PhysicalChannel(physChan);
       }
     }
 
     if (m_NIDAQPlugin->prepareContinuousInput(get_SampleRate(),
                                               get_AcquireDelay(),
                                               acq->get_ExposureTime(),
                                               uniqueChannels,
                                               channelMinimum,
                                               channelMaximum) == 0) {
       set_Skipping(true);
       set_ExposureTime(acq->get_ExposureTime());
 
       QTimer::singleShot(1000*(get_AcquireDelay() + acq->get_ExposureTime() + 1.0),
                          this, SLOT(timerDone()));
 
       set_Enabled(true);
     }
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdAcquisitionExtraInputs::logToImage ( QcepInt16ImageDataPtr img )

slot

Definition at line 286 of file qxrdacquisitionextrainputs.cpp.

References evaluateChannels().

 {
   if (get_Enabled() && img) {
     img->set_ExtraInputs(evaluateChannels().toList());
   }
 }

Here is the call graph for this function:

void QxrdAcquisitionExtraInputs::newDataAvailable ( )

signal

Referenced by acquire(), and QxrdAcquisitionExtraInputsDialog::QxrdAcquisitionExtraInputsDialog().

Here is the caller graph for this function:

QxrdNIDAQPluginInterfacePtr QxrdAcquisitionExtraInputs::nidaqPlugin ( ) const

Definition at line 66 of file qxrdacquisitionextrainputs.cpp.

References m_NIDAQPlugin.

Referenced by setNIDAQPlugin().

 {
   return m_NIDAQPlugin;
 }

Here is the caller graph for this function:

void QxrdAcquisitionExtraInputs::prepareForAcquisition ( QxrdAcquisitionParameterPackWPtr parms )

slot

Definition at line 151 of file qxrdacquisitionextrainputs.cpp.

References initiate().

 {
   if (!get_Enabled()) {
     initiate();
   }
 }

Here is the call graph for this function:

void QxrdAcquisitionExtraInputs::printMessage	(	QString	msg,
		QDateTime	ts = `QDateTime::currentDateTime()`
	)		const

virtual

Reimplemented from QcepObject.

Definition at line 124 of file qxrdacquisitionextrainputs.cpp.

References m_Acquisition.

Referenced by evaluateChannels().

 {
   QxrdAcquisitionPtr acq(m_Acquisition);
 
   if (acq) {
     acq->printMessage(msg, ts);
   }
 }

Here is the caller graph for this function:

QVector< double > QxrdAcquisitionExtraInputs::readChannel ( int ch )

slot

Definition at line 355 of file qxrdacquisitionextrainputs.cpp.

References channel().

Referenced by sumChannel().

 {
   QxrdAcquisitionExtraInputsChannelPtr chanp = channel(ch);
 
   if (chanp) {
     return chanp->readChannel();
   } else {
     return QVector<double>();
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdAcquisitionExtraInputs::readSettings	(	QSettings *	settings,
		QString	section
	)

virtual

Reimplemented from QcepObject.

Definition at line 71 of file qxrdacquisitionextrainputs.cpp.

References appendChannel(), channel(), initiate(), m_Channels, m_Mutex, QcepObject::readSettings(), and removeChannel().

 {
   QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);
 
   QcepObject::readSettings(settings, section);
 
   int n = settings->beginReadArray(section+"/channels");
 
   while (m_Channels.count() > n) {
     removeChannel();
   }
 
   while (m_Channels.count() < n) {
     appendChannel();
   }
 
   for (int i=0; i<n; i++) {
     settings->setArrayIndex(i);
 
     QxrdAcquisitionExtraInputsChannelPtr chan = channel(i);
 
     if (chan) {
       chan->readSettings(settings, "");
     }
   }
 
   settings->endArray();
 
   initiate();
 }

Here is the call graph for this function:

QVector< double > QxrdAcquisitionExtraInputs::readXChannel ( )

slot

Definition at line 336 of file qxrdacquisitionextrainputs.cpp.

References channel().

 {
   QxrdAcquisitionExtraInputsChannelPtr chanp = channel(0);
 
   if (chanp) {
     QVector<double> res(chanp->readChannel().count());
     double offset = get_AcquireDelay();
     double rate   = get_SampleRate();
 
     for (int i=0; i<res.count(); i++) {
       res[i] = i/rate - offset;
     }
 
     return res;
   } else {
     return QVector<double>();
   }
 }

Here is the call graph for this function:

void QxrdAcquisitionExtraInputs::reinitiate ( )

slot

Definition at line 205 of file qxrdacquisitionextrainputs.cpp.

References initiate().

Referenced by appendChannel(), and QxrdAcquisitionExtraInputs().

 {
   if (get_Enabled()) {
     initiate();
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdAcquisitionExtraInputs::removeChannel ( int ch = -1 )

slot

Definition at line 247 of file qxrdacquisitionextrainputs.cpp.

References channelCountChanged(), m_Channels, and m_Saver.

Referenced by readSettings().

 {
   m_Channels.remove((ch < 0 ? m_Channels.size()-1 : ch));
 
   QcepSettingsSaverPtr saver(m_Saver);
 
   if (saver) {
       saver->changed();
   }
 
   emit channelCountChanged();
 }

Here is the caller graph for this function:

void QxrdAcquisitionExtraInputs::setNIDAQPlugin ( QxrdNIDAQPluginInterfacePtr nidaqPlugin )

Definition at line 61 of file qxrdacquisitionextrainputs.cpp.

References m_NIDAQPlugin, and nidaqPlugin().

 {
   m_NIDAQPlugin = nidaqPlugin;
 }

Here is the call graph for this function:

void QxrdAcquisitionExtraInputs::statusMessage	(	QString	msg,
		QDateTime	ts = `QDateTime::currentDateTime()`
	)		const

virtual

Reimplemented from QcepObject.

Definition at line 142 of file qxrdacquisitionextrainputs.cpp.

References m_Acquisition.

 {
   QxrdAcquisitionPtr acq(m_Acquisition);
 
   if (acq) {
     acq->statusMessage(msg, ts);
   }
 }

double QxrdAcquisitionExtraInputs::sumChannel ( int ch )

slot

Definition at line 377 of file qxrdacquisitionextrainputs.cpp.

References readChannel().

 {
   QVector<double> res = readChannel(ch);
 
   double n=res.count(), sum=0;
 
   for(int i=0; i<n; i++) {
     sum += res[i];
   }
 
   return sum;
 }

Here is the call graph for this function:

void QxrdAcquisitionExtraInputs::timerDone ( )

slot

Definition at line 212 of file qxrdacquisitionextrainputs.cpp.

Referenced by initiate().

 {
   set_Skipping(false);
 }

Here is the caller graph for this function:

void QxrdAcquisitionExtraInputs::writeSettings	(	QSettings *	settings,
		QString	section
	)

virtual

Reimplemented from QcepObject.

Definition at line 102 of file qxrdacquisitionextrainputs.cpp.

References channel(), m_Channels, m_Mutex, and QcepObject::writeSettings().

 {
   QcepMutexLocker lock(__FILE__, __LINE__, &m_Mutex);
 
   QcepObject::writeSettings(settings, section);
 
   settings->beginWriteArray(section+"/channels");
 
   int n = m_Channels.count();
 
   for (int i=0; i<n; i++) {
     settings->setArrayIndex(i);
     QxrdAcquisitionExtraInputsChannelPtr chan = channel(i);
 
     if (chan) {
       chan->writeSettings(settings, "");
     }
   }
 
   settings->endArray();
 }