lasp_uldaq_bufhandler.h

Go to the documentation of this file.

#pragma once
#include <uldaq.h>
#include "lasp_types.h"
#include "lasp_uldaq_impl.h"
#include "lasp_uldaq_common.h"
 
 
 
class DT9837A;
class BufHandler {
protected:
  DT9837A &daq;
  const DataTypeDescriptor dtype_descr = dtype_desc_fl64;
  us nchannels, nFramesPerBlock;
  double samplerate;
  std::vector<double> buf;
  bool topenqueued = false;
  bool botenqueued = false;
 
  us totalFramesCount = 0;
  long long buffer_mid_idx;
 
public:
  BufHandler(DT9837A &daq, const us nchannels)
      : daq(daq), dtype_descr(daq.dtypeDescr()), nchannels(nchannels),
        nFramesPerBlock(daq.framesPerBlock()), samplerate(daq.samplerate()),
        buf(2 * nchannels *
                nFramesPerBlock, // Watch the two here, the top and the bottom!
            0),
        buffer_mid_idx(nchannels * nFramesPerBlock) {
    assert(nchannels > 0);
    assert(nFramesPerBlock > 0);
  }
};
class InBufHandler : public BufHandler {
  bool monitorOutput;
  InDaqCallback cb;
 
public:
  InBufHandler(DT9837A &daq, InDaqCallback cb);
  void start();
  bool operator()();
  ~InBufHandler();
};
class OutBufHandler : public BufHandler {
  OutDaqCallback cb;
 
public:
  OutBufHandler(DT9837A &daq, OutDaqCallback cb);
  void start();
  bool operator()();
 
  ~OutBufHandler();
};