summaryrefslogtreecommitdiff
path: root/src/transport/gnunet-transport.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/gnunet-transport.c
parent8072370857473b731f6e95d48860da0fbc6263f4 (diff)
converting GNUNET_TRANSPORT_monitor_peers implementation to MQ
Diffstat (limited to 'src/transport/gnunet-transport.c')
-rw-r--r--src/transport/gnunet-transport.c24
1 files changed, 16 insertions, 8 deletions
diff --git a/src/transport/gnunet-transport.c b/src/transport/gnunet-transport.c
index d7852893c..85f22a7f2 100644
--- a/src/transport/gnunet-transport.c
+++ b/src/transport/gnunet-transport.c
@@ -1875,8 +1875,11 @@ testservice_task (void *cls,
}
else if (iterate_connections) /* -i: List information about peers once */
{
- pic = GNUNET_TRANSPORT_monitor_peers (cfg, (NULL == cpid) ? NULL : &pid,
- GNUNET_YES, TIMEOUT, &process_peer_iteration_cb, (void *) cfg);
+ pic = GNUNET_TRANSPORT_monitor_peers (cfg,
+ (NULL == cpid) ? NULL : &pid,
+ GNUNET_YES,
+ &process_peer_iteration_cb,
+ (void *) cfg);
op_timeout = GNUNET_SCHEDULER_add_delayed (OP_TIMEOUT,
&operation_timeout,
NULL);
@@ -1888,8 +1891,8 @@ testservice_task (void *cls,
pic = GNUNET_TRANSPORT_monitor_peers (cfg,
(NULL == cpid) ? NULL : &pid,
GNUNET_NO,
- TIMEOUT,
- &process_peer_monitoring_cb, NULL);
+ &process_peer_monitoring_cb,
+ NULL);
}
else if (monitor_plugins) /* -P: List information about plugins continuously */
{
@@ -1933,7 +1936,7 @@ testservice_task (void *cls,
GNUNET_break(0);
return;
}
-
+
GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
NULL);
}
@@ -1959,12 +1962,17 @@ run (void *cls,
do_test_configuration (cfg);
return;
}
- GNUNET_CLIENT_service_test ("transport", cfg, GNUNET_TIME_UNIT_SECONDS,
- &testservice_task, (void *) cfg);
+ GNUNET_CLIENT_service_test ("transport",
+ cfg,
+ GNUNET_TIME_UNIT_SECONDS,
+ &testservice_task,
+ (void *) cfg);
}
+
int
-main (int argc, char * const *argv)
+main (int argc,
+ char * const *argv)
{
int res;
static const struct GNUNET_GETOPT_CommandLineOption options[] = {