diff options
author | Christian Grothoff <christian@grothoff.org> | 2016-07-06 21:57:30 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2016-07-06 21:57:30 +0000 |
commit | 55c16b6ab6a83a594303efccff1e59a022470982 (patch) | |
tree | 9476478b34bddf57c4e545cd0b588633d2a60265 /src/transport/test_transport_api_monitor_peers.c | |
parent | 8072370857473b731f6e95d48860da0fbc6263f4 (diff) | |
download | gnunet-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.c | 12 |
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 | ¬ify_receive, ¬ify_connect, | 450 | ¬ify_receive, ¬ify_connect, |
451 | ¬ify_disconnect, &start_cb, | 451 | ¬ify_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 | ¬ify_receive, ¬ify_connect, | 461 | ¬ify_receive, ¬ify_connect, |
458 | ¬ify_disconnect, &start_cb, | 462 | ¬ify_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 | { |