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

Fix error handling.

Browse Source
This commit is contained in:
Marcelo Zimbres
2022-04-16 16:47:32 +02:00
parent 8c4816fc8d
commit 20d6c67f3d
1 changed files with 28 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
aedis/generic/detail/client_ops.hpp
View File

@@ -52,9 +52,27 @@ struct run_op {
std::move(self));
switch (order[0]) {
case 0: recv->on_connect(); break;
case 1: self.complete(ec2); return;
default: assert(false);
case 0:
{
if (ec1) {
self.complete(ec1);
return;
}
recv->on_connect();
} break;
case 1:
{
if (!ec2) {
// The timer expired, we can't connect. Pass that to
// the user and leave.
// TODO: Use our own error code, not from asio.
self.complete(boost::asio::error::connection_refused);
return;
}
} break;
default: assert(false);
}
// Starts the reader and writer ops.
@@ -121,9 +139,13 @@ struct write_op {
case 1:
{
self.complete(ec2);
return;
}
if (!ec2) {
// The timer expired, we couldn't write the message.
// TODO: Add own error code e.g. write_timeout.
self.complete(boost::asio::error::connection_refused);
return;
}
} break;
default: assert(false);
}