feat: add legacy option in collector options

Author: ahuangfeng

src/listening_worker.h

@@ -19,6 +19,7 @@ struct listener_thread_input
   uint parser_queue_size;              /* Size of parser queue in bytes */
   uint monitoring_delay;               /* Monitoring frequence in seconds */
   bool msg_dst_ip;                     /* IP packet dst IP parsed */
+  bool legacy_proto;                   /* Legacy UDP-notif protocol */
 };
 
 struct parse_worker

src/parsing_worker.c

@@ -75,6 +75,13 @@ int parser(struct parser_thread_input *in)
   struct segment_buffer *segment_buff = in->segment_buff;
   int max_malloc_errs = 3;
   unyte_seg_counters_t *counters = in->counters;
+
+  unyte_seg_met_t *(*parse_with_metadata_func)(char *, unyte_min_t *);
+  if (in->legacy_proto)
+    parse_with_metadata_func = &parse_with_metadata;
+  else
+    parse_with_metadata_func = &parse_with_metadata;
+
   while (1)
   {
     void *queue_bef = unyte_udp_queue_read(in->input);
@@ -85,7 +92,7 @@ int parser(struct parser_thread_input *in)
       continue;
     }
     unyte_min_t *queue_data = (unyte_min_t *)queue_bef;
-    unyte_seg_met_t *parsed_segment = parse_with_metadata(queue_data->buffer, queue_data);
+    unyte_seg_met_t *parsed_segment = (*parse_with_metadata_func)(queue_data->buffer, queue_data);
 
     if (parsed_segment == NULL)
       return -1;

src/parsing_worker.h

@@ -13,6 +13,7 @@ struct parser_thread_input
   struct segment_buffer *segment_buff;
   unyte_seg_counters_t *counters;
   int monitoring_running;
+  bool legacy_proto;
 };
 
 /**

src/unyte_udp_collector.c

@@ -91,7 +91,8 @@ unyte_udp_collector_t *unyte_udp_create_listener(
     uint nb_parsers,
     uint parsers_q_size,
     uint monitoring_delay,
-    bool msg_dst_ip)
+    bool msg_dst_ip,
+    bool legacy)
 {
   pthread_t *udpListener = (pthread_t *)malloc(sizeof(pthread_t));
   struct listener_thread_input *listener_input = (struct listener_thread_input *)malloc(sizeof(struct listener_thread_input));
@@ -111,6 +112,7 @@ unyte_udp_collector_t *unyte_udp_create_listener(
   listener_input->parser_queue_size = parsers_q_size;
   listener_input->monitoring_delay = monitoring_delay;
   listener_input->msg_dst_ip = msg_dst_ip;
+  listener_input->legacy_proto = legacy;
 
   /*Threaded UDP listener*/
   pthread_create(udpListener, NULL, t_listener, (void *)listener_input);
@@ -141,7 +143,7 @@ unyte_udp_collector_t *unyte_udp_start_collector(unyte_udp_options_t *options)
   /* Return struct */
   unyte_udp_collector_t *collector = unyte_udp_create_listener(
       output_queue, monitoring_queue, conn, options->recvmmsg_vlen, options->nb_parsers,
-      options->parsers_queue_size, options->monitoring_delay, options->msg_dst_ip);
+      options->parsers_queue_size, options->monitoring_delay, options->msg_dst_ip, options->legacy);
 
   if (collector == NULL)
   {

src/unyte_udp_collector.h

@@ -30,6 +30,7 @@ typedef struct
   // monitoring
   uint monitoring_queue_size; // monitoring queue size
   uint monitoring_delay;      // monitoring queue frequence in seconds
+  bool legacy;                // legacy udp-notif: draft-ietf-netconf-udp-pub-channel-05
 } unyte_udp_options_t;
 
 /**