in_tail: use FLB_PIPE_WOULDBLOCK instead of flb_pipe_check_eagain().
flb_pipe_check_eagain() is deprecated in the parent commit, so we
replace it with an equivalent macro.
@@ -46,7 +46,7 @@ static inline int tail_signal_pending(struct flb_tail_config *ctx)
/* Insert a dummy event into the 'pending' channel */
n = flb_pipe_w(ctx->ch_pending[1], &val, sizeof(val));
/* If we get EAGAIN, it simply means pending channel is full. As notification is already pending, it's safe to ignore. */
- if (n == -1 && !flb_pipe_check_eagain()) {
+ if (n == -1 && !FLB_PIPE_WOULDBLOCK()) {
flb_errno();
return -1;
}
@@ -65,11 +65,11 @@ static inline int tail_consume_pending(struct flb_tail_config *ctx)
*/
do {
ret = flb_pipe_r(ctx->ch_pending[0], &val, sizeof(val));
- if (ret <= 0 && !flb_pipe_check_eagain()) {
+ if (ret <= 0 && !FLB_PIPE_WOULDBLOCK()) {
flb_errno();
return -1;
}
- } while (!flb_pipe_check_eagain());
+ } while (!FLB_PIPE_WOULDBLOCK());
return 0;
}
