Skip to content

Commit 37acacd

Browse files
authored
input_thread: pause coll_fd when read pipe is closed (fluent#5742)
Signed-off-by: Takahiro Yamashita <[email protected]>
1 parent 47cdf2c commit 37acacd

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/flb_input_thread.c

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -744,6 +744,7 @@ int flb_input_thread_collect(struct flb_input_instance *ins,
744744

745745
if (bytes_read == 0) {
746746
flb_plg_warn(ins, "end of file (read pipe closed by input thread)");
747+
flb_input_collector_pause(it->coll_fd, ins);
747748
return 0;
748749
}
749750

0 commit comments

Comments
 (0)