api: clean up use of deprecated flag
[vpp.git] / src / plugins / nat / nat_ipfix_logging.c
index 4bb96bc..42252b2 100644 (file)
@@ -48,7 +48,7 @@ typedef struct
   u8 nat_event;
   u32 src_ip;
   u32 nat_src_ip;
-  snat_protocol_t snat_proto;
+  nat_protocol_t nat_proto;
   u16 src_port;
   u16 nat_src_port;
   u32 vrf_id;
@@ -219,20 +219,6 @@ snat_template_rewrite (flow_report_main_t * frm,
           update_template_id(&silm->max_bibs_template_id,
                              fr->template_id);
        }
-      else if (quota_event == MAX_FRAGMENTS_PENDING_REASSEMBLY)
-       {
-         field_count = MAX_FRAGMENTS_FIELD_COUNT;
-
-          update_template_id(&silm->max_frags_ip4_template_id,
-                             fr->template_id);
-       }
-      else if (quota_event == MAX_FRAGMENTS_PENDING_REASSEMBLY_IP6)
-        {
-          field_count = MAX_FRAGMENTS_FIELD_COUNT;
-
-          update_template_id(&silm->max_frags_ip6_template_id,
-                             fr->template_id);
-        }
     }
 
   /* allocate rewrite space */
@@ -377,36 +363,6 @@ snat_template_rewrite (flow_report_main_t * frm,
          f->e_id_length = ipfix_e_id_length (0, maxBIBEntries, 4);
          f++;
         }
-      else if (quota_event == MAX_FRAGMENTS_PENDING_REASSEMBLY)
-        {
-         f->e_id_length = ipfix_e_id_length (0, observationTimeMilliseconds,
-                                             8);
-         f++;
-         f->e_id_length = ipfix_e_id_length (0, natEvent, 1);
-         f++;
-         f->e_id_length = ipfix_e_id_length (0, natQuotaExceededEvent, 4);
-         f++;
-         f->e_id_length = ipfix_e_id_length (0, maxFragmentsPendingReassembly,
-                                              4);
-         f++;
-         f->e_id_length = ipfix_e_id_length (0, sourceIPv4Address, 4);
-         f++;
-        }
-      else if (quota_event == MAX_FRAGMENTS_PENDING_REASSEMBLY_IP6)
-        {
-         f->e_id_length = ipfix_e_id_length (0, observationTimeMilliseconds,
-                                             8);
-         f++;
-         f->e_id_length = ipfix_e_id_length (0, natEvent, 1);
-         f++;
-         f->e_id_length = ipfix_e_id_length (0, natQuotaExceededEvent, 4);
-         f++;
-         f->e_id_length = ipfix_e_id_length (0, maxFragmentsPendingReassembly,
-                                              4);
-         f++;
-         f->e_id_length = ipfix_e_id_length (0, sourceIPv6Address, 16);
-         f++;
-        }
     }
 
   /* Back to the template packet... */
@@ -498,34 +454,6 @@ nat_template_rewrite_max_bibs (flow_report_main_t * frm,
                                MAX_BIB_ENTRIES);
 }
 
-u8 *
-nat_template_rewrite_max_frags_ip4 (flow_report_main_t * frm,
-                                   flow_report_t * fr,
-                                   ip4_address_t * collector_address,
-                                   ip4_address_t * src_address,
-                                   u16 collector_port,
-                                    ipfix_report_element_t *elts,
-                                    u32 n_elts, u32 *stream_index)
-{
-  return snat_template_rewrite (frm, fr, collector_address, src_address,
-                               collector_port, QUOTA_EXCEEDED,
-                               MAX_FRAGMENTS_PENDING_REASSEMBLY);
-}
-
-u8 *
-nat_template_rewrite_max_frags_ip6 (flow_report_main_t * frm,
-                                   flow_report_t * fr,
-                                   ip4_address_t * collector_address,
-                                   ip4_address_t * src_address,
-                                   u16 collector_port,
-                                    ipfix_report_element_t *elts,
-                                    u32 n_elts, u32 *stream_index)
-{
-  return snat_template_rewrite (frm, fr, collector_address, src_address,
-                               collector_port, QUOTA_EXCEEDED,
-                               MAX_FRAGMENTS_PENDING_REASSEMBLY_IP6);
-}
-
 u8 *
 nat_template_rewrite_nat64_bib (flow_report_main_t * frm,
                                flow_report_t * fr,
@@ -565,6 +493,7 @@ snat_ipfix_header_create (flow_report_main_t * frm,
   u32 stream_index;
   ip4_header_t *ip;
   udp_header_t *udp;
+  vlib_main_t *vm = vlib_get_main ();
   
   stream_index = clib_atomic_fetch_or(&silm->stream_index, 0);
   stream = &frm->streams[stream_index];
@@ -593,7 +522,7 @@ snat_ipfix_header_create (flow_report_main_t * frm,
 
   h->export_time = clib_host_to_net_u32 ((u32)
                                         (((f64) frm->unix_time_0) +
-                                         (vlib_time_now (frm->vlib_main) -
+                                         (vlib_time_now (vm) -
                                           frm->vlib_time_0)));
 
   sequence_number = clib_atomic_fetch_add (&stream->sequence_number, 1);
@@ -604,7 +533,7 @@ snat_ipfix_header_create (flow_report_main_t * frm,
 }
 
 static inline void
-snat_ipfix_send (flow_report_main_t * frm,
+snat_ipfix_send (u32 thread_index, flow_report_main_t * frm,
                 vlib_frame_t * f, vlib_buffer_t * b0, u16 template_id)
 {
   ip4_ipfix_template_packet_t *tp;
@@ -612,7 +541,7 @@ snat_ipfix_send (flow_report_main_t * frm,
   ipfix_set_header_t *s = 0;
   ip4_header_t *ip;
   udp_header_t *udp;
-  vlib_main_t *vm = frm->vlib_main;
+  vlib_main_t *vm = vlib_mains[thread_index];
 
   tp = vlib_buffer_get_current (b0);
   ip = (ip4_header_t *) & tp->ip4;
@@ -638,14 +567,14 @@ snat_ipfix_send (flow_report_main_t * frm,
        udp->checksum = 0xffff;
     }
 
-  ASSERT (ip->checksum == ip4_header_checksum (ip));
+  ASSERT (ip4_header_checksum_is_valid (ip));
 
   vlib_put_frame_to_node (vm, ip4_lookup_node.index, f);
 }
 
 static void
 snat_ipfix_logging_nat44_ses (u32 thread_index, u8 nat_event, u32 src_ip,
-                              u32 nat_src_ip, snat_protocol_t snat_proto,
+                              u32 nat_src_ip, nat_protocol_t nat_proto,
                               u16 src_port, u16 nat_src_port, u32 vrf_id,
                               int do_flush)
 {
@@ -656,12 +585,12 @@ snat_ipfix_logging_nat44_ses (u32 thread_index, u8 nat_event, u32 src_ip,
   vlib_buffer_t *b0 = 0;
   u32 bi0 = ~0;
   u32 offset;
-  vlib_main_t *vm = frm->vlib_main;
+  vlib_main_t *vm = vlib_mains[thread_index];
   u64 now;
-  u8 proto = ~0;
+  u8 proto;
   u16 template_id;
 
-  proto = snat_proto_to_ip_proto (snat_proto);
+  proto = nat_proto_to_ip_proto (nat_proto);
 
   now = (u64) ((vlib_time_now (vm) - silm->vlib_time_0) * 1e3);
   now += silm->milisecond_time_0;
@@ -675,7 +604,7 @@ snat_ipfix_logging_nat44_ses (u32 thread_index, u8 nat_event, u32 src_ip,
 
       if (vlib_buffer_alloc (vm, &bi0, 1) != 1)
        {
-         nat_log_err ("can't allocate buffer for NAT IPFIX event");
+         nat_elog_err ("can't allocate buffer for NAT IPFIX event");
          return;
        }
 
@@ -739,7 +668,7 @@ snat_ipfix_logging_nat44_ses (u32 thread_index, u8 nat_event, u32 src_ip,
       template_id = clib_atomic_fetch_or (
         &silm->nat44_session_template_id,
         0);
-      snat_ipfix_send (frm, f, b0, template_id);
+      snat_ipfix_send (thread_index, frm, f, b0, template_id);
       sitd->nat44_session_frame = 0;
       sitd->nat44_session_buffer = 0;
       offset = 0;
@@ -757,7 +686,7 @@ snat_ipfix_logging_addr_exhausted (u32 thread_index, u32 pool_id, int do_flush)
   vlib_buffer_t *b0 = 0;
   u32 bi0 = ~0;
   u32 offset;
-  vlib_main_t *vm = frm->vlib_main;
+  vlib_main_t *vm = vlib_mains[thread_index];
   u64 now;
   u8 nat_event = NAT_ADDRESSES_EXHAUTED;
   u16 template_id;
@@ -774,7 +703,7 @@ snat_ipfix_logging_addr_exhausted (u32 thread_index, u32 pool_id, int do_flush)
 
       if (vlib_buffer_alloc (vm, &bi0, 1) != 1)
        {
-         nat_log_err ("can't allocate buffer for NAT IPFIX event");
+         nat_elog_err ("can't allocate buffer for NAT IPFIX event");
          return;
        }
 
@@ -823,7 +752,7 @@ snat_ipfix_logging_addr_exhausted (u32 thread_index, u32 pool_id, int do_flush)
       template_id = clib_atomic_fetch_or (
           &silm->addr_exhausted_template_id,
           0);
-      snat_ipfix_send (frm, f, b0, template_id);
+      snat_ipfix_send (thread_index, frm, f, b0, template_id);
       sitd->addr_exhausted_frame = 0;
       sitd->addr_exhausted_buffer = 0;
       offset = 0;
@@ -842,7 +771,7 @@ snat_ipfix_logging_max_entries_per_usr (u32 thread_index,
   vlib_buffer_t *b0 = 0;
   u32 bi0 = ~0;
   u32 offset;
-  vlib_main_t *vm = frm->vlib_main;
+  vlib_main_t *vm = vlib_mains[thread_index];
   u64 now;
   u8 nat_event = QUOTA_EXCEEDED;
   u32 quota_event = MAX_ENTRIES_PER_USER;
@@ -860,7 +789,7 @@ snat_ipfix_logging_max_entries_per_usr (u32 thread_index,
 
       if (vlib_buffer_alloc (vm, &bi0, 1) != 1)
        {
-         nat_log_err ("can't allocate buffer for NAT IPFIX event");
+         nat_elog_err ("can't allocate buffer for NAT IPFIX event");
          return;
        }
 
@@ -915,7 +844,7 @@ snat_ipfix_logging_max_entries_per_usr (u32 thread_index,
       template_id = clib_atomic_fetch_or (
           &silm->max_entries_per_user_template_id,
           0);
-      snat_ipfix_send (frm, f, b0, template_id);
+      snat_ipfix_send (thread_index, frm, f, b0, template_id);
       sitd->max_entries_per_user_frame = 0;
       sitd->max_entries_per_user_buffer = 0;
       offset = 0;
@@ -933,7 +862,7 @@ nat_ipfix_logging_max_ses (u32 thread_index, u32 limit, int do_flush)
   vlib_buffer_t *b0 = 0;
   u32 bi0 = ~0;
   u32 offset;
-  vlib_main_t *vm = frm->vlib_main;
+  vlib_main_t *vm = vlib_mains[thread_index];
   u64 now;
   u8 nat_event = QUOTA_EXCEEDED;
   u32 quota_event = MAX_SESSION_ENTRIES;
@@ -951,7 +880,7 @@ nat_ipfix_logging_max_ses (u32 thread_index, u32 limit, int do_flush)
 
       if (vlib_buffer_alloc (vm, &bi0, 1) != 1)
        {
-         nat_log_err ("can't allocate buffer for NAT IPFIX event");
+         nat_elog_err ("can't allocate buffer for NAT IPFIX event");
          return;
        }
 
@@ -1003,7 +932,7 @@ nat_ipfix_logging_max_ses (u32 thread_index, u32 limit, int do_flush)
       template_id = clib_atomic_fetch_or (
         &silm->max_sessions_template_id,
         0);
-      snat_ipfix_send (frm, f, b0, template_id);
+      snat_ipfix_send (thread_index, frm, f, b0, template_id);
       sitd->max_sessions_frame = 0;
       sitd->max_sessions_buffer = 0;
       offset = 0;
@@ -1021,7 +950,7 @@ nat_ipfix_logging_max_bib (u32 thread_index, u32 limit, int do_flush)
   vlib_buffer_t *b0 = 0;
   u32 bi0 = ~0;
   u32 offset;
-  vlib_main_t *vm = frm->vlib_main;
+  vlib_main_t *vm = vlib_mains[thread_index];
   u64 now;
   u8 nat_event = QUOTA_EXCEEDED;
   u32 quota_event = MAX_BIB_ENTRIES;
@@ -1039,7 +968,7 @@ nat_ipfix_logging_max_bib (u32 thread_index, u32 limit, int do_flush)
 
       if (vlib_buffer_alloc (vm, &bi0, 1) != 1)
        {
-         nat_log_err ("can't allocate buffer for NAT IPFIX event");
+         nat_elog_err ("can't allocate buffer for NAT IPFIX event");
          return;
        }
 
@@ -1091,7 +1020,7 @@ nat_ipfix_logging_max_bib (u32 thread_index, u32 limit, int do_flush)
       template_id = clib_atomic_fetch_or (
         &silm->max_bibs_template_id,
         0);
-      snat_ipfix_send (frm, f, b0, template_id);
+      snat_ipfix_send (thread_index, frm, f, b0, template_id);
       sitd->max_bibs_frame = 0;
       sitd->max_bibs_buffer = 0;
       offset = 0;
@@ -1099,190 +1028,6 @@ nat_ipfix_logging_max_bib (u32 thread_index, u32 limit, int do_flush)
   sitd->max_bibs_next_record_offset = offset;
 }
 
-static void
-nat_ipfix_logging_max_frag_ip4 (u32 thread_index,
-                                u32 limit, u32 src, int do_flush)
-{
-  snat_ipfix_logging_main_t *silm = &snat_ipfix_logging_main;
-  snat_ipfix_per_thread_data_t *sitd = &silm->per_thread_data[thread_index];
-  flow_report_main_t *frm = &flow_report_main;
-  vlib_frame_t *f;
-  vlib_buffer_t *b0 = 0;
-  u32 bi0 = ~0;
-  u32 offset;
-  vlib_main_t *vm = frm->vlib_main;
-  u64 now;
-  u8 nat_event = QUOTA_EXCEEDED;
-  u32 quota_event = MAX_FRAGMENTS_PENDING_REASSEMBLY;
-  u16 template_id;
-
-  now = (u64) ((vlib_time_now (vm) - silm->vlib_time_0) * 1e3);
-  now += silm->milisecond_time_0;
-
-  b0 = sitd->max_frags_ip4_buffer;
-
-  if (PREDICT_FALSE (b0 == 0))
-    {
-      if (do_flush)
-       return;
-
-      if (vlib_buffer_alloc (vm, &bi0, 1) != 1)
-       {
-         nat_log_err ("can't allocate buffer for NAT IPFIX event");
-         return;
-       }
-
-      b0 = sitd->max_frags_ip4_buffer = vlib_get_buffer (vm, bi0);
-      VLIB_BUFFER_TRACE_TRAJECTORY_INIT (b0);
-      offset = 0;
-    }
-  else
-    {
-      bi0 = vlib_get_buffer_index (vm, b0);
-      offset = sitd->max_frags_ip4_next_record_offset;
-    }
-
-  f = sitd->max_frags_ip4_frame;
-  if (PREDICT_FALSE (f == 0))
-    {
-      u32 *to_next;
-      f = vlib_get_frame_to_node (vm, ip4_lookup_node.index);
-      sitd->max_frags_ip4_frame = f;
-      to_next = vlib_frame_vector_args (f);
-      to_next[0] = bi0;
-      f->n_vectors = 1;
-    }
-
-  if (PREDICT_FALSE (offset == 0))
-    snat_ipfix_header_create (frm, b0, &offset);
-
-  if (PREDICT_TRUE (do_flush == 0))
-    {
-      u64 time_stamp = clib_host_to_net_u64 (now);
-      clib_memcpy_fast (b0->data + offset, &time_stamp, sizeof (time_stamp));
-      offset += sizeof (time_stamp);
-
-      clib_memcpy_fast (b0->data + offset, &nat_event, sizeof (nat_event));
-      offset += sizeof (nat_event);
-
-      clib_memcpy_fast (b0->data + offset, &quota_event, sizeof (quota_event));
-      offset += sizeof (quota_event);
-
-      clib_memcpy_fast (b0->data + offset, &limit, sizeof (limit));
-      offset += sizeof (limit);
-
-      clib_memcpy_fast (b0->data + offset, &src, sizeof (src));
-      offset += sizeof (src);
-
-      b0->current_length += MAX_FRAGMENTS_IP4_LEN;
-    }
-
-  if (PREDICT_FALSE
-      (do_flush || (offset + MAX_BIBS_LEN) > frm->path_mtu))
-    {
-      template_id = clib_atomic_fetch_or (
-        &silm->max_frags_ip4_template_id,
-        0);
-      snat_ipfix_send (frm, f, b0, template_id);
-      sitd->max_frags_ip4_frame = 0;
-      sitd->max_frags_ip4_buffer = 0;
-      offset = 0;
-    }
-  sitd->max_frags_ip4_next_record_offset = offset;
-}
-
-static void
-nat_ipfix_logging_max_frag_ip6 (u32 thread_index,
-                                u32 limit, ip6_address_t * src, int do_flush)
-{
-  snat_ipfix_logging_main_t *silm = &snat_ipfix_logging_main;
-  snat_ipfix_per_thread_data_t *sitd = &silm->per_thread_data[thread_index];
-  flow_report_main_t *frm = &flow_report_main;
-  vlib_frame_t *f;
-  vlib_buffer_t *b0 = 0;
-  u32 bi0 = ~0;
-  u32 offset;
-  vlib_main_t *vm = frm->vlib_main;
-  u64 now;
-  u8 nat_event = QUOTA_EXCEEDED;
-  u32 quota_event = MAX_FRAGMENTS_PENDING_REASSEMBLY;
-  u16 template_id;
-
-  now = (u64) ((vlib_time_now (vm) - silm->vlib_time_0) * 1e3);
-  now += silm->milisecond_time_0;
-
-  b0 = sitd->max_frags_ip6_buffer;
-
-  if (PREDICT_FALSE (b0 == 0))
-    {
-      if (do_flush)
-       return;
-
-      if (vlib_buffer_alloc (vm, &bi0, 1) != 1)
-       {
-         nat_log_err ("can't allocate buffer for NAT IPFIX event");
-         return;
-       }
-
-      b0 = sitd->max_frags_ip6_buffer = vlib_get_buffer (vm, bi0);
-      VLIB_BUFFER_TRACE_TRAJECTORY_INIT (b0);
-      offset = 0;
-    }
-  else
-    {
-      bi0 = vlib_get_buffer_index (vm, b0);
-      offset = sitd->max_frags_ip6_next_record_offset;
-    }
-
-  f = sitd->max_frags_ip6_frame;
-  if (PREDICT_FALSE (f == 0))
-    {
-      u32 *to_next;
-      f = vlib_get_frame_to_node (vm, ip4_lookup_node.index);
-      sitd->max_frags_ip6_frame = f;
-      to_next = vlib_frame_vector_args (f);
-      to_next[0] = bi0;
-      f->n_vectors = 1;
-    }
-
-  if (PREDICT_FALSE (offset == 0))
-    snat_ipfix_header_create (frm, b0, &offset);
-
-  if (PREDICT_TRUE (do_flush == 0))
-    {
-      u64 time_stamp = clib_host_to_net_u64 (now);
-      clib_memcpy_fast (b0->data + offset, &time_stamp, sizeof (time_stamp));
-      offset += sizeof (time_stamp);
-
-      clib_memcpy_fast (b0->data + offset, &nat_event, sizeof (nat_event));
-      offset += sizeof (nat_event);
-
-      clib_memcpy_fast (b0->data + offset, &quota_event, sizeof (quota_event));
-      offset += sizeof (quota_event);
-
-      clib_memcpy_fast (b0->data + offset, &limit, sizeof (limit));
-      offset += sizeof (limit);
-
-      clib_memcpy_fast (b0->data + offset, src, sizeof (ip6_address_t));
-      offset += sizeof (ip6_address_t);
-
-      b0->current_length += MAX_FRAGMENTS_IP6_LEN;
-    }
-
-  if (PREDICT_FALSE
-      (do_flush || (offset + MAX_BIBS_LEN) > frm->path_mtu))
-    {
-      template_id = clib_atomic_fetch_or (
-        &silm->max_frags_ip6_template_id,
-        0);
-      snat_ipfix_send (frm, f, b0, template_id);
-      sitd->max_frags_ip6_frame = 0;
-      sitd->max_frags_ip6_buffer = 0;
-      offset = 0;
-    }
-  sitd->max_frags_ip6_next_record_offset = offset;
-}
-
 static void
 nat_ipfix_logging_nat64_bibe (u32 thread_index, u8 nat_event,
                               ip6_address_t * src_ip, u32 nat_src_ip,
@@ -1296,7 +1041,7 @@ nat_ipfix_logging_nat64_bibe (u32 thread_index, u8 nat_event,
   vlib_buffer_t *b0 = 0;
   u32 bi0 = ~0;
   u32 offset;
-  vlib_main_t *vm = frm->vlib_main;
+  vlib_main_t *vm = vlib_mains[thread_index];
   u64 now;
   u16 template_id;
 
@@ -1312,7 +1057,7 @@ nat_ipfix_logging_nat64_bibe (u32 thread_index, u8 nat_event,
 
       if (vlib_buffer_alloc (vm, &bi0, 1) != 1)
        {
-         nat_log_err ("can't allocate buffer for NAT IPFIX event");
+         nat_elog_err ("can't allocate buffer for NAT IPFIX event");
          return;
        }
 
@@ -1376,7 +1121,7 @@ nat_ipfix_logging_nat64_bibe (u32 thread_index, u8 nat_event,
       template_id = clib_atomic_fetch_or (
         &silm->nat64_bib_template_id,
         0);
-      snat_ipfix_send (frm, f, b0, template_id);
+      snat_ipfix_send (thread_index, frm, f, b0, template_id);
       sitd->nat64_bib_frame = 0;
       sitd->nat64_bib_buffer = 0;
       offset = 0;
@@ -1399,7 +1144,7 @@ nat_ipfix_logging_nat64_ses (u32 thread_index, u8 nat_event,
   vlib_buffer_t *b0 = 0;
   u32 bi0 = ~0;
   u32 offset;
-  vlib_main_t *vm = frm->vlib_main;
+  vlib_main_t *vm = vlib_mains[thread_index];
   u64 now;
   u16 template_id;
 
@@ -1415,7 +1160,7 @@ nat_ipfix_logging_nat64_ses (u32 thread_index, u8 nat_event,
 
       if (vlib_buffer_alloc (vm, &bi0, 1) != 1)
        {
-         nat_log_err ("can't allocate buffer for NAT IPFIX event");
+         nat_elog_err ("can't allocate buffer for NAT IPFIX event");
          return;
        }
 
@@ -1491,7 +1236,7 @@ nat_ipfix_logging_nat64_ses (u32 thread_index, u8 nat_event,
       template_id = clib_atomic_fetch_or (
         &silm->nat64_ses_template_id,
         0);
-      snat_ipfix_send (frm, f, b0, template_id);
+      snat_ipfix_send (thread_index, frm, f, b0, template_id);
       sitd->nat64_ses_frame = 0;
       sitd->nat64_ses_buffer = 0;
       offset = 0;
@@ -1510,8 +1255,6 @@ snat_ipfix_flush (u32 thread_index)
   snat_ipfix_logging_max_entries_per_usr (thread_index, 0, 0, do_flush);
   nat_ipfix_logging_max_ses (thread_index, 0, do_flush);
   nat_ipfix_logging_max_bib (thread_index, 0, do_flush);
-  nat_ipfix_logging_max_frag_ip4 (thread_index, 0, 0, do_flush);
-  nat_ipfix_logging_max_frag_ip6 (thread_index, 0, 0, do_flush);
   nat_ipfix_logging_nat64_bibe (thread_index,
                                 0, 0, 0, 0, 0, 0, 0, do_flush);
   nat_ipfix_logging_nat64_ses (thread_index,
@@ -1539,7 +1282,7 @@ snat_ipfix_flush_from_main (void)
     }
 
   /* Trigger flush for each worker thread */
-  for (i = 1; i < vec_len (silm->worker_vms); i++)
+  for (i = 0; i < vec_len (silm->worker_vms); i++)
     {
       worker_vm = silm->worker_vms[i];
       if (worker_vm)
@@ -1557,7 +1300,7 @@ snat_ipfix_flush_from_main (void)
  * @param thread_index thread index
  * @param src_ip       source IPv4 address
  * @param nat_src_ip   transaltes source IPv4 address
- * @param snat_proto   NAT transport protocol
+ * @param nat_proto   NAT transport protocol
  * @param src_port     source port
  * @param nat_src_port translated source port
  * @param vrf_id       VRF ID
@@ -1566,14 +1309,14 @@ void
 snat_ipfix_logging_nat44_ses_create (u32 thread_index,
                                      u32 src_ip,
                                     u32 nat_src_ip,
-                                    snat_protocol_t snat_proto,
+                                    nat_protocol_t nat_proto,
                                     u16 src_port,
                                     u16 nat_src_port, u32 vrf_id)
 {
   skip_if_disabled ();
 
   snat_ipfix_logging_nat44_ses (thread_index, NAT44_SESSION_CREATE, src_ip,
-                                nat_src_ip, snat_proto, src_port, nat_src_port,
+                                nat_src_ip, nat_proto, src_port, nat_src_port,
                                vrf_id, 0);
 }
 
@@ -1583,7 +1326,7 @@ snat_ipfix_logging_nat44_ses_create (u32 thread_index,
  * @param thread_index thread index
  * @param src_ip       source IPv4 address
  * @param nat_src_ip   transaltes source IPv4 address
- * @param snat_proto   NAT transport protocol
+ * @param nat_proto   NAT transport protocol
  * @param src_port     source port
  * @param nat_src_port translated source port
  * @param vrf_id       VRF ID
@@ -1592,14 +1335,14 @@ void
 snat_ipfix_logging_nat44_ses_delete (u32 thread_index,
                                      u32 src_ip,
                                     u32 nat_src_ip,
-                                    snat_protocol_t snat_proto,
+                                    nat_protocol_t nat_proto,
                                     u16 src_port,
                                     u16 nat_src_port, u32 vrf_id)
 {
   skip_if_disabled ();
 
   snat_ipfix_logging_nat44_ses (thread_index, NAT44_SESSION_DELETE, src_ip,
-                                nat_src_ip, snat_proto, src_port, nat_src_port,
+                                nat_src_ip, nat_proto, src_port, nat_src_port,
                                vrf_id, 0);
 }
 
@@ -1676,40 +1419,6 @@ nat_ipfix_logging_max_bibs (u32 thread_index, u32 limit)
   nat_ipfix_logging_max_bib (thread_index, limit, 0);
 }
 
-/**
- * @brief Generate maximum IPv4 fragments pending reassembly exceeded event
- *
- * @param thread_index thread index
- * @param limit configured limit
- * @param src source IPv4 address
- */
-void
-nat_ipfix_logging_max_fragments_ip4 (u32 thread_index,
-                                     u32 limit, ip4_address_t * src)
-{
-  //TODO: This event SHOULD be rate limited
-  skip_if_disabled ();
-
-  nat_ipfix_logging_max_frag_ip4 (thread_index, limit, src->as_u32, 0);
-}
-
-/**
- * @brief Generate maximum IPv6 fragments pending reassembly exceeded event
- *
- * @param thread_index thread index
- * @param limit configured limit
- * @param src source IPv6 address
- */
-void
-nat_ipfix_logging_max_fragments_ip6 (u32 thread_index,
-                                     u32 limit, ip6_address_t * src)
-{
-  //TODO: This event SHOULD be rate limited
-  skip_if_disabled ();
-
-  nat_ipfix_logging_max_frag_ip6 (thread_index, limit, src, 0);
-}
-
 /**
  * @brief Generate NAT64 BIB create and delete events
  *
@@ -1819,101 +1528,78 @@ snat_ipfix_logging_enable_disable (int enable, u32 domain_id, u16 src_port)
   a.src_port = src_port ? src_port : UDP_DST_PORT_ipfix;
   a.flow_data_callback = data_callback;
 
-  if (sm->deterministic)
+  /* TODO: ipfix needs to be separated from NAT base plugin
+  a.rewrite_callback = snat_template_rewrite_max_entries_per_usr;
+  rv = vnet_flow_report_add_del (frm, &a, NULL);
+  if (rv)
     {
-      a.rewrite_callback = snat_template_rewrite_max_entries_per_usr;
-
-      rv = vnet_flow_report_add_del (frm, &a, NULL);
-      if (rv)
-       {
-         nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-         return -1;
-       }
+      nat_elog_warn_X1 ("vnet_flow_report_add_del returned %d", "i4", rv);
+      return -1;
     }
-  else
-    {
-      a.rewrite_callback = snat_template_rewrite_nat44_session;
-
-      rv = vnet_flow_report_add_del (frm, &a, NULL);
-      if (rv)
-       {
-         nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-         return -1;
-       }
-
-      a.rewrite_callback = snat_template_rewrite_addr_exhausted;
+  */
+  a.rewrite_callback = snat_template_rewrite_nat44_session;
 
-      rv = vnet_flow_report_add_del (frm, &a, NULL);
-      if (rv)
-       {
-         nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-         return -1;
-       }
+  rv = vnet_flow_report_add_del (frm, &a, NULL);
+  if (rv)
+    {
+      nat_elog_warn_X1 ("vnet_flow_report_add_del returned %d", "i4", rv);
+      return -1;
+    }
 
-      a.rewrite_callback = nat_template_rewrite_max_sessions;
+  a.rewrite_callback = snat_template_rewrite_addr_exhausted;
 
-      rv = vnet_flow_report_add_del (frm, &a, NULL);
-      if (rv)
-       {
-         nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-         return -1;
-       }
+  rv = vnet_flow_report_add_del (frm, &a, NULL);
+  if (rv)
+    {
+      nat_elog_warn_X1 ("vnet_flow_report_add_del returned %d", "i4", rv);
+      return -1;
+    }
 
-      a.rewrite_callback = nat_template_rewrite_max_bibs;
+  a.rewrite_callback = nat_template_rewrite_max_sessions;
 
-      rv = vnet_flow_report_add_del (frm, &a, NULL);
-      if (rv)
-       {
-         nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-         return -1;
-       }
+  rv = vnet_flow_report_add_del (frm, &a, NULL);
+  if (rv)
+    {
+      nat_elog_warn_X1 ("vnet_flow_report_add_del returned %d", "i4", rv);
+      return -1;
+    }
 
-      a.rewrite_callback = nat_template_rewrite_max_frags_ip4;
+  a.rewrite_callback = nat_template_rewrite_max_bibs;
 
-      rv = vnet_flow_report_add_del (frm, &a, NULL);
-      if (rv)
-       {
-         nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-         return -1;
-       }
+  rv = vnet_flow_report_add_del (frm, &a, NULL);
+  if (rv)
+    {
+      nat_elog_warn_X1 ("vnet_flow_report_add_del returned %d", "i4", rv);
+      return -1;
+    }
 
-      a.rewrite_callback = nat_template_rewrite_max_frags_ip6;
+  a.rewrite_callback = nat_template_rewrite_nat64_bib;
 
-      rv = vnet_flow_report_add_del (frm, &a, NULL);
-      if (rv)
-       {
-         nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-         return -1;
-       }
+  rv = vnet_flow_report_add_del (frm, &a, NULL);
+  if (rv)
+    {
+      nat_elog_warn_X1 ("vnet_flow_report_add_del returned %d", "i4", rv);
+      return -1;
+    }
 
-      a.rewrite_callback = nat_template_rewrite_nat64_bib;
+  a.rewrite_callback = nat_template_rewrite_nat64_session;
 
-      rv = vnet_flow_report_add_del (frm, &a, NULL);
-      if (rv)
-       {
-         nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-         return -1;
-       }
+  rv = vnet_flow_report_add_del (frm, &a, NULL);
+  if (rv)
+    {
+      nat_elog_warn_X1 ("vnet_flow_report_add_del returned %d", "i4", rv);
+      return -1;
+    }
 
-      a.rewrite_callback = nat_template_rewrite_nat64_session;
+  if (sm->endpoint_dependent)
+    {
+      a.rewrite_callback = snat_template_rewrite_max_entries_per_usr;
 
       rv = vnet_flow_report_add_del (frm, &a, NULL);
       if (rv)
-       {
-         nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-         return -1;
-       }
-
-      if (sm->endpoint_dependent)
         {
-          a.rewrite_callback = snat_template_rewrite_max_entries_per_usr;
-
-          rv = vnet_flow_report_add_del (frm, &a, NULL);
-          if (rv)
-            {
-              nat_log_warn ("vnet_flow_report_add_del returned %d", rv);
-              return -1;
-            }
+          nat_elog_warn_X1 ("vnet_flow_report_add_del returned %d", "i4", rv);
+          return -1;
         }
     }