aboutsummaryrefslogtreecommitdiff
path: root/src/transport/test_transport_api_monitor_peers.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2016-07-06 21:57:30 +0000
committerChristian Grothoff <christian@grothoff.org>2016-07-06 21:57:30 +0000
commit55c16b6ab6a83a594303efccff1e59a022470982 (patch)
tree9476478b34bddf57c4e545cd0b588633d2a60265 /src/transport/test_transport_api_monitor_peers.c
parent8072370857473b731f6e95d48860da0fbc6263f4 (diff)
downloadgnunet-55c16b6ab6a83a594303efccff1e59a022470982.tar.gz
gnunet-55c16b6ab6a83a594303efccff1e59a022470982.zip
converting GNUNET_TRANSPORT_monitor_peers implementation to MQ
Diffstat (limited to 'src/transport/test_transport_api_monitor_peers.c')
-rw-r--r--src/transport/test_transport_api_monitor_peers.c12
1 files changed, 10 insertions, 2 deletions
diff --git a/src/transport/test_transport_api_monitor_peers.c b/src/transport/test_transport_api_monitor_peers.c
index 549394944..90c96829d 100644
--- a/src/transport/test_transport_api_monitor_peers.c
+++ b/src/transport/test_transport_api_monitor_peers.c
@@ -450,14 +450,22 @@ run (void *cls, char *const *args, const char *cfgfile,
450 &notify_receive, &notify_connect, 450 &notify_receive, &notify_connect,
451 &notify_disconnect, &start_cb, 451 &notify_disconnect, &start_cb,
452 NULL); 452 NULL);
453 pmc_p1 = GNUNET_TRANSPORT_monitor_peers (p1->cfg, NULL, GNUNET_NO, GNUNET_TIME_UNIT_FOREVER_REL, &monitor1_cb, NULL); 453 pmc_p1 = GNUNET_TRANSPORT_monitor_peers (p1->cfg,
454 NULL,
455 GNUNET_NO,
456 &monitor1_cb,
457 NULL);
454 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer 1 started\n"); 458 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer 1 started\n");
455 459
456 p2 = GNUNET_TRANSPORT_TESTING_start_peer (tth, cfg_file_p2, 2, 460 p2 = GNUNET_TRANSPORT_TESTING_start_peer (tth, cfg_file_p2, 2,
457 &notify_receive, &notify_connect, 461 &notify_receive, &notify_connect,
458 &notify_disconnect, &start_cb, 462 &notify_disconnect, &start_cb,
459 NULL); 463 NULL);
460 pmc_p2 = GNUNET_TRANSPORT_monitor_peers (p2->cfg, NULL, GNUNET_NO, GNUNET_TIME_UNIT_FOREVER_REL, &monitor2_cb, NULL); 464 pmc_p2 = GNUNET_TRANSPORT_monitor_peers (p2->cfg,
465 NULL,
466 GNUNET_NO,
467 &monitor2_cb,
468 NULL);
461 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer 1 started\n"); 469 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer 1 started\n");
462 if ((p1 == NULL) || (p2 == NULL)) 470 if ((p1 == NULL) || (p2 == NULL))
463 { 471 {