lasp_uldaq_impl.h

Go to the documentation of this file.

#pragma once
#include "debugtrace.hpp"
#include "lasp_uldaq_common.h"
#include <algorithm>
#include <cassert>
#include <chrono>
#include <iostream>
#include <stdexcept>
#include <thread>
#include <vector>
#include "lasp_daq.h"
 
using std::atomic;
using std::cerr;
using std::endl;
using rte = std::runtime_error;
 
class InBufHandler;
class OutBufHandler;
 
class DT9837A : public Daq {
 
  DaqDeviceHandle _handle = 0;
  std::mutex _daqmutex;
 
  std::thread _thread;
 
 
  atomic<bool> _stopThread{false};
  atomic<StreamStatus> _streamStatus;
 
  const us _nFramesPerBlock;
 
  void threadFcn(InDaqCallback inCallback, OutDaqCallback outcallback);
 
  DaqDeviceHandle getHandle() const { return _handle; }
  void sanityChecks() const;
public:
 
  DT9837A(const UlDaqDeviceInfo &devinfo, const DaqConfiguration &config);
 
  virtual ~DT9837A();
 
  bool isRunning() const;
 
  void stop() override final;
 
  friend class InBufHandler;
  friend class OutBufHandler;
 
  virtual void start(InDaqCallback inCallback,
                     OutDaqCallback outCallback) override final;
 
  virtual StreamStatus getStreamStatus() const override {
    return _streamStatus;
  }
};