CTcpServer.hpp

Go to the documentation of this file.

#ifndef C_TCP_SERVER_HPP
#define C_TCP_SERVER_HPP

#include <boost/asio.hpp>
#include <boost/function.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/noncopyable.hpp>

namespace freedm {
namespace broker {
namespace device {

class CTcpServer
    : private boost::noncopyable
{
public:
    typedef boost::shared_ptr<CTcpServer> Pointer;

    typedef boost::shared_ptr<boost::asio::ip::tcp::socket> Connection;

    typedef boost::function<void ()> ConnectionHandler;

    virtual ~CTcpServer();

    static Pointer Create(boost::asio::io_service & ios, unsigned short port,
        const std::string address="");

    void RegisterHandler(ConnectionHandler h);

    void Stop();

    void StartAccept();

    Connection GetClient() { return m_client; }
private:
    CTcpServer(boost::asio::io_service & ios, unsigned short port,
        const std::string address="");

    void HandleAccept(const boost::system::error_code & error);

    std::string hdr() const;

    boost::asio::ip::tcp::acceptor m_acceptor;

    unsigned short m_port;

    ConnectionHandler m_handler;
protected:
    Connection m_client;
};

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

#endif // C_TCP_SERVER_HPP