#include <EmptyFragmentRequestHandlerModel.hpp>

Inheritance diagram for dunedaq::datahandlinglibs::EmptyFragmentRequestHandlerModel< ReadoutType, LatencyBufferType >:

Collaboration diagram for dunedaq::datahandlinglibs::EmptyFragmentRequestHandlerModel< ReadoutType, LatencyBufferType >:

[legend]

Public Types
using	inherited = DefaultRequestHandlerModel<ReadoutType, LatencyBufferType>

using	RequestResult

using	ResultCode

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

Public Member Functions
	EmptyFragmentRequestHandlerModel (std::shared_ptr< LatencyBufferType > &latency_buffer, std::unique_ptr< FrameErrorRegistry > &error_registry)

void	issue_request (dfmessages::DataRequest datarequest, bool is_retry=false) override
	Issue a data request to the request handler.

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 nlohmann::json &) override

void	start (const nlohmann::json &)

void	stop (const nlohmann::json &)

void	record (const nlohmann::json &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.

virtual dunedaq::daqdataformats::timestamp_t	get_cutoff_timestamp ()

virtual bool	supports_cutoff_timestamp ()

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
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::size_t	m_max_requested_elements

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 }

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::EmptyFragmentRequestHandlerModel< ReadoutType, LatencyBufferType >

Definition at line 26 of file EmptyFragmentRequestHandlerModel.hpp.

Member Typedef Documentation

◆ inherited

template<class ReadoutType , class LatencyBufferType >

using dunedaq::datahandlinglibs::EmptyFragmentRequestHandlerModel< ReadoutType, LatencyBufferType >::inherited = DefaultRequestHandlerModel<ReadoutType, LatencyBufferType>

Definition at line 30 of file EmptyFragmentRequestHandlerModel.hpp.

◆ RequestResult

template<class ReadoutType , class LatencyBufferType >

using dunedaq::datahandlinglibs::EmptyFragmentRequestHandlerModel< ReadoutType, LatencyBufferType >::RequestResult

Initial value:

typename dunedaq::datahandlinglibs::RequestHandlerConcept<ReadoutType, LatencyBufferType>::RequestResult

dunedaq::datahandlinglibs::RequestHandlerConcept::RequestResult

Definition RequestHandlerConcept.hpp:81

Definition at line 31 of file EmptyFragmentRequestHandlerModel.hpp.

◆ ResultCode

template<class ReadoutType , class LatencyBufferType >

using dunedaq::datahandlinglibs::EmptyFragmentRequestHandlerModel< ReadoutType, LatencyBufferType >::ResultCode

Initial value:

typename dunedaq::datahandlinglibs::RequestHandlerConcept<ReadoutType, LatencyBufferType>::ResultCode

dunedaq::datahandlinglibs::RequestHandlerConcept::ResultCode

ResultCode

Definition RequestHandlerConcept.hpp:60

Definition at line 33 of file EmptyFragmentRequestHandlerModel.hpp.

Constructor & Destructor Documentation

◆ EmptyFragmentRequestHandlerModel()

template<class ReadoutType , class LatencyBufferType >

dunedaq::datahandlinglibs::EmptyFragmentRequestHandlerModel< ReadoutType, LatencyBufferType >::EmptyFragmentRequestHandlerModel	(	std::shared_ptr< LatencyBufferType > &	latency_buffer,
		std::unique_ptr< FrameErrorRegistry > &	error_registry )

inlineexplicit

Definition at line 38 of file EmptyFragmentRequestHandlerModel.hpp.

    : DefaultRequestHandlerModel<ReadoutType, LatencyBufferType>(latency_buffer, error_registry)
  {
    TLOG_DEBUG(TLVL_WORK_STEPS) << "EmptyFragmentRequestHandlerModel created...";
  }

Member Function Documentation

◆ issue_request()

template<class ReadoutType , class LatencyBufferType >

void dunedaq::datahandlinglibs::EmptyFragmentRequestHandlerModel< ReadoutType, LatencyBufferType >::issue_request	(	dfmessages::DataRequest	,
		bool	= false )

overridevirtual

Issue a data request to the request handler.

Reimplemented from dunedaq::datahandlinglibs::DefaultRequestHandlerModel< ReadoutType, LatencyBufferType >.

Definition at line 10 of file EmptyFragmentRequestHandlerModel.hxx.

{
  auto frag_header = inherited::create_fragment_header(datarequest);
  frag_header.error_bits |= (0x1 << static_cast<size_t>(daqdataformats::FragmentErrorBits::kDataNotFound));
  auto fragment = std::make_unique<daqdataformats::Fragment>(std::vector<std::pair<void*, size_t>>());
  fragment->set_header_fields(frag_header);
 
  // ers::warning(dunedaq::datahandlinglibs::TrmWithEmptyFragment(ERS_HERE, "DLH is configured to send empty fragment"));
  TLOG_DEBUG(TLVL_WORK_STEPS) << "DLH is configured to send empty fragment";
 
  try { // Push to Fragment queue
    TLOG_DEBUG(TLVL_QUEUE_PUSH) << "Sending fragment with trigger_number " << fragment->get_trigger_number()
                                << ", run number " << fragment->get_run_number() << ", and SourceID "
                                << fragment->get_element_id();
    //auto frag = std::make_pair(std::move(fragment), datarequest.data_destination);
    get_iom_sender<std::unique_ptr<daqdataformats::Fragment>>(datarequest.data_destination)
      ->send(std::move(fragment), inherited::m_fragment_send_timeout_ms);
  } catch (const ers::Issue& excpt) {
    ers::warning(CannotWriteToQueue(
      ERS_HERE, DefaultRequestHandlerModel<ReadoutType, LatencyBufferType>::m_sourceid, "fragment queue", excpt));
  }
}

The documentation for this class was generated from the following files:

/github/workspace/dunedaq/sourcecode/datahandlinglibs/include/datahandlinglibs/models/EmptyFragmentRequestHandlerModel.hpp
/github/workspace/dunedaq/sourcecode/datahandlinglibs/include/datahandlinglibs/models/detail/EmptyFragmentRequestHandlerModel.hxx

Public Types

Public Member Functions

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ inherited

◆ RequestResult

◆ ResultCode

Constructor & Destructor Documentation

◆ EmptyFragmentRequestHandlerModel()

Member Function Documentation

◆ issue_request()