summaryrefslogtreecommitdiff
path: root/src/mocking.c
diff options
context:
space:
mode:
authortongzongzhen <[email protected]>2024-05-28 14:59:28 +0800
committertongzongzhen <[email protected]>2024-05-28 14:59:28 +0800
commitb0b1777a1032a11ad227ee04ca1f96eb2046821d (patch)
tree3a53af991f4520db6289b4f7d74707843cdfeb57 /src/mocking.c
parentd85f991f782bea6896c434f66fd5c44dfb909096 (diff)
when traffic link id is not valid, dont send it.
Diffstat (limited to 'src/mocking.c')
-rw-r--r--src/mocking.c6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/mocking.c b/src/mocking.c
index 79a49a9..3255261 100644
--- a/src/mocking.c
+++ b/src/mocking.c
@@ -46,7 +46,11 @@ int kafka_dump_to_log(zlog_category_t * logger, const void * payload, size_t len
mpack_node_copy_cstr(mpack_node_map_cstr(root, "device_group"), packet.device_group, sizeof(packet.device_group));
- packet.traffic_link_id = mpack_node_i32(mpack_node_map_cstr(root, "traffic_link_id"));
+ mpack_node_t traffic_link_id_node = mpack_node_map_cstr(root, "traffic_link_id");
+ if (!mpack_node_is_nil(traffic_link_id_node))
+ {
+ packet.traffic_link_id = mpack_node_i32(traffic_link_id_node);
+ }
mpack_node_t source_ip_node = mpack_node_map_cstr(root, "source_ip");
if (!mpack_node_is_nil(source_ip_node))