@@ -721,6 +721,7 @@ struct flb_output_flush *flb_output_flush_create(struct flb_task *task,
721
721
out_flush = (struct flb_output_flush * ) flb_calloc (1 , sizeof (struct flb_output_flush ));
722
722
if (!out_flush ) {
723
723
flb_errno ();
724
+
724
725
return NULL ;
725
726
}
726
727
@@ -774,6 +775,8 @@ struct flb_output_flush *flb_output_flush_create(struct flb_task *task,
774
775
p_buf = flb_calloc (evc -> size * 2 , sizeof (char ));
775
776
776
777
if (p_buf == NULL ) {
778
+ flb_errno ();
779
+
777
780
flb_coro_destroy (coro );
778
781
flb_free (out_flush );
779
782
@@ -833,6 +836,8 @@ struct flb_output_flush *flb_output_flush_create(struct flb_task *task,
833
836
flb_realloc (p_buf , p_size + serialized_context_size );
834
837
835
838
if (resized_serialization_buffer == NULL ) {
839
+ flb_errno ();
840
+
836
841
cmt_encode_msgpack_destroy (serialized_context_buffer );
837
842
flb_coro_destroy (coro );
838
843
flb_free (out_flush );
@@ -883,6 +888,8 @@ struct flb_output_flush *flb_output_flush_create(struct flb_task *task,
883
888
p_buf = flb_calloc (evc -> size * 2 , sizeof (char ));
884
889
885
890
if (p_buf == NULL ) {
891
+ flb_errno ();
892
+
886
893
flb_coro_destroy (coro );
887
894
flb_free (out_flush );
888
895
@@ -930,6 +937,8 @@ struct flb_output_flush *flb_output_flush_create(struct flb_task *task,
930
937
flb_realloc (p_buf , p_size + serialized_context_size );
931
938
932
939
if (resized_serialization_buffer == NULL ) {
940
+ flb_errno ();
941
+
933
942
ctr_encode_msgpack_destroy (serialized_context_buffer );
934
943
flb_coro_destroy (coro );
935
944
flb_free (out_flush );
@@ -980,6 +989,8 @@ struct flb_output_flush *flb_output_flush_create(struct flb_task *task,
980
989
p_buf = flb_calloc (evc -> size * 2 , sizeof (char ));
981
990
982
991
if (p_buf == NULL ) {
992
+ flb_errno ();
993
+
983
994
flb_coro_destroy (coro );
984
995
flb_free (out_flush );
985
996
@@ -1026,6 +1037,8 @@ struct flb_output_flush *flb_output_flush_create(struct flb_task *task,
1026
1037
flb_realloc (p_buf , p_size + cfl_sds_len (serialized_profiles_context_buffer ));
1027
1038
1028
1039
if (resized_serialization_buffer == NULL ) {
1040
+ flb_errno ();
1041
+
1029
1042
cprof_encode_msgpack_destroy (serialized_profiles_context_buffer );
1030
1043
flb_coro_destroy (coro );
1031
1044
flb_free (out_flush );
0 commit comments