add debug option for invalid traffic link id

2 files changed, 4 insertions, 1 deletions

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);