dataAcquisition.hpp

Go to the documentation of this file.

// SPDX-FileCopyrightText: 2020-2025 European Southern Observatory (ESO)
//
// SPDX-License-Identifier: LGPL-3.0-only
 
#ifndef HLCC_TELIF_TELIF_DATAACQUISITION_HPP
#define HLCC_TELIF_TELIF_DATAACQUISITION_HPP
 
#include <vector>
#include <list>
#include <chrono>
#include <memory>
#include <mutex>
 
#include <Metadaqif.hpp>
 
#include "telif/logger.hpp"
#include "telif/oldbInterface.hpp"
#include "telif/dataAcquisitionFits.hpp"
 
 
namespace hlcc::telif {
 
class DataAcquisition {
public:
 
    enum DaqCmds {
        DC_START,
        DC_STOP,
        DC_ABORT,
    };
 
    DataAcquisition(OldbInterface &oldbif, const std::string &id);
 
    virtual ~DataAcquisition();
 
    bool ProcessCommand(DaqCmds command);
 
    const std::string &GetId() const;
 
    const metadaqif::DaqState &GetState() const;
 
    std::string GetStateStr() const;
 
    const std::string &GetMessage() const;
 
    const std::vector<std::string> &GetFiles() const;
 
    std::string GetKeywords();
 
    uint64_t GetTimestamp() const;
 
    DataAcquisition() = delete;                                   
    DataAcquisition(const DataAcquisition&) = delete;             
    DataAcquisition& operator=(const DataAcquisition&) = delete;  
 
private:
    OldbInterface& m_oldb_interface;
    std::string m_id;                   /* Unique data acquisition identifier */
    metadaqif::DaqState m_state;        /* Data acquisitions status enumeration */
    std::string m_message;              /* If DAQ failed this field should contain a message with details */
    std::vector<std::string> m_files;   /* If DAQ succeeds this enumerates the produced files */
    uint64_t m_timestamp;               /* Timestamp of last status update (DAQ state change) */
    FitsKeywords m_fits_keywords;
 
    bool SetState(metadaqif::DaqState new_state);
 
    bool SetMessage(const std::string &mmessage);
 
    bool SetFiles(const std::vector<std::string> &mfiles);
 
};
 
class DataAcquisitionList {
public:
 
    DataAcquisitionList();
 
    int GetNumberAcquisitions();
 
    std::shared_ptr<DataAcquisition> GetAcquisition(const std::string &given_id);
 
    std::shared_ptr<DataAcquisition> CreateAcquisition(OldbInterface& moldbif, std::string given_id);
 
    bool RemoveAcquisition(const std::string &given_id);
 
    DataAcquisitionList(const DataAcquisitionList&) = delete;               
    DataAcquisitionList& operator= (const DataAcquisitionList&) = delete;   
 
private:
    std::list<std::shared_ptr<DataAcquisition>> m_daq_list; /* List of all active acquisitions */
    const unsigned int max_number_acquisitions;
};
 
}  // namespace hlcc::telif
 
#endif  // HLCC_TELIF_TELIF_DATAACQUISITION_HPP