daq::dpm::DpmService Class Reference

daqif::DpmControl and DpmDaqControl implementation. More...

#include <dpmService.hpp>

Inheritance diagram for daq::dpm::DpmService:

Public Member Functions
	DpmService (rad::IoExecutor &executor, elt::mal::Mal &mal, Workspace &workspace, Scheduler &scheduler)
	Construct replier.
AsyncDpmControl
boost::future< std::shared_ptr<::daqif::StorageStatus > >	QueryStorageStatus () override
	Cancels any started merges and terminates application.
boost::future< std::string >	Exit () override
	Cancels any started merges and terminates application.
boost::future< std::string >	GetVersion () override
	Cancels any started merges and terminates application.
AsyncDpmDaqControl
boost::future< std::shared_ptr<::daqif::DaqReply > >	QueueDaq (std::string const &status, std::string const &specification) override
boost::future< std::shared_ptr<::daqif::DaqReply > >	AbortDaq (const std::string &id) override
boost::future< std::shared_ptr<::daqif::DaqStatus > >	GetDaqStatus (const std::string &id) override
boost::future< std::vector< std::shared_ptr<::daqif::DaqStatus > > >	GetActiveDaqs () override
boost::future< std::string >	GetInternalDaqStatus (const std::string &id) override

Static Public Attributes
static constexpr char const *	LOGGER_NAME = "dpm.replier"

Detailed Description

daqif::DpmControl and DpmDaqControl implementation.

It is mainly responsible for acting as gateway between CII and rest of application.

Aspects to consider

• "Requests" are method calls from foreign thread -> requires synchronization, typically by posting to main thread via io_context.
• Accept requests and transform CII arguments to application format.

Definition at line 39 of file dpmService.hpp.

Constructor & Destructor Documentation

DpmService()

daq::dpm::DpmService::DpmService	(	rad::IoExecutor &	executor,
		elt::mal::Mal &	mal,
		Workspace &	workspace,
		Scheduler &	scheduler
	)

Construct replier.

Parameters

executor

Executor to use, including the native asio::io_context.

Definition at line 27 of file dpmService.cpp.

Member Function Documentation

AbortDaq()

boost::future< std::shared_ptr<::daqif::DaqReply > > daq::dpm::DpmService::AbortDaq ( const std::string &  id )

override

Definition at line 106 of file dpmService.cpp.

Exit()

boost::future< std::string > daq::dpm::DpmService::Exit ( )

override

Cancels any started merges and terminates application.

Returns

future that is set only after all other active operations are cancelled.

Definition at line 59 of file dpmService.cpp.

GetActiveDaqs()

boost::future< std::vector< std::shared_ptr<::daqif::DaqStatus > > > daq::dpm::DpmService::GetActiveDaqs ( )

override

Definition at line 176 of file dpmService.cpp.

GetDaqStatus()

boost::future< std::shared_ptr<::daqif::DaqStatus > > daq::dpm::DpmService::GetDaqStatus ( const std::string &  id )

override

Definition at line 134 of file dpmService.cpp.

GetInternalDaqStatus()

boost::future< std::string > daq::dpm::DpmService::GetInternalDaqStatus ( const std::string &  id )

override

Definition at line 153 of file dpmService.cpp.

GetVersion()

boost::future< std::string > daq::dpm::DpmService::GetVersion ( )

override

Cancels any started merges and terminates application.

Returns

future that is set only after all other active operations are cancelled.

Definition at line 71 of file dpmService.cpp.

QueryStorageStatus()

boost::future< std::shared_ptr<::daqif::StorageStatus > > daq::dpm::DpmService::QueryStorageStatus ( )

override

Cancels any started merges and terminates application.

Returns

future that is set only after all other active operations are cancelled.

Definition at line 41 of file dpmService.cpp.

QueueDaq()

boost::future< std::shared_ptr<::daqif::DaqReply > > daq::dpm::DpmService::QueueDaq ( std::string const &  status, std::string const &  specification  )

override

Definition at line 76 of file dpmService.cpp.

Member Data Documentation

LOGGER_NAME

constexpr char const* daq::dpm::DpmService::LOGGER_NAME = "dpm.replier"

staticconstexpr

Definition at line 41 of file dpmService.hpp.

---

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

• dpm/libdpm/src/include/daq/dpm/dpmService.hpp
• dpm/libdpm/src/dpmService.cpp