164 lines
4.1 KiB
C++
164 lines
4.1 KiB
C++
//
|
|
// connect_pipe.cpp
|
|
// ~~~~~~~~~~~~~~~~
|
|
//
|
|
// Copyright (c) 2003-2023 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/connect_pipe.hpp>
|
|
|
|
#include <string>
|
|
#include <boost/asio/io_context.hpp>
|
|
#include <boost/asio/read.hpp>
|
|
#include <boost/asio/readable_pipe.hpp>
|
|
#include <boost/asio/writable_pipe.hpp>
|
|
#include <boost/asio/write.hpp>
|
|
#include "unit_test.hpp"
|
|
|
|
#if defined(BOOST_ASIO_HAS_BOOST_BIND)
|
|
# include <boost/bind/bind.hpp>
|
|
#else // defined(BOOST_ASIO_HAS_BOOST_BIND)
|
|
# include <functional>
|
|
#endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
|
|
|
|
//------------------------------------------------------------------------------
|
|
|
|
// connect_pipe_compile test
|
|
// ~~~~~~~~~~~~~~~~~~~~~~~~~
|
|
// The following test checks that all connect_pipe functions compile and link
|
|
// correctly. Runtime failures are ignored.
|
|
|
|
namespace connect_pipe_compile {
|
|
|
|
void test()
|
|
{
|
|
#if defined(BOOST_ASIO_HAS_PIPE)
|
|
using namespace boost::asio;
|
|
|
|
try
|
|
{
|
|
boost::asio::io_context io_context;
|
|
boost::system::error_code ec1;
|
|
|
|
readable_pipe p1(io_context);
|
|
writable_pipe p2(io_context);
|
|
connect_pipe(p1, p2);
|
|
|
|
readable_pipe p3(io_context);
|
|
writable_pipe p4(io_context);
|
|
connect_pipe(p3, p4, ec1);
|
|
}
|
|
catch (std::exception&)
|
|
{
|
|
}
|
|
#endif // defined(BOOST_ASIO_HAS_PIPE)
|
|
}
|
|
|
|
} // namespace connect_pipe_compile
|
|
|
|
//------------------------------------------------------------------------------
|
|
|
|
// connect_pipe_runtime test
|
|
// ~~~~~~~~~~~~~~~~~~~~~~~~~
|
|
// The following test checks that connect_pipe operates correctly at runtime.
|
|
|
|
namespace connect_pipe_runtime {
|
|
|
|
static const char write_data[]
|
|
= "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";
|
|
|
|
void handle_read(const boost::system::error_code& err,
|
|
size_t bytes_transferred, bool* called)
|
|
{
|
|
*called = true;
|
|
BOOST_ASIO_CHECK(!err);
|
|
BOOST_ASIO_CHECK(bytes_transferred == sizeof(write_data));
|
|
}
|
|
|
|
void handle_write(const boost::system::error_code& err,
|
|
size_t bytes_transferred, bool* called)
|
|
{
|
|
*called = true;
|
|
BOOST_ASIO_CHECK(!err);
|
|
BOOST_ASIO_CHECK(bytes_transferred == sizeof(write_data));
|
|
}
|
|
|
|
void test()
|
|
{
|
|
#if defined(BOOST_ASIO_HAS_PIPE)
|
|
using namespace std; // For memcmp.
|
|
using namespace boost::asio;
|
|
|
|
#if defined(BOOST_ASIO_HAS_BOOST_BIND)
|
|
namespace bindns = boost;
|
|
#else // defined(BOOST_ASIO_HAS_BOOST_BIND)
|
|
namespace bindns = std;
|
|
#endif // defined(BOOST_ASIO_HAS_BOOST_BIND)
|
|
using bindns::placeholders::_1;
|
|
using bindns::placeholders::_2;
|
|
|
|
try
|
|
{
|
|
boost::asio::io_context io_context;
|
|
boost::system::error_code ec1;
|
|
boost::system::error_code ec2;
|
|
|
|
readable_pipe p1(io_context);
|
|
writable_pipe p2(io_context);
|
|
connect_pipe(p1, p2);
|
|
|
|
std::string data1 = write_data;
|
|
boost::asio::write(p2, boost::asio::buffer(data1));
|
|
|
|
std::string data2;
|
|
data2.resize(data1.size());
|
|
boost::asio::read(p1, boost::asio::buffer(data2));
|
|
|
|
BOOST_ASIO_CHECK(data1 == data2);
|
|
|
|
char read_buffer[sizeof(write_data)];
|
|
bool read_completed = false;
|
|
boost::asio::async_read(p1,
|
|
boost::asio::buffer(read_buffer),
|
|
bindns::bind(handle_read,
|
|
_1, _2, &read_completed));
|
|
|
|
bool write_completed = false;
|
|
boost::asio::async_write(p2,
|
|
boost::asio::buffer(write_data),
|
|
bindns::bind(handle_write,
|
|
_1, _2, &write_completed));
|
|
|
|
io_context.run();
|
|
|
|
BOOST_ASIO_CHECK(read_completed);
|
|
BOOST_ASIO_CHECK(write_completed);
|
|
BOOST_ASIO_CHECK(memcmp(read_buffer, write_data, sizeof(write_data)) == 0);
|
|
}
|
|
catch (std::exception&)
|
|
{
|
|
BOOST_ASIO_CHECK(false);
|
|
}
|
|
#endif // defined(BOOST_ASIO_HAS_PIPE)
|
|
}
|
|
|
|
} // namespace connect_pipe_compile
|
|
|
|
//------------------------------------------------------------------------------
|
|
|
|
BOOST_ASIO_TEST_SUITE
|
|
(
|
|
"connect_pipe",
|
|
BOOST_ASIO_COMPILE_TEST_CASE(connect_pipe_compile::test)
|
|
BOOST_ASIO_TEST_CASE(connect_pipe_runtime::test)
|
|
)
|