tests: run some boost Asio mysterious tests

Author: yhabteab

.github/workflows/linux.yml

@@ -1,10 +1,7 @@
 name: Linux
 
 on:
-  push:
-    branches:
-      - master
-      - 'support/*'
+  push: {}
   pull_request: {}
 
 concurrency:

test/base-io-engine.cpp

@@ -8,6 +8,8 @@
 #include <BoostTestTargetConfig.h>
 #include <thread>
 
+#include "test-thread.hpp"
+
 using namespace icinga;
 
 BOOST_AUTO_TEST_SUITE(base_io_engine)
@@ -157,4 +159,56 @@ BOOST_AUTO_TEST_CASE(timeout_due_scope)
 	BOOST_CHECK_EQUAL(called, 0);
 }
 
+BOOST_AUTO_TEST_CASE(base_io_engine_coroutine_resume_continuation)
+{
+	for (int i = 0; i < 150; ++i) {
+		boost::asio::io_context io;
+		boost::asio::io_context::strand strand{io};
+
+		auto dummyWork = [&strand] {
+			BOOST_TEST(strand.running_in_this_thread() == true, "Doing some dummy work in the strand");
+		};
+
+		boost::asio::steady_timer timer(io);
+		timer.expires_after(std::chrono::seconds(10));
+
+		std::atomic_bool testFailed{false};
+		IoEngine::SpawnCoroutine(strand, [&](boost::asio::yield_context yc) {
+			BOOST_TEST(strand.running_in_this_thread() == true, "Coroutine started");
+			boost::system::error_code ec;
+			timer.async_wait(yc[ec]);
+			testFailed.store(strand.running_in_this_thread() == false);
+			BOOST_TEST(strand.running_in_this_thread() == true, "Coroutine resumed after timer expired/cancelled: running_in_this_thread -> " << strand.running_in_this_thread());
+		});
+
+		boost::asio::post(strand, [&] {
+			BOOST_TEST(strand.running_in_this_thread() == true, "Posting to strand from outside coroutine");
+			timer.cancel_one(); // Wake up the coroutine.
+			boost::asio::post(strand, dummyWork);
+			BOOST_TEST(strand.running_in_this_thread() == true, "End of post to strand from outside coroutine");
+		});
+
+		TestThread mockThread{[&io] {
+			try{
+				io.run();
+			} catch (const std::exception& ex) {
+				BOOST_FAIL("Exception in mock thread: " << ex.what());
+			} catch (...) {
+				BOOST_FAIL("Unknown exception in mock thread");
+			}
+		}};
+		try {
+			io.run();
+		} catch (const std::exception& ex) {
+			BOOST_FAIL("Exception in main thread: " << ex.what());
+		} catch (...) {
+			BOOST_FAIL("Unknown exception in main thread");
+		}
+		REQUIRE_JOINS_WITHIN(mockThread, 5s);
+		if (testFailed.load()) {
+			BOOST_FAIL("Test failed");
+		}
+	}
+}
+
 BOOST_AUTO_TEST_SUITE_END()