diff --git a/platform/src/ssl_fetch_cert.cpp b/platform/src/ssl_fetch_cert.cpp index 546f90d..4703503 100644 --- a/platform/src/ssl_fetch_cert.cpp +++ b/platform/src/ssl_fetch_cert.cpp @@ -6,6 +6,11 @@ #include "tfe_utils.h" #include +#include +#include +#include +#include + #include #include #include @@ -43,7 +48,7 @@ static unsigned int get_ip_by_eth(const char *eth) { goto error; } - memset(&ifr, 0, sizoef(ifr)); + memset(&ifr, 0, sizeof(ifr)); strcpy(ifr.ifr_name, eth); if (ioctl(sockfd, SIOCGIFADDR, &ifr) < 0) { goto error; @@ -91,7 +96,7 @@ void ssl_mid_cert_kafka_logger_destory(void) { free(g_kafka_logger->handle); } if (g_kafka_logger->topic) { - free(g_kafka_logger->topic) + free(g_kafka_logger->topic); } free(g_kafka_logger); } @@ -155,8 +160,8 @@ void ssl_mid_cert_kafka_logger_send(const char *sni, const char *fingerprint, co char *msg = NULL; obj = cJSON_CreateObject(); - cJSON_AddNumberToObject(obj, "sni", sni); - cJSON_AddNumberToObject(obj, "fingerprint", fingerprint); + cJSON_AddStringToObject(obj, "sni", sni); + cJSON_AddStringToObject(obj, "fingerprint", fingerprint); cJSON_AddStringToObject(obj, "cert", cert); cJSON_AddStringToObject(obj, "tfe_ip", g_kafka_logger->tfe_ip); dup = cJSON_Duplicate(obj, 1); @@ -165,7 +170,7 @@ void ssl_mid_cert_kafka_logger_send(const char *sni, const char *fingerprint, co rd_kafka_produce(g_kafka_logger->topic, RD_KAFKA_PARTITION_UA, RD_KAFKA_MSG_F_COPY, msg, strlen(msg), NULL, 0, NULL); free(msg); - JSON_Delete(dup); + cJSON_Delete(dup); cJSON_Delete(obj); }