COpenDssAdapter.hpp

Go to the documentation of this file.

#ifndef C_OPENDSS_ADAPTER_HPP
#define C_OPENDSS_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 COpenDssAdapter
                    : public IBufferAdapter
                            , public boost::enable_shared_from_this<COpenDssAdapter>
            {
            public:
                typedef boost::shared_ptr<COpenDssAdapter> Pointer;

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

                void Start();

                void Stop();

                ~COpenDssAdapter();

                static void sendCommand(std::string command);

            private:
                COpenDssAdapter(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;
                
                static const unsigned int BUFFER_SIZE = 1024;
            public:
                static unsigned int sd,n;
                
                //carries data received or data to be sent
                static char buffer[BUFFER_SIZE];

                static std::string openDss_data;

            public:
                static std::string GetData();
            };

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

#endif // C_RTDS_ADAPTER_HPP