Skip to content

Commit 62fa5e1

Browse files
astrophysikdenisichh
authored andcommitted
[k2] rework rpc-queue warning message (#1443)
1 parent 2dc73cb commit 62fa5e1

1 file changed

Lines changed: 4 additions & 3 deletions

File tree

runtime-light/stdlib/rpc/rpc-queue-functions.h

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ inline void rpc_queue_push(int64_t queue_id, int64_t request_id) noexcept {
2121

2222
const auto it_fork_id{rpc_client_instance_st.response_waiter_forks.find(request_id)};
2323
if (it_fork_id == rpc_client_instance_st.response_waiter_forks.end()) [[unlikely]] {
24-
kphp::log::warning("unexpectedly could not find query in pending queries");
24+
kphp::log::warning("could not find rpc query with id {} in pending queries", queue_id);
2525
return;
2626
}
2727

@@ -36,10 +36,11 @@ inline kphp::coro::task<std::optional<int64_t>> rpc_queue_next(int64_t queue_id,
3636
co_return std::nullopt;
3737
}
3838

39+
const int64_t ready_fork_id{*wait_result};
3940
auto& rpc_client_instance_st{RpcClientInstanceState::get()};
40-
const auto it_request_id{rpc_client_instance_st.awaiter_forks_to_response.find(*wait_result)};
41+
const auto it_request_id{rpc_client_instance_st.awaiter_forks_to_response.find(ready_fork_id)};
4142
if (it_request_id == rpc_client_instance_st.awaiter_forks_to_response.end()) [[unlikely]] {
42-
kphp::log::warning("awaiter forks in rpc queue isn't associated with response");
43+
kphp::log::warning("awaiter fork {} in the rpc queue isn't associated with any response", ready_fork_id);
4344
co_return std::nullopt;
4445
}
4546

0 commit comments

Comments
 (0)