[sr-dev] git:master:b6c3a155: kafka: convert to memory error logging helper

Module: kamailio Branch: master Commit: b6c3a15518e9b6c7259be7c906193aa0cd510449 URL: https://github.com/kamailio/kamailio/commit/b6c3a15518e9b6c7259be7c906193aa… Author: Pantelis Kolatsis <pk(a)gilawa.com> Committer: Henning Westerholt <hw(a)gilawa.com> Date: 2023-05-04T08:06:37Z kafka: convert to memory error logging helper --- Modified: src/modules/kafka/kfk.c --- Diff: https://github.com/kamailio/kamailio/commit/b6c3a15518e9b6c7259be7c906193aa… Patch: https://github.com/kamailio/kamailio/commit/b6c3a15518e9b6c7259be7c906193aa… --- 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);