DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
Public Member Functions | List of all members
dunedaq::datahandlinglibs::test::TestDefaultRequestHandlerModel< ReadoutType, LatencyBufferType > Class Template Reference

#include <TestUtilities.hpp>

Inheritance diagram for dunedaq::datahandlinglibs::test::TestDefaultRequestHandlerModel< ReadoutType, LatencyBufferType >:
[legend]
Collaboration diagram for dunedaq::datahandlinglibs::test::TestDefaultRequestHandlerModel< ReadoutType, LatencyBufferType >:
[legend]

Public Member Functions

 TestDefaultRequestHandlerModel (std::shared_ptr< LatencyBufferType > &latency_buffer, std::unique_ptr< dunedaq::datahandlinglibs::FrameErrorRegistry > &error_registry)
Public Member Functions inherited from dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >
 DefaultRequestHandlerModel (std::shared_ptr< LatencyBufferType > &latency_buffer, std::unique_ptr< FrameErrorRegistry > &error_registry)
void conf (const dunedaq::appmodel::DataHandlerModule *)
void scrap (const appfwk::DAQModule::CommandData_t &) override
void start (const appfwk::DAQModule::CommandData_t &)
void stop (const appfwk::DAQModule::CommandData_t &)
void record (const appfwk::DAQModule::CommandData_t &args) override
void cleanup_check () override
 Check if cleanup is necessary and execute it if necessary.
virtual void periodic_data_transmission () override
 Periodic data transmission - relevant for trigger in particular.
void issue_request (dfmessages::DataRequest datarequest, bool is_retry=false) override
 Issue a data request to the request handler.
virtual dunedaq::daqdataformats::timestamp_t get_cutoff_timestamp ()
virtual bool supports_cutoff_timestamp ()
void reset_oldest_time ()
std::uint64_t get_oldest_time () override
 Get oldest timestamp in the buffer.
Public Member Functions inherited from dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >
 RequestHandlerConcept ()
virtual ~RequestHandlerConcept ()
 RequestHandlerConcept (const RequestHandlerConcept &)=delete
 RequestHandlerConcept is not copy-constructible.
RequestHandlerConcept & operator= (const RequestHandlerConcept &)=delete
 RequestHandlerConcept is not copy-assginable.
 RequestHandlerConcept (RequestHandlerConcept &&)=delete
 RequestHandlerConcept is not move-constructible.
RequestHandlerConcept & operator= (RequestHandlerConcept &&)=delete
 RequestHandlerConcept is not move-assignable.
Public Member Functions inherited from dunedaq::opmonlib::MonitorableObject
 MonitorableObject (const MonitorableObject &)=delete
MonitorableObject & operator= (const MonitorableObject &)=delete
 MonitorableObject (MonitorableObject &&)=delete
MonitorableObject & operator= (MonitorableObject &&)=delete
virtual ~MonitorableObject ()=default
auto get_opmon_id () const noexcept
auto get_opmon_level () const noexcept

Additional Inherited Members

Public Types inherited from dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >
using RDT = ReadoutType
using LBT = LatencyBufferType
using RequestResult
using ResultCode
Public Types inherited from dunedaq::opmonlib::MonitorableObject
using NodePtr = std::weak_ptr<MonitorableObject>
using NewNodePtr = std::shared_ptr<MonitorableObject>
using ElementId = std::string
Static Public Member Functions inherited from dunedaq::opmonlib::MonitorableObject
static bool publishable_metric (OpMonLevel entry, OpMonLevel system) noexcept
Protected Types inherited from dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >
enum  ResultCode {
  kFound = 0 , kNotFound , kTooOld , kNotYet ,
  kPartial , kPartiallyOld , kCleanup , kUnknown
}
Protected Member Functions inherited from dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >
daqdataformats::FragmentHeader create_fragment_header (const dfmessages::DataRequest &dr)
std::unique_ptr< daqdataformats::Fragment > create_empty_fragment (const dfmessages::DataRequest &dr)
void dump_to_buffer (const void *data, std::size_t size, void *buffer, uint32_t buffer_pos, const std::size_t &buffer_size)
void periodic_cleanups ()
void periodic_data_transmissions ()
void cleanup ()
void check_waiting_requests ()
std::vector< std::pair< void *, size_t > > get_fragment_pieces (uint64_t start_win_ts, uint64_t end_win_ts, RequestResult &rres)
RequestResult data_request (dfmessages::DataRequest dr) override
virtual void generate_opmon_data () override
Protected Member Functions inherited from dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >
const std::string & resultCodeAsString (ResultCode rc)
Protected Member Functions inherited from dunedaq::opmonlib::MonitorableObject
 MonitorableObject ()=default
void register_node (ElementId name, NewNodePtr)
void publish (google::protobuf::Message &&, CustomOrigin &&co={}, OpMonLevel l=to_level(EntryOpMonLevel::kDefault)) const noexcept
Protected Attributes inherited from dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >
std::shared_ptr< LatencyBufferType > & m_latency_buffer
BufferedFileWriter m_buffered_writer
utilities::ReusableThread m_recording_thread
utilities::ReusableThread m_cleanup_thread
utilities::ReusableThread m_periodic_transmission_thread
std::map< dfmessages::DataRequest, int > m_request_counter
std::mutex m_cv_mutex
std::condition_variable m_cv
std::atomic< bool > m_cleanup_requested = false
std::atomic< int > m_requests_running = 0
std::vector< RequestElement > m_waiting_requests
std::mutex m_waiting_requests_lock
std::unique_ptr< boost::asio::thread_pool > m_request_handler_thread_pool
size_t m_num_request_handling_threads = 0
std::unique_ptr< FrameErrorRegistry > & m_error_registry
std::chrono::time_point< std::chrono::high_resolution_clock > m_t0
std::atomic< bool > m_run_marker = false
std::thread m_waiting_queue_thread
std::atomic< bool > m_recording = false
std::atomic< uint64_t > m_next_timestamp_to_record = std::numeric_limits<uint64_t>::max()
bool m_configured
float m_pop_limit_pct
float m_pop_size_pct
unsigned m_pop_limit_size
size_t m_buffer_capacity
daqdataformats::SourceID m_sourceid
uint16_t m_detid
std::string m_output_file
size_t m_stream_buffer_size = 0
bool m_recording_configured = false
bool m_warn_on_timeout = true
bool m_warn_about_empty_buffer = true
uint32_t m_periodic_data_transmission_ms = 0
std::vector< std::string > m_frag_out_conn_ids
std::atomic< int > m_pop_counter
std::atomic< int > m_num_buffer_cleanups { 0 }
std::atomic< int > m_pop_reqs
std::atomic< int > m_pops_count
std::atomic< int > m_occupancy
std::atomic< int > m_num_requests_found { 0 }
std::atomic< int > m_num_requests_bad { 0 }
std::atomic< int > m_num_requests_old_window { 0 }
std::atomic< int > m_num_requests_delayed { 0 }
std::atomic< int > m_num_requests_uncategorized { 0 }
std::atomic< int > m_num_requests_timed_out { 0 }
std::atomic< int > m_handled_requests { 0 }
std::atomic< int > m_response_time_acc { 0 }
std::atomic< int > m_response_time_min { std::numeric_limits<int>::max() }
std::atomic< int > m_response_time_max { 0 }
std::atomic< int > m_payloads_written { 0 }
std::atomic< int > m_bytes_written { 0 }
std::atomic< uint64_t > m_num_periodic_sent { 0 }
std::atomic< uint64_t > m_num_periodic_send_failed { 0 }
std::atomic< uint64_t > m_oldest_timestamp { 0 }
int m_fragment_send_timeout_ms
Protected Attributes inherited from dunedaq::datahandlinglibs::RequestHandlerConcept< ReadoutType, LatencyBufferType >
std::map< ResultCode, std::string > ResultCodeStrings

Detailed Description

template<class ReadoutType, class LatencyBufferType>
class dunedaq::datahandlinglibs::test::TestDefaultRequestHandlerModel< ReadoutType, LatencyBufferType >

Definition at line 180 of file TestUtilities.hpp.

Constructor & Destructor Documentation

◆ TestDefaultRequestHandlerModel()

template<class ReadoutType, class LatencyBufferType>
dunedaq::datahandlinglibs::test::TestDefaultRequestHandlerModel< ReadoutType, LatencyBufferType >::TestDefaultRequestHandlerModel ( std::shared_ptr< LatencyBufferType > & latency_buffer,
std::unique_ptr< dunedaq::datahandlinglibs::FrameErrorRegistry > & error_registry )
inline

Definition at line 183 of file TestUtilities.hpp.

185 : dunedaq::datahandlinglibs::DefaultRequestHandlerModel<ReadoutType, LatencyBufferType>(latency_buffer,error_registry) {}
The documentation for this class was generated from the following file:
Generated on for DUNE-DAQ by doxygen 1.16.1