lasp_threadedindatahandler.h

Go to the documentation of this file.

#pragma once
#include "debugtrace.hpp"
#include "lasp_indatahandler.h"
#include "lasp_thread.h"
#include <atomic>
#include <memory>
#include <mutex>
 
using std::placeholders::_1;
const us RINGBUFFER_SIZE = 1024;
 
class SafeQueue;
class ThreadedInDataHandlerBase {
  InDataHandler _indatahandler;
  std::unique_ptr<SafeQueue> _queue;
 
  mutable std::recursive_mutex _mtx;
 
  std::atomic<bool> _thread_running{false};
  std::atomic<bool> _thread_can_safely_run{false};
 
  GlobalThreadPool _pool;
 
  const InCallbackType inCallback;
 
  void threadFcn();
 
 
  void _inCallbackFromInDataHandler(const DaqData &daqdata);
 
  public:
  ThreadedInDataHandlerBase(SmgrHandle mgr, InCallbackType cb, InResetType reset);
  ~ThreadedInDataHandlerBase();
  void startThread();
  void stopThread();
 
};
 
template <typename Derived>
class ThreadedInDataHandler : public ThreadedInDataHandlerBase {
  public:
  ThreadedInDataHandler(SmgrHandle mgr):
    ThreadedInDataHandlerBase(mgr, 
        std::bind(&ThreadedInDataHandler::_inCallback, this, _1),
        std::bind(&ThreadedInDataHandler::_reset, this, _1))
  {
 
  }
 
  void _reset(const Daq* daq) {
    DEBUGTRACE_ENTER;
    return static_cast<Derived*>(this)->reset(daq);
  }
  void _inCallback(const DaqData& data) {
    DEBUGTRACE_ENTER;
    return static_cast<Derived*>(this)->inCallback(data);
  }
};