sha512sum/cserver
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixes

Browse source
This commit is contained in:
sha512sum 2024-06-11 08:21:08 +00:00
parent 1b7899743c
commit da0bcfbb63
2 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
include/cserver/engine/basic/task_processor.hpp
View file

@ -15,7 +15,7 @@ struct TaskProcessor {
pool{} { pool{} {
}; };
inline constexpr ~TaskProcessor() { inline ~TaskProcessor() {
for(auto& thread : this->pool) { for(auto& thread : this->pool) {
if(thread && thread->joinable()) { if(thread && thread->joinable()) {
thread->join(); thread->join();

8
include/cserver/engine/coroutine.hpp
View file

@ -61,14 +61,14 @@ struct awaitable_frame_base<any_io_executor> {
public: public:
using Executor = any_io_executor; using Executor = any_io_executor;
#if !defined(BOOST_ASIO_DISABLE_AWAITABLE_FRAME_RECYCLING) #if !defined(BOOST_ASIO_DISABLE_AWAITABLE_FRAME_RECYCLING)
auto constexpr operator new(std::size_t size) -> void* { inline auto operator new(std::size_t size) -> void* {
return boost::asio::detail::thread_info_base::allocate( return boost::asio::detail::thread_info_base::allocate(
boost::asio::detail::thread_info_base::awaitable_frame_tag(), boost::asio::detail::thread_info_base::awaitable_frame_tag(),
boost::asio::detail::thread_context::top_of_thread_call_stack(), boost::asio::detail::thread_context::top_of_thread_call_stack(),
size); size);
}; };
inline constexpr auto operator delete(void* pointer, std::size_t size) -> void { inline auto operator delete(void* pointer, std::size_t size) -> void {
boost::asio::detail::thread_info_base::deallocate( boost::asio::detail::thread_info_base::deallocate(
boost::asio::detail::thread_info_base::awaitable_frame_tag(), boost::asio::detail::thread_info_base::awaitable_frame_tag(),
boost::asio::detail::thread_context::top_of_thread_call_stack(), boost::asio::detail::thread_context::top_of_thread_call_stack(),
@ -99,7 +99,7 @@ public:
return Result{this}; return Result{this};
}; };
inline constexpr auto set_except(std::exception_ptr e) noexcept -> void { inline auto set_except(std::exception_ptr e) noexcept -> void {
pending_exception_ = e; pending_exception_ = e;
}; };
@ -170,7 +170,7 @@ public:
inline constexpr auto await_suspend(coroutine_handle<void>) noexcept -> void {}; inline constexpr auto await_suspend(coroutine_handle<void>) noexcept -> void {};
inline constexpr auto await_resume() const noexcept { inline auto await_resume() const noexcept {
return this_->attached_thread_->get_executor(); return this_->attached_thread_->get_executor();
}; };
}; };