scheduler: Dispose ch_events on destroy

Signed-off-by: Hiroshi Hatake <hiroshi@chronosphere.io>

Author: cosmo0920

include/fluent-bit/flb_scheduler.h

@@ -135,6 +135,7 @@ struct flb_sched {
      * case is the use of timers running under a co-routine that needs to
      * be handled in active event loop.
      */
+    int ch_events_initialized;
     flb_pipefd_t ch_events[2];
 };
 

src/flb_scheduler.c

@@ -796,6 +796,7 @@ struct flb_sched *flb_sched_create(struct flb_config *config,
         flb_sched_destroy(sched);
         return NULL;
     }
+    sched->ch_events_initialized = FLB_TRUE;
     sched->event.type = FLB_ENGINE_EV_SCHED_CORO;
 
     /*
@@ -849,6 +850,14 @@ int flb_sched_destroy(struct flb_sched *sched)
         c++;
     }
 
+    if (sched->ch_events_initialized == FLB_TRUE) {
+        mk_event_channel_destroy(sched->evl,
+                                 sched->ch_events[0],
+                                 sched->ch_events[1],
+                                 sched);
+        sched->ch_events_initialized = FLB_FALSE;
+    }
+
     flb_free(sched);
     return c;
 }