mirror of
https://github.com/boostorg/process.git
synced 2026-01-19 04:22:15 +00:00
ab28b511a9
As of 2ccd97cd48, v2 is the default when using the unversioned includes.
This broke the v1 tests which were still using those.
147 lines
3.5 KiB
C++
147 lines
3.5 KiB
C++
// Copyright (c) 2016 Klemens D. Morgenstern
|
|
//
|
|
// 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)
|
|
|
|
|
|
#define BOOST_TEST_MAIN
|
|
|
|
#include <boost/test/included/unit_test.hpp>
|
|
#include <iostream>
|
|
#include <thread>
|
|
#include <vector>
|
|
#include <boost/algorithm/string/predicate.hpp>
|
|
|
|
#include <boost/process/v1/async_pipe.hpp>
|
|
#include <boost/process/v1/pipe.hpp>
|
|
#include <boost/asio/read.hpp>
|
|
#include <boost/asio/read_until.hpp>
|
|
#include <boost/asio/write.hpp>
|
|
#include <boost/asio/streambuf.hpp>
|
|
|
|
using namespace std;
|
|
namespace bp = boost::process::v1;
|
|
namespace asio = boost::asio;
|
|
|
|
BOOST_AUTO_TEST_SUITE( async );
|
|
|
|
|
|
BOOST_AUTO_TEST_CASE(plain_async, *boost::unit_test::timeout(5))
|
|
{
|
|
asio::io_context ios;
|
|
bp::async_pipe pipe{ios};
|
|
|
|
std::string st = "test-string\n";
|
|
|
|
asio::streambuf buf;
|
|
|
|
asio::async_write(pipe, asio::buffer(st), [](const boost::system::error_code &, std::size_t){});
|
|
asio::async_read_until(pipe, buf, '\n', [](const boost::system::error_code &, std::size_t){});
|
|
|
|
ios.run();
|
|
|
|
std::string line;
|
|
std::istream istr(&buf);
|
|
BOOST_CHECK(std::getline(istr, line));
|
|
|
|
line.resize(11);
|
|
BOOST_CHECK_EQUAL(line, "test-string");
|
|
|
|
}
|
|
|
|
BOOST_AUTO_TEST_CASE(closed_transform)
|
|
{
|
|
asio::io_context ios;
|
|
|
|
bp::async_pipe ap{ios};
|
|
|
|
BOOST_CHECK(ap.is_open());
|
|
bp::pipe p2 = static_cast<bp::pipe>(ap);
|
|
BOOST_CHECK(p2.is_open());
|
|
|
|
ap.close();
|
|
BOOST_CHECK(!ap.is_open());
|
|
|
|
bp::pipe p = static_cast<bp::pipe>(ap);
|
|
BOOST_CHECK(!p.is_open());
|
|
|
|
}
|
|
|
|
BOOST_AUTO_TEST_CASE(multithreaded_async_pipe)
|
|
{
|
|
asio::io_context ioc;
|
|
|
|
std::vector<std::thread> threads;
|
|
for (auto i = 0u; i < std::thread::hardware_concurrency(); i++)
|
|
{
|
|
threads.emplace_back([&ioc]
|
|
{
|
|
std::vector<bp::async_pipe*> pipes;
|
|
for (size_t i = 0; i < 100; i++)
|
|
pipes.push_back(new bp::async_pipe(ioc));
|
|
for (auto &p : pipes)
|
|
delete p;
|
|
});
|
|
}
|
|
for (auto &t : threads)
|
|
t.join();
|
|
}
|
|
|
|
|
|
|
|
BOOST_AUTO_TEST_CASE(move_pipe)
|
|
{
|
|
asio::io_context ios;
|
|
|
|
bp::async_pipe ap{ios};
|
|
BOOST_TEST_CHECKPOINT("First move");
|
|
bp::async_pipe ap2{std::move(ap)};
|
|
#if defined(BOOST_WINDOWS_API)
|
|
BOOST_CHECK_EQUAL(ap.native_source(), ::boost::winapi::INVALID_HANDLE_VALUE_);
|
|
BOOST_CHECK_EQUAL(ap.native_sink (), ::boost::winapi::INVALID_HANDLE_VALUE_);
|
|
#elif defined(BOOST_POSIX_API)
|
|
BOOST_CHECK_EQUAL(ap.native_source(), -1);
|
|
BOOST_CHECK_EQUAL(ap.native_sink (), -1);
|
|
#endif
|
|
|
|
BOOST_TEST_CHECKPOINT("Second move");
|
|
ap = std::move(ap2);
|
|
|
|
{
|
|
BOOST_TEST_CHECKPOINT("Third move, from closed");
|
|
bp::async_pipe ap_inv{ios};
|
|
ap_inv.close();
|
|
ap = std::move(ap_inv);
|
|
}
|
|
|
|
{
|
|
BOOST_TEST_CHECKPOINT("Fourth move, from closed");
|
|
bp::async_pipe ap_inv{ios};
|
|
ap_inv.close();
|
|
const auto ap3 = std::move(ap_inv);
|
|
}
|
|
/*
|
|
{
|
|
//copy a closed pipe
|
|
BOOST_TEST_CHECKPOINT("Copy assign");
|
|
BOOST_TEST_CHECKPOINT("Fourth move, from closed");
|
|
bp::async_pipe ap_inv{ios};
|
|
ap_inv.close();
|
|
ap = ap_inv; //copy an invalid pipe
|
|
}
|
|
|
|
{
|
|
//copy a closed pipe
|
|
BOOST_TEST_CHECKPOINT("Copy assign");
|
|
BOOST_TEST_CHECKPOINT("Fourth move, from closed");
|
|
bp::async_pipe ap_inv{ios};
|
|
ap_inv.close();
|
|
BOOST_TEST_CHECKPOINT("Copy construct");
|
|
bp::async_pipe ap4{ap_inv};
|
|
}
|
|
*/
|
|
|
|
}
|
|
|
|
|
|
BOOST_AUTO_TEST_SUITE_END(); |