moved a line for comprehension

[simgrid.git] / examples / c / dht-pastry / dht-pastry.c

diff --git a/examples/c/dht-pastry/dht-pastry.c b/examples/c/dht-pastry/dht-pastry.c
index f26900a84d6855c48bdd0ef7bee249467fcab696..c6e5947b9189e46dbda6292e3986a998e7c5e323 100644 (file)
--- a/examples/c/dht-pastry/dht-pastry.c
+++ b/examples/c/dht-pastry/dht-pastry.c
@@ -236,6 +236,7 @@ static void handle_message(node_t node, pastry_message_t message)
         err  = sg_comm_wait_for(comm, timeout);
         if (err == SG_ERROR_TIMEOUT) {
           XBT_DEBUG("Timeout expired when forwarding join to next %d", next);
+          xbt_free(request);
           break;
         }
         type = JOIN_REPLY;
@@ -250,7 +251,7 @@ static void handle_message(node_t node, pastry_message_t message)
       err                = sg_comm_wait_for(comm, timeout);
       if (err == SG_ERROR_TIMEOUT) {
         XBT_DEBUG("Timeout expired when sending back the current node state to the joining node to %d", node->id);
-        message_free(message);
+        message_free(request);
       }
       break;
     /* Join reply from all the node touched by the join  */
@@ -312,6 +313,7 @@ static void handle_message(node_t node, pastry_message_t message)
             err                = sg_comm_wait_for(comm, timeout);
             if (err == SG_ERROR_TIMEOUT) {
               XBT_DEBUG("Timeout expired when sending update to %d", j);
+              message_free(request);
               break;
             }
           }