Merge branch '0.9-devel' of https://github.com/omalashenko/cpp-netlib into omalashenko-0.9-devel

deanberris · deanberris · commit 30dac6feaeaf · 2010-12-12T18:00:31.000+08:00
diff --git a/boost/network/protocol/http/server/async_connection.hpp b/boost/network/protocol/http/server/async_connection.hpp
@@ -227,6 +227,21 @@ namespace boost { namespace network { namespace http {
 
         void read(read_callback_function callback) {
             if (error_encountered) boost::throw_exception(boost::system::system_error(*error_encountered));
+            if (new_start != read_buffer_.begin())
+            {
+                input_range input = boost::make_iterator_range(new_start, read_buffer_.end());
+                thread_pool().post(
+                    boost::bind(
+                        callback
+                        , input
+                        , boost::system::error_code()
+                        , std::distance(new_start, data_end)
+                        , async_connection<Tag,Handler>::shared_from_this())
+                );
+                new_start = read_buffer_.begin();
+                return;
+            }
+
             socket().async_read_some(
                 asio::buffer(read_buffer_)
                 , strand.wrap(
@@ -247,9 +262,13 @@ namespace boost { namespace network { namespace http {
 
         void wrap_read_handler(read_callback_function callback, boost::system::error_code const & ec, std::size_t bytes_transferred) {
             if (ec) error_encountered = in_place<boost::system::system_error>(ec);
+            buffer_type::const_iterator data_start = read_buffer_.begin()
+                                       ,data_end   = read_buffer_.begin();
+            std::advance(data_end, bytes_transferred);
             thread_pool().post(
                 boost::bind(
                     callback
+                    , boost::make_iterator_range(data_start, data_end)
                     , ec
                     , bytes_transferred
                     , async_connection<Tag,Handler>::shared_from_this()));
@@ -279,7 +298,7 @@ namespace boost { namespace network { namespace http {
         status_t status;
         request_parser_type parser;
         request request_;
-        buffer_type::iterator new_start;
+        buffer_type::iterator new_start, data_end;
         string_type partial_parsed;
         optional<boost::system::system_error> error_encountered;
         pending_actions_list pending_actions;
@@ -317,10 +336,12 @@ namespace boost { namespace network { namespace http {
             if (!ec) {
                 logic::tribool parsed_ok;
                 iterator_range<buffer_type::iterator> result_range, input_range;
+                data_end = read_buffer_.begin();
+                std::advance(data_end, bytes_transferred);
                 switch (state) {
                     case method:
                         input_range = boost::make_iterator_range(
-                            new_start, read_buffer_.end());
+                            new_start, data_end);
                         fusion::tie(parsed_ok, result_range) = parser.parse_until(
                             request_parser_type::method_done, input_range);
                         if (!parsed_ok) { 
@@ -343,7 +364,7 @@ namespace boost { namespace network { namespace http {
                         }
                     case uri:
                         input_range = boost::make_iterator_range(
-                            new_start, read_buffer_.end());
+                            new_start, data_end);
                         fusion::tie(parsed_ok, result_range) = parser.parse_until(
                             request_parser_type::uri_done,
                             input_range);
@@ -367,7 +388,7 @@ namespace boost { namespace network { namespace http {
                         }
                     case version:
                         input_range = boost::make_iterator_range(
-                            new_start, read_buffer_.end());
+                            new_start, data_end);
                         fusion::tie(parsed_ok, result_range) = parser.parse_until(
                             request_parser_type::version_done,
                             input_range);
@@ -391,7 +412,7 @@ namespace boost { namespace network { namespace http {
                         }
                     case headers:
                         input_range = boost::make_iterator_range(
-                            new_start, read_buffer_.end());
+                            new_start, data_end);
                         fusion::tie(parsed_ok, result_range) = parser.parse_until(
                             request_parser_type::headers_done,
                             input_range);
