diff options
Diffstat (limited to 'src/transport/plugin_transport_unix.c')
-rw-r--r-- | src/transport/plugin_transport_unix.c | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/transport/plugin_transport_unix.c b/src/transport/plugin_transport_unix.c index e320785d4..d0566c2d3 100644 --- a/src/transport/plugin_transport_unix.c +++ b/src/transport/plugin_transport_unix.c | |||
@@ -1229,11 +1229,9 @@ unix_plugin_select_read (void *cls) | |||
1229 | { | 1229 | { |
1230 | struct Plugin *plugin = cls; | 1230 | struct Plugin *plugin = cls; |
1231 | const struct GNUNET_SCHEDULER_TaskContext *tc; | 1231 | const struct GNUNET_SCHEDULER_TaskContext *tc; |
1232 | 1232 | ||
1233 | tc = GNUNET_SCHEDULER_get_task_context (); | ||
1234 | plugin->read_task = NULL; | 1233 | plugin->read_task = NULL; |
1235 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | 1234 | tc = GNUNET_SCHEDULER_get_task_context (); |
1236 | return; | ||
1237 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_READ_READY)) | 1235 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_READ_READY)) |
1238 | unix_plugin_do_read (plugin); | 1236 | unix_plugin_do_read (plugin); |
1239 | plugin->read_task = | 1237 | plugin->read_task = |
@@ -1254,11 +1252,9 @@ unix_plugin_select_write (void *cls) | |||
1254 | { | 1252 | { |
1255 | struct Plugin *plugin = cls; | 1253 | struct Plugin *plugin = cls; |
1256 | const struct GNUNET_SCHEDULER_TaskContext *tc; | 1254 | const struct GNUNET_SCHEDULER_TaskContext *tc; |
1257 | 1255 | ||
1258 | tc = GNUNET_SCHEDULER_get_task_context (); | ||
1259 | plugin->write_task = NULL; | 1256 | plugin->write_task = NULL; |
1260 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | 1257 | tc = GNUNET_SCHEDULER_get_task_context (); |
1261 | return; | ||
1262 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_WRITE_READY)) | 1258 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_WRITE_READY)) |
1263 | unix_plugin_do_write (plugin); | 1259 | unix_plugin_do_write (plugin); |
1264 | if (NULL == plugin->msg_head) | 1260 | if (NULL == plugin->msg_head) |