IBufferAdapter.hpp

Go to the documentation of this file.

#ifndef I_BUFFER_ADAPTER_HPP
#define I_BUFFER_ADAPTER_HPP

#include "IAdapter.hpp"

#include <map>
#include <string>
#include <vector>

#include <boost/shared_ptr.hpp>
#include <boost/thread/shared_mutex.hpp>

namespace freedm {
namespace broker {
namespace device {

class IBufferAdapter
    : public virtual IAdapter
{
public:
    typedef boost::shared_ptr<IBufferAdapter> Pointer;

    void SetCommand(const std::string device, const std::string signal,
            const SignalValue value);

    SignalValue GetState(const std::string device, const std::string signal) const;

    void RegisterStateInfo(const std::string device, const std::string signal,
            const std::size_t index);

    void RegisterCommandInfo(const std::string device, const std::string signal,
            const std::size_t index);

    void Start();

    virtual ~IBufferAdapter();
protected:
    IBufferAdapter();

    std::map<const DeviceSignal, const std::size_t> m_stateInfo;

    std::map<const DeviceSignal, const std::size_t> m_commandInfo;

    std::vector<SignalValue> m_rxBuffer;

    std::vector<SignalValue> m_txBuffer;

    mutable boost::shared_mutex m_rxMutex;

    mutable boost::shared_mutex m_txMutex;

    bool m_buffer_initialized;
};

} // namespace device
} // namespace broker
} // namespace freedm

#endif // I_BUFFER_ADAPTER_HPP