#include <DAPHNEListRequestHandler.hpp>

Inheritance diagram for dunedaq::fdreadoutlibs::DAPHNEListRequestHandler:

Collaboration diagram for dunedaq::fdreadoutlibs::DAPHNEListRequestHandler:

Public Types
using	inherited

using	SkipListAcc = typename folly::ConcurrentSkipList<types::DAPHNESuperChunkTypeAdapter>::Accessor

using	SkipListSkip = typename folly::ConcurrentSkipList<types::DAPHNESuperChunkTypeAdapter>::Skipper

Public Types inherited from dunedaq::datahandlinglibs::DefaultRequestHandlerModel< types::DAPHNESuperChunkTypeAdapter, datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > >
using	RDT

using	LBT

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
	DAPHNEListRequestHandler (std::shared_ptr< datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > > &latency_buffer, std::unique_ptr< datahandlinglibs::FrameErrorRegistry > &error_registry)

Public Member Functions inherited from dunedaq::datahandlinglibs::DefaultRequestHandlerModel< types::DAPHNESuperChunkTypeAdapter, datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > >
	DefaultRequestHandlerModel (std::shared_ptr< datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > > &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< types::DAPHNESuperChunkTypeAdapter, datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > >
	RequestHandlerConcept ()

	RequestHandlerConcept (const RequestHandlerConcept &)=delete
	RequestHandlerConcept is not copy-constructible.

	RequestHandlerConcept (RequestHandlerConcept &&)=delete
	RequestHandlerConcept is not move-constructible.

virtual	~RequestHandlerConcept ()

RequestHandlerConcept &	operator= (const RequestHandlerConcept &)=delete
	RequestHandlerConcept is not copy-assginable.

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

Protected Member Functions
void	cleanup () override

void	daphne_cleanup_request ()

Protected Member Functions inherited from dunedaq::datahandlinglibs::DefaultRequestHandlerModel< types::DAPHNESuperChunkTypeAdapter, datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > >
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< types::DAPHNESuperChunkTypeAdapter, datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > >
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

Private Attributes
std::atomic< int >	m_found_requested_count { 0 }

std::atomic< int >	m_bad_requested_count { 0 }

Static Private Attributes
static const constexpr uint64_t	m_max_ts_diff = 10000000

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< types::DAPHNESuperChunkTypeAdapter, datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > >
enum	ResultCode

Protected Attributes inherited from dunedaq::datahandlinglibs::DefaultRequestHandlerModel< types::DAPHNESuperChunkTypeAdapter, datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > >
std::shared_ptr< datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > > &	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

std::atomic< int >	m_requests_running

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

std::unique_ptr< FrameErrorRegistry > &	m_error_registry

std::chrono::time_point< std::chrono::high_resolution_clock >	m_t0

std::atomic< bool >	m_run_marker

std::thread	m_waiting_queue_thread

std::atomic< bool >	m_recording

std::atomic< uint64_t >	m_next_timestamp_to_record

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

bool	m_recording_configured

bool	m_warn_on_timeout

bool	m_warn_about_empty_buffer

uint32_t	m_periodic_data_transmission_ms

std::vector< std::string >	m_frag_out_conn_ids

std::atomic< int >	m_pop_counter

std::atomic< int >	m_num_buffer_cleanups

std::atomic< int >	m_pop_reqs

std::atomic< int >	m_pops_count

std::atomic< int >	m_occupancy

std::atomic< int >	m_num_requests_found

std::atomic< int >	m_num_requests_bad

std::atomic< int >	m_num_requests_old_window

std::atomic< int >	m_num_requests_delayed

std::atomic< int >	m_num_requests_uncategorized

std::atomic< int >	m_num_requests_timed_out

std::atomic< int >	m_handled_requests

std::atomic< int >	m_response_time_acc

std::atomic< int >	m_response_time_min

std::atomic< int >	m_response_time_max

std::atomic< int >	m_payloads_written

std::atomic< int >	m_bytes_written

std::atomic< uint64_t >	m_num_periodic_sent

std::atomic< uint64_t >	m_num_periodic_send_failed

std::atomic< uint64_t >	m_oldest_timestamp

int	m_fragment_send_timeout_ms

Protected Attributes inherited from dunedaq::datahandlinglibs::RequestHandlerConcept< types::DAPHNESuperChunkTypeAdapter, datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > >
std::map< ResultCode, std::string >	ResultCodeStrings

Detailed Description

Definition at line 40 of file DAPHNEListRequestHandler.hpp.

Member Typedef Documentation

◆ inherited

using dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::inherited

Initial value:

 
    datahandlinglibs::DefaultRequestHandlerModel<types::DAPHNESuperChunkTypeAdapter,
                                            datahandlinglibs::SkipListLatencyBufferModel<types::DAPHNESuperChunkTypeAdapter>>

Definition at line 47 of file DAPHNEListRequestHandler.hpp.

◆ SkipListAcc

using dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::SkipListAcc = typename folly::ConcurrentSkipList<types::DAPHNESuperChunkTypeAdapter>::Accessor

Definition at line 50 of file DAPHNEListRequestHandler.hpp.

◆ SkipListSkip

using dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::SkipListSkip = typename folly::ConcurrentSkipList<types::DAPHNESuperChunkTypeAdapter>::Skipper

Definition at line 51 of file DAPHNEListRequestHandler.hpp.

Constructor & Destructor Documentation

◆ DAPHNEListRequestHandler()

dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::DAPHNEListRequestHandler	(	std::shared_ptr< datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > > &	latency_buffer,
		std::unique_ptr< datahandlinglibs::FrameErrorRegistry > &	error_registry )

inline

Definition at line 54 of file DAPHNEListRequestHandler.hpp.

    : DefaultRequestHandlerModel<types::DAPHNESuperChunkTypeAdapter,
                                 datahandlinglibs::SkipListLatencyBufferModel<types::DAPHNESuperChunkTypeAdapter>>(
        latency_buffer,
        error_registry)
  {
    TLOG_DEBUG(TLVL_WORK_STEPS) << "DAPHNEListRequestHandler created...";
  }

Member Function Documentation

◆ cleanup()

void dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::cleanup ( )

inlineoverrideprotectedvirtual

Implements dunedaq::datahandlinglibs::RequestHandlerConcept< types::DAPHNESuperChunkTypeAdapter, datahandlinglibs::SkipListLatencyBufferModel< types::DAPHNESuperChunkTypeAdapter > >.

Definition at line 67 of file DAPHNEListRequestHandler.hpp.

67{ daphne_cleanup_request(); }

dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::daphne_cleanup_request

void daphne_cleanup_request()

◆ daphne_cleanup_request()

void dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::daphne_cleanup_request ( )

protected

Member Data Documentation

◆ m_bad_requested_count

std::atomic<int> dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::m_bad_requested_count { 0 }

private

Definition at line 78 of file DAPHNEListRequestHandler.hpp.

78{ 0 };

◆ m_found_requested_count

std::atomic<int> dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::m_found_requested_count { 0 }

private

Definition at line 77 of file DAPHNEListRequestHandler.hpp.

77{ 0 };

◆ m_max_ts_diff

const constexpr uint64_t dunedaq::fdreadoutlibs::DAPHNEListRequestHandler::m_max_ts_diff = 10000000

staticconstexprprivate

Definition at line 74 of file DAPHNEListRequestHandler.hpp.

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

/github/workspace/dunedaq/sourcecode/fdreadoutlibs/include/fdreadoutlibs/daphne/DAPHNEListRequestHandler.hpp

Public Types

Public Member Functions

Protected Member Functions

Private Attributes

Static Private Attributes

Additional Inherited Members