[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r35453 - gnunet/src/rps
From: |
gnunet |
Subject: |
[GNUnet-SVN] r35453 - gnunet/src/rps |
Date: |
Wed, 25 Mar 2015 18:18:39 +0100 |
Author: ch3
Date: 2015-03-25 18:18:39 +0100 (Wed, 25 Mar 2015)
New Revision: 35453
Modified:
gnunet/src/rps/gnunet-service-rps.c
Log:
-additional assertions, fix
Modified: gnunet/src/rps/gnunet-service-rps.c
===================================================================
--- gnunet/src/rps/gnunet-service-rps.c 2015-03-25 17:17:21 UTC (rev 35452)
+++ gnunet/src/rps/gnunet-service-rps.c 2015-03-25 17:18:39 UTC (rev 35453)
@@ -734,6 +734,9 @@
struct PeerContext *peer_ctx;
peer_ctx = get_peer_ctx (peer_map, peer);
+
+ GNUNET_assert (NULL == peer_ctx->is_live_task);
+
if (NULL == peer_ctx->send_channel)
{
LOG (GNUNET_ERROR_TYPE_DEBUG,
@@ -772,6 +775,8 @@
peer_ctx = get_peer_ctx (peer_map, peer_id);
+ GNUNET_assert (NULL == peer_ctx->is_live_task);
+
if (NULL == peer_ctx->mq)
{
(void) get_channel (peer_map, peer_id);
@@ -1797,8 +1802,8 @@
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Updating with peer %s from pull list\n",
GNUNET_i2s (&pull_list[i]));
- RPS_sampler_update (prot_sampler, &push_list[i]);
- RPS_sampler_update (client_sampler, &push_list[i]);
+ RPS_sampler_update (prot_sampler, &pull_list[i]);
+ RPS_sampler_update (client_sampler, &pull_list[i]);
// TODO set in_flag?
}
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r35453 - gnunet/src/rps,
gnunet <=