in_health: filter plugin support
@@ -79,6 +79,10 @@ static int in_health_collect(struct flb_input_instance *i_ins,
/*
* Store the new data into the MessagePack buffer,
*/
+
+ /* Mark the start of a 'buffer write' operation */
+ flb_input_buf_write_start(i_ins);
+
msgpack_pack_array(&i_ins->mp_pck, 2);
msgpack_pack_uint64(&i_ins->mp_pck, time(NULL));
@@ -117,6 +121,8 @@ static int in_health_collect(struct flb_input_instance *i_ins,
msgpack_pack_int32(&i_ins->mp_pck, ctx->port);
}
+ flb_input_buf_write_end(i_ins);
+
FLB_INPUT_RETURN();
return 0;
}
