...

2 files changed, 4 insertions, 3 deletions

diff --git a/src/hotstuff.cpp b/src/hotstuff.cpp
index 99ab80f..1912946 100644
--- a/src/hotstuff.cpp
+++ b/src/hotstuff.cpp
@@ -410,6 +410,7 @@ void HotStuffBase::do_vote(ReplicaID last_proposer, const Vote &vote) {
 }
 
 void HotStuffBase::do_decide(Finality &&fin) {
+    part_decided++;
     state_machine_execute(fin);
     auto it = decision_waiting.find(fin.cmd_hash);
     if (it != decision_waiting.end())
diff --git a/src/hotstuff_client.cpp b/src/hotstuff_client.cpp
index b32bcb5..d8a6087 100644
--- a/src/hotstuff_client.cpp
+++ b/src/hotstuff_client.cpp
@@ -65,8 +65,8 @@ void try_send() {
     {
         auto cmd = new CommandDummy(cid, cnt++);
         //mn.send_msg(MsgReqCmd(*cmd), *conns.at(proposer));
-        for (auto &p: conns)
-            mn.send_msg(MsgReqCmd(*cmd), *(p.second));
+        MsgReqCmd msg(*cmd);
+        for (auto &p: conns) mn.send_msg(msg, *(p.second));
 #ifndef HOTSTUFF_ENABLE_BENCHMARK
         HOTSTUFF_LOG_INFO("send new cmd %.10s",
                             get_hex(cmd->get_hash()).c_str());
@@ -103,7 +103,7 @@ void client_resp_cmd_handler(MsgRespCmd &&msg, MsgNetwork<opcode_t>::Conn &) {
 //        it->second.rid = proposer;
 //        return;
 //    }
-    if (++it->second.confirmed <= nfaulty) return; // wait for f + 1 ack
+//    if (++it->second.confirmed <= nfaulty) return; // wait for f + 1 ack
 #ifndef HOTSTUFF_ENABLE_BENCHMARK
     HOTSTUFF_LOG_INFO("got %s, wall: %.3f, cpu: %.3f",
                         std::string(fin).c_str(),