fixup

awslabs · Sep 17, 2024 · 702312a · 702312a
1 parent d8a8085
commit 702312a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/source/qnx/ionotify_event_loop.c b/source/qnx/ionotify_event_loop.c
@@ -536,7 +536,7 @@ static void s_process_io_result(
     struct aws_io_handle *handle,
     const struct aws_io_handle_io_op_result *io_op_result) {
 
-    AWS_ASSERT(!s_is_on_callers_thread(event_loop));
+    AWS_ASSERT(s_is_on_callers_thread(event_loop));
 
     AWS_ASSERT(handle->additional_data);
     struct ionotify_event_data *ionotify_event_data = handle->additional_data;
@@ -570,7 +570,8 @@ static void s_process_io_result(
             AWS_LS_IO_EVENT_LOOP, "id=%p: Got EWOULDBLOCK for fd %d, rearming it", (void *)event_loop, handle->data.fd);
         /* We're on the event loop thread, just schedule subscribing task. */
         ionotify_event_data->events_subscribed = event_types;
-        s_subscribe_task(NULL, ionotify_event_data, AWS_TASK_STATUS_RUN_READY);
+        struct ionotify_loop *ionotify_loop = event_loop->impl_data;
+        aws_task_scheduler_schedule_now(&ionotify_loop->scheduler, &ionotify_event_data->subscribe_task);
     }
 
     /* Notify event loop of error conditions. */

diff --git a/source/qnx/pipe.c b/source/qnx/pipe.c
@@ -288,8 +288,7 @@ int aws_pipe_read(struct aws_pipe_read_end *read_end, struct aws_byte_buf *dst_b
             return aws_raise_error(AWS_IO_READ_WOULD_BLOCK);
         }
         return s_raise_posix_error(errno_value);
-    }
-    else if (read_val == 0) {
+    } else if (read_val == 0) {
         // Return results back to event loop.
         if (read_impl->handle.update_io_result) {
             struct aws_io_handle_io_op_result io_op_result;