logreader: retry on main_loop_io_worker_job_submit() failure

Signed-off-by: Balazs Scheidler <balazs.scheidler@axoflow.com>
axoflow · Oct 20, 2024 · b660f7b · b660f7b
1 parent 592bd98
commit b660f7b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/logreader.c b/lib/logreader.c
@@ -573,7 +573,11 @@ log_reader_io_handle_in(gpointer s)
   log_reader_disable_watches(self);
   if ((self->options->flags & LR_THREADED))
     {
-      main_loop_io_worker_job_submit(&self->io_job, NULL);
+      if (!main_loop_io_worker_job_submit(&self->io_job, NULL))
+        {
+          log_reader_set_immediate_check(self);
+          log_reader_update_watches(self);
+        }
     }
   else
     {