diff options
| author | Dennis Brentjes <d.brentjes@gmail.com> | 2016-10-30 19:59:30 +0100 |
|---|---|---|
| committer | Dennis Brentjes <d.brentjes@gmail.com> | 2016-10-30 20:00:49 +0100 |
| commit | bc0cc7d5030b80e6dbb05f6a0b49481881bd26c8 (patch) | |
| tree | ac54dadf5a31c835779a307b32ab55d0990891ff | |
| parent | 6d4efd424682f90896d5237ede4326416b6fa97d (diff) | |
| download | cmix-bc0cc7d5030b80e6dbb05f6a0b49481881bd26c8.tar.gz cmix-bc0cc7d5030b80e6dbb05f6a0b49481881bd26c8.tar.bz2 cmix-bc0cc7d5030b80e6dbb05f6a0b49481881bd26c8.zip | |
Adds a start to the precomputation mix phase.
| -rw-r--r-- | libcmix-common/cmixprotofunctor.hpp | 7 | ||||
| -rw-r--r-- | libcmix-protobuf/cmix.proto | 4 | ||||
| -rw-r--r-- | node/node.cpp | 31 |
3 files changed, 40 insertions, 2 deletions
diff --git a/libcmix-common/cmixprotofunctor.hpp b/libcmix-common/cmixprotofunctor.hpp index 75944f9..5fd736b 100644 --- a/libcmix-common/cmixprotofunctor.hpp +++ b/libcmix-common/cmixprotofunctor.hpp @@ -67,7 +67,12 @@ struct CMixProtoFunctor { /*! * #MESSAGE_SETTER_DECL(PrePre, prepre) */ - MESSAGE_SETTER_DEF(PrePre, prepre); + MESSAGE_SETTER_DEF(PrePre, prepre) + + /*! + * #MESSAGE_SETTER_DECL(PreMix, premix) + */ + MESSAGE_SETTER_DEF(PreMix, premix) #undef MESSAGE_SETTER_DEF }; diff --git a/libcmix-protobuf/cmix.proto b/libcmix-protobuf/cmix.proto index 2fe2d83..00ab377 100644 --- a/libcmix-protobuf/cmix.proto +++ b/libcmix-protobuf/cmix.proto @@ -35,7 +35,8 @@ message PrePre { } message PreMix { - repeated bytes EPiRS = 1; + repeated bytes r_EPiRS = 1; + repeated bytes m_EPiRS = 2; } message PrePost { @@ -52,5 +53,6 @@ message CMixMessage { KeyExchange keyexchange = 6; NodeReady nodeready = 7; PrePre prepre = 8; + PreMix premix = 9; } } diff --git a/node/node.cpp b/node/node.cpp index 2e5fd32..02ddb3e 100644 --- a/node/node.cpp +++ b/node/node.cpp @@ -128,6 +128,37 @@ void Node::handle_node_secretkey(cmix_proto::SecretKey const& secret) void Node::handle_node_prepre(cmix_proto::PrePre const& pre) { if(network_settings.is_first) { + cmix_proto::PreMix premix; + for(int i = 0; i < pre.m_er_size(); ++i) { + GroupElement random_r = api.array_to_element(pre.r_er(i).data(), pre.r_er(i).size(), true); + GroupElement message_r = api.array_to_element(pre.m_er(i).data(), pre.m_er(i).size(), true); + + GroupElement random_s; + GroupElement message_s; + + api.encrypt(&random_s, &message_s, precomputation_data[precomputation_data[i].new_location].s, network_key); + + GroupElement random_pirs = api.multiply(random_r, random_s, true); + GroupElement message_pirs = api.multiply(message_r, message_s, true); + + unsigned char* data; + size_t len; + + api.element_to_array(&data, &len, random_pirs); + premix.set_r_epirs(precomputation_data[i].new_location, data, len); + api.free_buffer(data); + + api.element_to_array(&data, &len, message_pirs); + premix.set_m_epirs(precomputation_data[i].new_location, data, len); + api.free_buffer(data); + + api.free_group_element(random_r); + api.free_group_element(message_r); + api.free_group_element(random_s); + api.free_group_element(message_s); + } + + next_node.async_send(premix); } else { std::vector<size_t> permutation(clients.size()); |