boost/redis
2
0
Fork 0
mirror of https://github.com/boostorg/redis.git synced 2026-01-19 04:42:09 +00:00
Code Issues Projects Releases Wiki Activity

Reconnection no longer causes the writer to perform busy waiting (#253)

Browse Source 
Reconnection now uses a separate timer to wait

close #252
This commit is contained in:
Anarthal (Rubén Pérez)
2025-05-19 16:46:56 +02:00
committed by GitHub
parent 328ad97a79
commit c1c50e3e24
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
include/boost/redis/connection.hpp
View File

@@ -442,12 +442,10 @@ public:
return;
}
// It is safe to use the writer timer here because we are not
// connected.
conn_->writer_timer_.expires_after(conn_->cfg_.reconnect_wait_interval);
conn_->reconnect_timer_.expires_after(conn_->cfg_.reconnect_wait_interval);
BOOST_ASIO_CORO_YIELD
conn_->writer_timer_.async_wait(asio::prepend(std::move(self), order_t{}));
conn_->reconnect_timer_.async_wait(asio::prepend(std::move(self), order_t{}));
if (ec0) {
self.complete(ec0);
return;
@@ -507,6 +505,7 @@ public:
: ctx_{std::move(ctx)}
, stream_{std::make_unique<next_layer_type>(ex, ctx_)}
, writer_timer_{ex}
, reconnect_timer_{ex}
, receive_channel_{ex, 256}
, resv_{ex}
, health_checker_{ex}
@@ -826,6 +825,7 @@ private:
// also more suitable than a channel and the notify operation does
// not suspend.
timer_type writer_timer_;
timer_type reconnect_timer_; // to wait the reconnection period
receive_channel_type receive_channel_;
resolver_type resv_;
detail::connector ctor_;