gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GNUnet-SVN] r35448 - gnunet/src/rps


From: gnunet
Subject: [GNUnet-SVN] r35448 - gnunet/src/rps
Date: Wed, 25 Mar 2015 18:17:04 +0100

Author: ch3
Date: 2015-03-25 18:17:04 +0100 (Wed, 25 Mar 2015)
New Revision: 35448

Modified:
   gnunet/src/rps/gnunet-service-rps.c
Log:
-corrected peer_is_live() checking

Modified: gnunet/src/rps/gnunet-service-rps.c
===================================================================
--- gnunet/src/rps/gnunet-service-rps.c 2015-03-25 17:17:00 UTC (rev 35447)
+++ gnunet/src/rps/gnunet-service-rps.c 2015-03-25 17:17:04 UTC (rev 35448)
@@ -615,6 +615,13 @@
 {
   struct GNUNET_PeerIdentity *peer;
 
+  /* Cancle is_live_task if still scheduled */
+  if (NULL != peer_ctx->is_live_task)
+  {
+    GNUNET_CADET_notify_transmit_ready_cancel (peer_ctx->is_live_task);
+    peer_ctx->is_live_task = NULL;
+  }
+
   peer = &peer_ctx->peer_id;
   set_peer_flag (peer_ctx, VALID);
 
@@ -629,12 +636,6 @@
     GNUNET_array_grow (peer_ctx->outstanding_ops, 
peer_ctx->num_outstanding_ops, 0);
   }
 
-  if (NULL != peer_ctx->is_live_task)
-  {
-    GNUNET_CADET_notify_transmit_ready_cancel (peer_ctx->is_live_task);
-    peer_ctx->is_live_task = NULL;
-  }
-
   return 0;
 }
 
@@ -1792,8 +1793,12 @@
                          0);
 
     if (NULL != peer_ctx->mq)
+    {
       GNUNET_MQ_destroy (peer_ctx->mq);
+      peer_ctx->mq = NULL;
+    }
 
+
     if (NULL != peer_ctx->is_live_task)
     {
     LOG (GNUNET_ERROR_TYPE_DEBUG,




reply via email to

[Prev in Thread] Current Thread [Next in Thread]