out_forward: if secure forward handshake fails do a proper exit

Signed-off-by: Eduardo Silva <[email protected]>
fluent · Apr 12, 2017 · d613b2e · d613b2e
1 parent e093834
commit d613b2e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/plugins/out_forward/forward.c b/plugins/out_forward/forward.c
@@ -517,6 +517,11 @@ void cb_forward_flush(void *data, size_t bytes,
     if (ctx->secured == FLB_TRUE) {
         ret = secure_forward_handshake(u_conn, ctx);
         flb_debug("[out_fw] handshake status = %i", ret);
+        if (ret == -1) {
+            flb_upstream_conn_release(u_conn);
+            msgpack_sbuffer_destroy(&mp_sbuf);
+            FLB_OUTPUT_RETURN(FLB_RETRY);
+        }
     }
 #endif