diff options
author | Christian Grothoff <christian@grothoff.org> | 2009-10-01 16:23:25 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2009-10-01 16:23:25 +0000 |
commit | f0aa7bc0a136b1e436018ef72e1c814f04c33379 (patch) | |
tree | d52c0ad69e3507610fb3271f1f5273bd4d05c124 /src/util/test_connection_receive_cancel.c | |
parent | 028a762caf0c2e1cc7b23a9dc4becf9859d13c15 (diff) | |
download | gnunet-f0aa7bc0a136b1e436018ef72e1c814f04c33379.tar.gz gnunet-f0aa7bc0a136b1e436018ef72e1c814f04c33379.zip |
moving resolver to util, making DNS lookups asynchronous in util
Diffstat (limited to 'src/util/test_connection_receive_cancel.c')
-rw-r--r-- | src/util/test_connection_receive_cancel.c | 25 |
1 files changed, 13 insertions, 12 deletions
diff --git a/src/util/test_connection_receive_cancel.c b/src/util/test_connection_receive_cancel.c index 49df185b7..6434228f7 100644 --- a/src/util/test_connection_receive_cancel.c +++ b/src/util/test_connection_receive_cancel.c | |||
@@ -40,9 +40,7 @@ static struct GNUNET_CONNECTION_Handle *lsock; | |||
40 | 40 | ||
41 | static struct GNUNET_NETWORK_Handle *ls; | 41 | static struct GNUNET_NETWORK_Handle *ls; |
42 | 42 | ||
43 | static GNUNET_SCHEDULER_TaskIdentifier receive_task; | 43 | static struct GNUNET_CONFIGURATION_Handle *cfg; |
44 | |||
45 | |||
46 | 44 | ||
47 | 45 | ||
48 | /** | 46 | /** |
@@ -95,12 +93,11 @@ run_accept_cancel (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
95 | GNUNET_assert (asock != NULL); | 93 | GNUNET_assert (asock != NULL); |
96 | GNUNET_assert (GNUNET_YES == GNUNET_CONNECTION_check (asock)); | 94 | GNUNET_assert (GNUNET_YES == GNUNET_CONNECTION_check (asock)); |
97 | GNUNET_CONNECTION_destroy (lsock); | 95 | GNUNET_CONNECTION_destroy (lsock); |
98 | receive_task | 96 | GNUNET_CONNECTION_receive (asock, |
99 | = GNUNET_CONNECTION_receive (asock, | 97 | 1024, |
100 | 1024, | 98 | GNUNET_TIME_relative_multiply |
101 | GNUNET_TIME_relative_multiply | 99 | (GNUNET_TIME_UNIT_SECONDS, 5), &dead_receive, |
102 | (GNUNET_TIME_UNIT_SECONDS, 5), &dead_receive, | 100 | cls); |
103 | cls); | ||
104 | } | 101 | } |
105 | 102 | ||
106 | 103 | ||
@@ -108,7 +105,7 @@ static void | |||
108 | receive_cancel_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | 105 | receive_cancel_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) |
109 | { | 106 | { |
110 | int *ok = cls; | 107 | int *ok = cls; |
111 | GNUNET_CONNECTION_receive_cancel (asock, receive_task); | 108 | GNUNET_CONNECTION_receive_cancel (asock); |
112 | GNUNET_CONNECTION_destroy (csock); | 109 | GNUNET_CONNECTION_destroy (csock); |
113 | GNUNET_CONNECTION_destroy (asock); | 110 | GNUNET_CONNECTION_destroy (asock); |
114 | *ok = 0; | 111 | *ok = 0; |
@@ -122,8 +119,8 @@ task_receive_cancel (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
122 | ls = open_listen_socket (); | 119 | ls = open_listen_socket (); |
123 | lsock = GNUNET_CONNECTION_create_from_existing (tc->sched, ls, 0); | 120 | lsock = GNUNET_CONNECTION_create_from_existing (tc->sched, ls, 0); |
124 | GNUNET_assert (lsock != NULL); | 121 | GNUNET_assert (lsock != NULL); |
125 | csock = GNUNET_CONNECTION_create_from_connect (tc->sched, | 122 | csock = GNUNET_CONNECTION_create_from_connect (tc->sched, cfg, |
126 | "localhost", PORT, 1024); | 123 | "localhost", PORT, 1024); |
127 | GNUNET_assert (csock != NULL); | 124 | GNUNET_assert (csock != NULL); |
128 | GNUNET_SCHEDULER_add_read_net (tc->sched, | 125 | GNUNET_SCHEDULER_add_read_net (tc->sched, |
129 | GNUNET_NO, | 126 | GNUNET_NO, |
@@ -150,7 +147,11 @@ check_receive_cancel () | |||
150 | int ok; | 147 | int ok; |
151 | 148 | ||
152 | ok = 1; | 149 | ok = 1; |
150 | cfg = GNUNET_CONFIGURATION_create (); | ||
151 | GNUNET_CONFIGURATION_set_value_string (cfg, | ||
152 | "resolver", "HOSTNAME", "localhost"); | ||
153 | GNUNET_SCHEDULER_run (&task_receive_cancel, &ok); | 153 | GNUNET_SCHEDULER_run (&task_receive_cancel, &ok); |
154 | GNUNET_CONFIGURATION_destroy (cfg); | ||
154 | return ok; | 155 | return ok; |
155 | } | 156 | } |
156 | 157 | ||