From 9baabed9a7a45e367458754e7ce6c19b4245f22b Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Fri, 13 Nov 2009 11:41:56 +0000 Subject: [PATCH] use add_now --- src/core/test_core_api.c | 3 +-- src/util/connection.c | 5 ++--- src/util/resolver_api.c | 15 ++++++--------- src/util/test_server_with_client.c | 4 ++-- 4 files changed, 11 insertions(+), 16 deletions(-) diff --git a/src/core/test_core_api.c b/src/core/test_core_api.c index 6ad396415..901fc12b2 100644 --- a/src/core/test_core_api.c +++ b/src/core/test_core_api.c @@ -171,8 +171,7 @@ process_mtype (void *cls, GNUNET_assert (ok == 5); OKPP; GNUNET_SCHEDULER_cancel (sched, err_task); - GNUNET_SCHEDULER_add_delayed (sched, - GNUNET_TIME_UNIT_ZERO, &terminate_task, NULL); + GNUNET_SCHEDULER_add_now (sched, &terminate_task, NULL); return GNUNET_OK; } diff --git a/src/util/connection.c b/src/util/connection.c index 993a3c783..6463972be 100644 --- a/src/util/connection.c +++ b/src/util/connection.c @@ -1400,9 +1400,8 @@ GNUNET_CONNECTION_notify_transmit_ready (struct GNUNET_CONNECTION_Handle if ((sock->sock == NULL) && (sock->ap_head == NULL) && (sock->dns_active == NULL)) { - sock->write_task = GNUNET_SCHEDULER_add_delayed (sock->sched, - GNUNET_TIME_UNIT_ZERO, - &connect_error, sock); + sock->write_task = GNUNET_SCHEDULER_add_now (sock->sched, + &connect_error, sock); return &sock->nth; } if (GNUNET_SCHEDULER_NO_TASK != sock->write_task) diff --git a/src/util/resolver_api.c b/src/util/resolver_api.c index 812cdc84e..e99cab8de 100644 --- a/src/util/resolver_api.c +++ b/src/util/resolver_api.c @@ -441,9 +441,8 @@ GNUNET_RESOLVER_ip_get (struct GNUNET_SCHEDULER_Handle *sched, &v6)) && ((domain == AF_INET6) || (domain == AF_UNSPEC)))) { - rh->task = GNUNET_SCHEDULER_add_delayed (sched, - GNUNET_TIME_UNIT_ZERO, - &numeric_resolution, rh); + rh->task = GNUNET_SCHEDULER_add_now (sched, + &numeric_resolution, rh); return rh; } /* then, check if this is a loopback address */ @@ -451,9 +450,8 @@ GNUNET_RESOLVER_ip_get (struct GNUNET_SCHEDULER_Handle *sched, while (loopback[i] != NULL) if (0 == strcasecmp (loopback[i++], hostname)) { - rh->task = GNUNET_SCHEDULER_add_delayed (sched, - GNUNET_TIME_UNIT_ZERO, - &loopback_resolution, rh); + rh->task = GNUNET_SCHEDULER_add_now (sched, + &loopback_resolution, rh); return rh; } @@ -616,9 +614,8 @@ GNUNET_RESOLVER_hostname_get (struct GNUNET_SCHEDULER_Handle *sched, if (GNUNET_NO == do_resolve) { - rh->task = GNUNET_SCHEDULER_add_delayed (sched, - GNUNET_TIME_UNIT_ZERO, - &numeric_reverse, rh); + rh->task = GNUNET_SCHEDULER_add_now (sched, + &numeric_reverse, rh); return rh; } if (salen + sizeof (struct GNUNET_RESOLVER_GetMessage) > diff --git a/src/util/test_server_with_client.c b/src/util/test_server_with_client.c index 453ae5ed4..f22c15300 100644 --- a/src/util/test_server_with_client.c +++ b/src/util/test_server_with_client.c @@ -125,8 +125,8 @@ notify_disconnect (void *cls, struct GNUNET_SERVER_Client *client) { GNUNET_assert (ok == 5); ok = 0; - GNUNET_SCHEDULER_add_delayed (sched, - GNUNET_TIME_UNIT_ZERO, &clean_up, NULL); + GNUNET_SCHEDULER_add_now (sched, + &clean_up, NULL); } -- 2.25.1