out_forward: fix connection leak on successfull flush (fix #234)

In recent changes, the function call to release the upstream connection when the data is flushed was commented, for hence the connection is leaked. This patch fix the problem releasing the connection properly. Signed-off-by: Eduardo Silva <[email protected]>
fluent · Apr 12, 2017 · c54601d · c54601d
1 parent 89b6cc8
commit c54601d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/plugins/out_forward/forward.c b/plugins/out_forward/forward.c
@@ -541,7 +541,8 @@ void cb_forward_flush(void *data, size_t bytes,
     }
 
     total += bytes_sent;
-    //flb_upstream_conn_release(u_conn);
+    flb_upstream_conn_release(u_conn);
+
     flb_trace("[out_fw] ended write()=%d bytes", total);
 
     FLB_OUTPUT_RETURN(FLB_OK);