Ticket #5815: http_server.cpp

#include "http_server.h"
#include "../../engine/logger.h"
#include <boost/bind.hpp>
#include <signal.h>

namespace http_server
{

using namespace boost::asio::ip;
using namespace engine;

cHttpServer::cHttpServer(unsigned int port)
    :m_IOService(),
        m_Acceptor(m_IOService, tcp::endpoint(tcp::v4(), port)),
        m_Signals(m_IOService)
{
        m_Signals.add(SIGINT);
        m_Signals.add(SIGTERM);
#if defined(SIGQUIT)
        m_Signals.add(SIGQUIT);
#endif // defined(SIGQUIT)
        m_Signals.async_wait(boost::bind(&cHttpServer::Stop, this));

    StartAccept();
};

cHttpServer::~cHttpServer()
{
        Stop();
};

void cHttpServer::StartAccept()
{
    connection_ptr new_connection = cHttpConnection::Create(m_Acceptor.get_io_service(), m_ConnectionManager);

    m_Acceptor.async_accept(new_connection->GetSocket(),
    boost::bind(&cHttpServer::HandleConnection, this, new_connection,
           boost::asio::placeholders::error));
};

void cHttpServer::HandleConnection(connection_ptr new_connection,
                const boost::system::error_code& error)
{
    if (!error)
    {
                m_ConnectionManager.StartConnection(new_connection);
        StartAccept();
    }
        else
        {
                cLogger log(LOG_SEV_ERROR);
                log<< CONTEXT_STR + error.message();
        }
};

void cHttpServer::Start()
{
        m_IOService.run();
};

void cHttpServer::Stop()
{
        cLogger log(LOG_SEV_INFO);
        log<< CONTEXT_STR + "Server is stopping...ignore further errors";
        m_Acceptor.close();
        m_ConnectionManager.StopAllConnections();
};



}