From b6c3a15518e9b6c7259be7c906193aa0cd510449 Mon Sep 17 00:00:00 2001 From: Pantelis Kolatsis Date: Thu, 4 May 2023 07:42:27 +0000 Subject: [PATCH] kafka: convert to memory error logging helper --- src/modules/kafka/kfk.c | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/src/modules/kafka/kfk.c b/src/modules/kafka/kfk.c index 555351710b7..4b892942af1 100644 --- a/src/modules/kafka/kfk.c +++ b/src/modules/kafka/kfk.c @@ -352,7 +352,7 @@ int kfk_conf_parse(char *spec) kconf = (kfk_conf_t*)pkg_malloc(sizeof(kfk_conf_t)); if (kconf == NULL) { - LM_ERR("No more pkg memory\n"); + PKG_MEM_ERROR; goto error; } memset(kconf, 0, sizeof(kfk_conf_t)); @@ -364,7 +364,7 @@ int kfk_conf_parse(char *spec) kfk_conf_node_t *knode = NULL; knode = (kfk_conf_node_t*)pkg_malloc(sizeof(kfk_conf_node_t)); if (knode == NULL) { - LM_ERR("No more pkg memory\n"); + PKG_MEM_ERROR; goto error; } memset(knode, 0, sizeof(kfk_conf_node_t)); @@ -504,7 +504,7 @@ int kfk_topic_parse(char *spec) ktopic = (kfk_topic_t*)pkg_malloc(sizeof(kfk_topic_t)); if (ktopic == NULL) { - LM_ERR("No more pkg memory\n"); + PKG_MEM_ERROR; goto error; } memset(ktopic, 0, sizeof(kfk_topic_t)); @@ -527,7 +527,7 @@ int kfk_topic_parse(char *spec) kfk_conf_node_t *knode = NULL; knode = (kfk_conf_node_t*)pkg_malloc(sizeof(kfk_conf_node_t)); if (knode == NULL) { - LM_ERR("No more pkg memory\n"); + PKG_MEM_ERROR; goto error; } memset(knode, 0, sizeof(kfk_conf_node_t)); @@ -898,7 +898,7 @@ int kfk_stats_init() stats_general = shm_malloc(sizeof(kfk_stats_t)); if (!stats_general) { - LM_ERR("Out of shared memory\n"); + SHM_MEM_ERROR; return -1; } memset(stats_general, 0, sizeof(kfk_stats_t)); @@ -971,21 +971,21 @@ static kfk_stats_t* kfk_stats_topic_new(const char *topic, rd_kafka_resp_err_t e st = shm_malloc(sizeof(kfk_stats_t)); if (!st) { - LM_ERR("Out of shared memory\n"); + SHM_MEM_ERROR; goto error; } memset(st, 0, sizeof(kfk_stats_t)); st->topic_name = shm_malloc(sizeof(str)); if (!st->topic_name) { - LM_ERR("Out of shared memory\n"); + SHM_MEM_ERROR; goto error; } memset(st->topic_name, 0, sizeof(str)); st->topic_name->s = shm_malloc(topic_len + 1); if (!st->topic_name->s) { - LM_ERR("Out of shared memory\n"); + SHM_MEM_ERROR; goto error; } memcpy(st->topic_name->s, topic, topic_len);