dataAcquisitionImpl.h

/*
 * Nominal Device Support v3 (NDS3)
 *
 * Copyright (c) 2015 Cosylab d.d.
 *
 * For more information about the license please refer to the license.txt
 * file included in the distribution.
 */

#ifndef NDSDATAACQUISITIONIMPL_H
#define NDSDATAACQUISITIONIMPL_H

#include <memory>
#include "nds3/definitions.h"
#include "nds3/impl/nodeImpl.h"

namespace nds
{

template <typename T> class PVVariableInImpl;
template <typename T> class PVVariableOutImpl;


template<typename T>
class DataAcquisitionImpl: public NodeImpl
{
public:
    DataAcquisitionImpl(const std::string& name,
                    size_t maxElements,
                    stateChange_t switchOnFunction,
                    stateChange_t switchOffFunction,
                    stateChange_t startFunction,
                    stateChange_t stopFunction,
                    stateChange_t recoverFunction,
                    allowChange_t allowStateChangeFunction);

    void setStartTimestampDelegate(getTimestampPlugin_t timestampDelegate);

    void push(const timespec& timestamp, const T& data);

    double getFrequencyHz();
    double getDurationSeconds();
    double getAmplitude();
    double getOffset();
    size_t getMaxElements();
    size_t getDecimation();
    size_t getSamplingMode();
    size_t getGround();

    timespec getStartTimestamp() const;

    void onStart();


protected:
    stateChange_t m_onStartDelegate;

    getTimestampPlugin_t m_startTimestampFunction;

    timespec m_startTime;

    // PVs
    std::shared_ptr<PVVariableInImpl<T> > m_dataPV;
    std::shared_ptr<PVVariableOutImpl<double> > m_frequencyPV;
    std::shared_ptr<PVVariableOutImpl<double> > m_durationPV;
    std::shared_ptr<PVVariableOutImpl<double> > m_amplitudePV;
    std::shared_ptr<PVVariableOutImpl<double> > m_offsetPV;
    std::shared_ptr<PVVariableOutImpl<std::int32_t> > m_decimationPV;
    std::shared_ptr<PVVariableOutImpl<std::int32_t> > m_samplingmodePV;
    std::shared_ptr<PVVariableOutImpl<std::int32_t> > m_groundPV;
    std::shared_ptr<StateMachineImpl> m_stateMachine;



};

}
#endif // NDSDATAACQUISITIONIMPL_H