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 · e093834 · e093834
1 parent 558ff17
commit e093834
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);