CRtdsAdapter.hpp

Go to the documentation of this file.

#ifndef C_RTDS_ADAPTER_HPP
#define C_RTDS_ADAPTER_HPP

#include "IBufferAdapter.hpp"

#include <boost/enable_shared_from_this.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/asio/io_service.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/deadline_timer.hpp>
#include <boost/property_tree/ptree_fwd.hpp>

namespace freedm {
namespace broker {
namespace device {

class CRtdsAdapter
     : public IBufferAdapter
     , public boost::enable_shared_from_this<CRtdsAdapter>
{
public:
    typedef boost::shared_ptr<CRtdsAdapter> Pointer;

    static IAdapter::Pointer Create(boost::asio::io_service & service,
            const boost::property_tree::ptree & ptree);

    void Start();

    void Stop();

    ~CRtdsAdapter();

private:
    CRtdsAdapter(boost::asio::io_service & service,
            const boost::property_tree::ptree & ptree);

    void Run(const boost::system::error_code & e);

    void ReverseBytes( char * buffer, const int numBytes );

    void EndianSwapIfNeeded(std::vector<SignalValue> & v);

    void Connect();

    boost::asio::deadline_timer m_runTimer;

    mutable boost::asio::ip::tcp::socket m_socket;

    std::string m_host;

    std::string m_port;
};

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

#endif // C_RTDS_ADAPTER_HPP