[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,
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r35448 - gnunet/src/rps,
gnunet <=