Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
PettitWesley committed Mar 17, 2022
1 parent a5dee29 commit 91478eb
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions plugins/filter_multiline/ml_concat.c
Original file line number Diff line number Diff line change
Expand Up @@ -214,23 +214,23 @@ struct split_message_packer *ml_create_packer(const char *tag, char *input_name,
tmp = flb_sds_create(tag);
if (!tmp) {
flb_errno();
split_message_packer_destroy(packer);
ml_split_message_packer_destroy(packer);
return NULL;
}
packer->tag = tmp;

tmp = flb_sds_create_len(partial_id_str, partial_id_size);
if (!tmp) {
flb_errno();
split_message_packer_destroy(packer);
ml_split_message_packer_destroy(packer);
return NULL;
}
packer->partial_id = tmp;

packer->buf = flb_sds_create_size(FLB_MULTILINE_PARTIAL_BUF_SIZE);
if (!packer->buf) {
flb_errno();
split_message_packer_destroy(packer);
ml_split_message_packer_destroy(packer);
return NULL;
}

Expand All @@ -241,7 +241,7 @@ struct split_message_packer *ml_create_packer(const char *tag, char *input_name,
split_kv = ml_get_key(map, multiline_key_content);
if (split_kv == NULL) {
flb_error("[partial message concat] Could not find key %s in record", multiline_key_content);
split_message_packer_destroy(packer);
ml_split_message_packer_destroy(packer);
return NULL;
}

Expand Down

0 comments on commit 91478eb

Please sign in to comment.