Skip to content
Snippets Groups Projects
Commit c56a1c7d authored by irene's avatar irene
Browse files

adding take slow path immediately if responses do not match

parent bc11c80c
No related branches found
No related tags found
No related merge requests found
......@@ -225,8 +225,8 @@ IRClient::ConsensusSlowPath(const uint64_t reqId)
req->timer->Start();
} else {
Warning("Could not send finalize message to replicas");
pendingReqs.erase(reqId);
delete req;
pendingReqs.erase(reqId);
delete req;
}
}
......@@ -412,9 +412,12 @@ IRClient::HandleConsensusReply(const TransportAddress &remote,
req->continuation(req->request, result.first);
req->continuationInvoked = true;
}
break;
return;
}
}
// Otherwise no matching results, so take slow path
ConsensusSlowPath(reqId);
}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment