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

Fix RemoteProduceRpcServer OngoingProduce

Browse Source 
Summary: Create a map entry with correct key (tx_id and plan_id).

Reviewers: teon.banek, florijan

Reviewed By: teon.banek

Subscribers: mferencevic

Differential Revision: https://phabricator.memgraph.io/D1278
This commit is contained in:
Matija Santl 2018-03-06 16:02:45 +01:00
parent 5637703317
commit 011b653ce6
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/distributed/remote_produce_rpc_server.hpp
View File

@ -175,7 +175,8 @@ class RemoteProduceRpcServer {
auto &GetOngoingProduce(const RemotePullReq &req) {
auto access = ongoing_produces_.access();
auto found = access.find({req.tx_id, req.plan_id});
auto key_pair = std::make_pair(req.tx_id, req.plan_id);
auto found = access.find(key_pair);
if (found != access.end()) {
return found->second;
}
@ -185,9 +186,8 @@ class RemoteProduceRpcServer {
.RunningTransaction(req.tx_id, req.tx_snapshot);
}
auto &plan_pack = plan_consumer_.PlanForId(req.plan_id);
auto key_par = std::make_pair(req.tx_id, req.tx_id);
return access
.emplace(key_par, std::forward_as_tuple(key_par),
.emplace(key_pair, std::forward_as_tuple(key_pair),
std::forward_as_tuple(db_, req.tx_id, plan_pack.plan,
plan_pack.symbol_table, req.params,
req.symbols))