engine: validate connection event thread is not null
@@ -616,10 +616,12 @@ int flb_engine_start(struct flb_config *config)
*/
u_conn = (struct flb_upstream_conn *) event;
th = u_conn->thread;
+ if (th) {
flb_trace("[engine] resuming thread=%p", th);
flb_thread_resume(th);
}
}
+ }
/* Cleanup functions associated to events and timers */
if (config->is_running == FLB_TRUE) {
