Use thread local storage for thread index

[vpp.git] / src / vnet / udp / udp_input.c

diff --git a/src/vnet/udp/udp_input.c b/src/vnet/udp/udp_input.c
index 4d50933..810278e 100644 (file)
--- a/src/vnet/udp/udp_input.c
+++ b/src/vnet/udp/udp_input.c
@@ -70,7 +70,7 @@ udp4_uri_input_node_fn (vlib_main_t * vm,
   udp4_uri_input_next_t next_index;
   udp_uri_main_t *um = vnet_get_udp_main ();
   session_manager_main_t *smm = vnet_get_session_manager_main ();
-  u32 my_thread_index = vm->cpu_index;
+  u32 my_thread_index = vm->thread_index;
   u8 my_enqueue_epoch;
   u32 *session_indices_to_enqueue;
   static u32 serial_number;
@@ -251,37 +251,46 @@ udp4_uri_input_node_fn (vlib_main_t * vm,
          continue;
        }
 
-      /* Fabricate event */
-      evt.fifo = s0->server_rx_fifo;
-      evt.event_type = FIFO_EVENT_SERVER_RX;
-      evt.event_id = serial_number++;
-      evt.enqueue_length = svm_fifo_max_dequeue (s0->server_rx_fifo);
+      if (svm_fifo_set_event (s0->server_rx_fifo))
+       {
+         /* Fabricate event */
+         evt.fifo = s0->server_rx_fifo;
+         evt.event_type = FIFO_EVENT_SERVER_RX;
+         evt.event_id = serial_number++;
 
-      /* Add event to server's event queue */
-      q = server0->event_queue;
+         /* Add event to server's event queue */
+         q = server0->event_queue;
 
-      /* Don't block for lack of space */
-      if (PREDICT_TRUE (q->cursize < q->maxsize))
-       unix_shared_memory_queue_add (server0->event_queue, (u8 *) & evt,
-                                     0 /* do wait for mutex */ );
-      else
-       {
-         vlib_node_increment_counter (vm, udp4_uri_input_node.index,
-                                      SESSION_ERROR_FIFO_FULL, 1);
+         /* Don't block for lack of space */
+         if (PREDICT_TRUE (q->cursize < q->maxsize))
+           {
+             unix_shared_memory_queue_add (server0->event_queue,
+                                           (u8 *) & evt,
+                                           0 /* do wait for mutex */ );
+           }
+         else
+           {
+             vlib_node_increment_counter (vm, udp4_uri_input_node.index,
+                                          SESSION_ERROR_FIFO_FULL, 1);
+           }
        }
+      /* *INDENT-OFF* */
       if (1)
        {
          ELOG_TYPE_DECLARE (e) =
          {
-         .format = "evt-enqueue: id %d length %d",.format_args = "i4i4",};
+             .format = "evt-enqueue: id %d length %d",
+             .format_args = "i4i4",};
          struct
          {
            u32 data[2];
          } *ed;
          ed = ELOG_DATA (&vlib_global_main.elog_main, e);
          ed->data[0] = evt.event_id;
-         ed->data[1] = evt.enqueue_length;
+         ed->data[1] = svm_fifo_max_dequeue (s0->server_rx_fifo);
        }
+      /* *INDENT-ON* */
+
     }
 
   vec_reset_length (session_indices_to_enqueue);