aboutsummaryrefslogtreecommitdiff
path: root/src/util/test_connection_receive_cancel.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2009-10-01 16:23:25 +0000
committerChristian Grothoff <christian@grothoff.org>2009-10-01 16:23:25 +0000
commitf0aa7bc0a136b1e436018ef72e1c814f04c33379 (patch)
treed52c0ad69e3507610fb3271f1f5273bd4d05c124 /src/util/test_connection_receive_cancel.c
parent028a762caf0c2e1cc7b23a9dc4becf9859d13c15 (diff)
downloadgnunet-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.c25
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
41static struct GNUNET_NETWORK_Handle *ls; 41static struct GNUNET_NETWORK_Handle *ls;
42 42
43static GNUNET_SCHEDULER_TaskIdentifier receive_task; 43static 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
108receive_cancel_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 105receive_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