diff options
| author | Dennis Brentjes <d.brentjes@gmail.com> | 2016-11-28 15:48:59 +0100 |
|---|---|---|
| committer | Dennis Brentjes <d.brentjes@gmail.com> | 2016-11-28 15:48:59 +0100 |
| commit | a4a912873058e50060561c21e965b4fec1d9b08b (patch) | |
| tree | 564432cf3f760483a9acfa64f109f5f42be469c1 /node/node.cpp | |
| parent | b8d2fe28870d1f54aad1fd9fce04e57caa85ba0b (diff) | |
| download | cmix-a4a912873058e50060561c21e965b4fec1d9b08b.tar.gz cmix-a4a912873058e50060561c21e965b4fec1d9b08b.tar.bz2 cmix-a4a912873058e50060561c21e965b4fec1d9b08b.zip | |
Cleans up and documents the whole cmix protocol.
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) { |