tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Simplify usage of PromiseKey in LocalTransportHandle to avoid replier address

Browse Source
This commit is contained in:
Tyler Neely 2022-11-02 17:11:26 +00:00
parent 7596e85358
commit 6239f4fc3e
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/io/local_transport/local_transport_handle.hpp
View File

@ -113,8 +113,7 @@ class LocalTransportHandle {
.message = std::move(message_any), .message = std::move(message_any),
.type_info = type_info}; .type_info = type_info};
PromiseKey promise_key{ PromiseKey promise_key{.requester_address = to_address, .request_id = opaque_message.request_id};
.requester_address = to_address, .request_id = opaque_message.request_id, .replier_address = from_address};
{ {
std::unique_lock<std::mutex> lock(mu_); std::unique_lock<std::mutex> lock(mu_);
@ -152,8 +151,7 @@ class LocalTransportHandle {
{ {
std::unique_lock<std::mutex> lock(mu_); std::unique_lock<std::mutex> lock(mu_);
PromiseKey promise_key{ PromiseKey promise_key{.requester_address = from_address, .request_id = request_id};
.requester_address = from_address, .request_id = request_id, .replier_address = to_address};
OpaquePromise opaque_promise(std::move(promise).ToUnique()); OpaquePromise opaque_promise(std::move(promise).ToUnique());
DeadlineAndOpaquePromise dop{.requested_at = now, .deadline = deadline, .promise = std::move(opaque_promise)}; DeadlineAndOpaquePromise dop{.requested_at = now, .deadline = deadline, .promise = std::move(opaque_promise)};
promises_.emplace(std::move(promise_key), std::move(dop)); promises_.emplace(std::move(promise_key), std::move(dop));