Line data    Source code

       1             : //
       2             : // Copyright (c) 2023 Vinnie Falco (vinnie.falco@gmail.com)
       3             : //
       4             : // Distributed under the Boost Software License, Version 1.0. (See accompanying
       5             : // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
       6             : //
       7             : // Official repository: https://github.com/cppalliance/buffers
       8             : //
       9             : 
      10             : #ifndef BOOST_BUFFERS_IMPL_SOURCE_HPP
      11             : #define BOOST_BUFFERS_IMPL_SOURCE_HPP
      12             : 
      13             : #include <boost/http_proto/detail/except.hpp>
      14             : #include <boost/buffers/range.hpp>
      15             : #include <boost/buffers/type_traits.hpp>
      16             : #include <boost/assert.hpp>
      17             : 
      18             : namespace boost {
      19             : namespace http_proto {
      20             : 
      21             : inline
      22             : auto
      23          54 : source::
      24             : results::
      25             : operator+=(
      26             :     results const& rv) noexcept ->
      27             :         results&
      28             : {
      29          54 :     BOOST_ASSERT(! ec.failed());
      30          54 :     BOOST_ASSERT(! finished);
      31          54 :     ec = rv.ec;
      32          54 :     bytes += rv.bytes;
      33          54 :     finished = rv.finished;
      34          54 :     return *this;
      35             : }
      36             : 
      37             : //------------------------------------------------
      38             : 
      39             : template<class T>
      40             : auto
      41          17 : source::
      42             : read_impl(
      43             :     T const& bs) ->
      44             :         results
      45             : {
      46          17 :     results rv;
      47          17 :     constexpr int SmallArraySize = 16;
      48          17 :     buffers::mutable_buffer tmp[SmallArraySize];
      49          17 :     auto const tmp_end =
      50             :         tmp + SmallArraySize;
      51          17 :     auto it = buffers::begin(bs);
      52          17 :     auto const end_ = buffers::end(bs);
      53          28 :     while(it != end_)
      54             :     {
      55          17 :         auto p = tmp;
      56          17 :         do
      57             :         {
      58          34 :             *p++ = *it++;
      59             :         }
      60             :         while(
      61          34 :             p != tmp_end &&
      62             :             it != end_);
      63          17 :         rv += on_read(
      64             :             buffers::mutable_buffer_span(
      65          17 :                 tmp, p - tmp));
      66          17 :         if(rv.ec.failed())
      67           0 :             return rv;
      68          17 :         if(rv.finished)
      69           6 :             break;
      70             :     }
      71          17 :     return rv;
      72             : }
      73             : 
      74             : } // http_proto
      75             : } // boost
      76             : 
      77             : #endif