@@ -39,7 +39,7 @@ static int emitter_create(struct flb_rewrite_tag *ctx)
39
39
{
40
40
int ret ;
41
41
struct flb_input_instance * ins ;
42
- char ring_buffer_size [8 ];
42
+ char ring_buffer_size [42 ];
43
43
44
44
ret = flb_input_name_exists (ctx -> emitter_name , ctx -> config );
45
45
if (ret == FLB_TRUE ) {
@@ -76,15 +76,8 @@ static int emitter_create(struct flb_rewrite_tag *ctx)
76
76
77
77
/* Set ring_buffer_size */
78
78
if (ctx -> emitter_ring_buffer_size > 0 ) {
79
- ret = snprintf (ring_buffer_size , sizeof (ring_buffer_size )- 1 , "%zd" ,
80
- ctx -> emitter_ring_buffer_size );
81
- if (ret > sizeof (ring_buffer_size )- 1 ) {
82
- flb_plg_error (ctx -> ins , "ring_buffer_size exceeds maximum size" );
83
- flb_input_instance_exit (ins , ctx -> config );
84
- flb_input_instance_destroy (ins );
85
- return -1 ;
86
- }
87
- ring_buffer_size [ret ] = '\0' ;
79
+ snprintf (ring_buffer_size , sizeof (ring_buffer_size )- 1 , "%zd" ,
80
+ ctx -> emitter_ring_buffer_size );
88
81
ret = flb_input_set_property (ins , "ring_buffer_size" , ring_buffer_size );
89
82
if (ret == -1 ) {
90
83
flb_plg_error (ins , "cannot set ring buffer size" );
0 commit comments