diff options
Diffstat (limited to 'src/scalarproduct/gnunet-service-scalarproduct_alice.c')
-rw-r--r-- | src/scalarproduct/gnunet-service-scalarproduct_alice.c | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/scalarproduct/gnunet-service-scalarproduct_alice.c b/src/scalarproduct/gnunet-service-scalarproduct_alice.c index 393a1951b..18c5cc49a 100644 --- a/src/scalarproduct/gnunet-service-scalarproduct_alice.c +++ b/src/scalarproduct/gnunet-service-scalarproduct_alice.c | |||
@@ -893,6 +893,8 @@ send_alices_cryptodata_message (struct AliceServiceSession *s) | |||
893 | e = GNUNET_MQ_msg_extra (msg, | 893 | e = GNUNET_MQ_msg_extra (msg, |
894 | todo_count * sizeof (struct GNUNET_CRYPTO_PaillierCiphertext), | 894 | todo_count * sizeof (struct GNUNET_CRYPTO_PaillierCiphertext), |
895 | GNUNET_MESSAGE_TYPE_SCALARPRODUCT_ALICE_CRYPTODATA); | 895 | GNUNET_MESSAGE_TYPE_SCALARPRODUCT_ALICE_CRYPTODATA); |
896 | GNUNET_MQ_env_set_options(e, | ||
897 | GNUNET_MQ_PREF_RELIABLE); | ||
896 | msg->contained_element_count = htonl (todo_count); | 898 | msg->contained_element_count = htonl (todo_count); |
897 | payload = (struct GNUNET_CRYPTO_PaillierCiphertext *) &msg[1]; | 899 | payload = (struct GNUNET_CRYPTO_PaillierCiphertext *) &msg[1]; |
898 | a = gcry_mpi_new (0); | 900 | a = gcry_mpi_new (0); |
@@ -1073,7 +1075,6 @@ client_request_complete_alice (struct AliceServiceSession *s) | |||
1073 | s, | 1075 | s, |
1074 | &s->peer, | 1076 | &s->peer, |
1075 | &s->session_id, | 1077 | &s->session_id, |
1076 | GNUNET_CADET_OPTION_RELIABLE, | ||
1077 | NULL, | 1078 | NULL, |
1078 | &cb_channel_destruction, | 1079 | &cb_channel_destruction, |
1079 | cadet_handlers); | 1080 | cadet_handlers); |
@@ -1101,6 +1102,8 @@ client_request_complete_alice (struct AliceServiceSession *s) | |||
1101 | 1102 | ||
1102 | e = GNUNET_MQ_msg (msg, | 1103 | e = GNUNET_MQ_msg (msg, |
1103 | GNUNET_MESSAGE_TYPE_SCALARPRODUCT_SESSION_INITIALIZATION); | 1104 | GNUNET_MESSAGE_TYPE_SCALARPRODUCT_SESSION_INITIALIZATION); |
1105 | GNUNET_MQ_env_set_options(e, | ||
1106 | GNUNET_MQ_PREF_RELIABLE); | ||
1104 | msg->session_id = s->session_id; | 1107 | msg->session_id = s->session_id; |
1105 | msg->public_key = my_pubkey; | 1108 | msg->public_key = my_pubkey; |
1106 | GNUNET_MQ_send (s->cadet_mq, | 1109 | GNUNET_MQ_send (s->cadet_mq, |