EFInterfaceEmulator.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef TRIGDFEMULATOR_EFINTERFACEEMULATOR_H
#define TRIGDFEMULATOR_EFINTERFACEEMULATOR_H
 
#include <mutex>
#include <utility>
#include <queue>
#include <future>
#include <unordered_map>
#include <vector>
 
#include "ers/ers.h"
#include "eformat/eformat.h"
#include "eformat/index.h"
#include "eformat/write/eformat.h"
#include "eformat/SourceIdentifier.h"
#include "eformat/FullEventFragmentNoTemplates.h"
 
#include <boost/interprocess/shared_memory_object.hpp>
#include "df_ef_interface/df_ef_interface.h"
#include "TrigKernel/EventLoopUtils.h"
#include "FileReaderWriter.h"

 
namespace DFEF{
  class EFInterfaceEmulator:public daq::df_ef_interface::EventHandler{
 
  public:
 
    EFInterfaceEmulator(const boost::property_tree::ptree &args);

    virtual void open() override; 

    virtual void close() override;

    virtual std::future<std::unique_ptr<uint32_t[]>> getNext() override;

    virtual std::future<void> accept(uint64_t l0id, std::unique_ptr<uint32_t[]> hltr) override;

    virtual std::future<void> reject(uint64_t l0id) override;
 
    virtual ~EFInterfaceEmulator();
 
 
  private:
 
    std::string m_name;
    std::unique_ptr<FileReaderWriter> m_file_rw;
    eformat::Compression m_comp;  
    unsigned int m_compLevel;  

    void inputThreadCallback();
    void outputThreadCallback();

    std::unique_ptr<HLT::LoopThread> m_inputThread;
    std::unique_ptr<HLT::LoopThread> m_outputThread;

    std::queue<std::promise<std::unique_ptr<uint32_t[]>>> m_inputQueue; 
    std::mutex m_iQMutex;
  
    std::queue<std::pair<uint64_t, std::unique_ptr<uint32_t[]>>> m_outputQueue; 
    std::mutex m_oQMutex;

    std::unordered_map<uint64_t, std::vector<std::unique_ptr<uint32_t[]>>> m_events;
    std::mutex m_mMutex;

    std::mutex m_RWMutex; 
 
  };
}
#endif