From 442b1d33c81681e20ed9684b8503ff9471fca38c Mon Sep 17 00:00:00 2001 From: Matthias Wachs Date: Wed, 20 Apr 2011 08:19:03 +0000 Subject: SHUTDOWN --- src/transport/plugin_transport_tcp.c | 2 +- src/transport/plugin_transport_udp.c | 4 ++-- src/transport/plugin_transport_unix.c | 4 ++-- src/transport/plugin_transport_wlan.c | 4 ++-- 4 files changed, 7 insertions(+), 7 deletions(-) (limited to 'src/transport') diff --git a/src/transport/plugin_transport_tcp.c b/src/transport/plugin_transport_tcp.c index fb65e1eb2..9dc67dcdf 100644 --- a/src/transport/plugin_transport_tcp.c +++ b/src/transport/plugin_transport_tcp.c @@ -2336,7 +2336,7 @@ tcp_plugin_server_read (void *cls, struct TCPProbeContext *tcp_probe_ctx; struct GNUNET_CONNECTION_Handle *sock; - if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) + if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) return; memset (mybuf, 0, sizeof(mybuf)); bytes = GNUNET_DISK_file_read(plugin->server_stdout_handle, diff --git a/src/transport/plugin_transport_udp.c b/src/transport/plugin_transport_udp.c index ca6bbe138..26644bdd3 100644 --- a/src/transport/plugin_transport_udp.c +++ b/src/transport/plugin_transport_udp.c @@ -1167,7 +1167,7 @@ udp_plugin_server_read (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc char *port_start; struct IPv4UdpAddress a4; - if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) + if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) return; bytes = GNUNET_DISK_file_read(plugin->server_stdout_handle, &mybuf, sizeof(mybuf)); @@ -1524,7 +1524,7 @@ udp_plugin_select (void *cls, uint16_t csize; plugin->select_task = GNUNET_SCHEDULER_NO_TASK; - if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) + if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) return; udp_sock = NULL; if (GNUNET_NETWORK_fdset_isset (tc->read_ready, diff --git a/src/transport/plugin_transport_unix.c b/src/transport/plugin_transport_unix.c index 0163a8e5b..d9b666f77 100644 --- a/src/transport/plugin_transport_unix.c +++ b/src/transport/plugin_transport_unix.c @@ -476,7 +476,7 @@ void retry_send_message (void *cls, { struct RetrySendContext *retry_ctx = cls; - if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) + if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) { GNUNET_free(retry_ctx->msg); GNUNET_free(retry_ctx->addr); @@ -817,7 +817,7 @@ unix_plugin_select (void *cls, uint16_t csize; plugin->select_task = GNUNET_SCHEDULER_NO_TASK; - if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) + if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) return; addrlen = sizeof(un); diff --git a/src/transport/plugin_transport_wlan.c b/src/transport/plugin_transport_wlan.c index f53e4b648..441989165 100644 --- a/src/transport/plugin_transport_wlan.c +++ b/src/transport/plugin_transport_wlan.c @@ -780,7 +780,7 @@ delay_fragment_task(void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) struct Plugin * plugin = cls; plugin->server_write_delay_task = GNUNET_SCHEDULER_NO_TASK; - if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) + if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) return; // GNUNET_TIME_UNIT_FOREVER_REL is needed to clean up old msg @@ -2884,7 +2884,7 @@ wlan_plugin_helper_read(void *cls, struct Plugin *plugin = cls; plugin->server_read_task = GNUNET_SCHEDULER_NO_TASK; - if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) + if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) return; char mybuf[WLAN_MTU + sizeof(struct GNUNET_MessageHeader)]; -- cgit v1.2.3