in_kubernetes_events: fix end of chunked stream deadlock

Signed-off-by: ryanohnemus <[email protected]>

plugins/in_kubernetes_events/kubernetes_events.c

@@ -906,6 +906,7 @@ static int k8s_events_collect(struct flb_input_instance *ins,
     }
 
     if (check_and_init_stream(ctx) == FLB_FALSE) {
+        pthread_mutex_unlock(&ctx->lock);
         FLB_INPUT_RETURN(0);
     }
 
@@ -921,15 +922,19 @@ static int k8s_events_collect(struct flb_input_instance *ins,
     }
     /* NOTE: skipping any processing after streaming socket closes */
 
-    if (ctx->streaming_client->resp.status != 200 || ret == FLB_HTTP_ERROR) {
+    if (ctx->streaming_client->resp.status != 200 || ret == FLB_HTTP_ERROR || ret == FLB_HTTP_OK) {
         if (ret == FLB_HTTP_ERROR) {
             flb_plg_warn(ins, "kubernetes chunked stream error.");
         }
+        else if (ret == FLB_HTTP_OK) {
+            flb_plg_info(ins, "kubernetes stream closed by api server. Reconnect will happen on next interval.");
+        }
         else {
             flb_plg_warn(ins, "events watch failure, http_status=%d payload=%s",
                          ctx->streaming_client->resp.status, ctx->streaming_client->resp.payload);
         }
 
+        flb_plg_info(ins, "kubernetes stream disconnected, ret=%d", ret);
         flb_http_client_destroy(ctx->streaming_client);
         flb_upstream_conn_release(ctx->current_connection);
         ctx->streaming_client = NULL;