saberbud/rest_rpc
1
0
Fork 0
mirror of https://github.com/qicosmos/rest_rpc.git synced 2026-08-29 08:34:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix client call exception

Browse Source
This commit is contained in:
qicosmos
2022-01-16 16:33:04 +08:00
parent 3354666e57
commit a4224a3c93
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
include/rest_rpc/rpc_client.hpp
+9 -8
View File
@@ -229,6 +229,10 @@ public:
call(const std::string &rpc_name, Args &&...args) {
auto future_result =
async_call<FUTURE>(rpc_name, std::forward<Args>(args)...);
std::shared_ptr<bool> guard(nullptr, [this, &future_result](auto) {
std::unique_lock<std::mutex> lock(cb_mtx_);
future_map_.erase(future_result.id);
});
auto status = future_result.wait_for(std::chrono::milliseconds(TIMEOUT));
if (status == std::future_status::timeout ||
status == std::future_status::deferred) {
@@ -236,8 +240,6 @@ public:
}
future_result.get().as();
std::unique_lock<std::mutex> lock(cb_mtx_);
future_map_.erase(future_result.id);
}
template <typename T = void, typename... Args>
@@ -251,18 +253,17 @@ public:
call(const std::string &rpc_name, Args &&...args) {
auto future_result =
async_call<FUTURE>(rpc_name, std::forward<Args>(args)...);
std::shared_ptr<bool> guard(nullptr, [this, &future_result](auto) {
std::unique_lock<std::mutex> lock(cb_mtx_);
future_map_.erase(future_result.id);
});
auto status = future_result.wait_for(std::chrono::milliseconds(TIMEOUT));
if (status == std::future_status::timeout ||
status == std::future_status::deferred) {
throw std::out_of_range("timeout or deferred");
}
auto t = future_result.get().template as<T>();
{
std::unique_lock<std::mutex> lock(cb_mtx_);
future_map_.erase(future_result.id);
}
return t;
return future_result.get().template as<T>();
}
template <typename T, typename... Args>