diff options
| author | tongzongzhen <[email protected]> | 2024-05-28 15:26:56 +0800 |
|---|---|---|
| committer | tongzongzhen <[email protected]> | 2024-05-28 15:26:56 +0800 |
| commit | 69586f49f2d37fe61ba68e1c2f67077433afc41d (patch) | |
| tree | c2486705f739e51f33974921341b2627a765f876 | |
| parent | b0b1777a1032a11ad227ee04ca1f96eb2046821d (diff) | |
add debug option for invalid traffic link id
| -rw-r--r-- | etc/dp_trace.conf | 1 | ||||
| -rw-r--r-- | include/config.h | 1 | ||||
| -rw-r--r-- | src/config.c | 2 | ||||
| -rw-r--r-- | src/trace_output.c | 3 |
4 files changed, 6 insertions, 1 deletions
diff --git a/etc/dp_trace.conf b/etc/dp_trace.conf index 82348c6..9f72037 100644 --- a/etc/dp_trace.conf +++ b/etc/dp_trace.conf @@ -31,5 +31,6 @@ maat_redis_db_index=1 [debug] send_ctrlbuf=0 +send_invalid_traffic_link_id=0 kafka_dump_to_log=0 arp_pkt_has_ip_test=0
\ No newline at end of file diff --git a/include/config.h b/include/config.h index 8de481e..47e9bd1 100644 --- a/include/config.h +++ b/include/config.h @@ -57,6 +57,7 @@ struct config // debug unsigned int send_ctrlbuf; + unsigned int send_invalid_traffic_link_id; unsigned int kafka_dump_to_log; unsigned int arp_pkt_has_ip_test; }; diff --git a/src/config.c b/src/config.c index d3a4ef3..0cac3e4 100644 --- a/src/config.c +++ b/src/config.c @@ -124,6 +124,8 @@ void config_load() MESA_load_profile_int_def(config_path, "maat", "maat_redis_db_index", &(g_conf->redis_db_idx), 0); MESA_load_profile_uint_def(config_path, "debug", "send_ctrlbuf", &g_conf->send_ctrlbuf, 0); + MESA_load_profile_uint_def(config_path, "debug", "send_invalid_traffic_link_id", + &g_conf->send_invalid_traffic_link_id, 0); MESA_load_profile_uint_def(config_path, "debug", "kafka_dump_to_log", &(g_conf->kafka_dump_to_log), 0); MESA_load_profile_uint_def(config_path, "debug", "arp_pkt_has_ip_test", &(g_conf->arp_pkt_has_ip_test), 0); } diff --git a/src/trace_output.c b/src/trace_output.c index 15ea94e..5fa66c4 100644 --- a/src/trace_output.c +++ b/src/trace_output.c @@ -545,7 +545,8 @@ static void dp_trace_decode_to_message_pack(marsio_buff_t * mr_mbuf, char ** dat mpack_write_cstr(&writer, "device_group"); mpack_write_cstr(&writer, conf->device_group); - if (trace_buff_info.traffic_link_id != 0 && trace_buff_info.traffic_link_id != 65535) + if (conf->send_invalid_traffic_link_id == 1 || + (trace_buff_info.traffic_link_id != 0 && trace_buff_info.traffic_link_id != 65535)) { mpack_write_cstr(&writer, "traffic_link_id"); mpack_write_i32(&writer, trace_buff_info.traffic_link_id); |