in_mem: filter plugin support (fluent#173)

Signed-off-by: Takahiro YAMASHITA <[email protected]>
nokute78 · Feb 6, 2017 · 9b5c5bb · 9b5c5bb
1 parent 31a45e5
commit 9b5c5bb
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/plugins/in_mem/mem.c b/plugins/in_mem/mem.c
@@ -209,6 +209,9 @@ static int in_mem_collect(struct flb_input_instance *i_ins,
         entries += 2;
     }
 
+    /* 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));
     msgpack_pack_map(&i_ins->mp_pck, entries);
@@ -241,6 +244,7 @@ static int in_mem_collect(struct flb_input_instance *i_ins,
               total, free);
     ++ctx->idx;
 
+    flb_input_buf_write_end(i_ins);
     flb_stats_update(in_mem_plugin.stats_fd, 0, 1);
     return 0;
 }