ab8efbceee
- Doc updates
- Fixed a minor bug in the creating scopes with lambda and let
- Speed up of the lambda and let compile times
- Made use of the new proto::basic_default_domain
[SVN r72178]
112 lines
3.2 KiB
C++
112 lines
3.2 KiB
C++
//
|
|
// Copyright (c) 2011 Thomas Heller
|
|
//
|
|
// 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)
|
|
//
|
|
|
|
#include <cstdlib>
|
|
#include <iostream>
|
|
|
|
#define BOOST_PHOENIX_NO_PREDEFINED_TERMINALS
|
|
|
|
#include <boost/phoenix.hpp>
|
|
#include <boost/asio.hpp>
|
|
|
|
namespace phx = boost::phoenix;
|
|
|
|
using boost::phoenix::ref;
|
|
|
|
BOOST_PHOENIX_ADAPT_FUNCTION(void, read, boost::asio::async_read, 4)
|
|
BOOST_PHOENIX_ADAPT_FUNCTION(void, write, boost::asio::async_write, 3)
|
|
BOOST_PHOENIX_ADAPT_FUNCTION(boost::asio::mutable_buffers_1, buffer, boost::asio::buffer, 2)
|
|
|
|
template <typename Acceptor, typename Socket, typename Handler>
|
|
void accept_impl(Acceptor & acceptor, Socket & socket, Handler const & handler)
|
|
{
|
|
acceptor.async_accept(socket, handler);
|
|
}
|
|
BOOST_PHOENIX_ADAPT_FUNCTION(void, accept, accept_impl, 3)
|
|
|
|
typedef phx::expression::local_variable<struct action_key>::type action;
|
|
|
|
#include <boost/function.hpp>
|
|
|
|
int main(int argc, char* argv[])
|
|
{
|
|
try
|
|
{
|
|
if (argc != 2)
|
|
{
|
|
std::cerr << "Usage: async_tcp_echo_server <port>\n";
|
|
return 1;
|
|
}
|
|
|
|
phx::lambda_type lambda;
|
|
phx::arg_names::_1_type _1;
|
|
|
|
boost::asio::io_service io_service;
|
|
boost::asio::ip::tcp::acceptor acceptor(io_service, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), std::atoi(argv[1])));
|
|
boost::asio::ip::tcp::socket socket(io_service);
|
|
std::size_t const max_length = 1024;
|
|
char buf[max_length];
|
|
|
|
std::cout << "server starting...\n";
|
|
|
|
boost::function<void(boost::system::error_code const &)> accept_handler;
|
|
phx::expression::argument<1>::type _error;
|
|
phx::expression::argument<2>::type _length;
|
|
action _action;
|
|
BOOST_AUTO(
|
|
create_handler
|
|
, (lambda(_action = lambda[_1])
|
|
[
|
|
if_(!_error)
|
|
[
|
|
bind(_action, ref(socket), ref(buf), _error, _length)
|
|
]
|
|
.else_
|
|
[
|
|
bind(&boost::asio::ip::tcp::socket::close, ref(socket))
|
|
, accept(ref(acceptor), ref(socket), phx::ref(accept_handler))
|
|
]
|
|
])
|
|
);
|
|
boost::function<void(boost::system::error_code const &, std::size_t)> read_handler;
|
|
boost::function<void(boost::system::error_code const &, std::size_t)> write_handler;
|
|
|
|
accept_handler =
|
|
if_(!_error)
|
|
[
|
|
read(ref(socket), buffer(ref(buf), max_length), boost::asio::transfer_at_least(1), phx::ref(read_handler))
|
|
];
|
|
|
|
{
|
|
phx::expression::argument<1>::type _socket;
|
|
phx::expression::argument<2>::type _buf;
|
|
phx::expression::argument<3>::type _error;
|
|
phx::expression::argument<4>::type _length;
|
|
read_handler = create_handler(
|
|
write(_socket, buffer(_buf, _length), phx::ref(write_handler))
|
|
);
|
|
|
|
write_handler = create_handler(
|
|
read(_socket, buffer(_buf, max_length), boost::asio::transfer_at_least(1), phx::ref(read_handler))
|
|
);
|
|
}
|
|
|
|
acceptor.async_accept(
|
|
socket
|
|
, accept_handler
|
|
);
|
|
|
|
io_service.run();
|
|
}
|
|
catch (std::exception& e)
|
|
{
|
|
std::cerr << "Exception: " << e.what() << "\n";
|
|
}
|
|
|
|
return 0;
|
|
}
|