QxrdNIDAQPlugin Class Reference

#include <qxrdnidaqplugin.h>

Inheritance diagram for QxrdNIDAQPlugin:

Collaboration diagram for QxrdNIDAQPlugin:

Public Slots
void	printMessage (QString msg)
void	setAnalogWaveform (QString chan, double rate, double wfm[], int size)
void	setAnalogOutput (int chan, double val)
double	getAnalogInput (int chan)
void	triggerAnalogWaveform ()
void	pulseOutput ()
double	count (int chan, double time)
int	configCounters (QStringList chans)
QVector< double >	readCounters ()
QStringList	deviceNames ()
QString	deviceType (QString device)
int	deviceIsSimulated (QString device)
QStringList	deviceAIChannels (QString device)
QStringList	deviceAOChannels (QString device)
QStringList	deviceDIPorts (QString device)
QStringList	deviceDILines (QString port)
QStringList	deviceDOPorts (QString device)
QStringList	deviceDOLines (QString port)
QStringList	deviceCIChannels (QString device)
QStringList	deviceCOChannels (QString device)
double	getAnalogInput (QString channelName)
void	setAnalogOutput (QString channelName, double value)
void	setAnalogOutput (double value)
virtual int	prepareContinuousInput (double sampleRate, double acquireDelay, double exposureTime, QStringList chans, QVector< double > minVals, QVector< double > maxVals)
virtual int	countContinuousInput ()
virtual int	readContinuousInput ()
virtual QVector< double >	readContinuousInputChannel (int ch)
virtual void	finishContinuousInput ()

Public Member Functions
	QxrdNIDAQPlugin ()
virtual	~QxrdNIDAQPlugin ()
virtual void	setErrorOutput (QObject *errors)
QString	name () const
Public Member Functions inherited from QxrdNIDAQPluginInterface
virtual	~QxrdNIDAQPluginInterface ()
virtual void	setAnalogWaveform (QString chan, double rate, double wfm[], int size)=0
virtual void	triggerAnalogWaveform ()=0
virtual void	pulseOutput ()=0
virtual QStringList	deviceNames ()=0
virtual QString	deviceType (QString device)=0
virtual int	deviceIsSimulated (QString device)=0
virtual QStringList	deviceAIChannels (QString device)=0
virtual QStringList	deviceAOChannels (QString device)=0
virtual QStringList	deviceDIPorts (QString device)=0
virtual QStringList	deviceDILines (QString port)=0
virtual QStringList	deviceDOPorts (QString device)=0
virtual QStringList	deviceDOLines (QString port)=0
virtual QStringList	deviceCIChannels (QString device)=0
virtual QStringList	deviceCOChannels (QString device)=0
virtual double	getAnalogInput (QString channelName)=0
virtual void	setAnalogOutput (QString channelName, double value)=0
virtual void	setAnalogOutput (double value)=0
virtual int	prepareContinuousInput (double sampleRate, double acquireDelay, double exposureTime, QStringList chans, QVector< double > minVals, QVector< double > maxVals)=0
virtual int	countContinuousInput ()=0
virtual int	readContinuousInput ()=0
virtual QVector< double >	readContinuousInputChannel (int ch)=0
virtual void	finishContinuousInput ()=0
Public Member Functions inherited from QxrdNamedPluginInterface
virtual	~QxrdNamedPluginInterface ()

Private Member Functions
void	initTaskHandles ()
void	closeTaskHandles ()
void	errorCheck (const char *file, int line, int err)

Private Attributes
QObject *	m_ErrorOutput
QMutex	m_Mutex
TaskHandle	m_AOTaskHandle
TaskHandle	m_AITaskHandle
TaskHandle	m_TrigAOTask
TaskHandle	m_PulseTask
TaskHandle	m_CountersTask
int	m_NCounters
QVector< double >	m_Counts
double	m_SampleRate
double	m_ExposureTime
double	m_AcquireDelay
int	m_NContinuousInputs
int	m_NContinuousSamples
int	m_NAIChannels
int	m_NCIChannels
TaskHandle	m_ContinuousAITask
QVector< TaskHandle >	m_ContinuousCITasks
QVector< int >	m_ContinuousFlags
QVector< int >	m_ContinuousChans
QVector< QVector< double > >	m_ContinuousInputData

Detailed Description

Definition at line 13 of file qxrdnidaqplugin.h.

Constructor & Destructor Documentation

QxrdNIDAQPlugin::QxrdNIDAQPlugin

(

)

Definition at line 13 of file qxrdnidaqplugin.cpp.

                                 :
  m_ErrorOutput(NULL),
  m_AOTaskHandle(0),
  m_AITaskHandle(0),
  m_TrigAOTask(0),
  m_PulseTask(0),
  m_CountersTask(0)
{
  setObjectName("nidaq");

  //  printf("NI-DAQ plugin constructed\n");
  //  initTaskHandles();

  //  res = DAQmxGetDevTerminals("Dev1", buffer, sizeof(buffer));
  //  printf("%d: DAQmxGetDevTerminals : \"%s\"\n", res, buffer);

  //  int32 aiTrigUsage;
  //  int32 aoTrigUsage;
  //  int32 diTrigUsage;
  //  int32 doTrigUsage;
  //  int32 ciTrigUsage;
  //  int32 coTrigUsage;

  //  res = DAQmxGetDevAITrigUsage("Dev1", &aiTrigUsage);
  //  res = DAQmxGetDevAOTrigUsage("Dev1", &aoTrigUsage);
  //  res = DAQmxGetDevDITrigUsage("Dev1", &diTrigUsage);
  //  res = DAQmxGetDevDOTrigUsage("Dev1", &doTrigUsage);
  //  res = DAQmxGetDevCITrigUsage("Dev1", &ciTrigUsage);
  //  res = DAQmxGetDevCOTrigUsage("Dev1", &coTrigUsage);

  //  printf("AI:%02x, AO:%02x, DI:%02x, DO:%02x, CI:%02x, CO:%02x\n",
  //         aiTrigUsage, aoTrigUsage, diTrigUsage, doTrigUsage, ciTrigUsage, coTrigUsage
  //         );

  //  bool32 isSupported=false;
  //  res = DAQmxGetDevCISampClkSupported("Dev1", &isSupported);

  //  printf("%d: DAQmxGetDevCISampClkSupported=%d\n", res, isSupported);
}

QxrdNIDAQPlugin::~QxrdNIDAQPlugin ( )

virtual

Definition at line 53 of file qxrdnidaqplugin.cpp.

References closeTaskHandles().

{
  //  printf("NI-DAQ plugin destroyed");
  closeTaskHandles();
}

Here is the call graph for this function:

Member Function Documentation

void QxrdNIDAQPlugin::closeTaskHandles ( )

private

Definition at line 128 of file qxrdnidaqplugin.cpp.

References m_AITaskHandle, m_AOTaskHandle, m_Mutex, and m_TrigAOTask.

Referenced by ~QxrdNIDAQPlugin().

{
  QMutexLocker lock(&m_Mutex);

  if (m_AOTaskHandle) {
    DAQmxClearTask(m_AOTaskHandle);
    m_AOTaskHandle = 0;
  }

  if (m_AITaskHandle) {
    DAQmxClearTask(m_AITaskHandle);
    m_AITaskHandle = 0;
  }

  if (m_TrigAOTask) {
    DAQmxClearTask(m_TrigAOTask);
    m_TrigAOTask = 0;
  }
}

Here is the caller graph for this function:

int QxrdNIDAQPlugin::configCounters ( QStringList  chans )

slot

Definition at line 436 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, m_CountersTask, m_Counts, and m_NCounters.

{
  int error;

  if (m_CountersTask) {
    DAQmxClearTask(m_CountersTask);

    m_CountersTask = 0;
  }

  if (m_CountersTask == 0) {
    DAQmxErrChk(DAQmxCreateTask("counters", &m_CountersTask));

    m_NCounters = chans.count();
    m_Counts.resize(m_NCounters);

    foreach(QString chan, chans) {
      QStringList parsed = chan.split(",");
      QString ch = parsed.value(0);
      QString sig = parsed.value(1);

      DAQmxErrChk(DAQmxCreateCICountEdgesChan(m_CountersTask, qPrintable(parsed.value(0)), "", DAQmx_Val_Rising, 0, DAQmx_Val_CountUp));
      DAQmxErrChk(DAQmxSetCICountEdgesTerm(m_CountersTask, qPrintable(ch), qPrintable(sig)));
    }

    DAQmxErrChk(DAQmxStartTask(m_CountersTask));

    return m_NCounters;
  }

Error:
  DAQmxClearTask(m_CountersTask);

  m_CountersTask = 0;

  return error;
}

double QxrdNIDAQPlugin::count ( int  chan, double  time  )

slot

Definition at line 410 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, and m_Mutex.

Referenced by readContinuousInput().

{
  QMutexLocker lock(&m_Mutex);

  static TaskHandle counterTask = 0;
  int error;
  float64 res = 0;

  if (counterTask == 0) {
    DAQmxErrChk(DAQmxCreateTask("counter", &counterTask));
    DAQmxErrChk(DAQmxCreateCICountEdgesChan(counterTask,"Dev1/ctr2", "", DAQmx_Val_Rising, 0, DAQmx_Val_CountUp));
    DAQmxErrChk(DAQmxSetCICountEdgesTerm(counterTask, "/Dev1/ctr2", "/Dev1/100MHzTimebase"));
    DAQmxErrChk(DAQmxStartTask(counterTask));
  }

  if (counterTask) {
    DAQmxErrChk(DAQmxReadCounterScalarF64(counterTask, 0, &res, NULL));
  }

  return res;

Error:
  DAQmxClearTask(counterTask);
  return res;
}

Here is the caller graph for this function:

int QxrdNIDAQPlugin::countContinuousInput ( )

virtualslot

Definition at line 618 of file qxrdnidaqplugin.cpp.

References m_NContinuousSamples.

{
  return m_NContinuousSamples;
}

QStringList QxrdNIDAQPlugin::deviceAIChannels ( QString  device )

slot

Definition at line 773 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetDevAIPhysicalChans(qPrintable(device), buffer, sizeof(buffer)));
  //  printf("%d: DAQmxGetDevAIPhysicalChans : \"%s\"\n", res, buffer);

Error:
  QStringList result = QString(buffer).split(", ");

  return result;
}

QStringList QxrdNIDAQPlugin::deviceAOChannels ( QString  device )

slot

Definition at line 787 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetDevAOPhysicalChans(qPrintable(device), buffer, sizeof(buffer)));

Error:
  QStringList result = QString(buffer).split(", ");

  return result;
}

QStringList QxrdNIDAQPlugin::deviceCIChannels ( QString  device )

slot

Definition at line 852 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetDevCIPhysicalChans(qPrintable(device), buffer, sizeof(buffer)));

Error:
  QStringList result = QString(buffer).split(", ");

  return result;
}

QStringList QxrdNIDAQPlugin::deviceCOChannels ( QString  device )

slot

Definition at line 865 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetDevCOPhysicalChans(qPrintable(device), buffer, sizeof(buffer)));

Error:
  QStringList result = QString(buffer).split(", ");

  return result;
}

QStringList QxrdNIDAQPlugin::deviceDILines ( QString  port )

slot

Definition at line 813 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetDevDILines(qPrintable(port), buffer, sizeof(buffer)));

Error:
  QStringList result = QString(buffer).split(", ");

  return result;
}

QStringList QxrdNIDAQPlugin::deviceDIPorts ( QString  device )

slot

Definition at line 800 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetDevDIPorts(qPrintable(device), buffer, sizeof(buffer)));

Error:
  QStringList result = QString(buffer).split(", ");

  return result;
}

QStringList QxrdNIDAQPlugin::deviceDOLines ( QString  port )

slot

Definition at line 839 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetDevDOLines(qPrintable(port), buffer, sizeof(buffer)));

Error:
  QStringList result = QString(buffer).split(", ");

  return result;
}

QStringList QxrdNIDAQPlugin::deviceDOPorts ( QString  device )

slot

Definition at line 826 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetDevDOPorts(qPrintable(device), buffer, sizeof(buffer)));

Error:
  QStringList result = QString(buffer).split(", ");

  return result;
}

int QxrdNIDAQPlugin::deviceIsSimulated ( QString  device )

slot

Definition at line 761 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  bool32 res = true;

  int error;

  DAQmxErrChk(DAQmxGetDevIsSimulated(qPrintable(device), &res));

Error:
  return res;
}

QStringList QxrdNIDAQPlugin::deviceNames ( )

slot

Definition at line 734 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetSysDevNames(buffer, sizeof(buffer)));
  //  printf("%d: DAQmxGetSysDevNames : \"%s\"\n", res, buffer);

Error:
  QStringList result = QString(buffer).split(", ");

  return result;
}

QString QxrdNIDAQPlugin::deviceType ( QString  device )

slot

Definition at line 748 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  char buffer[5120]="";
  int error;

  DAQmxErrChk(DAQmxGetDevProductType(qPrintable(device), buffer, sizeof(buffer)));

Error:
  QString result = QString(buffer);

  return result;
}

void QxrdNIDAQPlugin::errorCheck ( const char *  file, int  line, int  err  )

private

Definition at line 76 of file qxrdnidaqplugin.cpp.

References m_ErrorOutput.

{
  if (DAQmxFailed(err)) {
    int sz = DAQmxGetErrorString(err, NULL, 0);

    if (sz > 0) {
      char *buff = (char*) malloc(sz);

      if (DAQmxGetErrorString(err, buff, sz) == 0) {
        if (m_ErrorOutput &&
            QMetaObject::invokeMethod(m_ErrorOutput, "printMessage", Qt::QueuedConnection,
                                      Q_ARG(QString, tr("%1:%2 NI-DAQ Error %3 : %4").arg(file).arg(line).arg(err).arg(buff)))) {
        } else {
          printf("%s:%d NI-DAQ Error %d : %s\n", file, line, err, buff);
        }
      }

      free(buff);
    }
  }
}

void QxrdNIDAQPlugin::finishContinuousInput ( )

virtualslot

Definition at line 715 of file qxrdnidaqplugin.cpp.

References m_ContinuousAITask, m_ContinuousChans, m_ContinuousCITasks, m_ContinuousFlags, m_NAIChannels, and m_NCIChannels.

Referenced by prepareContinuousInput().

{
  if (m_ContinuousAITask) {
    DAQmxClearTask(m_ContinuousAITask);
  }

  foreach (TaskHandle tsk, m_ContinuousCITasks) {
    DAQmxClearTask(tsk);
  }

  m_ContinuousCITasks.clear();
  m_ContinuousAITask = 0;
  m_ContinuousFlags.clear();
  m_ContinuousChans.clear();

  m_NAIChannels = 0;
  m_NCIChannels = 0;
}

Here is the caller graph for this function:

double QxrdNIDAQPlugin::getAnalogInput ( int  chan )

slot

Definition at line 236 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, m_AITaskHandle, and m_Mutex.

{
  QMutexLocker lock(&m_Mutex);

  int error;
  float64 res = 0;

  if (m_AITaskHandle) {
    DAQmxStopTask(m_AITaskHandle);
    DAQmxClearTask(m_AITaskHandle);
    m_AITaskHandle = 0;
  }

  if (chan >= 0) {
    DAQmxErrChk(DAQmxCreateTask("qxrd-input", &m_AITaskHandle));
    DAQmxErrChk(DAQmxCreateAIVoltageChan (m_AITaskHandle,
                                          qPrintable(tr("Dev1/ai%1").arg(chan)), NULL, DAQmx_Val_Cfg_Default, -10.0, 10.0, DAQmx_Val_Volts, NULL));

    if (m_AITaskHandle) {
      DAQmxErrChk(DAQmxReadAnalogScalarF64(m_AITaskHandle, 10.0, &res, NULL));
    }
  }

Error:
  return res;
}

double QxrdNIDAQPlugin::getAnalogInput ( QString  channelName )

slot

Definition at line 878 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk.

{
  TaskHandle task = 0;
  float64 res = 0;
  int error;

  DAQmxErrChk(DAQmxCreateTask("qxrd-analog-in", &task));
  DAQmxErrChk(DAQmxCreateAIVoltageChan (task,
                                        qPrintable(channelName),
                                        NULL,
                                        DAQmx_Val_Cfg_Default, -10.0, 10.0,
                                        DAQmx_Val_Volts, NULL));

  DAQmxErrChk(DAQmxReadAnalogScalarF64(task, 10.0, &res, NULL));

Error:
  DAQmxClearTask(task);

  return res;
}

void QxrdNIDAQPlugin::initTaskHandles ( )

private

Definition at line 98 of file qxrdnidaqplugin.cpp.

{
  //  int error;

  //  if (m_AOTaskHandle == 0) {
  //    DAQmxErrChk(DAQmxCreateTask("", &m_AOTaskHandle));
  //    DAQmxErrChk(DAQmxCreateAOVoltageChan (m_AOTaskHandle, "Dev1/ao0", NULL, -10.0, 10.0, DAQmx_Val_Volts, NULL));
  //    DAQmxErrChk(DAQmxCreateAOVoltageChan (m_AOTaskHandle, "Dev1/ao1", NULL, -10.0, 10.0, DAQmx_Val_Volts, NULL));
  //  }

  //  if (m_AITaskHandle == 0) {
  //    DAQmxErrChk(DAQmxCreateTask("", &m_AITaskHandle));
  //    DAQmxErrChk(DAQmxCreateAIVoltageChan (m_AITaskHandle, "Dev1/ai0", NULL, DAQmx_Val_Cfg_Default, -10.0, 10.0, DAQmx_Val_Volts, NULL));
  //    DAQmxErrChk(DAQmxCreateAIVoltageChan (m_AITaskHandle, "Dev1/ai1", NULL, DAQmx_Val_Cfg_Default, -10.0, 10.0, DAQmx_Val_Volts, NULL));
  //  }

  //  if (m_TrigAOTask == 0) {
  //    DAQmxErrChk(DAQmxCreateTask("", &m_TrigAOTask));
  //    DAQmxErrChk(DAQmxCreateAOVoltageChan (m_TrigAOTask, "Dev1/ao0", NULL, -10.0, 10.0, DAQmx_Val_Volts, NULL));
  //  }

  //  return;

  //Error:
  //  printf("Error in initTaskHandles\n");

  //  closeTaskHandles();
}

QString QxrdNIDAQPlugin::name ( ) const

virtual

Implements QxrdNamedPluginInterface.

Definition at line 64 of file qxrdnidaqplugin.cpp.

{
  return "NI DAQ Card";
}

int QxrdNIDAQPlugin::prepareContinuousInput ( double  sampleRate, double  acquireDelay, double  exposureTime, QStringList  chans, QVector< double >  minVals, QVector< double >  maxVals  )

virtualslot

Definition at line 497 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, finishContinuousInput(), m_AcquireDelay, m_ContinuousAITask, m_ContinuousChans, m_ContinuousCITasks, m_ContinuousFlags, m_ContinuousInputData, m_ExposureTime, m_NAIChannels, m_NCIChannels, m_NContinuousInputs, m_NContinuousSamples, m_SampleRate, and printMessage().

{
  int error = 0;
  int bufferSize = 0;

  m_SampleRate = sampleRate;
  m_AcquireDelay = acquireDelay;
  m_ExposureTime = exposureTime;

  finishContinuousInput();

  QRegExp re_ai("^(.*)/ai\\d+$");
  QRegExp re_ci("^(.*)/ctr\\d+$");
  QString aiDevice;

  if (m_ContinuousAITask == NULL) {
    DAQmxErrChk(DAQmxCreateTask("continuousAI", &m_ContinuousAITask));
  }

  for(int i=0; i<chans.count(); i++) {
    QString chan = chans.value(i);

    if (re_ai.exactMatch(chan)) {

      DAQmxErrChk(DAQmxCreateAIVoltageChan(m_ContinuousAITask, qPrintable(chan), "",
                                           DAQmx_Val_Cfg_Default,
                                           minVals.value(i),
                                           maxVals.value(i),
                                           DAQmx_Val_Volts, NULL ));

      m_ContinuousFlags.append(1);
      m_ContinuousChans.append(m_NAIChannels++);

      if (re_ai.capturedTexts().count() >= 2) {
        if (aiDevice.count() == 0) {
          aiDevice = re_ai.capturedTexts().value(1);
        }
      }

      printMessage(tr("Analog input channel : %1").arg(chan));
    } else if (re_ci.exactMatch(chan)) {
      TaskHandle thdl;

      DAQmxErrChk(DAQmxCreateTask(qPrintable(tr("continuousCI_%1").arg(m_ContinuousCITasks.count())), &thdl));

      m_ContinuousCITasks.append(thdl);

      DAQmxErrChk(DAQmxCreateCICountEdgesChan(thdl, qPrintable(chan), "", DAQmx_Val_Rising, 0, DAQmx_Val_CountUp));

      m_ContinuousFlags.append(-1);
      m_ContinuousChans.append(m_NCIChannels++);

      if (re_ci.capturedTexts().count() >= 2) {
        if (aiDevice.count() == 0) {
          aiDevice = re_ci.capturedTexts().value(1);
        }
      }

      printMessage(tr("Counter input channel : %1").arg(chan));
    } else {
      m_ContinuousFlags.append(0);
      m_ContinuousChans.append(0);

      printMessage(tr("Skipped channel : %1").arg(chan));
    }
  }

  if (m_NAIChannels == 0) {
    DAQmxErrChk(DAQmxCreateAIVoltageChan(m_ContinuousAITask,
                                         qPrintable(tr("%1/ai0").arg(aiDevice)), "",
                                         DAQmx_Val_Cfg_Default, -10.0, 10.0, DAQmx_Val_Volts, NULL ));

  }

  m_NContinuousSamples = m_SampleRate*(m_ExposureTime + m_AcquireDelay + 0.1);

  bufferSize = m_NContinuousSamples+(2.0*m_SampleRate);

  printMessage(tr("Buffer size %1").arg(bufferSize));

  if (m_ContinuousAITask) {
    DAQmxErrChk(DAQmxCfgSampClkTiming(m_ContinuousAITask, NULL,
                                      sampleRate, DAQmx_Val_Rising, DAQmx_Val_ContSamps, bufferSize));
    DAQmxErrChk(DAQmxSetBufInputBufSize(m_ContinuousAITask, bufferSize));
    DAQmxErrChk(DAQmxSetReadOverWrite(m_ContinuousAITask, DAQmx_Val_OverwriteUnreadSamps));
  }

  foreach (TaskHandle tsk, m_ContinuousCITasks) {
    DAQmxErrChk(DAQmxCfgSampClkTiming(tsk, qPrintable(tr("/%1/ai/SampleClock").arg(aiDevice)),
                                      sampleRate, DAQmx_Val_Rising, DAQmx_Val_ContSamps, bufferSize));
    DAQmxErrChk(DAQmxSetBufInputBufSize(tsk, bufferSize));
    DAQmxErrChk(DAQmxSetReadOverWrite(tsk, DAQmx_Val_OverwriteUnreadSamps));
    //    DAQmxErrChk(DAQmxCfgDigEdgeStartTrig(tsk, qPrintable(tr("/%1/ai/StartTrigger").arg(aiDevice)),
    //                                         DAQmx_Val_Rising));
  }

  foreach (TaskHandle tsk, m_ContinuousCITasks) {
    DAQmxErrChk(DAQmxStartTask(tsk));
  }

  if (m_ContinuousAITask) {
    DAQmxErrChk(DAQmxStartTask(m_ContinuousAITask));
  }

  m_NContinuousInputs = chans.count();

  m_ContinuousInputData.resize(m_NContinuousInputs);

  for (int i=0; i<m_NContinuousInputs; i++) {
    m_ContinuousInputData[i].resize(m_NContinuousSamples);
  }
Error:

  return error;
}

Here is the call graph for this function:

void QxrdNIDAQPlugin::printMessage ( QString  msg )

slot

Definition at line 69 of file qxrdnidaqplugin.cpp.

References m_ErrorOutput.

Referenced by prepareContinuousInput().

{
  if (m_ErrorOutput) {
    QMetaObject::invokeMethod(m_ErrorOutput, "printMessage", Qt::QueuedConnection, Q_ARG(QString, msg));
  }
}

Here is the caller graph for this function:

void QxrdNIDAQPlugin::pulseOutput ( )

slot

Definition at line 387 of file qxrdnidaqplugin.cpp.

{
//  QMutexLocker lock(&m_Mutex);

//  int error;

//  DAQmxErrChk(DAQmxCreateTask("", &m_PulseTask));
//  DAQmxErrChk(DAQmxCreateCOPulseChanTime(m_PulseTask, "Dev1/ctr0", "", DAQmx_Val_Seconds, DAQmx_Val_Low, 0, 1e-6, 1e-6));

//  DAQmxErrChk(DAQmxStartTask(m_PulseTask));
//  DAQmxErrChk(DAQmxWaitUntilTaskDone(m_PulseTask, 0.5));
//  DAQmxErrChk(DAQmxStopTask(m_PulseTask));

//Error:

//  if (m_PulseTask) {
//    DAQmxClearTask(m_PulseTask);
//  }

//  m_PulseTask = 0;
//  return;
}

int QxrdNIDAQPlugin::readContinuousInput ( )

virtualslot

Definition at line 623 of file qxrdnidaqplugin.cpp.

References count(), DAQmxErrChk, m_ContinuousAITask, m_ContinuousChans, m_ContinuousCITasks, m_ContinuousFlags, m_ContinuousInputData, m_NAIChannels, m_NCIChannels, m_NContinuousInputs, and m_NContinuousSamples.

{
  int error = 0;

  uInt32 avail;

  QVector<double> aiBuff(m_NAIChannels*m_NContinuousSamples);
  QVector< QVector<double> > ciBuff(m_NCIChannels);

  for (int i=0; i<m_NCIChannels; i++) {
    ciBuff[i].resize(m_NContinuousSamples + 1);
  }

  if (m_ContinuousAITask) {
    DAQmxErrChk(DAQmxGetReadAvailSampPerChan(m_ContinuousAITask, &avail));

    if (avail < m_NContinuousSamples) {
      return -1;
    }

    DAQmxErrChk(DAQmxSetReadRelativeTo(m_ContinuousAITask, DAQmx_Val_MostRecentSamp));
    DAQmxErrChk(DAQmxSetReadOffset(m_ContinuousAITask, -m_NContinuousSamples));
  }

//  foreach(TaskHandle tsk, m_ContinuousCITasks) {
//    DAQmxErrChk(DAQmxSetReadRelativeTo(tsk, DAQmx_Val_MostRecentSamp));
//    DAQmxErrChk(DAQmxSetReadOffset(tsk, -m_NContinuousSamples));
//  }

  int32 actuallyRead;
  uInt64 lastSample[30];

  if (m_ContinuousAITask && m_NAIChannels) {
    DAQmxErrChk(DAQmxReadAnalogF64(m_ContinuousAITask, m_NContinuousSamples, -1,
                                   DAQmx_Val_GroupByChannel, aiBuff.data(), aiBuff.count(),
                                   &actuallyRead, NULL));

    DAQmxErrChk(DAQmxGetReadCurrReadPos(m_ContinuousAITask, &lastSample[0]));
  }

  for(int i=0; i<m_NCIChannels; i++) {
    TaskHandle tsk = m_ContinuousCITasks.value(i);

    if (tsk) {
      uInt64 currentPos;

      DAQmxErrChk(DAQmxGetReadCurrReadPos(tsk, &currentPos));
      DAQmxErrChk(DAQmxSetReadRelativeTo(tsk, DAQmx_Val_CurrReadPos));
      int32 offset = ((int64)lastSample[0]) - ((int64)currentPos) - (m_NContinuousSamples+1);
      DAQmxErrChk(DAQmxSetReadOffset(tsk, offset));
      DAQmxErrChk(DAQmxReadCounterF64(tsk, m_NContinuousSamples+1, -1,
                                      ciBuff[i].data(), ciBuff[i].count(),
                                      &actuallyRead, NULL));

      if (i<29) {
        DAQmxErrChk(DAQmxGetReadCurrReadPos(tsk, &lastSample[i+1]));

        if (lastSample[i+1] != lastSample[i]) {
          printf("Sync error %ld:%ld\n", lastSample[i+1], lastSample[i]);
        }
      }
    }
  }

  for (int i=0; i<m_NCIChannels; i++) {
    for (int j=0; j<m_NContinuousSamples; j++) {
      ciBuff[i][j] = ciBuff[i][j+1] - ciBuff[i][j];
    }

    ciBuff[i].resize(m_NContinuousSamples);
  }

  for (int i=0; i<m_NContinuousInputs; i++) {
    if (m_ContinuousFlags.value(i) == 1) { // an Analog Input Channel
      int chan = m_ContinuousChans.value(i);

      m_ContinuousInputData[i] = aiBuff.mid(chan*m_NContinuousSamples, m_NContinuousSamples);
    } else if (m_ContinuousFlags.value(i) == -1) { // a counter Input Channel
      int chan = m_ContinuousChans.value(i);

      m_ContinuousInputData[i] = ciBuff[chan].mid(0, m_NContinuousSamples);
    }
  }
Error:
  return error;
}

Here is the call graph for this function:

QVector< double > QxrdNIDAQPlugin::readContinuousInputChannel ( int  ch )

virtualslot

Definition at line 710 of file qxrdnidaqplugin.cpp.

References m_ContinuousInputData.

{
  return m_ContinuousInputData.value(ch);
}

QVector< double > QxrdNIDAQPlugin::readCounters ( )

slot

Definition at line 474 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, m_CountersTask, m_Counts, and m_NCounters.

{
  int error;

  if (m_CountersTask) {
    QVector<float64> counts(m_NCounters);

    DAQmxErrChk(DAQmxReadCounterScalarF64(m_CountersTask, 0, counts.data(), NULL));

    QVector<double> res(m_NCounters);

    for (int i=0; i<m_NCounters; i++) {
      res[i] = counts[i] - m_Counts[i];
      m_Counts[i] = counts[i];
    }

    return res;
  }

Error:
  return QVector<double>();
}

void QxrdNIDAQPlugin::setAnalogOutput ( int  chan, double  val  )

slot

Definition at line 263 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, m_AOTaskHandle, and m_Mutex.

{
  QMutexLocker lock(&m_Mutex);

  int error;

  if (m_AOTaskHandle) {
    DAQmxStopTask(m_AOTaskHandle);
    DAQmxClearTask(m_AOTaskHandle);
    m_AOTaskHandle = 0;
  }

  if (chan >= 0) {
    DAQmxErrChk(DAQmxCreateTask("qxrd-output", &m_AOTaskHandle));
    DAQmxErrChk(DAQmxCreateAOVoltageChan (m_AOTaskHandle,
                                          qPrintable(tr("Dev1/ao%1").arg(chan)), NULL, -10.0, 10.0, DAQmx_Val_Volts, NULL));

    if (m_AOTaskHandle) {
      DAQmxErrChk(DAQmxWriteAnalogScalarF64(m_AOTaskHandle, true, 10.0, value, NULL));
    }
  }

Error:
  return;
}

void QxrdNIDAQPlugin::setAnalogOutput ( QString  channelName, double  value  )

slot

Definition at line 289 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, m_AOTaskHandle, and m_Mutex.

{
  QMutexLocker lock(&m_Mutex);

  int error;

  if (m_AOTaskHandle) {
    DAQmxStopTask(m_AOTaskHandle);
    DAQmxClearTask(m_AOTaskHandle);
    m_AOTaskHandle = 0;
  }

  DAQmxErrChk(DAQmxCreateTask("qxrd-analog-out", &m_AOTaskHandle));
  DAQmxErrChk(DAQmxCreateAOVoltageChan (m_AOTaskHandle,
                                        qPrintable(channelName),
                                        NULL,
                                        -10.0, 10.0,
                                        DAQmx_Val_Volts, NULL));

  DAQmxErrChk(DAQmxWriteAnalogScalarF64(m_AOTaskHandle, true, 10.0, value, NULL));

Error:
  return;
}

void QxrdNIDAQPlugin::setAnalogOutput ( double  value )

slot

Definition at line 375 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, and m_AOTaskHandle.

{
  int error;

  if (m_AOTaskHandle) {
    DAQmxErrChk(DAQmxWriteAnalogScalarF64(m_AOTaskHandle, true, 10.0, value, NULL));
  }

Error:
  return;
}

void QxrdNIDAQPlugin::setAnalogWaveform ( QString  chan, double  rate, double  wfm[], int  size  )

slot

Definition at line 314 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, m_AOTaskHandle, and m_Mutex.

{
  QMutexLocker lock(&m_Mutex);
//  printf("setAnalogWaveform(%g,%g...,%d)\n", rate, wfm[0], size);

  int error;
  int32 nsampwrt;

  if (m_AOTaskHandle) {
    DAQmxStopTask(m_AOTaskHandle);
    DAQmxClearTask(m_AOTaskHandle);
    m_AOTaskHandle = 0;
  }

  if (chan >= 0) {
    DAQmxErrChk(DAQmxCreateTask("qxrd-output", &m_AOTaskHandle));
    DAQmxErrChk(DAQmxCreateAOVoltageChan (m_AOTaskHandle,
                                          qPrintable(chan), NULL, -10.0, 10.0, DAQmx_Val_Volts, NULL));

    if (m_AOTaskHandle) {
      DAQmxErrChk(
            DAQmxCfgSampClkTiming(m_AOTaskHandle, NULL, rate, DAQmx_Val_Rising, DAQmx_Val_FiniteSamps, size)
            );

      DAQmxErrChk(
            DAQmxWriteAnalogF64(m_AOTaskHandle, size, false, -1, DAQmx_Val_GroupByChannel, wfm, &nsampwrt, NULL)
            );
    }
  }

//  printf("%d samples written\n", nsampwrt);

Error:
  return;
}

void QxrdNIDAQPlugin::setErrorOutput ( QObject *  errors )

virtual

Implements QxrdNIDAQPluginInterface.

Definition at line 59 of file qxrdnidaqplugin.cpp.

References m_ErrorOutput.

{
  m_ErrorOutput = errors;
}

void QxrdNIDAQPlugin::triggerAnalogWaveform ( )

slot

Definition at line 350 of file qxrdnidaqplugin.cpp.

References DAQmxErrChk, m_AOTaskHandle, and m_Mutex.

{
  QMutexLocker lock(&m_Mutex);
//  printf("triggerAnalogWaveform()\n");

  int error;

  if (m_AOTaskHandle) {
    //    DAQmxErrChk(
    //      DAQmxWaitUntilTaskDone(m_AOTaskHandle, -1)
    //    )

    DAQmxErrChk(
          DAQmxStopTask(m_AOTaskHandle)
          );

    DAQmxErrChk(
          DAQmxStartTask(m_AOTaskHandle)
          );
  }

Error:
  return;
}

Member Data Documentation

double QxrdNIDAQPlugin::m_AcquireDelay

private

Definition at line 87 of file qxrdnidaqplugin.h.

Referenced by prepareContinuousInput().

TaskHandle QxrdNIDAQPlugin::m_AITaskHandle

private

Definition at line 78 of file qxrdnidaqplugin.h.

Referenced by closeTaskHandles(), and getAnalogInput().

TaskHandle QxrdNIDAQPlugin::m_AOTaskHandle

private

Definition at line 77 of file qxrdnidaqplugin.h.

Referenced by closeTaskHandles(), setAnalogOutput(), setAnalogWaveform(), and triggerAnalogWaveform().

TaskHandle QxrdNIDAQPlugin::m_ContinuousAITask

private

Definition at line 94 of file qxrdnidaqplugin.h.

Referenced by finishContinuousInput(), prepareContinuousInput(), and readContinuousInput().

QVector<int> QxrdNIDAQPlugin::m_ContinuousChans

private

Definition at line 97 of file qxrdnidaqplugin.h.

Referenced by finishContinuousInput(), prepareContinuousInput(), and readContinuousInput().

QVector<TaskHandle> QxrdNIDAQPlugin::m_ContinuousCITasks

private

Definition at line 95 of file qxrdnidaqplugin.h.

Referenced by finishContinuousInput(), prepareContinuousInput(), and readContinuousInput().

QVector<int> QxrdNIDAQPlugin::m_ContinuousFlags

private

Definition at line 96 of file qxrdnidaqplugin.h.

Referenced by finishContinuousInput(), prepareContinuousInput(), and readContinuousInput().

QVector< QVector<double> > QxrdNIDAQPlugin::m_ContinuousInputData

private

Definition at line 99 of file qxrdnidaqplugin.h.

Referenced by prepareContinuousInput(), readContinuousInput(), and readContinuousInputChannel().

TaskHandle QxrdNIDAQPlugin::m_CountersTask

private

Definition at line 81 of file qxrdnidaqplugin.h.

Referenced by configCounters(), and readCounters().

QVector<double> QxrdNIDAQPlugin::m_Counts

private

Definition at line 83 of file qxrdnidaqplugin.h.

Referenced by configCounters(), and readCounters().

QObject* QxrdNIDAQPlugin::m_ErrorOutput

private

Definition at line 75 of file qxrdnidaqplugin.h.

Referenced by errorCheck(), printMessage(), and setErrorOutput().

double QxrdNIDAQPlugin::m_ExposureTime

private

Definition at line 86 of file qxrdnidaqplugin.h.

Referenced by prepareContinuousInput().

QMutex QxrdNIDAQPlugin::m_Mutex

private

Definition at line 76 of file qxrdnidaqplugin.h.

Referenced by closeTaskHandles(), count(), getAnalogInput(), setAnalogOutput(), setAnalogWaveform(), and triggerAnalogWaveform().

int QxrdNIDAQPlugin::m_NAIChannels

private

Definition at line 92 of file qxrdnidaqplugin.h.

Referenced by finishContinuousInput(), prepareContinuousInput(), and readContinuousInput().

int QxrdNIDAQPlugin::m_NCIChannels

private

Definition at line 93 of file qxrdnidaqplugin.h.

Referenced by finishContinuousInput(), prepareContinuousInput(), and readContinuousInput().

int QxrdNIDAQPlugin::m_NContinuousInputs

private

Definition at line 89 of file qxrdnidaqplugin.h.

Referenced by prepareContinuousInput(), and readContinuousInput().

int QxrdNIDAQPlugin::m_NContinuousSamples

private

Definition at line 90 of file qxrdnidaqplugin.h.

Referenced by countContinuousInput(), prepareContinuousInput(), and readContinuousInput().

int QxrdNIDAQPlugin::m_NCounters

private

Definition at line 82 of file qxrdnidaqplugin.h.

Referenced by configCounters(), and readCounters().

TaskHandle QxrdNIDAQPlugin::m_PulseTask

private

Definition at line 80 of file qxrdnidaqplugin.h.

double QxrdNIDAQPlugin::m_SampleRate

private

Definition at line 85 of file qxrdnidaqplugin.h.

Referenced by prepareContinuousInput().

TaskHandle QxrdNIDAQPlugin::m_TrigAOTask

private

Definition at line 79 of file qxrdnidaqplugin.h.

Referenced by closeTaskHandles().

---

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

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