mirror of
https://github.com/qicosmos/rest_rpc.git
synced 2026-08-29 08:34:47 +08:00
fix issue 82
This commit is contained in:
@@ -508,6 +508,14 @@ private:
|
||||
}
|
||||
} else {
|
||||
std::cout << ec.message() << "\n";
|
||||
|
||||
{
|
||||
std::unique_lock<std::mutex> lock(cb_mtx_);
|
||||
for (auto& item : callback_map_) {
|
||||
item.second->callback(ec, {});
|
||||
}
|
||||
}
|
||||
|
||||
close(false);
|
||||
error_callback(ec);
|
||||
}
|
||||
@@ -544,6 +552,7 @@ private:
|
||||
} else {
|
||||
// LOG(INFO) << ec.message();
|
||||
has_connected_ = false;
|
||||
call_back(req_id, ec, {});
|
||||
close();
|
||||
error_callback(ec);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user