gfwleak/tango-tfe
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TSG-148 修复笔误

Browse Source
This commit is contained in:
luwenpeng
2019-12-06 17:23:21 +08:00
parent 67c27a2fb5
commit 6a335e0072
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
platform/src/ssl_fetch_cert.cpp
View File

@@ -6,6 +6,11 @@
#include "tfe_utils.h" #include "tfe_utils.h"
#include <assert.h> #include <assert.h>
#include <unistd.h>
#include <net/if.h>
#include <sys/ioctl.h>
#include <arpa/inet.h>
#include <cjson/cJSON.h> #include <cjson/cJSON.h>
#include <librdkafka/rdkafka.h> #include <librdkafka/rdkafka.h>
#include <MESA/MESA_prof_load.h> #include <MESA/MESA_prof_load.h>
@@ -43,7 +48,7 @@ static unsigned int get_ip_by_eth(const char *eth) {
goto error; goto error;
} }
memset(&ifr, 0, sizoef(ifr)); memset(&ifr, 0, sizeof(ifr));
strcpy(ifr.ifr_name, eth); strcpy(ifr.ifr_name, eth);
if (ioctl(sockfd, SIOCGIFADDR, &ifr) < 0) { if (ioctl(sockfd, SIOCGIFADDR, &ifr) < 0) {
goto error; goto error;
@@ -91,7 +96,7 @@ void ssl_mid_cert_kafka_logger_destory(void) {
free(g_kafka_logger->handle); free(g_kafka_logger->handle);
} }
if (g_kafka_logger->topic) { if (g_kafka_logger->topic) {
free(g_kafka_logger->topic) free(g_kafka_logger->topic);
} }
free(g_kafka_logger); 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; char *msg = NULL;
obj = cJSON_CreateObject(); obj = cJSON_CreateObject();
cJSON_AddNumberToObject(obj, "sni", sni); cJSON_AddStringToObject(obj, "sni", sni);
cJSON_AddNumberToObject(obj, "fingerprint", fingerprint); cJSON_AddStringToObject(obj, "fingerprint", fingerprint);
cJSON_AddStringToObject(obj, "cert", cert); cJSON_AddStringToObject(obj, "cert", cert);
cJSON_AddStringToObject(obj, "tfe_ip", g_kafka_logger->tfe_ip); cJSON_AddStringToObject(obj, "tfe_ip", g_kafka_logger->tfe_ip);
dup = cJSON_Duplicate(obj, 1); 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); rd_kafka_produce(g_kafka_logger->topic, RD_KAFKA_PARTITION_UA, RD_KAFKA_MSG_F_COPY, msg, strlen(msg), NULL, 0, NULL);
free(msg); free(msg);
JSON_Delete(dup); cJSON_Delete(dup);
cJSON_Delete(obj); cJSON_Delete(obj);
} }