ifw-daq
3.0.0-pre2
IFW Data Acquisition modules
|
#include <mockAsyncProcess.hpp>
Public Types | |
using | SigProgress = boost::signals2::signal< void(pid_t, RsyncProgress const &)> |
Progress update signal. More... | |
Public Types inherited from daq::RsyncAsyncProcessIf | |
enum class | DryRun { Disabled = 0 , Enabled } |
using | SigProgress = boost::signals2::signal< void(pid_t, RsyncProgress const &)> |
Progress update signal. More... | |
Public Types inherited from daq::AsyncProcessIf | |
using | SigOutStream = boost::signals2::signal< void(pid_t, std::string const &)> |
Signal type for stdout/stderr signals. More... | |
Public Types inherited from daq::MockAsyncProcess | |
using | SigOutStream = boost::signals2::signal< void(pid_t, std::string const &)> |
Signal type for stdout/stderr signals. More... | |
Public Member Functions | |
boost::signals2::connection | ConnectProgress (SigProgress::slot_type const &slot) override |
Connect to progress signal. More... | |
Public Member Functions inherited from daq::RsyncAsyncProcessIf | |
virtual | ~RsyncAsyncProcessIf () |
Public Member Functions inherited from daq::AsyncProcessIf | |
virtual | ~AsyncProcessIf () |
virtual std::optional< pid_t > | GetPid () const noexcept=0 |
Get PID. More... | |
virtual std::error_code | Abort () noexcept=0 |
Aborts the operation by terminating process which completes the operation. More... | |
virtual std::error_code | Signal (int sig) noexcept=0 |
Send signal to process. More... | |
virtual std::vector< std::string > const & | GetArguments () const noexcept=0 |
virtual bool | IsRunning () const noexcept=0 |
Public Member Functions inherited from daq::MockAsyncProcess | |
virtual boost::future< int > | Initiate () override |
Initiates async operation by executing the specified process. More... | |
MOCK_METHOD (std::optional< pid_t >, GetPid,(),(const, noexcept, override)) | |
MOCK_METHOD (std::error_code, Abort,(),(noexcept, override)) | |
MOCK_METHOD (std::error_code, Signal,(int),(override, noexcept)) | |
MOCK_METHOD (std::vector< std::string > const &, GetArguments,(),(const, override, noexcept)) | |
MOCK_METHOD (bool, IsRunning,(),(const, noexcept, override)) | |
boost::signals2::connection | ConnectStdout (SigOutStream::slot_type const &slot) override |
Connect slot to line-buffered stdout signal. More... | |
boost::signals2::connection | ConnectStderr (SigOutStream::slot_type const &slot) override |
Connect slot to line-buffered stderr signal. More... | |
Public Attributes | |
SigProgress | progress |
Public Attributes inherited from daq::MockAsyncProcess | |
SigOutStream | stdout |
SigOutStream | stderr |
boost::promise< int > | promise |
Definition at line 45 of file mockAsyncProcess.hpp.
using daq::RsyncAsyncProcessIf::SigProgress = boost::signals2::signal<void(pid_t, RsyncProgress const&)> |
Progress update signal.
Definition at line 86 of file rsyncAsyncProcess.hpp.
|
inlineoverridevirtual |
Connect to progress signal.
Implements daq::RsyncAsyncProcessIf.
Definition at line 47 of file mockAsyncProcess.hpp.
SigProgress daq::MockRsyncAsyncProcess::progress |
Definition at line 50 of file mockAsyncProcess.hpp.