vppinfra: add atomic macros for __sync builtins

[vpp.git] / src / plugins / ioam / analyse / ip6 / node.c

diff --git a/src/plugins/ioam/analyse/ip6/node.c b/src/plugins/ioam/analyse/ip6/node.c
index 902fb9b..7a8d71d 100644 (file)
--- a/src/plugins/ioam/analyse/ip6/node.c
+++ b/src/plugins/ioam/analyse/ip6/node.c
@@ -256,17 +256,17 @@ ip6_ioam_analyse_node_fn (vlib_main_t * vm, vlib_node_runtime_t * node,
                  data0 = ioam_analyse_get_data_from_flow_id (flow_id0);
                  data1 = ioam_analyse_get_data_from_flow_id (flow_id1);
 
-                 while (__sync_lock_test_and_set (data0->writer_lock, 1))
+                 while (clib_atomic_test_and_set (data0->writer_lock))
                    ;
                  data0->pkt_counter++;
                  data0->bytes_counter += p_len0;
-                 *(data0->writer_lock) = 0;
+                 clib_atomic_release (data0->writer_lock);
 
-                 while (__sync_lock_test_and_set (data1->writer_lock, 1))
+                 while (clib_atomic_test_and_set (data1->writer_lock))
                    ;
                  data1->pkt_counter++;
                  data1->bytes_counter += p_len1;
-                 *(data1->writer_lock) = 0;
+                 clib_atomic_release (data1->writer_lock);
                }
              else if (error0 == 0)
                {
@@ -274,11 +274,11 @@ ip6_ioam_analyse_node_fn (vlib_main_t * vm, vlib_node_runtime_t * node,
                  pkts_failed++;
 
                  data0 = ioam_analyse_get_data_from_flow_id (flow_id0);
-                 while (__sync_lock_test_and_set (data0->writer_lock, 1))
+                 while (clib_atomic_test_and_set (data0->writer_lock))
                    ;
                  data0->pkt_counter++;
                  data0->bytes_counter += p_len0;
-                 *(data0->writer_lock) = 0;
+                 clib_atomic_release (data0->writer_lock);
                }
              else if (error1 == 0)
                {
@@ -286,11 +286,11 @@ ip6_ioam_analyse_node_fn (vlib_main_t * vm, vlib_node_runtime_t * node,
                  pkts_failed++;
 
                  data1 = ioam_analyse_get_data_from_flow_id (flow_id1);
-                 while (__sync_lock_test_and_set (data1->writer_lock, 1))
+                 while (clib_atomic_test_and_set (data1->writer_lock))
                    ;
                  data1->pkt_counter++;
                  data1->bytes_counter += p_len1;
-                 *(data1->writer_lock) = 0;
+                 clib_atomic_release (data1->writer_lock);
                }
              else
                pkts_failed += 2;
@@ -327,12 +327,12 @@ ip6_ioam_analyse_node_fn (vlib_main_t * vm, vlib_node_runtime_t * node,
                {
                  pkts_analysed++;
                  data0 = ioam_analyse_get_data_from_flow_id (flow_id0);
-                 while (__sync_lock_test_and_set (data0->writer_lock, 1))
+                 while (clib_atomic_test_and_set (data0->writer_lock))
                    ;
                  data0->pkt_counter++;
                  data0->bytes_counter +=
                    clib_net_to_host_u16 (ip60->payload_length);
-                 *(data0->writer_lock) = 0;
+                 clib_atomic_release (data0->writer_lock);
                }
              else
                pkts_failed++;
@@ -393,13 +393,13 @@ ip6_ioam_analyse_hbh_pot (u32 flow_id, ip6_hop_by_hop_option_t * opt0,
   pot_profile = pot_profile_get_active ();
   ret = pot_validate (pot_profile, cumulative, random);
 
-  while (__sync_lock_test_and_set (data->writer_lock, 1))
+  while (clib_atomic_test_and_set (data->writer_lock))
     ;
 
   (0 == ret) ? (data->pot_data.sfc_validated_count++) :
     (data->pot_data.sfc_invalidated_count++);
 
-  *(data->writer_lock) = 0;
+  clib_atomic_release (data->writer_lock);
   return 0;
 }