aboutsummaryrefslogtreecommitdiff
path: root/src/transport
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2011-04-20 08:19:03 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2011-04-20 08:19:03 +0000
commit442b1d33c81681e20ed9684b8503ff9471fca38c (patch)
tree36e73d330a1a86c078f4a532f4dd02347c32363a /src/transport
parentd0d88da8754bd5184be826dc4d271c5abeece0c5 (diff)
downloadgnunet-442b1d33c81681e20ed9684b8503ff9471fca38c.tar.gz
gnunet-442b1d33c81681e20ed9684b8503ff9471fca38c.zip
SHUTDOWN
Diffstat (limited to 'src/transport')
-rw-r--r--src/transport/plugin_transport_tcp.c2
-rw-r--r--src/transport/plugin_transport_udp.c4
-rw-r--r--src/transport/plugin_transport_unix.c4
-rw-r--r--src/transport/plugin_transport_wlan.c4
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)];