filter: nightfall: updated the code to use the new base stream type
@@ -112,7 +112,8 @@ static int cb_nightfall_init(struct flb_filter_instance *f_ins,
return -1;
}
- ctx->upstream->flags &= ~(FLB_IO_ASYNC);
+ flb_stream_disable_async_mode(&ctx->upstream->base);
+
flb_filter_set_context(f_ins, ctx);
srand((unsigned int)time(NULL));
