daq::DpmClientImpl Class Reference

#include <dpmClient.hpp>

Inheritance diagram for daq::DpmClientImpl:

Classes
struct	Subscriptions

Public Types
using	StorageSignal = DpmClient::StorageSignal
using	StatusSignal = DpmClient::StatusSignal
Public Types inherited from daq::DpmClient
using	StorageSignal = boost::signals2::signal< void(std::filesystem::space_info)>
using	StatusSignal = boost::signals2::signal< void(Status)>

Public Member Functions
	DpmClientImpl (boost::asio::io_context &io_ctx, mal::Mal &mal, DpmClientParams params)
	~DpmClientImpl ()
virtual auto	ScheduleAsync (std::string const &spec) -> boost::future< State > override
	Schedule merging. More...
virtual auto	AbortAsync (std::string const &id) -> boost::future< State > override
	Abort merging. More...
virtual auto	ConnectStatusSignal (StatusSignal::slot_type const &slot) -> boost::signals2::connection override
	Connect slot to status change signal. More...
virtual auto	ConnectStorageSignal (StorageSignal::slot_type const &slot) -> boost::signals2::connection override
	Connect slot to storage change signal. More...

Detailed Description

Definition at line 80 of file dpmClient.hpp.

---

Class Documentation

daq::DpmClientImpl::Subscriptions

struct daq::DpmClientImpl::Subscriptions

Definition at line 21 of file dpmClient.cpp.

Class Members
shared_ptr< bool >	alive
Subscription< DaqStatus >	status
Subscription< StorageStatus >	storage

Member Typedef Documentation

StatusSignal

using daq::DpmClientImpl::StatusSignal = DpmClient::StatusSignal

Definition at line 83 of file dpmClient.hpp.

StorageSignal

using daq::DpmClientImpl::StorageSignal = DpmClient::StorageSignal

Definition at line 82 of file dpmClient.hpp.

Constructor & Destructor Documentation

DpmClientImpl()

daq::DpmClientImpl::DpmClientImpl	(	boost::asio::io_context &	io_ctx,
		mal::Mal &	mal,
		DpmClientParams	params
	)

Definition at line 27 of file dpmClient.cpp.

~DpmClientImpl()

daq::DpmClientImpl::~DpmClientImpl ( )

default

Member Function Documentation

AbortAsync()

auto daq::DpmClientImpl::AbortAsync ( std::string const &  id ) -> boost::future<State>

overridevirtual

Abort merging.

Implements daq::DpmClient.

Definition at line 97 of file dpmClient.cpp.

ConnectStatusSignal()

auto daq::DpmClientImpl::ConnectStatusSignal ( StatusSignal::slot_type const &  slot ) -> boost::signals2::connection

overridevirtual

Connect slot to status change signal.

DpmClient ensures that signals are only emitted from main thread.

Implements daq::DpmClient.

Definition at line 106 of file dpmClient.cpp.

ConnectStorageSignal()

auto daq::DpmClientImpl::ConnectStorageSignal ( StorageSignal::slot_type const &  slot ) -> boost::signals2::connection

overridevirtual

Connect slot to storage change signal.

DpmClient ensures that signals are only emitted from main thread.

Implements daq::DpmClient.

Definition at line 111 of file dpmClient.cpp.

ScheduleAsync()

auto daq::DpmClientImpl::ScheduleAsync ( std::string const &  spec ) -> boost::future<State>

overridevirtual

Schedule merging.

Implements daq::DpmClient.

Definition at line 88 of file dpmClient.cpp.

---

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

• common/libdaq/src/include/daq/dpmClient.hpp
• common/libdaq/src/dpmClient.cpp