diff options
author | Nathan S. Evans <evans@in.tum.de> | 2010-11-05 18:21:50 +0000 |
---|---|---|
committer | Nathan S. Evans <evans@in.tum.de> | 2010-11-05 18:21:50 +0000 |
commit | 75a33a1499cf60ea4364c9aa673816629a6c1413 (patch) | |
tree | 0620da4312bb04de4d7b65074fdd3b0c3dd6cc0e /src/util/test_server_disconnect.c | |
parent | 7217c601ad30760872823193d62307e7a335d226 (diff) | |
download | gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.tar.gz gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.zip |
big scheduler refactoring, expect some issues
Diffstat (limited to 'src/util/test_server_disconnect.c')
-rw-r--r-- | src/util/test_server_disconnect.c | 15 |
1 files changed, 4 insertions, 11 deletions
diff --git a/src/util/test_server_disconnect.c b/src/util/test_server_disconnect.c index 2fef5642e..8ab8ef35b 100644 --- a/src/util/test_server_disconnect.c +++ b/src/util/test_server_disconnect.c | |||
@@ -42,8 +42,6 @@ static struct GNUNET_CLIENT_Connection *cc; | |||
42 | 42 | ||
43 | static struct GNUNET_CONFIGURATION_Handle *cfg; | 43 | static struct GNUNET_CONFIGURATION_Handle *cfg; |
44 | 44 | ||
45 | static struct GNUNET_SCHEDULER_Handle *sched; | ||
46 | |||
47 | static int ok; | 45 | static int ok; |
48 | 46 | ||
49 | 47 | ||
@@ -66,8 +64,7 @@ notify_disconnect (void *cls, struct GNUNET_SERVER_Client *clientarg) | |||
66 | return; | 64 | return; |
67 | GNUNET_assert (ok == 4); | 65 | GNUNET_assert (ok == 4); |
68 | ok = 5; | 66 | ok = 5; |
69 | GNUNET_SCHEDULER_add_now (sched, | 67 | GNUNET_SCHEDULER_add_now (&finish_up, |
70 | &finish_up, | ||
71 | NULL); | 68 | NULL); |
72 | } | 69 | } |
73 | 70 | ||
@@ -91,8 +88,7 @@ recv_cb (void *cls, | |||
91 | GNUNET_assert (ok == 2); | 88 | GNUNET_assert (ok == 2); |
92 | ok = 3; | 89 | ok = 3; |
93 | GNUNET_SERVER_client_keep (client); | 90 | GNUNET_SERVER_client_keep (client); |
94 | GNUNET_SCHEDULER_add_now (sched, | 91 | GNUNET_SCHEDULER_add_now (&server_disconnect, client); |
95 | &server_disconnect, client); | ||
96 | GNUNET_assert (sizeof (struct GNUNET_MessageHeader) == | 92 | GNUNET_assert (sizeof (struct GNUNET_MessageHeader) == |
97 | ntohs (message->size)); | 93 | ntohs (message->size)); |
98 | GNUNET_assert (MY_TYPE == ntohs (message->type)); | 94 | GNUNET_assert (MY_TYPE == ntohs (message->type)); |
@@ -134,15 +130,13 @@ task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
134 | slens[0] = sizeof (sa); | 130 | slens[0] = sizeof (sa); |
135 | sap[1] = NULL; | 131 | sap[1] = NULL; |
136 | slens[1] = 0; | 132 | slens[1] = 0; |
137 | sched = tc->sched; | ||
138 | memset (&sa, 0, sizeof (sa)); | 133 | memset (&sa, 0, sizeof (sa)); |
139 | #if HAVE_SOCKADDR_IN_SIN_LEN | 134 | #if HAVE_SOCKADDR_IN_SIN_LEN |
140 | sa.sin_len = sizeof (sa); | 135 | sa.sin_len = sizeof (sa); |
141 | #endif | 136 | #endif |
142 | sa.sin_family = AF_INET; | 137 | sa.sin_family = AF_INET; |
143 | sa.sin_port = htons (PORT); | 138 | sa.sin_port = htons (PORT); |
144 | server = GNUNET_SERVER_create (tc->sched, | 139 | server = GNUNET_SERVER_create (NULL, |
145 | NULL, | ||
146 | NULL, | 140 | NULL, |
147 | sap, | 141 | sap, |
148 | slens, | 142 | slens, |
@@ -155,8 +149,7 @@ task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
155 | GNUNET_CONFIGURATION_set_value_number (cfg, "test-server", "PORT", PORT); | 149 | GNUNET_CONFIGURATION_set_value_number (cfg, "test-server", "PORT", PORT); |
156 | GNUNET_CONFIGURATION_set_value_string (cfg, "test-server", "HOSTNAME", "localhost"); | 150 | GNUNET_CONFIGURATION_set_value_string (cfg, "test-server", "HOSTNAME", "localhost"); |
157 | GNUNET_CONFIGURATION_set_value_string (cfg, "resolver", "HOSTNAME", "localhost"); | 151 | GNUNET_CONFIGURATION_set_value_string (cfg, "resolver", "HOSTNAME", "localhost"); |
158 | cc = GNUNET_CLIENT_connect (tc->sched, | 152 | cc = GNUNET_CLIENT_connect ("test-server", |
159 | "test-server", | ||
160 | cfg); | 153 | cfg); |
161 | GNUNET_assert (cc != NULL); | 154 | GNUNET_assert (cc != NULL); |
162 | GNUNET_assert (NULL != | 155 | GNUNET_assert (NULL != |