diff options
| author | 童宗振 <[email protected]> | 2024-05-28 07:36:01 +0000 |
|---|---|---|
| committer | 童宗振 <[email protected]> | 2024-05-28 07:36:01 +0000 |
| commit | e2200bb6c2cd93554b06d0193e4f64cee03376d9 (patch) | |
| tree | c2486705f739e51f33974921341b2627a765f876 /src/mocking.c | |
| parent | d85f991f782bea6896c434f66fd5c44dfb909096 (diff) | |
| parent | 69586f49f2d37fe61ba68e1c2f67077433afc41d (diff) | |
Merge branch 'no_traffic_link_id_no_send' into 'dev-0.1'v0.1.16-20240528dev-0.1
when traffic link id is not valid, dont send it.
See merge request tsg/dp_telemetry_app!45
Diffstat (limited to 'src/mocking.c')
| -rw-r--r-- | src/mocking.c | 6 |
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)) |