CPnpAdapter.hpp

Go to the documentation of this file.

#ifndef C_PNP_ADAPTER_HPP
#define C_PNP_ADAPTER_HPP

#include "IBufferAdapter.hpp"
#include "CTcpServer.hpp"

#include <boost/asio.hpp>
#include <boost/thread.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/property_tree/ptree_fwd.hpp>

namespace freedm {
namespace broker {
namespace device {

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

    static IAdapter::Pointer Create(boost::asio::io_service & service,
            boost::property_tree::ptree & p, CTcpServer::Connection client);

    void Start();

    void Stop();

    void Heartbeat();

    ~CPnpAdapter();
private:
    CPnpAdapter(boost::asio::io_service & service,
            boost::property_tree::ptree & p, CTcpServer::Connection client);

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

    void StartRead();

    void StartWrite();

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

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

    void ReadStatePacket(const std::string packet);

    std::string GetCommandPacket();

    boost::shared_ptr<boost::asio::deadline_timer> m_countdown;

    boost::asio::io_service& m_ios;

    std::string m_identifier;

    CTcpServer::Connection m_client;

    boost::asio::streambuf m_buffer;

    bool m_stopping;

    boost::mutex m_stoppingMutex;
};

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

#endif // C_PNP_ADAPTER_HPP