lasp_indatahandler.h

Go to the documentation of this file.

#pragma once
#include "lasp_types.h"
#include <atomic>
#include <functional>
#include <memory>
#include <thread>
 
class StreamMgr;
using SmgrHandle = std::shared_ptr<StreamMgr>;
 
class DaqData;
class Daq;
 
using InCallbackType = std::function<void(const DaqData &)>;
using InResetType = std::function<void(const Daq *)>;
 
class InDataHandler {
 
protected:
  std::weak_ptr<StreamMgr> _mgr;
#if LASP_DEBUG == 1
  // This is a flag to indicate whether the method stop() is called for the
  // current handler. It should call the method stop() from the derived class's
  // destructor.
  std::atomic<bool> stopCalled{false};
#endif
 
public:
  ~InDataHandler();
  const InCallbackType inCallback;
  const InResetType reset;
 
  InDataHandler(SmgrHandle mgr, InCallbackType cb,
                InResetType resetfcn);
 
  void start();
 
  void stop();
 
#if LASP_DEBUG == 1
  const std::thread::id main_thread_id;
  void checkRightThread() const;
#else
  void checkRightThread() const {}
#endif
};