libs/rpc/include/mace/rpc/http/server.hpp

//
// server.hpp
// ~~~~~~~~~~
//
// Copyright (c) 2003-2012 Christopher M. Kohlhoff (chris at kohlhoff dot com)
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//

#ifndef MACE_RPC_HTTP_SERVER_HPP
#define MACE_RPC_HTTP_SERVER_HPP

#include <boost/asio.hpp>
#include <string>
#include <boost/array.hpp>
#include <boost/function.hpp>
#include <boost/shared_ptr.hpp>
#include <mace/rpc/http/coroutine.hpp>
#include <mace/rpc/http/request_parser.hpp>

namespace mace { namespace rpc { namespace http {

  struct request;
  struct reply;

  class server : coroutine {
    public:
      explicit server( const std::string& address, const std::string& port,
          boost::function<void(const request&, reply&)> request_handler);

      void operator()(
          boost::system::error_code ec = boost::system::error_code(),
          std::size_t length = 0);

    private:
      typedef boost::asio::ip::tcp tcp;

      boost::function<void(const request&, reply&)> request_handler_;

      boost::shared_ptr<tcp::acceptor> acceptor_;

      boost::shared_ptr<tcp::socket> socket_;

      boost::shared_ptr<boost::array<char, 8192> > buffer_;

      boost::shared_ptr<request> request_;

      boost::tribool valid_request_;

      request_parser request_parser_;

      boost::shared_ptr<reply> reply_;

      boost::shared_ptr<boost::asio::strand>  strand_;
  };

} } }// mace::rpc::http

#endif // HTTP_SERVER4_SERVER_HPP