mirror of
https://github.com/boostorg/beast.git
synced 2025-08-03 06:44:39 +02:00
Add detail::dynamic_buffer_prepare:
This function acts as a bottleneck for handling exceptions thrown by dynamic buffers.
This commit is contained in:
83
include/boost/beast/core/detail/buffer.hpp
Normal file
83
include/boost/beast/core/detail/buffer.hpp
Normal file
@@ -0,0 +1,83 @@
|
||||
//
|
||||
// Copyright (c) 2018 Vinnie Falco (vinnie dot falco at gmail 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)
|
||||
//
|
||||
// Official repository: https://github.com/boostorg/beast
|
||||
//
|
||||
|
||||
#ifndef BOOST_BEAST_CORE_DETAIL_BUFFER_HPP
|
||||
#define BOOST_BEAST_CORE_DETAIL_BUFFER_HPP
|
||||
|
||||
#include <boost/beast/core/error.hpp>
|
||||
#include <boost/optional.hpp>
|
||||
#include <stdexcept>
|
||||
|
||||
namespace boost {
|
||||
namespace beast {
|
||||
namespace detail {
|
||||
|
||||
template<
|
||||
class DynamicBuffer,
|
||||
class ErrorValue>
|
||||
auto
|
||||
dynamic_buffer_prepare_noexcept(
|
||||
DynamicBuffer& buffer,
|
||||
std::size_t size,
|
||||
error_code& ec,
|
||||
ErrorValue ev) ->
|
||||
boost::optional<typename
|
||||
DynamicBuffer::mutable_buffers_type>
|
||||
{
|
||||
if(buffer.max_size() - buffer.size() < size)
|
||||
{
|
||||
// length error
|
||||
ec = ev;
|
||||
return boost::none;
|
||||
}
|
||||
boost::optional<typename
|
||||
DynamicBuffer::mutable_buffers_type> result;
|
||||
result.emplace(buffer.prepare(size));
|
||||
ec.assign(0, ec.category());
|
||||
return result;
|
||||
}
|
||||
|
||||
template<
|
||||
class DynamicBuffer,
|
||||
class ErrorValue>
|
||||
auto
|
||||
dynamic_buffer_prepare(
|
||||
DynamicBuffer& buffer,
|
||||
std::size_t size,
|
||||
error_code& ec,
|
||||
ErrorValue ev) ->
|
||||
boost::optional<typename
|
||||
DynamicBuffer::mutable_buffers_type>
|
||||
{
|
||||
#ifndef BOOST_NO_EXCEPTIONS
|
||||
try
|
||||
{
|
||||
boost::optional<typename
|
||||
DynamicBuffer::mutable_buffers_type> result;
|
||||
result.emplace(buffer.prepare(size));
|
||||
ec.assign(0, ec.category());
|
||||
return result;
|
||||
}
|
||||
catch(std::length_error const&)
|
||||
{
|
||||
ec = ev;
|
||||
}
|
||||
return boost::none;
|
||||
|
||||
#else
|
||||
return dynamic_buffer_prepare_noexcept(
|
||||
buffer, size, ec, ev);
|
||||
#endif
|
||||
}
|
||||
|
||||
} // detail
|
||||
} // beast
|
||||
} // boost
|
||||
|
||||
#endif
|
@@ -20,6 +20,7 @@ add_executable (tests-beast-core
|
||||
buffer_test.hpp
|
||||
file_test.hpp
|
||||
bind_handler.cpp
|
||||
buffer.cpp
|
||||
buffered_read_stream.cpp
|
||||
buffers_adapter.cpp
|
||||
buffers_cat.cpp
|
||||
|
@@ -9,6 +9,7 @@
|
||||
|
||||
local SOURCES =
|
||||
bind_handler.cpp
|
||||
buffer.cpp
|
||||
buffered_read_stream.cpp
|
||||
buffers_adapter.cpp
|
||||
buffers_cat.cpp
|
||||
|
87
test/beast/core/buffer.cpp
Normal file
87
test/beast/core/buffer.cpp
Normal file
@@ -0,0 +1,87 @@
|
||||
//
|
||||
// Copyright (c) 2016-2017 Vinnie Falco (vinnie dot falco at gmail 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)
|
||||
//
|
||||
// Official repository: https://github.com/boostorg/beast
|
||||
//
|
||||
|
||||
// Test that header file is self-contained.
|
||||
//#include <boost/beast/core/buffer.hpp>
|
||||
|
||||
#include <boost/beast/core/detail/buffer.hpp>
|
||||
#include <boost/beast/core/flat_buffer.hpp>
|
||||
#include <boost/beast/unit_test/suite.hpp>
|
||||
#include <string>
|
||||
|
||||
#include <boost/asio/error.hpp>
|
||||
|
||||
namespace boost {
|
||||
namespace beast {
|
||||
|
||||
// VFALCO No idea why boost::system::errc::message_size fails
|
||||
// to compile, so we use boost::asio::error::eof instead.
|
||||
//
|
||||
class buffer_test : public beast::unit_test::suite
|
||||
{
|
||||
public:
|
||||
template<class DynamicBuffer>
|
||||
void
|
||||
testPrepare()
|
||||
{
|
||||
#ifndef BOOST_NO_EXCEPTIONS
|
||||
error_code ec;
|
||||
DynamicBuffer b(32);
|
||||
detail::dynamic_buffer_prepare(b, 20, ec,
|
||||
//boost::system::errc::message_size);
|
||||
boost::asio::error::eof);
|
||||
BEAST_EXPECTS(! ec, ec.message());
|
||||
b.commit(20);
|
||||
auto const result =
|
||||
detail::dynamic_buffer_prepare(b, 20, ec,
|
||||
//boost::system::errc::message_size);
|
||||
boost::asio::error::eof);
|
||||
BEAST_EXPECT(result == boost::none);
|
||||
BEAST_EXPECTS(
|
||||
//ec == boost::system::errc::message_size,
|
||||
ec == boost::asio::error::eof, ec.message());
|
||||
#else
|
||||
fail("exceptions disabled", __FILE__, __LINE__);
|
||||
#endif
|
||||
}
|
||||
|
||||
template<class DynamicBuffer>
|
||||
void
|
||||
testPrepareNoexcept()
|
||||
{
|
||||
error_code ec;
|
||||
DynamicBuffer b(32);
|
||||
detail::dynamic_buffer_prepare_noexcept(b, 20, ec,
|
||||
//boost::system::errc::message_size);
|
||||
boost::asio::error::eof);
|
||||
BEAST_EXPECTS(! ec, ec.message());
|
||||
b.commit(20);
|
||||
auto const result =
|
||||
detail::dynamic_buffer_prepare_noexcept(b, 20, ec,
|
||||
//boost::system::errc::message_size);
|
||||
boost::asio::error::eof);
|
||||
BEAST_EXPECT(result == boost::none);
|
||||
BEAST_EXPECTS(
|
||||
//ec == boost::system::errc::message_size,
|
||||
ec == boost::asio::error::eof, ec.message());
|
||||
}
|
||||
|
||||
void
|
||||
run() override
|
||||
{
|
||||
testPrepare<flat_buffer>();
|
||||
testPrepareNoexcept<flat_buffer>();
|
||||
pass();
|
||||
}
|
||||
};
|
||||
|
||||
BEAST_DEFINE_TESTSUITE(beast,core,buffer);
|
||||
|
||||
} // beast
|
||||
} // boost
|
Reference in New Issue
Block a user