Line data    Source code

       1              : //
       2              : // Copyright (c) 2022 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/http_proto
       8              : //
       9              : 
      10              : #include <boost/http_proto/file_body.hpp>
      11              : #include <boost/buffers/algorithm.hpp>
      12              : #include <boost/assert.hpp>
      13              : 
      14              : namespace boost {
      15              : namespace http_proto {
      16              : 
      17            0 : file_body::
      18              : ~file_body() = default;
      19              : 
      20            0 : file_body::
      21              : file_body(
      22              :     file_body&&) noexcept = default;
      23              : 
      24            0 : file_body::
      25              : file_body(
      26              :     file&& f,
      27            0 :     std::uint64_t size) noexcept
      28            0 :     : f_(std::move(f))
      29            0 :     , n_(size)
      30              : {
      31            0 : }
      32              : 
      33              : auto
      34            0 : file_body::
      35              : on_read(
      36              :     buffers::mutable_buffer b) ->
      37              :         source::results
      38              : {
      39            0 :     source::results rv;
      40            0 :     if(n_ > 0)
      41              :     {
      42              :         std::size_t n;
      43            0 :         if( n_ >= b.size())
      44            0 :             n = b.size();
      45              :         else
      46            0 :             n = static_cast<std::size_t>(n_);
      47            0 :         n = f_.read(
      48              :             b.data(), n, rv.ec);
      49            0 :         rv.bytes = n;
      50            0 :         n_ -= n;
      51              :     }
      52            0 :     rv.finished = n_ == 0;
      53            0 :     return rv;
      54              : }
      55              : 
      56              : auto
      57            0 : file_body::
      58              : on_write(
      59              :     buffers::const_buffer b, bool) ->
      60              :         sink::results
      61              : {
      62            0 :     sink::results rv;
      63            0 :     if(n_ > 0)
      64              :     {
      65              :         std::size_t n;
      66            0 :         if( n_ >= b.size())
      67            0 :             n = b.size();
      68              :         else
      69            0 :             n = static_cast<std::size_t>(n_);
      70            0 :         n = f_.write(
      71              :             b.data(), n, rv.ec);
      72            0 :         rv.bytes = n;
      73            0 :         n_ -= n;
      74              :     }
      75            0 :     return rv;
      76              : }
      77              : 
      78              : } // http_proto
      79              : } // boost