DAPHNEListRequestHandler.hpp

Go to the documentation of this file.

 
#ifndef FDREADOUTLIBS_INCLUDE_FDREADOUTLIBS_DAPHNE_DAPHNELISTREQUESTHANDLER_HPP_
#define FDREADOUTLIBS_INCLUDE_FDREADOUTLIBS_DAPHNE_DAPHNELISTREQUESTHANDLER_HPP_
 
#include "logging/Logging.hpp"
 
#include "datahandlinglibs/FrameErrorRegistry.hpp"
#include "datahandlinglibs/DataHandlingIssues.hpp"
#include "datahandlinglibs/ReadoutLogging.hpp"
#include "datahandlinglibs/models/DefaultRequestHandlerModel.hpp"
#include "datahandlinglibs/models/SkipListLatencyBufferModel.hpp"
 
#include "fddetdataformats/DAPHNEFrame.hpp"
 
#include "fdreadoutlibs/DAPHNESuperChunkTypeAdapter.hpp"
 
#include <atomic>
#include <deque>
#include <functional>
#include <future>
#include <iomanip>
#include <memory>
#include <string>
#include <thread>
#include <utility>
#include <vector>
 
using dunedaq::datahandlinglibs::logging::TLVL_WORK_STEPS;
 
namespace dunedaq {
namespace fdreadoutlibs {
 
class DAPHNEListRequestHandler
  : public datahandlinglibs::DefaultRequestHandlerModel<
      types::DAPHNESuperChunkTypeAdapter,
      datahandlinglibs::SkipListLatencyBufferModel<types::DAPHNESuperChunkTypeAdapter>>
{
public:
  // Using shorter typenames
  using inherited =
    datahandlinglibs::DefaultRequestHandlerModel<types::DAPHNESuperChunkTypeAdapter,
                                            datahandlinglibs::SkipListLatencyBufferModel<types::DAPHNESuperChunkTypeAdapter>>;
  using SkipListAcc = typename folly::ConcurrentSkipList<types::DAPHNESuperChunkTypeAdapter>::Accessor;
  using SkipListSkip = typename folly::ConcurrentSkipList<types::DAPHNESuperChunkTypeAdapter>::Skipper;
 
  // Constructor
  DAPHNEListRequestHandler(
    std::shared_ptr<datahandlinglibs::SkipListLatencyBufferModel<types::DAPHNESuperChunkTypeAdapter>>& latency_buffer,
    std::unique_ptr<datahandlinglibs::FrameErrorRegistry>& error_registry)
    : DefaultRequestHandlerModel<types::DAPHNESuperChunkTypeAdapter,
                                 datahandlinglibs::SkipListLatencyBufferModel<types::DAPHNESuperChunkTypeAdapter>>(
        latency_buffer,
        error_registry)
  {
    TLOG_DEBUG(TLVL_WORK_STEPS) << "DAPHNEListRequestHandler created...";
  }
 
protected:
  // Override cleanup with special implementation
  void cleanup() override { daphne_cleanup_request(); }
 
  // The DAPHNE with SkipList needs a special cleanup method.
  void daphne_cleanup_request();
 
private:
  // Constants
  static const constexpr uint64_t m_max_ts_diff = 10000000; // NOLINT(build/unsigned)
 
  // Stats
  std::atomic<int> m_found_requested_count{ 0 };
  std::atomic<int> m_bad_requested_count{ 0 };
};
 
} // namespace fdreadoutlibs
} // namespace dunedaq
 
#endif // FDREADOUTLIBS_INCLUDE_FDREADOUTLIBS_DAPHNE_DAPHNELISTREQUESTHANDLER_HPP_