diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2011-04-20 08:19:03 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2011-04-20 08:19:03 +0000 |
commit | 442b1d33c81681e20ed9684b8503ff9471fca38c (patch) | |
tree | 36e73d330a1a86c078f4a532f4dd02347c32363a /src/transport | |
parent | d0d88da8754bd5184be826dc4d271c5abeece0c5 (diff) | |
download | gnunet-442b1d33c81681e20ed9684b8503ff9471fca38c.tar.gz gnunet-442b1d33c81681e20ed9684b8503ff9471fca38c.zip |
SHUTDOWN
Diffstat (limited to 'src/transport')
-rw-r--r-- | src/transport/plugin_transport_tcp.c | 2 | ||||
-rw-r--r-- | src/transport/plugin_transport_udp.c | 4 | ||||
-rw-r--r-- | src/transport/plugin_transport_unix.c | 4 | ||||
-rw-r--r-- | src/transport/plugin_transport_wlan.c | 4 |
4 files changed, 7 insertions, 7 deletions
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, | |||
2336 | struct TCPProbeContext *tcp_probe_ctx; | 2336 | struct TCPProbeContext *tcp_probe_ctx; |
2337 | struct GNUNET_CONNECTION_Handle *sock; | 2337 | struct GNUNET_CONNECTION_Handle *sock; |
2338 | 2338 | ||
2339 | if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) | 2339 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) |
2340 | return; | 2340 | return; |
2341 | memset (mybuf, 0, sizeof(mybuf)); | 2341 | memset (mybuf, 0, sizeof(mybuf)); |
2342 | bytes = GNUNET_DISK_file_read(plugin->server_stdout_handle, | 2342 | 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 | |||
1167 | char *port_start; | 1167 | char *port_start; |
1168 | struct IPv4UdpAddress a4; | 1168 | struct IPv4UdpAddress a4; |
1169 | 1169 | ||
1170 | if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) | 1170 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) |
1171 | return; | 1171 | return; |
1172 | 1172 | ||
1173 | bytes = GNUNET_DISK_file_read(plugin->server_stdout_handle, &mybuf, sizeof(mybuf)); | 1173 | bytes = GNUNET_DISK_file_read(plugin->server_stdout_handle, &mybuf, sizeof(mybuf)); |
@@ -1524,7 +1524,7 @@ udp_plugin_select (void *cls, | |||
1524 | uint16_t csize; | 1524 | uint16_t csize; |
1525 | 1525 | ||
1526 | plugin->select_task = GNUNET_SCHEDULER_NO_TASK; | 1526 | plugin->select_task = GNUNET_SCHEDULER_NO_TASK; |
1527 | if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) | 1527 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) |
1528 | return; | 1528 | return; |
1529 | udp_sock = NULL; | 1529 | udp_sock = NULL; |
1530 | if (GNUNET_NETWORK_fdset_isset (tc->read_ready, | 1530 | 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, | |||
476 | { | 476 | { |
477 | struct RetrySendContext *retry_ctx = cls; | 477 | struct RetrySendContext *retry_ctx = cls; |
478 | 478 | ||
479 | if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) | 479 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) |
480 | { | 480 | { |
481 | GNUNET_free(retry_ctx->msg); | 481 | GNUNET_free(retry_ctx->msg); |
482 | GNUNET_free(retry_ctx->addr); | 482 | GNUNET_free(retry_ctx->addr); |
@@ -817,7 +817,7 @@ unix_plugin_select (void *cls, | |||
817 | uint16_t csize; | 817 | uint16_t csize; |
818 | 818 | ||
819 | plugin->select_task = GNUNET_SCHEDULER_NO_TASK; | 819 | plugin->select_task = GNUNET_SCHEDULER_NO_TASK; |
820 | if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) | 820 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) |
821 | return; | 821 | return; |
822 | 822 | ||
823 | addrlen = sizeof(un); | 823 | 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) | |||
780 | struct Plugin * plugin = cls; | 780 | struct Plugin * plugin = cls; |
781 | plugin->server_write_delay_task = GNUNET_SCHEDULER_NO_TASK; | 781 | plugin->server_write_delay_task = GNUNET_SCHEDULER_NO_TASK; |
782 | 782 | ||
783 | if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) | 783 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) |
784 | return; | 784 | return; |
785 | 785 | ||
786 | // GNUNET_TIME_UNIT_FOREVER_REL is needed to clean up old msg | 786 | // GNUNET_TIME_UNIT_FOREVER_REL is needed to clean up old msg |
@@ -2884,7 +2884,7 @@ wlan_plugin_helper_read(void *cls, | |||
2884 | struct Plugin *plugin = cls; | 2884 | struct Plugin *plugin = cls; |
2885 | plugin->server_read_task = GNUNET_SCHEDULER_NO_TASK; | 2885 | plugin->server_read_task = GNUNET_SCHEDULER_NO_TASK; |
2886 | 2886 | ||
2887 | if (tc->reason == GNUNET_SCHEDULER_REASON_SHUTDOWN) | 2887 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) |
2888 | return; | 2888 | return; |
2889 | 2889 | ||
2890 | char mybuf[WLAN_MTU + sizeof(struct GNUNET_MessageHeader)]; | 2890 | char mybuf[WLAN_MTU + sizeof(struct GNUNET_MessageHeader)]; |