start.hpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_common_libdaq
 * @copyright 2022 ESO - European Southern Observatory
 *
 * @brief Contains declaration for the StartAsync operation
 */
#ifndef OCM_DAQ_OP_START_HPP_
#define OCM_DAQ_OP_START_HPP_
#include "../config.hpp"
#include "../dpPart.hpp"
#include "asyncOpParams.hpp"
 
#include <vector>
#include <chrono>
 
#include <boost/thread/future.hpp>
 
namespace daq::op {
 
/**
 * Keeps record when operation started and finished
 */
struct OpStat {
 
    std::chrono::time_point<std::chrono::steady_clock> begin;
    std::chrono::time_point<std::chrono::steady_clock> end;
 
};
 
/**
 * A composite async operation that starts DAQ
 *
 * @ingroup daq_common_libdaq
 */
struct StartAsync {
    explicit StartAsync(AsyncOpParams params) noexcept;
 
    /**
     * Initiates operation that starts metadata acquisition.
     *
     * @post Async operation has been initated.
     *
     * @returns future that is set on failure when when primary data acquisition has started.
     *
     * @note Caller is responsible for keeping object alive until
     * result is set.
     */
    [[nodiscard]] boost::future<void> Initiate();
 
private:
    [[nodiscard]] boost::future<void> StartMeta();
    [[nodiscard]] boost::future<void> StartPrim();
 
    AsyncOpParams m_params;
};
 
}  // namespace daq::op
 
#endif  // #ifndef OCM_DAQ_OP_START_HPP_