Skip to content

Commit 2415c64

Browse files
cosmo0920edsiper
authored andcommitted
in_tail: Align the comments for timer of progress check
Signed-off-by: Hiroshi Hatake <hiroshi@chronosphere.io>
1 parent b671b21 commit 2415c64

2 files changed

Lines changed: 5 additions & 2 deletions

File tree

plugins/in_tail/tail_config.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,11 +73,11 @@ struct flb_tail_config {
7373
int coll_fd_inactive;
7474
int coll_fd_dmode_flush;
7575
int coll_fd_mult_flush;
76-
int coll_fd_progress_check;
7776

7877
/* Backend collectors */
7978
int coll_fd_fs1; /* used by fs_inotify & fs_stat */
8079
int coll_fd_fs2; /* only used by fs_stat */
80+
int coll_fd_progress_check; /* inotify missed-event recovery timer */
8181

8282
/* Configuration */
8383
int dynamic_tag; /* dynamic tag ? e.g: abc.* */

plugins/in_tail/tail_fs_inotify.c

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -433,7 +433,10 @@ int flb_tail_fs_inotify_init(struct flb_input_instance *in,
433433
}
434434
ctx->coll_fd_fs1 = ret;
435435

436-
/* Register callback to check current tail offsets */
436+
/*
437+
* Keep the collector ID so the recovery timer follows the inotify
438+
* collector through input pause and resume transitions.
439+
*/
437440
ret = flb_input_set_collector_time(in, in_tail_progress_check_callback,
438441
ctx->progress_check_interval,
439442
ctx->progress_check_interval_nsec,

0 commit comments

Comments
 (0)