diff options
Diffstat (limited to 'node/node.cpp')
| -rw-r--r-- | node/node.cpp | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/node/node.cpp b/node/node.cpp index b31f60a..c17fe4f 100644 --- a/node/node.cpp +++ b/node/node.cpp @@ -202,14 +202,22 @@ void Node::start_precomputation() { if(encrypt_r( &cmix_ctx, r_er.data(), - m_er.data(), - cmix_ctx.nr_participants + m_er.data() ) != no_error) { exit(-1); } BOOST_LOG_TRIVIAL(trace) << "Sending prepre message: " << prepre.ShortDebugString(); next_node.async_send(prepre); + + auto it = messages.cbegin(); + while(it != messages.cend()) { + if(it->second.empty()) { + it = messages.erase(it); + } else { + ++it; + } + } } void Node::start_realtime_phase() { @@ -251,8 +259,7 @@ void Node::start_realtime_phase() { &cmix_ctx, ms.data(), msv.data(), - keys.data(), - index_map.size() + keys.data() ); for(auto&& pair : index_map) { |