aboutsummaryrefslogtreecommitdiff
path: root/src/peerinfo
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2010-04-23 08:53:28 +0000
committerChristian Grothoff <christian@grothoff.org>2010-04-23 08:53:28 +0000
commit1f773086de781730e80f256f36f8e1a83b578515 (patch)
tree28795e27847fefa7e84202474667f6e778d14455 /src/peerinfo
parent067436522b13b5f638059fc9c591acc7b510d6da (diff)
downloadgnunet-1f773086de781730e80f256f36f8e1a83b578515.tar.gz
gnunet-1f773086de781730e80f256f36f8e1a83b578515.zip
fix
Diffstat (limited to 'src/peerinfo')
-rw-r--r--src/peerinfo/peerinfo_api.c11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/peerinfo/peerinfo_api.c b/src/peerinfo/peerinfo_api.c
index 0a0916d72..8d1ab3c63 100644
--- a/src/peerinfo/peerinfo_api.c
+++ b/src/peerinfo/peerinfo_api.c
@@ -478,9 +478,9 @@ iterator_start_receive (void *cls,
478 ic->timeout_task); 478 ic->timeout_task);
479 ic->timeout_task = GNUNET_SCHEDULER_NO_TASK; 479 ic->timeout_task = GNUNET_SCHEDULER_NO_TASK;
480 } 480 }
481 ic->callback (ic->callback_cls, NULL, NULL, 2);
482 reconnect (ic->h); 481 reconnect (ic->h);
483 trigger_transmit (ic->h); 482 trigger_transmit (ic->h);
483 ic->callback (ic->callback_cls, NULL, NULL, 2);
484 GNUNET_free (ic); 484 GNUNET_free (ic);
485 return; 485 return;
486 } 486 }
@@ -507,13 +507,14 @@ signal_timeout (void *cls,
507 struct GNUNET_PEERINFO_IteratorContext *ic = cls; 507 struct GNUNET_PEERINFO_IteratorContext *ic = cls;
508 508
509 ic->timeout_task = GNUNET_SCHEDULER_NO_TASK; 509 ic->timeout_task = GNUNET_SCHEDULER_NO_TASK;
510 if (! ic->in_receive)
511 GNUNET_CONTAINER_DLL_remove (ic->h->tq_head,
512 ic->h->tq_tail,
513 ic->tqe);
510 ic->callback (ic->callback_cls, NULL, NULL, 1); 514 ic->callback (ic->callback_cls, NULL, NULL, 1);
511 ic->callback = NULL; 515 ic->callback = NULL;
512 if (ic->in_receive) 516 if (ic->in_receive)
513 return; /* need to finish processing */ 517 return;
514 GNUNET_CONTAINER_DLL_remove (ic->h->tq_head,
515 ic->h->tq_tail,
516 ic->tqe);
517 GNUNET_free (ic->tqe); 518 GNUNET_free (ic->tqe);
518 GNUNET_free (ic); 519 GNUNET_free (ic);
519} 520}