aboutsummaryrefslogtreecommitdiff
path: root/src/nat
diff options
context:
space:
mode:
Diffstat (limited to 'src/nat')
-rw-r--r--src/nat/gnunet-nat-server.c8
-rw-r--r--src/nat/nat.c38
-rw-r--r--src/nat/nat_auto.c11
-rw-r--r--src/nat/nat_mini.c16
-rw-r--r--src/nat/nat_test.c26
-rw-r--r--src/nat/test_nat.c2
-rw-r--r--src/nat/test_nat_mini.c2
-rw-r--r--src/nat/test_nat_test.c7
-rw-r--r--src/nat/test_stun.c6
9 files changed, 47 insertions, 69 deletions
diff --git a/src/nat/gnunet-nat-server.c b/src/nat/gnunet-nat-server.c
index 31a8f294b..0069303ca 100644
--- a/src/nat/gnunet-nat-server.c
+++ b/src/nat/gnunet-nat-server.c
@@ -92,13 +92,14 @@ struct TcpContext
92 * (or once we failed to connect...). 92 * (or once we failed to connect...).
93 * 93 *
94 * @param cls the 'struct TcpContext' 94 * @param cls the 'struct TcpContext'
95 * @param tc scheduler context
96 */ 95 */
97static void 96static void
98tcp_send (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 97tcp_send (void *cls)
99{ 98{
100 struct TcpContext *ctx = cls; 99 struct TcpContext *ctx = cls;
100 const struct GNUNET_SCHEDULER_TaskContext *tc;
101 101
102 tc = GNUNET_SCHEDULER_get_task_context ();
102 if ((NULL != tc->write_ready) && 103 if ((NULL != tc->write_ready) &&
103 (GNUNET_NETWORK_fdset_isset (tc->write_ready, ctx->s))) 104 (GNUNET_NETWORK_fdset_isset (tc->write_ready, ctx->s)))
104 { 105 {
@@ -228,10 +229,9 @@ test (void *cls, struct GNUNET_SERVER_Client *client,
228 * Task run during shutdown. 229 * Task run during shutdown.
229 * 230 *
230 * @param cls unused 231 * @param cls unused
231 * @param tc scheduler context
232 */ 232 */
233static void 233static void
234shutdown_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 234shutdown_task (void *cls)
235{ 235{
236 GNUNET_SERVER_destroy (server); 236 GNUNET_SERVER_destroy (server);
237 server = NULL; 237 server = NULL;
diff --git a/src/nat/nat.c b/src/nat/nat.c
index 57961ffaf..1c60e4e0d 100644
--- a/src/nat/nat.c
+++ b/src/nat/nat.c
@@ -463,11 +463,9 @@ start_gnunet_nat_server (struct GNUNET_NAT_Handle *h);
463 * Call task to process STUN 463 * Call task to process STUN
464 * 464 *
465 * @param cls handle to NAT 465 * @param cls handle to NAT
466 * @param tc TaskContext
467 */ 466 */
468static void 467static void
469process_stun (void *cls, 468process_stun (void *cls);
470 const struct GNUNET_SCHEDULER_TaskContext *tc);
471 469
472 470
473/** 471/**
@@ -662,10 +660,9 @@ add_ip_to_address_list (struct GNUNET_NAT_Handle *h,
662 * get DynDNS-IP addresses. 660 * get DynDNS-IP addresses.
663 * 661 *
664 * @param cls the NAT handle 662 * @param cls the NAT handle
665 * @param tc scheduler context
666 */ 663 */
667static void 664static void
668resolve_dns (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc); 665resolve_dns (void *cls);
669 666
670 667
671/** 668/**
@@ -716,11 +713,9 @@ process_external_ip (void *cls,
716 * Task to do a lookup on our hostname for IP addresses. 713 * Task to do a lookup on our hostname for IP addresses.
717 * 714 *
718 * @param cls the NAT handle 715 * @param cls the NAT handle
719 * @param tc scheduler context
720 */ 716 */
721static void 717static void
722resolve_hostname (void *cls, 718resolve_hostname (void *cls);
723 const struct GNUNET_SCHEDULER_TaskContext *tc);
724 719
725 720
726/** 721/**
@@ -938,14 +933,15 @@ process_interfaces (void *cls,
938 * after a certain delay. 933 * after a certain delay.
939 * 934 *
940 * @param cls the `struct GNUNET_NAT_Handle` 935 * @param cls the `struct GNUNET_NAT_Handle`
941 * @param tc scheduler context
942 */ 936 */
943static void 937static void
944restart_nat_server (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 938restart_nat_server (void *cls)
945{ 939{
946 struct GNUNET_NAT_Handle *h = cls; 940 struct GNUNET_NAT_Handle *h = cls;
941 const struct GNUNET_SCHEDULER_TaskContext *tc;
947 942
948 h->server_read_task = NULL; 943 h->server_read_task = NULL;
944 tc = GNUNET_SCHEDULER_get_task_context ();
949 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) 945 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
950 return; 946 return;
951 start_gnunet_nat_server (h); 947 start_gnunet_nat_server (h);
@@ -958,11 +954,9 @@ restart_nat_server (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
958 * function to be called again once more is available. 954 * function to be called again once more is available.
959 * 955 *
960 * @param cls the NAT handle 956 * @param cls the NAT handle
961 * @param tc the scheduling context
962 */ 957 */
963static void 958static void
964nat_server_read (void *cls, 959nat_server_read (void *cls)
965 const struct GNUNET_SCHEDULER_TaskContext *tc)
966{ 960{
967 struct GNUNET_NAT_Handle *h = cls; 961 struct GNUNET_NAT_Handle *h = cls;
968 char mybuf[40]; 962 char mybuf[40];
@@ -971,8 +965,10 @@ nat_server_read (void *cls,
971 int port; 965 int port;
972 const char *port_start; 966 const char *port_start;
973 struct sockaddr_in sin_addr; 967 struct sockaddr_in sin_addr;
968 const struct GNUNET_SCHEDULER_TaskContext *tc;
974 969
975 h->server_read_task = NULL; 970 h->server_read_task = NULL;
971 tc = GNUNET_SCHEDULER_get_task_context ();
976 if ((tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) 972 if ((tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0)
977 return; 973 return;
978 memset (mybuf, 0, sizeof (mybuf)); 974 memset (mybuf, 0, sizeof (mybuf));
@@ -1099,11 +1095,9 @@ start_gnunet_nat_server (struct GNUNET_NAT_Handle *h)
1099 * Task to scan the local network interfaces for IP addresses. 1095 * Task to scan the local network interfaces for IP addresses.
1100 * 1096 *
1101 * @param cls the NAT handle 1097 * @param cls the NAT handle
1102 * @param tc scheduler context
1103 */ 1098 */
1104static void 1099static void
1105list_interfaces (void *cls, 1100list_interfaces (void *cls)
1106 const struct GNUNET_SCHEDULER_TaskContext *tc)
1107{ 1101{
1108 struct GNUNET_NAT_Handle *h = cls; 1102 struct GNUNET_NAT_Handle *h = cls;
1109 1103
@@ -1209,11 +1203,9 @@ GNUNET_NAT_is_valid_stun_packet (void *cls,
1209 * Task to do a STUN request 1203 * Task to do a STUN request
1210 * 1204 *
1211 * @param cls the NAT handle 1205 * @param cls the NAT handle
1212 * @param tc scheduler context
1213 */ 1206 */
1214static void 1207static void
1215process_stun (void *cls, 1208process_stun (void *cls)
1216 const struct GNUNET_SCHEDULER_TaskContext *tc)
1217{ 1209{
1218 struct GNUNET_NAT_Handle *h = cls; 1210 struct GNUNET_NAT_Handle *h = cls;
1219 struct StunServerList* elem = h->actual_stun_server; 1211 struct StunServerList* elem = h->actual_stun_server;
@@ -1264,11 +1256,9 @@ process_stun (void *cls,
1264 * Task to do a lookup on our hostname for IP addresses. 1256 * Task to do a lookup on our hostname for IP addresses.
1265 * 1257 *
1266 * @param cls the NAT handle 1258 * @param cls the NAT handle
1267 * @param tc scheduler context
1268 */ 1259 */
1269static void 1260static void
1270resolve_hostname (void *cls, 1261resolve_hostname (void *cls)
1271 const struct GNUNET_SCHEDULER_TaskContext *tc)
1272{ 1262{
1273 struct GNUNET_NAT_Handle *h = cls; 1263 struct GNUNET_NAT_Handle *h = cls;
1274 1264
@@ -1285,11 +1275,9 @@ resolve_hostname (void *cls,
1285 * get DynDNS-IP addresses. 1275 * get DynDNS-IP addresses.
1286 * 1276 *
1287 * @param cls the NAT handle 1277 * @param cls the NAT handle
1288 * @param tc scheduler context
1289 */ 1278 */
1290static void 1279static void
1291resolve_dns (void *cls, 1280resolve_dns (void *cls)
1292 const struct GNUNET_SCHEDULER_TaskContext *tc)
1293{ 1281{
1294 struct GNUNET_NAT_Handle *h = cls; 1282 struct GNUNET_NAT_Handle *h = cls;
1295 struct LocalAddressList *pos; 1283 struct LocalAddressList *pos;
diff --git a/src/nat/nat_auto.c b/src/nat/nat_auto.c
index 9fab8bf67..82e067f73 100644
--- a/src/nat/nat_auto.c
+++ b/src/nat/nat_auto.c
@@ -258,18 +258,17 @@ stop_stun ()
258 * incoming connection. 258 * incoming connection.
259 * 259 *
260 * @param cls 260 * @param cls
261 * @param tc scheduler context
262 */ 261 */
263static void 262static void
264do_udp_read (void *cls, 263do_udp_read (void *cls)
265 const struct GNUNET_SCHEDULER_TaskContext *tc)
266{ 264{
267 struct GNUNET_NAT_AutoHandle *ah = cls; 265 struct GNUNET_NAT_AutoHandle *ah = cls;
268 unsigned char reply_buf[1024]; 266 unsigned char reply_buf[1024];
269 ssize_t rlen; 267 ssize_t rlen;
270 struct sockaddr_in answer; 268 struct sockaddr_in answer;
269 const struct GNUNET_SCHEDULER_TaskContext *tc;
271 270
272 271 tc = GNUNET_SCHEDULER_get_task_context ();
273 if ((0 != (tc->reason & GNUNET_SCHEDULER_REASON_READ_READY)) && 272 if ((0 != (tc->reason & GNUNET_SCHEDULER_REASON_READ_READY)) &&
274 (GNUNET_NETWORK_fdset_isset (tc->read_ready, 273 (GNUNET_NETWORK_fdset_isset (tc->read_ready,
275 lsock4))) 274 lsock4)))
@@ -402,11 +401,9 @@ result_callback (void *cls,
402 * Main function for the connection reversal test. 401 * Main function for the connection reversal test.
403 * 402 *
404 * @param cls the `struct GNUNET_NAT_AutoHandle` 403 * @param cls the `struct GNUNET_NAT_AutoHandle`
405 * @param tc scheduler context
406 */ 404 */
407static void 405static void
408reversal_test (void *cls, 406reversal_test (void *cls)
409 const struct GNUNET_SCHEDULER_TaskContext *tc)
410{ 407{
411 struct GNUNET_NAT_AutoHandle *ah = cls; 408 struct GNUNET_NAT_AutoHandle *ah = cls;
412 409
diff --git a/src/nat/nat_mini.c b/src/nat/nat_mini.c
index aa29ff07b..d310b3e14 100644
--- a/src/nat/nat_mini.c
+++ b/src/nat/nat_mini.c
@@ -110,17 +110,17 @@ struct GNUNET_NAT_ExternalHandle
110 * address and call our callback. 110 * address and call our callback.
111 * 111 *
112 * @param cls the `struct GNUNET_NAT_ExternalHandle` 112 * @param cls the `struct GNUNET_NAT_ExternalHandle`
113 * @param tc scheduler context
114 */ 113 */
115static void 114static void
116read_external_ipv4 (void *cls, 115read_external_ipv4 (void *cls)
117 const struct GNUNET_SCHEDULER_TaskContext *tc)
118{ 116{
119 struct GNUNET_NAT_ExternalHandle *eh = cls; 117 struct GNUNET_NAT_ExternalHandle *eh = cls;
120 ssize_t ret; 118 ssize_t ret;
121 struct in_addr addr; 119 struct in_addr addr;
120 const struct GNUNET_SCHEDULER_TaskContext *tc;
122 121
123 eh->task = NULL; 122 eh->task = NULL;
123 tc = GNUNET_SCHEDULER_get_task_context ();
124 if (GNUNET_YES == GNUNET_NETWORK_fdset_handle_isset (tc->read_ready, eh->r)) 124 if (GNUNET_YES == GNUNET_NETWORK_fdset_handle_isset (tc->read_ready, eh->r))
125 ret = 125 ret =
126 GNUNET_DISK_file_read (eh->r, &eh->buf[eh->off], 126 GNUNET_DISK_file_read (eh->r, &eh->buf[eh->off],
@@ -162,11 +162,9 @@ read_external_ipv4 (void *cls,
162 * (Asynchronously) signal error invoking "external-ip" to client. 162 * (Asynchronously) signal error invoking "external-ip" to client.
163 * 163 *
164 * @param cls the `struct GNUNET_NAT_ExternalHandle` (freed) 164 * @param cls the `struct GNUNET_NAT_ExternalHandle` (freed)
165 * @param tc scheduler context
166 */ 165 */
167static void 166static void
168signal_external_ip_error (void *cls, 167signal_external_ip_error (void *cls)
169 const struct GNUNET_SCHEDULER_TaskContext *tc)
170{ 168{
171 struct GNUNET_NAT_ExternalHandle *eh = cls; 169 struct GNUNET_NAT_ExternalHandle *eh = cls;
172 170
@@ -329,10 +327,9 @@ struct GNUNET_NAT_MiniHandle
329 * Run "upnpc -l" to find out if our mapping changed. 327 * Run "upnpc -l" to find out if our mapping changed.
330 * 328 *
331 * @param cls the `struct GNUNET_NAT_MiniHandle` 329 * @param cls the `struct GNUNET_NAT_MiniHandle`
332 * @param tc scheduler context
333 */ 330 */
334static void 331static void
335do_refresh (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc); 332do_refresh (void *cls);
336 333
337 334
338/** 335/**
@@ -478,10 +475,9 @@ process_refresh_output (void *cls, const char *line)
478 * Run "upnpc -l" to find out if our mapping changed. 475 * Run "upnpc -l" to find out if our mapping changed.
479 * 476 *
480 * @param cls the 'struct GNUNET_NAT_MiniHandle' 477 * @param cls the 'struct GNUNET_NAT_MiniHandle'
481 * @param tc scheduler context
482 */ 478 */
483static void 479static void
484do_refresh (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 480do_refresh (void *cls)
485{ 481{
486 struct GNUNET_NAT_MiniHandle *mini = cls; 482 struct GNUNET_NAT_MiniHandle *mini = cls;
487 int ac; 483 int ac;
diff --git a/src/nat/nat_test.c b/src/nat/nat_test.c
index 32cf6c42c..33f81d800 100644
--- a/src/nat/nat_test.c
+++ b/src/nat/nat_test.c
@@ -205,15 +205,15 @@ reversal_cb (void *cls,
205 * incoming connection. 205 * incoming connection.
206 * 206 *
207 * @param cls the `struct GNUNET_NAT_Test` 207 * @param cls the `struct GNUNET_NAT_Test`
208 * @param tc scheduler context
209 */ 208 */
210static void 209static void
211do_udp_read (void *cls, 210do_udp_read (void *cls)
212 const struct GNUNET_SCHEDULER_TaskContext *tc)
213{ 211{
214 struct GNUNET_NAT_Test *tst = cls; 212 struct GNUNET_NAT_Test *tst = cls;
215 uint16_t data; 213 uint16_t data;
214 const struct GNUNET_SCHEDULER_TaskContext *tc;
216 215
216 tc = GNUNET_SCHEDULER_get_task_context ();
217 tst->ltask = 217 tst->ltask =
218 GNUNET_SCHEDULER_add_read_net (GNUNET_TIME_UNIT_FOREVER_REL, 218 GNUNET_SCHEDULER_add_read_net (GNUNET_TIME_UNIT_FOREVER_REL,
219 tst->lsock, 219 tst->lsock,
@@ -240,16 +240,16 @@ do_udp_read (void *cls,
240 * incoming connection. 240 * incoming connection.
241 * 241 *
242 * @param cls the `struct NatActivity` 242 * @param cls the `struct NatActivity`
243 * @param tc scheduler context
244 */ 243 */
245static void 244static void
246do_read (void *cls, 245do_read (void *cls)
247 const struct GNUNET_SCHEDULER_TaskContext *tc)
248{ 246{
249 struct NatActivity *na = cls; 247 struct NatActivity *na = cls;
250 struct GNUNET_NAT_Test *tst; 248 struct GNUNET_NAT_Test *tst;
251 uint16_t data; 249 uint16_t data;
250 const struct GNUNET_SCHEDULER_TaskContext *tc;
252 251
252 tc = GNUNET_SCHEDULER_get_task_context ();
253 na->rtask = NULL; 253 na->rtask = NULL;
254 tst = na->h; 254 tst = na->h;
255 GNUNET_CONTAINER_DLL_remove (tst->na_head, tst->na_tail, na); 255 GNUNET_CONTAINER_DLL_remove (tst->na_head, tst->na_tail, na);
@@ -277,17 +277,17 @@ do_read (void *cls,
277 * incoming connection. 277 * incoming connection.
278 * 278 *
279 * @param cls the `struct GNUNET_NAT_Test` 279 * @param cls the `struct GNUNET_NAT_Test`
280 * @param tc scheduler context
281 */ 280 */
282static void 281static void
283do_accept (void *cls, 282do_accept (void *cls)
284 const struct GNUNET_SCHEDULER_TaskContext *tc)
285{ 283{
286 struct GNUNET_NAT_Test *tst = cls; 284 struct GNUNET_NAT_Test *tst = cls;
287 struct GNUNET_NETWORK_Handle *s; 285 struct GNUNET_NETWORK_Handle *s;
288 struct NatActivity *wl; 286 struct NatActivity *wl;
287 const struct GNUNET_SCHEDULER_TaskContext *tc;
289 288
290 tst->ltask = NULL; 289 tst->ltask = NULL;
290 tc = GNUNET_SCHEDULER_get_task_context ();
291 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) 291 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
292 return; 292 return;
293 tst->ltask = 293 tst->ltask =
@@ -378,11 +378,9 @@ addr_cb (void *cls,
378 * Destroys the nat handle after the callback has been processed. 378 * Destroys the nat handle after the callback has been processed.
379 * 379 *
380 * @param cls handle to the timed out NAT test 380 * @param cls handle to the timed out NAT test
381 * @param tc not used
382 */ 381 */
383static void 382static void
384do_timeout (void *cls, 383do_timeout (void *cls)
385 const struct GNUNET_SCHEDULER_TaskContext *tc)
386{ 384{
387 struct GNUNET_NAT_Test *nh = cls; 385 struct GNUNET_NAT_Test *nh = cls;
388 386
@@ -440,8 +438,8 @@ GNUNET_NAT_test_start (const struct GNUNET_CONFIGURATION_Handle *cfg,
440 nh->status = GNUNET_NAT_ERROR_SUCCESS; 438 nh->status = GNUNET_NAT_ERROR_SUCCESS;
441 if (0 == bnd_port) 439 if (0 == bnd_port)
442 { 440 {
443 nh->nat 441 nh->nat
444 = GNUNET_NAT_register (cfg, is_tcp, 0, 0, 442 = GNUNET_NAT_register (cfg, is_tcp, 0, 0,
445 NULL, NULL, 443 NULL, NULL,
446 &addr_cb, 444 &addr_cb,
447 &reversal_cb, nh, NULL); 445 &reversal_cb, nh, NULL);
diff --git a/src/nat/test_nat.c b/src/nat/test_nat.c
index de8ff8c13..a840f3ef9 100644
--- a/src/nat/test_nat.c
+++ b/src/nat/test_nat.c
@@ -65,7 +65,7 @@ addr_callback (void *cls, int add_remove, const struct sockaddr *addr,
65 * Function that terminates the test. 65 * Function that terminates the test.
66 */ 66 */
67static void 67static void
68stop (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 68stop (void *cls)
69{ 69{
70 struct GNUNET_NAT_Handle *nat = cls; 70 struct GNUNET_NAT_Handle *nat = cls;
71 71
diff --git a/src/nat/test_nat_mini.c b/src/nat/test_nat_mini.c
index 1819d5e91..f5b63f698 100644
--- a/src/nat/test_nat_mini.c
+++ b/src/nat/test_nat_mini.c
@@ -67,7 +67,7 @@ addr_callback (void *cls, int add_remove,
67 * Function that terminates the test. 67 * Function that terminates the test.
68 */ 68 */
69static void 69static void
70stop (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 70stop (void *cls)
71{ 71{
72 struct GNUNET_NAT_MiniHandle *mini = cls; 72 struct GNUNET_NAT_MiniHandle *mini = cls;
73 73
diff --git a/src/nat/test_nat_test.c b/src/nat/test_nat_test.c
index c0cce6e45..402671bd2 100644
--- a/src/nat/test_nat_test.c
+++ b/src/nat/test_nat_test.c
@@ -59,8 +59,7 @@ report_result (void *cls,
59 59
60 60
61static void 61static void
62failed_timeout (void *cls, 62failed_timeout (void *cls)
63 const struct GNUNET_SCHEDULER_TaskContext *tc)
64{ 63{
65 tsk = NULL; 64 tsk = NULL;
66 fprintf (stderr, 65 fprintf (stderr,
@@ -86,7 +85,7 @@ run (void *cls, char *const *args, const char *cfgfile,
86 2), 85 2),
87 &failed_timeout, 86 &failed_timeout,
88 NULL); 87 NULL);
89 88
90} 89}
91 90
92 91
@@ -127,7 +126,7 @@ main (int argc, char *const argv[])
127 "12345", NULL); 126 "12345", NULL);
128 GNUNET_assert (NULL != gns); 127 GNUNET_assert (NULL != gns);
129 GNUNET_PROGRAM_run (3, argv_prog, 128 GNUNET_PROGRAM_run (3, argv_prog,
130 "test-nat-test", "nohelp", 129 "test-nat-test", "nohelp",
131 options, &run, 130 options, &run,
132 NULL); 131 NULL);
133 GNUNET_break (0 == GNUNET_OS_process_kill (gns, GNUNET_TERM_SIG)); 132 GNUNET_break (0 == GNUNET_OS_process_kill (gns, GNUNET_TERM_SIG));
diff --git a/src/nat/test_stun.c b/src/nat/test_stun.c
index a856fa971..7fbba1cd6 100644
--- a/src/nat/test_stun.c
+++ b/src/nat/test_stun.c
@@ -112,18 +112,18 @@ stop ()
112 * incoming connection. 112 * incoming connection.
113 * 113 *
114 * @param cls 114 * @param cls
115 * @param tc scheduler context
116 */ 115 */
117static void 116static void
118do_udp_read (void *cls, 117do_udp_read (void *cls)
119 const struct GNUNET_SCHEDULER_TaskContext *tc)
120{ 118{
121 //struct GNUNET_NAT_Test *tst = cls; 119 //struct GNUNET_NAT_Test *tst = cls;
122 unsigned char reply_buf[1024]; 120 unsigned char reply_buf[1024];
123 ssize_t rlen; 121 ssize_t rlen;
124 struct sockaddr_in answer; 122 struct sockaddr_in answer;
123 const struct GNUNET_SCHEDULER_TaskContext *tc;
125 124
126 ltask4 = NULL; 125 ltask4 = NULL;
126 tc = GNUNET_SCHEDULER_get_task_context ();
127 if ( (0 == (tc->reason & GNUNET_SCHEDULER_REASON_READ_READY)) || 127 if ( (0 == (tc->reason & GNUNET_SCHEDULER_REASON_READ_READY)) ||
128 (! GNUNET_NETWORK_fdset_isset (tc->read_ready, 128 (! GNUNET_NETWORK_fdset_isset (tc->read_ready,
129 lsock4)) ) 129 lsock4)) )