aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_unix.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/plugin_transport_unix.c')
-rw-r--r--src/transport/plugin_transport_unix.c12
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)