feedc0de/boost_beast
1
0
Fork 0
forked from boostorg/beast
Code Pull Requests Activity

server-flex-awaitable: connections get their own strand

Browse Source
This commit is contained in:
Mohammad Nejati
2024-07-08 06:37:08 +00:00
committed by Mohammad Nejati
parent ff5672ec07
commit 375b0b5ee8
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
example/advanced/server-flex-awaitable/advanced_server_flex_awaitable.cpp
View File

@@ -498,7 +498,9 @@ listen(
while(!cs.cancelled()) while(!cs.cancelled())
{ {
auto [ec, socket] = co_await acceptor.async_accept(net::as_tuple); auto socket_executor = net::make_strand(executor.get_inner_executor());
auto [ec, socket] =
co_await acceptor.async_accept(socket_executor, net::as_tuple);
if(ec == net::error::operation_aborted) if(ec == net::error::operation_aborted)
co_return; co_return;
@@ -507,7 +509,7 @@ listen(
throw boost::system::system_error{ ec }; throw boost::system::system_error{ ec };
net::co_spawn( net::co_spawn(
net::make_strand(executor.get_inner_executor()), std::move(socket_executor),
detect_session(stream_type{ std::move(socket) }, ctx, doc_root), detect_session(stream_type{ std::move(socket) }, ctx, doc_root),
task_group.adapt( task_group.adapt(
[](std::exception_ptr e) [](std::exception_ptr e)