aboutsummaryrefslogtreecommitdiff
path: root/src/transport/transport-testing2.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/transport-testing2.c')
-rw-r--r--src/transport/transport-testing2.c9
1 files changed, 8 insertions, 1 deletions
diff --git a/src/transport/transport-testing2.c b/src/transport/transport-testing2.c
index ee0c4494e..d553a3961 100644
--- a/src/transport/transport-testing2.c
+++ b/src/transport/transport-testing2.c
@@ -337,6 +337,7 @@ hello_iter_cb (void *cb_cls,
337 struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cb_cls; 337 struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cb_cls;
338 if ((NULL == record) && (NULL == emsg)) 338 if ((NULL == record) && (NULL == emsg))
339 { 339 {
340 p->pic = NULL;
340 LOG (GNUNET_ERROR_TYPE_DEBUG, "Iteration End\n"); 341 LOG (GNUNET_ERROR_TYPE_DEBUG, "Iteration End\n");
341 return; 342 return;
342 } 343 }
@@ -347,6 +348,7 @@ hello_iter_cb (void *cb_cls,
347 p->hello[p->hello_size-1] = '\0'; 348 p->hello[p->hello_size-1] = '\0';
348 349
349 GNUNET_PEERSTORE_iterate_cancel (p->pic); 350 GNUNET_PEERSTORE_iterate_cancel (p->pic);
351 p->pic = NULL;
350 if (NULL != p->start_cb) 352 if (NULL != p->start_cb)
351 { 353 {
352 LOG (GNUNET_ERROR_TYPE_DEBUG, 354 LOG (GNUNET_ERROR_TYPE_DEBUG,
@@ -658,7 +660,7 @@ GNUNET_TRANSPORT_TESTING_stop_peer (struct
658 } 660 }
659 if (NULL != p->pic) 661 if (NULL != p->pic)
660 { 662 {
661 GNUNET_PEERSTORE_iterate_cancel (p->pic); 663 //GNUNET_PEERSTORE_iterate_cancel (p->pic);
662 p->pic = NULL; 664 p->pic = NULL;
663 } 665 }
664 if (NULL != p->th) 666 if (NULL != p->th)
@@ -684,6 +686,11 @@ GNUNET_TRANSPORT_TESTING_stop_peer (struct
684 GNUNET_ATS_connectivity_done (p->ats); 686 GNUNET_ATS_connectivity_done (p->ats);
685 p->ats = NULL; 687 p->ats = NULL;
686 } 688 }
689 if (NULL != p->ah)
690 {
691 GNUNET_TRANSPORT_application_done (p->ah);
692 p->ah = NULL;
693 }
687 if (NULL != p->ph) 694 if (NULL != p->ph)
688 { 695 {
689 GNUNET_PEERSTORE_disconnect (p->ph, GNUNET_NO); 696 GNUNET_PEERSTORE_disconnect (p->ph, GNUNET_NO);