diff options
| author | 刘学利 <[email protected]> | 2022-05-17 10:05:40 +0000 |
|---|---|---|
| committer | 刘学利 <[email protected]> | 2022-05-17 10:05:40 +0000 |
| commit | f7c0f018be16586ed877aa02a6554a9fa453994f (patch) | |
| tree | a333469b5acfce64d4a422b07e119e8a98096e08 /src/tsg_tamper.cpp | |
| parent | 89deb48c319a2ba5cec08d2229ac155ef2884f4c (diff) | |
TSG-10275: kafka缺少topic时触发发送日志降级机制，仅丢弃本topic的日志，不影响别的topic日志发送
Diffstat (limited to 'src/tsg_tamper.cpp')
| -rw-r--r-- | src/tsg_tamper.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/tsg_tamper.cpp b/src/tsg_tamper.cpp index 897e6dd..9ddd027 100644 --- a/src/tsg_tamper.cpp +++ b/src/tsg_tamper.cpp @@ -32,7 +32,7 @@ #define IPV6_UDP_PALYLOAD_START_INDEX 48 //ipv6_len(40) + udp_len(8) #define IPV6_IP_PAYLOAD_INDEX 4 //ipv6_payload_index(4) -int swop_payload2byte(char *str, int endlen) +int swap_payload2byte(char *str, int endlen) { int i = 0; int j = 0; @@ -88,7 +88,7 @@ int send_tamper_xxx(const struct streaminfo *a_stream, long *tamper_count, const } memcpy(tamper_buf, p_trans_payload, trans_layload_len); - tamper_index = swop_payload2byte(tamper_buf, trans_layload_len); + tamper_index = swap_payload2byte(tamper_buf, trans_layload_len); if(tamper_index > 0 ){ if(0 == tsg_send_inject_packet(a_stream, SIO_DEFAULT, tamper_buf, trans_layload_len, a_stream->routedir)){ FS_operate(g_tsg_para.fs2_handle, g_tsg_para.fs2_field_id[TSG_FS2_SUCESS_TAMPER], 0, FS_OP_ADD, 1); @@ -108,7 +108,7 @@ int send_tamper_xxx(const struct streaminfo *a_stream, long *tamper_count, const } } - FS_operate(g_tsg_para.fs2_handle, g_tsg_para.fs2_field_id[TSG_FS2_TAMPER_FAILED_NOSWOP], 0, FS_OP_ADD, 1); + FS_operate(g_tsg_para.fs2_handle, g_tsg_para.fs2_field_id[TSG_FS2_TAMPER_FAILED_NOSWAP], 0, FS_OP_ADD, 1); MESA_handle_runtime_log(g_tsg_para.logger, RLOG_LV_DEBUG, __FUNCTION__, |