daq::DpmClient Class Reference

Interface to DPM server. More...

#include <dpmClient.hpp>

Inheritance diagram for daq::DpmClient:

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

Public Member Functions
virtual auto	ScheduleAsync (std::string const &spec) -> boost::future< State >=0
	Schedule merging. More...
virtual auto	AbortAsync (std::string const &id) -> boost::future< State >=0
	Abort merging. More...
virtual void	StartMonitorStatus (std::string const &id)=0
	Start monitoring DAQ status. More...
virtual void	StopMonitorStatus (std::string const &id)=0
	Stop monitoring DAQ status. More...
virtual auto	ConnectStatusSignal (StatusSignal::slot_type const &slot) -> boost::signals2::connection=0
	Connect slot to status change signal. More...
virtual auto	ConnectStorageSignal (StorageSignal::slot_type const &slot) -> boost::signals2::connection=0
	Connect slot to storage change signal. More...

Detailed Description

Interface to DPM server.

Any implementation is expected to also provide a subscriber for DPM status and storage change signals.

Definition at line 41 of file dpmClient.hpp.

Member Typedef Documentation

StatusSignal

using daq::DpmClient::StatusSignal = boost::signals2::signal<void(Status)>

Definition at line 44 of file dpmClient.hpp.

StorageSignal

using daq::DpmClient::StorageSignal = boost::signals2::signal<void(std::filesystem::space_info)>

Definition at line 43 of file dpmClient.hpp.

Member Function Documentation

AbortAsync()

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

pure virtual

Abort merging.

Implemented in daq::DpmClientImpl.

ConnectStatusSignal()

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

pure virtual

Connect slot to status change signal.

DpmClient ensures that signals are only emitted from main thread.

Implemented in daq::DpmClientMock, and daq::DpmClientImpl.

ConnectStorageSignal()

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

pure virtual

Connect slot to storage change signal.

DpmClient ensures that signals are only emitted from main thread.

Implemented in daq::DpmClientMock, and daq::DpmClientImpl.

ScheduleAsync()

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

pure virtual

Schedule merging.

Implemented in daq::DpmClientImpl.

StartMonitorStatus()

virtual void daq::DpmClient::StartMonitorStatus ( std::string const &  id )

pure virtual

Start monitoring DAQ status.

Status is requested:

• Initially.
• Periodically.

Changes are reported via the StatusSignal.

Implemented in daq::DpmClientImpl.

StopMonitorStatus()

virtual void daq::DpmClient::StopMonitorStatus ( std::string const &  id )

pure virtual

Stop monitoring DAQ status.

Implemented in daq::DpmClientImpl.

---

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

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