Skip to content

WIP: GSoC21 - python eventloop using Boost.Asio strand #365

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
philoinovsky wants to merge 15 commits into
base: develop
Choose a base branch
from
Open

WIP: GSoC21 - python eventloop using Boost.Asio strand #365

Changes from 1 commit
Commits
Show all changes
15 commits
Select commit Hold shift + click to select a range
e6b292f
add eventloop implementations for call_* and call_when_*_completed fu…
Jun 8, 2021
7d8fae8
add implementations of sock_* functions
Jun 26, 2021
5747a3a
Fixed namespace related issues
Jun 27, 2021
a2a2bbe
add implementations for eventloop functions sock_*
Jun 27, 2021
0510847
add TLS Upgrade, DNS, Error Handling API
Jun 29, 2021
d23977f
change event_loop constructor parameter from io_context to strand
Jul 10, 2021
587c1ea
change std::future to python concurrent.futures.Future
Jul 10, 2021
914a18d
remove _id_to_timer_map; change sock_recv_handlers to lambdas
Jul 11, 2021
570a387
replace make_function with lambda
Jul 11, 2021
53666c6
replace call_later call in call_at with other code
Jul 11, 2021
a9efac6
fix issues
Jul 11, 2021
afcccbc
add interface to set default eventloop
Aug 8, 2021
e4ec199
add event_loop doc
Aug 9, 2021
a2e1238
add create_future
Aug 21, 2021
1d32002
fix multiple issues
Aug 22, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
replace call_later call in call_at with other code
  • Loading branch information
philoinovsky committed Jul 11, 2021
commit 53666c6c3070a5ec790d3bb731dbfc3c141157dc
19 changes: 13 additions & 6 deletions src/eventloop.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -98,19 +98,26 @@ void event_loop::_sock_accept(event_loop& loop, object fut, object sock)

void event_loop::call_later(double delay, object f)
{
auto p_timer = std::make_shared<boost::asio::steady_timer>(_strand.context(),
std::chrono::nanoseconds(int64_t(delay * 1e9)));
p_timer->async_wait(boost::asio::bind_executor(
_strand,
auto p_timer = std::make_shared<boost::asio::steady_timer>(
_strand.context(),
std::chrono::nanoseconds(int64_t(delay * 1e9)));
p_timer->async_wait(boost::asio::bind_executor(_strand,
[f, p_timer, this] (const boost::system::error_code& ec) {f();}));
}

void event_loop::call_at(double when, object f)
{
double diff = when - time();
if (diff > 0)
return call_later(diff, f);
return call_soon(f);
{
auto p_timer = std::make_shared<boost::asio::steady_timer>(
_strand.context(),
std::chrono::nanoseconds(int64_t(diff * 1e9)));
p_timer->async_wait(boost::asio::bind_executor(_strand,
[f, p_timer, this] (const boost::system::error_code& ec) {f();}));
return;
}
call_soon(f);
}

object event_loop::sock_recv(object sock, size_t nbytes)
Expand Down