summaryrefslogtreecommitdiffstats
path: root/src/boost/libs/process/test/async_system_stackless.cpp
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-27 18:24:20 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-27 18:24:20 +0000
commit483eb2f56657e8e7f419ab1a4fab8dce9ade8609 (patch)
treee5d88d25d870d5dedacb6bbdbe2a966086a0a5cf /src/boost/libs/process/test/async_system_stackless.cpp
parentInitial commit. (diff)
downloadceph-upstream.tar.xz
ceph-upstream.zip
Adding upstream version 14.2.21.upstream/14.2.21upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/boost/libs/process/test/async_system_stackless.cpp')
-rw-r--r--src/boost/libs/process/test/async_system_stackless.cpp71
1 files changed, 71 insertions, 0 deletions
diff --git a/src/boost/libs/process/test/async_system_stackless.cpp b/src/boost/libs/process/test/async_system_stackless.cpp
new file mode 100644
index 00000000..8973469e
--- /dev/null
+++ b/src/boost/libs/process/test/async_system_stackless.cpp
@@ -0,0 +1,71 @@
+// 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
+#define BOOST_TEST_IGNORE_SIGCHLD
+#include <boost/test/included/unit_test.hpp>
+
+#include <boost/process/error.hpp>
+#include <boost/process/io.hpp>
+#include <boost/process/async.hpp>
+#include <boost/process/child.hpp>
+#include <boost/process/async_system.hpp>
+
+#include <string>
+#include <boost/asio/io_context.hpp>
+#include <boost/asio/post.hpp>
+#include <boost/asio/spawn.hpp>
+#include <boost/asio/coroutine.hpp>
+#include <boost/asio/use_future.hpp>
+#include <boost/asio/yield.hpp>
+
+#include <vector>
+#include <array>
+BOOST_AUTO_TEST_SUITE( async );
+
+namespace bp = boost::process;
+BOOST_AUTO_TEST_CASE(stackless, *boost::unit_test::timeout(15))
+{
+ using boost::unit_test::framework::master_test_suite;
+
+ boost::asio::io_context ios;
+
+ bool did_something_else = false;
+
+ struct stackless_t : boost::asio::coroutine
+ {
+ boost::asio::io_context & ios;
+ bool & did_something_else;
+
+ stackless_t(boost::asio::io_context & ios_,
+ bool & did_something_else)
+ : ios(ios_), did_something_else(did_something_else) {}
+ void operator()(
+ boost::system::error_code ec = boost::system::error_code(),
+ std::size_t exit_code = 0)
+ {
+ if (!ec) reenter (this)
+ {
+ yield bp::async_system(
+ ios, *this,
+ master_test_suite().argv[1],
+ "test", "--exit-code", "42");
+
+ BOOST_CHECK_EQUAL(exit_code, 42);
+ BOOST_CHECK(did_something_else);
+ }
+ }
+ } stackless{ios, did_something_else};
+
+ boost::asio::post(ios.get_executor(), [&]{stackless();});
+ boost::asio::post(ios.get_executor(), [&]{did_something_else = true;});
+
+ ios.run();
+
+ BOOST_CHECK(did_something_else);
+}
+
+
+BOOST_AUTO_TEST_SUITE_END(); \ No newline at end of file