aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorDeterminant <[email protected]>2018-09-12 02:15:03 -0400
committerDeterminant <[email protected]>2018-09-12 02:15:03 -0400
commit652b6ac27a5f86af8f442321a5b4abe5e6c3d2b9 (patch)
treecabb1b761f5dec8cc5d2294deef65e514bc7a61d /src
parentb730a496b39d1ecef3763c07dc8f82a3f86c07fb (diff)
create branch nsdi-eval
Diffstat (limited to 'src')
-rw-r--r--src/hotstuff_app.cpp26
1 files changed, 13 insertions, 13 deletions
diff --git a/src/hotstuff_app.cpp b/src/hotstuff_app.cpp
index 014fe16..16d4abf 100644
--- a/src/hotstuff_app.cpp
+++ b/src/hotstuff_app.cpp
@@ -83,12 +83,12 @@ class HotStuffApp: public HotStuff {
#ifndef HOTSTUFF_ENABLE_BENCHMARK
HOTSTUFF_LOG_INFO("replicated %s", std::string(fin).c_str());
#endif
- auto it = unconfirmed.find(fin.cmd_hash);
- if (it != unconfirmed.end())
- {
- it->second.resolve(fin);
- unconfirmed.erase(it);
- }
+ //auto it = unconfirmed.find(fin.cmd_hash);
+ //if (it != unconfirmed.end())
+ //{
+ // it->second.resolve(fin);
+ // unconfirmed.erase(it);
+ //}
}
public:
@@ -264,13 +264,13 @@ void HotStuffApp::client_request_cmd_handler(MsgReqCmd &&msg, Conn &conn) {
});
else
{
- auto it = unconfirmed.find(cmd_hash);
- if (it == unconfirmed.end())
- it = unconfirmed.insert(
- std::make_pair(cmd_hash, promise_t([](promise_t &){}))).first;
- it->second.then([this, addr](const Finality &fin) {
- cn.send_msg(MsgRespCmd(std::move(fin)), addr);
- });
+ //auto it = unconfirmed.find(cmd_hash);
+ //if (it == unconfirmed.end())
+ // it = unconfirmed.insert(
+ // std::make_pair(cmd_hash, promise_t([](promise_t &){}))).first;
+ //it->second.then([this, addr](const Finality &fin) {
+ // cn.send_msg(MsgRespCmd(std::move(fin)), addr);
+ //});
}
}