[GNUnet-SVN] r30321 - gnunet/src/scalarproduct

[gnunet]

Author: cfuchs
Date: 2013-10-18 15:47:30 +0200 (Fri, 18 Oct 2013)
New Revision: 30321

Modified:
   gnunet/src/scalarproduct/gnunet-service-scalarproduct.c
   gnunet/src/scalarproduct/test_scalarproduct.sh
Log:
finished SP-testcase
SP now properly resets a couple of freed values
fixed a double-free
fixed a logics bug in handle_service_response



Modified: gnunet/src/scalarproduct/gnunet-service-scalarproduct.c
===================================================================
--- gnunet/src/scalarproduct/gnunet-service-scalarproduct.c     2013-10-18 
13:41:13 UTC (rev 30320)
+++ gnunet/src/scalarproduct/gnunet-service-scalarproduct.c     2013-10-18 
13:47:30 UTC (rev 30321)
@@ -692,7 +692,6 @@
   return NULL;
 }
 
-
 /**
  * Safely frees ALL memory areas referenced by a session.
  * 
@@ -709,7 +708,10 @@
     GNUNET_free (session->a);
     session->a = NULL;
   }
-  GNUNET_free_non_null (session->mask);
+  if (session->mask) {
+    GNUNET_free (session->mask);
+    session->mask = NULL;
+  }
   if (session->r) {
     for (i = 0; i < session->used; i++)
       if (session->r[i]) gcry_mpi_release (session->r[i]);
@@ -722,24 +724,24 @@
     GNUNET_free (session->r_prime);
     session->r_prime = NULL;
   }
-  if (session->s){
+  if (session->s) {
     gcry_mpi_release (session->s);
-  session->s = NULL;
+    session->s = NULL;
   }
-  
-  if (session->s_prime){
+
+  if (session->s_prime) {
     gcry_mpi_release (session->s_prime);
-  session->s_prime = NULL;
+    session->s_prime = NULL;
   }
-  
-  if (session->product){
+
+  if (session->product) {
     gcry_mpi_release (session->product);
-  session->product = NULL;
+    session->product = NULL;
   }
 
-  if (session->remote_pubkey){
+  if (session->remote_pubkey) {
     gcry_sexp_release (session->remote_pubkey);
-  session->remote_pubkey = NULL;
+    session->remote_pubkey = NULL;
   }
 
   if (session->vector) {
@@ -849,7 +851,8 @@
   }
   else
     GNUNET_log (GNUNET_ERROR_TYPE_INFO, _ ("Sending session-end notification 
to client (%p) for session %s\n"), &session->client, GNUNET_h2s 
(&session->key));
-
+  
+  free_session_variables (session);
 }
 
 
@@ -943,6 +946,7 @@
                 _ ("Sent result to client (%p), this session (%s) has 
ended!\n"),
                 session->client,
                 GNUNET_h2s (&session->key));
+  free_session_variables (session);
 }
 
 
@@ -1003,7 +1007,9 @@
   GNUNET_free (element_exported);
   for (i = session->transferred; i < session->transferred; i++) {
     gcry_mpi_release (session->r_prime[i]);
+    session->r_prime[i] = NULL;
     gcry_mpi_release (session->r[i]);
+    session->r[i] = NULL;
   }
   session->transferred += todo_count;
   session->msg = (struct GNUNET_MessageHeader *) msg;
@@ -1135,10 +1141,14 @@
   GNUNET_free (element_exported);
   for (i = 0; i < session->transferred; i++) {
     gcry_mpi_release (session->r_prime[i]);
+    session->r_prime[i] = NULL;
     gcry_mpi_release (session->r[i]);
+    session->r[i] = NULL;
   }
   gcry_mpi_release (s);
+  session->s = NULL;
   gcry_mpi_release (s_prime);
+  session->s_prime = NULL;
 
   session->msg = (struct GNUNET_MessageHeader *) msg;
   session->service_transmit_handle =
@@ -1851,7 +1861,7 @@
               GNUNET_i2s (&session->peer));
   if (ALICE == session->role) {
     // as we have only one peer connected in each session, just remove the 
session
-
+    
     if ((SERVICE_RESPONSE_RECEIVED > session->state) && (!do_shutdown)) {
       session->tunnel = NULL;
       // if this happened before we received the answer, we must terminate the 
session
@@ -2235,6 +2245,7 @@
   size_t i;
   uint32_t contained = 0;
   size_t msg_size;
+  size_t required_size;
   int rc;
 
   GNUNET_assert (NULL != message);
@@ -2243,15 +2254,17 @@
   if ((ALICE != session->role) || (WAITING_FOR_MULTIPART_TRANSMISSION != 
session->state)) {
     goto invalid_msg;
   }
+  msg_size = ntohs (msg->header.size);
+  required_size = sizeof (struct GNUNET_SCALARPRODUCT_multipart_message) + 2 * 
PAILLIER_ELEMENT_LENGTH;
   // shorter than minimum?
-  if (ntohs (msg->header.size) <= sizeof (struct 
GNUNET_SCALARPRODUCT_multipart_message)) {
+  if (required_size > msg_size) {
     goto invalid_msg;
   }
   contained = ntohl (msg->multipart_element_count);
-  msg_size = sizeof (struct GNUNET_SCALARPRODUCT_multipart_message)
+  required_size = sizeof (struct GNUNET_SCALARPRODUCT_multipart_message)
           + 2 * contained * PAILLIER_ELEMENT_LENGTH;
   //sanity check: is the message as long as the message_count fields suggests?
-  if ((ntohs (msg->header.size) != msg_size) || (session->used < contained)) {
+  if ((required_size != msg_size) || (session->used < session->transferred + 
contained)) {
     goto invalid_msg;
   }
   current = (unsigned char *) &msg[1];
@@ -2274,19 +2287,19 @@
   if (session->transferred != session->used)
     return GNUNET_OK;
   session->state = SERVICE_RESPONSE_RECEIVED;
-  session->product = compute_scalar_product (session);
-  return GNUNET_SYSERR; // terminate the tunnel right away, we are done here!
+  session->product = compute_scalar_product (session); //never NULL
+  
+invalid_msg:
+  GNUNET_break_op (NULL != session->product);
 
-invalid_msg:
-  GNUNET_break_op (0);
-  free_session_variables (session);
-  session->state = FINALIZED;
-  session->tunnel = NULL;
   // send message with product to client
-  if (ALICE == session->role)
+  if (ALICE == session->role){
+    session->state = FINALIZED;
+    session->tunnel = NULL;
     session->client_notification_task =
           GNUNET_SCHEDULER_add_now (&prepare_client_response,
                                     session);
+  }
   // the tunnel has done its job, terminate our connection and the tunnel
   // the peer will be notified that the tunnel was destroyed via 
tunnel_destruction_handler
   // just close the connection, as recommended by Christian
@@ -2317,27 +2330,28 @@
   size_t i;
   uint32_t contained = 0;
   size_t msg_size;
+  size_t required_size;
   int rc;
 
   GNUNET_assert (NULL != message);
   session = (struct ServiceSession *) * tunnel_ctx;
   // are we in the correct state?
-  if (session->state != WAITING_FOR_SERVICE_REQUEST) {
+  if (WAITING_FOR_SERVICE_RESPONSE != session->state) {
     goto invalid_msg;
   }
   //we need at least a full message without elements attached
   msg_size = ntohs (msg->header.size);
-  size_t expected = sizeof (struct GNUNET_SCALARPRODUCT_service_response) + 2 
* PAILLIER_ELEMENT_LENGTH;
+  required_size = sizeof (struct GNUNET_SCALARPRODUCT_service_response) + 2 * 
PAILLIER_ELEMENT_LENGTH;
   
-  if (expected > msg_size) {
+  if (required_size > msg_size) {
     goto invalid_msg;
   }
   contained = ntohl (msg->contained_element_count);
-  msg_size = sizeof (struct GNUNET_SCALARPRODUCT_service_response)
+  required_size = sizeof (struct GNUNET_SCALARPRODUCT_service_response)
           + 2 * contained * PAILLIER_ELEMENT_LENGTH
           + 2 * PAILLIER_ELEMENT_LENGTH;
   //sanity check: is the message as long as the message_count fields suggests?
-  if ((ntohs (msg->header.size) != msg_size) || (session->used < contained)) {
+  if ((msg_size != required_size) || (session->used < contained)) {
     goto invalid_msg;
   }
   session->state = WAITING_FOR_MULTIPART_TRANSMISSION;
@@ -2378,19 +2392,18 @@
     return GNUNET_OK; //wait for the other multipart chunks
 
   session->state = SERVICE_RESPONSE_RECEIVED;
-  session->product = compute_scalar_product (session);
-  return GNUNET_SYSERR; // terminate the tunnel right away, we are done here!
-
+  session->product = compute_scalar_product (session); //never NULL
+  
 invalid_msg:
-  GNUNET_break_op (0);
-  free_session_variables (session);
-  session->state = FINALIZED;
-  session->tunnel = NULL;
+  GNUNET_break_op (NULL != session->product);
   // send message with product to client
-  if (ALICE == session->role)
+  if (ALICE == session->role){
+    session->state = FINALIZED;
+    session->tunnel = NULL;
     session->client_notification_task =
           GNUNET_SCHEDULER_add_now (&prepare_client_response,
                                     session);
+  }
   // the tunnel has done its job, terminate our connection and the tunnel
   // the peer will be notified that the tunnel was destroyed via 
tunnel_destruction_handler
   // just close the connection, as recommended by Christian

Modified: gnunet/src/scalarproduct/test_scalarproduct.sh
===================================================================
--- gnunet/src/scalarproduct/test_scalarproduct.sh      2013-10-18 13:41:13 UTC 
(rev 30320)
+++ gnunet/src/scalarproduct/test_scalarproduct.sh      2013-10-18 13:47:30 UTC 
(rev 30321)
@@ -1,31 +1,40 @@
 #!/bin/bash
 # compute a simple scalar product
+# payload for this test:
+INPUTALICE="-k AAAA -e 10,10,10"
+INPUTBOB="-k AAAA -e 10,10,10"
 
-#necessary to make the testing prefix deterministic, so we can access the 
config files
+# necessary to make the testing prefix deterministic, so we can access the 
config files
 PREFIX=/tmp/test-scalarproduct`date +%H%M%S`
 
-#where can we find the peers config files?
+# where can we find the peers config files?
 CFGALICE="-c $PREFIX/0/config"
 CFGBOB="-c $PREFIX/1/config"
+# log at which loglevel?
+LOGLEVEL=DEBUG
 
-#log at which loglevel?
-LOG="-L ERROR"
+echo start
+# launch two peers in line topology non-interactively
+#
+# interactive mode would terminate the test immediately 
+# because the rest of the script is already in stdin, 
+# thus redirecting stdin does not suffice)
+GNUNET_LOG="scalarproduct;;;;$LOGLEVEL" GNUNET_TESTING_PREFIX=$PREFIX 
../testbed/gnunet-testbed-profiler -n -c test_scalarproduct.conf -p 2 
2>service.log &
+sleep 2
+echo tesbed up
 
-#launch two peers in line topology
-GNUNET_TESTING_PREFIX=$PREFIX ../testbed/gnunet-testbed-profiler $LOG -c 
test_scalarproduct.conf -p 2 2>gnunet_error.log &
-sleep 5
-
-#get bob's peer ID, necessary for alice
+# get bob's peer ID, necessary for alice
 PEERIDBOB=`gnunet-peerinfo -qs $CFGB`
+echo peerinfo receivd
 
-#payload for this test on both sides
-INPUTALICE="-k AAAA -e 10,10,10"
-INPUTBOB="-k AAAA -e 10,10,10"
+GNUNET_LOG="scalarproduct;;;;$LOGLEVEL" gnunet-scalarproduct $CFGBOB $INPUTBOB 
2>bob.log &
+echo bob started
+GNUNET_LOG="scalarproduct;;;;$LOGLEVEL" gnunet-scalarproduct $CFGALICE 
$INPUTALICE -p $PEERIDBOB 2>alice.log
+echo alice returned
 
-echo "gnunet-scalarproduct $LOG $CFGBOB $INPUTBOB &"
-echo "gnunet-scalarproduct $LOG $CFGALICE $INPUTALICE -p $PEERIDBOB -L ERROR"
-gnunet-scalarproduct $LOG $CFGBOB $INPUTBOB 2>bob_error.log &
-RESULT=`gnunet-scalarproduct $LOG $CFGALICE $INPUTALICE -p $PEERIDBOB 
2>alice_error.log`
+# termiante the testbed
+kill $( pgrep -P $$ | tr '\n' ' ' )
+echo killed testbed
 
 EXPECTED="12C"
 if [ "$RESULT" == "$EXPECTED" ]