| // |
| // write_at.cpp |
| // ~~~~~~~~~~~~ |
| // |
| // Copyright (c) 2003-2010 Christopher M. Kohlhoff (chris at kohlhoff 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) |
| // |
| |
| // Disable autolinking for unit tests. |
| #if !defined(BOOST_ALL_NO_LIB) |
| #define BOOST_ALL_NO_LIB 1 |
| #endif // !defined(BOOST_ALL_NO_LIB) |
| |
| // Test that header file is self-contained. |
| #include <boost/asio/write_at.hpp> |
| |
| #include <boost/array.hpp> |
| #include <boost/bind.hpp> |
| #include <boost/noncopyable.hpp> |
| #include <cstring> |
| #include <boost/asio/io_service.hpp> |
| #include <boost/asio/placeholders.hpp> |
| #include "unit_test.hpp" |
| |
| using namespace std; // For memcmp, memcpy and memset. |
| |
| class test_random_access_device |
| : private boost::noncopyable |
| { |
| public: |
| typedef boost::asio::io_service io_service_type; |
| |
| test_random_access_device(boost::asio::io_service& io_service) |
| : io_service_(io_service), |
| length_(max_length), |
| next_write_length_(max_length) |
| { |
| memset(data_, 0, max_length); |
| } |
| |
| io_service_type& get_io_service() |
| { |
| return io_service_; |
| } |
| |
| void reset() |
| { |
| memset(data_, 0, max_length); |
| next_write_length_ = max_length; |
| } |
| |
| void next_write_length(size_t length) |
| { |
| next_write_length_ = length; |
| } |
| |
| template <typename Const_Buffers> |
| bool check_buffers(boost::uint64_t offset, |
| const Const_Buffers& buffers, size_t length) |
| { |
| if (offset + length > max_length) |
| return false; |
| |
| typename Const_Buffers::const_iterator iter = buffers.begin(); |
| typename Const_Buffers::const_iterator end = buffers.end(); |
| size_t checked_length = 0; |
| for (; iter != end && checked_length < length; ++iter) |
| { |
| size_t buffer_length = boost::asio::buffer_size(*iter); |
| if (buffer_length > length - checked_length) |
| buffer_length = length - checked_length; |
| if (memcmp(data_ + offset + checked_length, |
| boost::asio::buffer_cast<const void*>(*iter), buffer_length) != 0) |
| return false; |
| checked_length += buffer_length; |
| } |
| |
| return true; |
| } |
| |
| template <typename Const_Buffers> |
| size_t write_some_at(boost::uint64_t offset, const Const_Buffers& buffers) |
| { |
| size_t total_length = 0; |
| |
| typename Const_Buffers::const_iterator iter = buffers.begin(); |
| typename Const_Buffers::const_iterator end = buffers.end(); |
| for (; iter != end && total_length < next_write_length_; ++iter) |
| { |
| size_t length = boost::asio::buffer_size(*iter); |
| if (length > length_ - offset) |
| length = length_ - offset; |
| |
| if (length > next_write_length_ - total_length) |
| length = next_write_length_ - total_length; |
| |
| memcpy(data_ + offset, |
| boost::asio::buffer_cast<const void*>(*iter), length); |
| offset += length; |
| total_length += length; |
| } |
| |
| return total_length; |
| } |
| |
| template <typename Const_Buffers> |
| size_t write_some_at(boost::uint64_t offset, |
| const Const_Buffers& buffers, boost::system::error_code& ec) |
| { |
| ec = boost::system::error_code(); |
| return write_some_at(offset, buffers); |
| } |
| |
| template <typename Const_Buffers, typename Handler> |
| void async_write_some_at(boost::uint64_t offset, |
| const Const_Buffers& buffers, Handler handler) |
| { |
| size_t bytes_transferred = write_some_at(offset, buffers); |
| io_service_.post(boost::asio::detail::bind_handler( |
| handler, boost::system::error_code(), bytes_transferred)); |
| } |
| |
| private: |
| io_service_type& io_service_; |
| enum { max_length = 8192 }; |
| char data_[max_length]; |
| size_t length_; |
| size_t next_write_length_; |
| }; |
| |
| static const char write_data[] |
| = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz"; |
| static char mutable_write_data[] |
| = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz"; |
| |
| void test_3_arg_const_buffers_1_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::const_buffers_1 buffers |
| = boost::asio::buffer(write_data, sizeof(write_data)); |
| |
| s.reset(); |
| size_t bytes_transferred = boost::asio::write_at(s, 0, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| } |
| |
| void test_3_arg_mutable_buffers_1_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::mutable_buffers_1 buffers |
| = boost::asio::buffer(mutable_write_data, sizeof(mutable_write_data)); |
| |
| s.reset(); |
| size_t bytes_transferred = boost::asio::write_at(s, 0, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| } |
| |
| void test_3_arg_multi_buffers_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::array<boost::asio::const_buffer, 2> buffers = { { |
| boost::asio::buffer(write_data, 32), |
| boost::asio::buffer(write_data) + 32 } }; |
| |
| s.reset(); |
| size_t bytes_transferred = boost::asio::write_at(s, 0, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| } |
| |
| bool old_style_transfer_all(const boost::system::error_code& ec, |
| size_t /*bytes_transferred*/) |
| { |
| return !!ec; |
| } |
| |
| size_t short_transfer(const boost::system::error_code& ec, |
| size_t /*bytes_transferred*/) |
| { |
| return !!ec ? 0 : 3; |
| } |
| |
| void test_4_arg_const_buffers_1_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::const_buffers_1 buffers |
| = boost::asio::buffer(write_data, sizeof(write_data)); |
| |
| s.reset(); |
| size_t bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(0, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(0, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(0, buffers, 50)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 50)); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| } |
| |
| void test_4_arg_mutable_buffers_1_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::mutable_buffers_1 buffers |
| = boost::asio::buffer(mutable_write_data, sizeof(mutable_write_data)); |
| |
| s.reset(); |
| size_t bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(0, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(0, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(0, buffers, 50)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 50)); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| } |
| |
| void test_4_arg_multi_buffers_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::array<boost::asio::const_buffer, 2> buffers = { { |
| boost::asio::buffer(write_data, 32), |
| boost::asio::buffer(write_data) + 32 } }; |
| |
| s.reset(); |
| size_t bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all()); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(0, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10)); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(0, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(0, buffers, 50)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42)); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 50)); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, short_transfer); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| } |
| |
| void test_5_arg_const_buffers_1_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::const_buffers_1 buffers |
| = boost::asio::buffer(write_data, sizeof(write_data)); |
| |
| s.reset(); |
| boost::system::error_code error; |
| size_t bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(0, buffers, 1)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 1)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(0, buffers, 42)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 42)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(0, buffers, 50)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 50)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| } |
| |
| void test_5_arg_mutable_buffers_1_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::mutable_buffers_1 buffers |
| = boost::asio::buffer(mutable_write_data, sizeof(mutable_write_data)); |
| |
| s.reset(); |
| boost::system::error_code error; |
| size_t bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(0, buffers, 1)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 1)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(0, buffers, 42)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 42)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(0, buffers, 50)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 50)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(mutable_write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| BOOST_CHECK(!error); |
| } |
| |
| void test_5_arg_multi_buffers_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::array<boost::asio::const_buffer, 2> buffers = { { |
| boost::asio::buffer(write_data, 32), |
| boost::asio::buffer(write_data) + 32 } }; |
| |
| s.reset(); |
| boost::system::error_code error; |
| size_t bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(0, buffers, 1)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 1); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 1)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), error); |
| BOOST_CHECK(bytes_transferred == 10); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(0, buffers, 42)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 42); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 42)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(0, buffers, 50)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), error); |
| BOOST_CHECK(bytes_transferred == 50); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 50)); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| old_style_transfer_all, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(1); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 0, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| |
| s.reset(); |
| s.next_write_length(10); |
| error = boost::system::error_code(); |
| bytes_transferred = boost::asio::write_at(s, 1234, buffers, |
| short_transfer, error); |
| BOOST_CHECK(bytes_transferred == sizeof(write_data)); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| BOOST_CHECK(!error); |
| } |
| |
| void async_write_handler(const boost::system::error_code& e, |
| size_t bytes_transferred, size_t expected_bytes_transferred, bool* called) |
| { |
| *called = true; |
| BOOST_CHECK(!e); |
| BOOST_CHECK(bytes_transferred == expected_bytes_transferred); |
| } |
| |
| void test_4_arg_const_buffers_1_async_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::const_buffers_1 buffers |
| = boost::asio::buffer(write_data, sizeof(write_data)); |
| |
| s.reset(); |
| bool called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| } |
| |
| void test_4_arg_mutable_buffers_1_async_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::mutable_buffers_1 buffers |
| = boost::asio::buffer(mutable_write_data, sizeof(mutable_write_data)); |
| |
| s.reset(); |
| bool called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| } |
| |
| void test_4_arg_multi_buffers_async_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::array<boost::asio::const_buffer, 2> buffers = { { |
| boost::asio::buffer(write_data, 32), |
| boost::asio::buffer(write_data) + 32 } }; |
| |
| s.reset(); |
| bool called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| } |
| |
| void test_5_arg_const_buffers_1_async_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::const_buffers_1 buffers |
| = boost::asio::buffer(write_data, sizeof(write_data)); |
| |
| s.reset(); |
| bool called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 1, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 1, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 42, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 42, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 50, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 50)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 50, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 50)); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| } |
| |
| void test_5_arg_mutable_buffers_1_async_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::asio::mutable_buffers_1 buffers |
| = boost::asio::buffer(mutable_write_data, sizeof(mutable_write_data)); |
| |
| s.reset(); |
| bool called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 1, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 1, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 42, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 42, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 50, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 50)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 50, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 50)); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(mutable_write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(mutable_write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(mutable_write_data))); |
| } |
| |
| void test_5_arg_multi_buffers_async_write_at() |
| { |
| boost::asio::io_service ios; |
| test_random_access_device s(ios); |
| boost::array<boost::asio::const_buffer, 2> buffers = { { |
| boost::asio::buffer(write_data, 32), |
| boost::asio::buffer(write_data) + 32 } }; |
| |
| s.reset(); |
| bool called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_all(), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 1, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 1, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 1)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(1), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 10)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(10), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 10, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 10)); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 42, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 42, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 42)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 50, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, 50)); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, |
| boost::asio::transfer_at_least(42), |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| 50, &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, 50)); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, old_style_transfer_all, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(1); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 0, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(0, buffers, sizeof(write_data))); |
| |
| s.reset(); |
| s.next_write_length(10); |
| called = false; |
| boost::asio::async_write_at(s, 1234, buffers, short_transfer, |
| boost::bind(async_write_handler, |
| boost::asio::placeholders::error, |
| boost::asio::placeholders::bytes_transferred, |
| sizeof(write_data), &called)); |
| ios.reset(); |
| ios.run(); |
| BOOST_CHECK(called); |
| BOOST_CHECK(s.check_buffers(1234, buffers, sizeof(write_data))); |
| } |
| |
| test_suite* init_unit_test_suite(int, char*[]) |
| { |
| test_suite* test = BOOST_TEST_SUITE("write_at"); |
| test->add(BOOST_TEST_CASE(&test_3_arg_const_buffers_1_write_at)); |
| test->add(BOOST_TEST_CASE(&test_3_arg_mutable_buffers_1_write_at)); |
| test->add(BOOST_TEST_CASE(&test_3_arg_multi_buffers_write_at)); |
| test->add(BOOST_TEST_CASE(&test_4_arg_const_buffers_1_write_at)); |
| test->add(BOOST_TEST_CASE(&test_4_arg_mutable_buffers_1_write_at)); |
| test->add(BOOST_TEST_CASE(&test_4_arg_multi_buffers_write_at)); |
| test->add(BOOST_TEST_CASE(&test_5_arg_const_buffers_1_write_at)); |
| test->add(BOOST_TEST_CASE(&test_5_arg_mutable_buffers_1_write_at)); |
| test->add(BOOST_TEST_CASE(&test_5_arg_multi_buffers_write_at)); |
| test->add(BOOST_TEST_CASE(&test_4_arg_const_buffers_1_async_write_at)); |
| test->add(BOOST_TEST_CASE(&test_4_arg_mutable_buffers_1_async_write_at)); |
| test->add(BOOST_TEST_CASE(&test_4_arg_multi_buffers_async_write_at)); |
| test->add(BOOST_TEST_CASE(&test_5_arg_const_buffers_1_async_write_at)); |
| test->add(BOOST_TEST_CASE(&test_5_arg_mutable_buffers_1_async_write_at)); |
| test->add(BOOST_TEST_CASE(&test_5_arg_multi_buffers_async_write_at)); |
| return test; |
| } |
