tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-23 21:55:03 +02:00
Code Issues Packages Projects Releases Wiki Activity

IoEngine: allow to bind to rvalue Executor objects

Browse Source 
Don't require the Executor to be of type non-const reference but allow it to be a forwarding
reference instead. This allows us to use`IoEngine::SpawnCoroutine()` with both lvalue and rvalue
executors.
This commit is contained in:
Yonas Habteab 2025-07-14 17:44:48 +02:00
parent 42cee50cc0
commit 1d29260d77
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
lib/base/io-engine.hpp
View File

@ -103,8 +103,8 @@ public:
#endif /* _WIN32 */ #endif /* _WIN32 */
} }
template <typename Handler, typename Function> template <typename Executor, typename Function>
static void SpawnCoroutine(Handler& h, Function f) { static void SpawnCoroutine(Executor&& e, Function f) {
auto wrapper = [f = std::move(f)](boost::asio::yield_context yc) { auto wrapper = [f = std::move(f)](boost::asio::yield_context yc) {
try { try {
f(yc); f(yc);
@ -123,13 +123,14 @@ public:
}; };
#if BOOST_VERSION >= 108700 #if BOOST_VERSION >= 108700
boost::asio::spawn(h, boost::asio::spawn(
std::forward<Executor>(e),
std::allocator_arg, boost::context::fixedsize_stack(GetCoroutineStackSize()), std::allocator_arg, boost::context::fixedsize_stack(GetCoroutineStackSize()),
std::move(wrapper), std::move(wrapper),
boost::asio::detached boost::asio::detached
); );
#else // BOOST_VERSION >= 108700 #else // BOOST_VERSION >= 108700
boost::asio::spawn(h, std::move(wrapper), boost::coroutines::attributes(GetCoroutineStackSize())); boost::asio::spawn(std::forward<Executor>(e), std::move(wrapper), boost::coroutines::attributes(GetCoroutineStackSize()));
#endif // BOOST_VERSION >= 108700 #endif // BOOST_VERSION >= 108700
} }