pvBaseInImpl.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 NDSPVBASEINIMPL_H
#define NDSPVBASEINIMPL_H

#include <string>
#include <set>
#include <mutex>
#include "nds3/definitions.h"
#include "nds3/impl/baseImpl.h"
#include "nds3/impl/pvBaseImpl.h"

namespace nds
{

class PVBase;
class PVBaseOutImpl;

class PVBaseInImpl: public PVBaseImpl
{
public:
    PVBaseInImpl(const std::string& name, const inputPvType_t pvType);

    virtual void initialize(FactoryBaseImpl& controlSystem);

    virtual void deinitialize();

    virtual void read(timespec* pTimestamp, std::int32_t* pValue) const;
    virtual void read(timespec* pTimestamp, double* pValue) const;
    virtual void read(timespec* pTimestamp, std::vector<std::int8_t>* pValue) const;
    virtual void read(timespec* pTimestamp, std::vector<std::uint8_t>* pValue) const;
    virtual void read(timespec* pTimestamp, std::vector<std::int32_t>* pValue) const;
    virtual void read(timespec* pTimestamp, std::vector<double>* pValue) const;
    virtual void read(timespec* pTimestamp, std::string* pValue) const;

    template<typename T>
    void push(const timespec& timestamp, const T& value);

    void subscribeReceiver(PVBaseOutImpl* pReceiver);

    void unsubscribeReceiver(PVBaseOutImpl* pReceiver);

    void replicateTo(PVBaseInImpl* pDestination);

    void stopReplicationTo(PVBaseInImpl* pDestination);

    void setDecimation(const std::uint32_t decimation);

    void replicateFrom(const std::string& sourceInputPVName);

    virtual dataDirection_t getDataDirection() const;

    virtual std::string buildFullExternalName(const FactoryBaseImpl& controlSystem) const;
    virtual std::string buildFullExternalNameFromPort(const FactoryBaseImpl& controlSystem) const;

protected:
    std::string buildFullExternalName(const FactoryBaseImpl& controlSystem, const bool bStopAtPort) const;

    inputPvType_t m_pvType;

    typedef std::set<PVBaseOutImpl*> subscribersList_t;

    subscribersList_t m_subscriberOutputPVs;

    typedef std::set<PVBaseInImpl*> destinationList_t;

    destinationList_t m_replicationDestinationPVs;

    std::mutex m_lockSubscribersList; 

    std::uint32_t m_decimationFactor;  
    std::uint32_t m_decimationCount;   

private:
    parameters_t commandReplicate(const parameters_t& parameters);
    parameters_t commandDecimation(const parameters_t& parameters);

};

}
#endif // NDSPVBASEINIMPL_H