added per message GNUNET_MQ_PriorityPreferences

2 files changed, 8 insertions, 2 deletions

diff --git a/src/scalarproduct/gnunet-service-scalarproduct-ecc_alice.c b/src/scalarproduct/gnunet-service-scalarproduct-ecc_alice.c
index 4b1a09e50..123a02188 100644
--- a/src/scalarproduct/gnunet-service-scalarproduct-ecc_alice.c
+++ b/src/scalarproduct/gnunet-service-scalarproduct-ecc_alice.c
@@ -634,6 +634,8 @@ send_alices_cryptodata_message (struct AliceServiceSession *s)
     e = GNUNET_MQ_msg_extra (msg,
                              todo_count * 2 * sizeof (struct GNUNET_CRYPTO_EccPoint),
                              GNUNET_MESSAGE_TYPE_SCALARPRODUCT_ECC_ALICE_CRYPTODATA);
+    GNUNET_MQ_env_set_options(e,
+                              GNUNET_MQ_PREF_RELIABLE);
     msg->contained_element_count = htonl (todo_count);
     payload = (struct GNUNET_CRYPTO_EccPoint *) &msg[1];
     r_ia = gcry_mpi_new (0);
@@ -837,7 +839,6 @@ client_request_complete_alice (struct AliceServiceSession *s)
                                    s,
                                    &s->peer,
                                    &s->session_id,
-                                   GNUNET_CADET_OPTION_RELIABLE,
                                    NULL,
                                    &cb_channel_destruction,
                                    cadet_handlers);
@@ -865,6 +866,8 @@ client_request_complete_alice (struct AliceServiceSession *s)
 
   e = GNUNET_MQ_msg (msg,
                      GNUNET_MESSAGE_TYPE_SCALARPRODUCT_ECC_SESSION_INITIALIZATION);
+  GNUNET_MQ_env_set_options(e,
+                              GNUNET_MQ_PREF_RELIABLE);
   msg->session_id = s->session_id;
   GNUNET_MQ_send (s->cadet_mq,
                   e);
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)
     e = GNUNET_MQ_msg_extra (msg,
                              todo_count * sizeof (struct GNUNET_CRYPTO_PaillierCiphertext),
                              GNUNET_MESSAGE_TYPE_SCALARPRODUCT_ALICE_CRYPTODATA);
+    GNUNET_MQ_env_set_options(e,
+                              GNUNET_MQ_PREF_RELIABLE);
     msg->contained_element_count = htonl (todo_count);
     payload = (struct GNUNET_CRYPTO_PaillierCiphertext *) &msg[1];
     a = gcry_mpi_new (0);
@@ -1073,7 +1075,6 @@ client_request_complete_alice (struct AliceServiceSession *s)
                                    s,
                                    &s->peer,
                                    &s->session_id,
-                                   GNUNET_CADET_OPTION_RELIABLE,
                                    NULL,
                                    &cb_channel_destruction,
                                    cadet_handlers);
@@ -1101,6 +1102,8 @@ client_request_complete_alice (struct AliceServiceSession *s)
 
   e = GNUNET_MQ_msg (msg,
                      GNUNET_MESSAGE_TYPE_SCALARPRODUCT_SESSION_INITIALIZATION);
+  GNUNET_MQ_env_set_options(e,
+                              GNUNET_MQ_PREF_RELIABLE);
   msg->session_id = s->session_id;
   msg->public_key = my_pubkey;
   GNUNET_MQ_send (s->cadet_mq,