Code Review / vpp.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
libmemif: zero-copy-slave mode + header space
[vpp.git] / extras / libmemif / examples / icmp_responder-epoll / main.c
diff --git a/extras/libmemif/examples/icmp_responder-epoll/main.c b/extras/libmemif/examples/icmp_responder-epoll/main.c
index 80a7f7e..fd354a3 100644 (file)
--- a/extras/libmemif/examples/icmp_responder-epoll/main.c
+++ b/extras/libmemif/examples/icmp_responder-epoll/main.c
@@ -47,6 +47,10 @@
 
 #include <time.h>
 
+#ifndef TIME_UTC
+#define TIME_UTC 1
+#endif
+
 #include <libmemif.h>
 #include <icmp_proto.h>
 
@@ -185,6 +189,10 @@ print_memif_details ()
        {
          printf ("\t\tqueue id: %u\n", md.rx_queues[e].qid);
          printf ("\t\tring size: %u\n", md.rx_queues[e].ring_size);
+         printf ("\t\tring rx mode: %s\n",
+                 md.rx_queues[e].flags ? "polling" : "interrupt");
+         printf ("\t\tring head: %u\n", md.rx_queues[e].head);
+         printf ("\t\tring tail: %u\n", md.rx_queues[e].tail);
          printf ("\t\tbuffer size: %u\n", md.rx_queues[e].buffer_size);
        }
       printf ("\ttx queues:\n");
@@ -192,6 +200,10 @@ print_memif_details ()
        {
          printf ("\t\tqueue id: %u\n", md.tx_queues[e].qid);
          printf ("\t\tring size: %u\n", md.tx_queues[e].ring_size);
+         printf ("\t\tring rx mode: %s\n",
+                 md.tx_queues[e].flags ? "polling" : "interrupt");
+         printf ("\t\tring head: %u\n", md.tx_queues[e].head);
+         printf ("\t\tring tail: %u\n", md.tx_queues[e].tail);
          printf ("\t\tbuffer size: %u\n", md.tx_queues[e].buffer_size);
        }
       printf ("\tlink: ");
@@ -270,6 +282,7 @@ int
 on_connect (memif_conn_handle_t conn, void *private_ctx)
 {
   INFO ("memif connected!");
+  memif_refill_queue (conn, 0, -1, 0);
   enable_log = 1;
   return 0;
 }
@@ -311,7 +324,7 @@ icmpr_buffer_alloc (long index, long n, uint16_t * r, uint16_t i,
   memif_connection_t *c = &memif_connection[index];
   int err;
   /* set data pointer to shared memory and set buffer_len to shared mmeory buffer len */
-  err = memif_buffer_alloc (c->conn, qid, c->tx_bufs + i, n, r, 0);
+  err = memif_buffer_alloc (c->conn, qid, c->tx_bufs + i, n, r, 128);
   if ((err != MEMIF_ERR_SUCCESS) && (err != MEMIF_ERR_NOBUF_RING))
     {
       INFO ("memif_buffer_alloc: %s", memif_strerror (err));
@@ -353,10 +366,10 @@ on_interrupt (memif_conn_handle_t conn, void *private_ctx, uint16_t qid)
     }
 
   int err = MEMIF_ERR_SUCCESS, ret_val;
-  uint16_t rx, tx;
-  uint16_t fb;
-  int i;                       /* rx buffer iterator */
-  int j;                       /* tx bufferiterator */
+  uint16_t rx = 0, tx = 0;
+  uint16_t fb = 0;
+  int i = 0;                   /* rx buffer iterator */
+  int j = 0;                   /* tx bufferiterator */
 
   /* loop while there are packets in shm */
   do
@@ -372,54 +385,35 @@ on_interrupt (memif_conn_handle_t conn, void *private_ctx, uint16_t qid)
        }
 
       i = 0;
-
-      /* try to alloc required number of buffers buffers */
-      err = memif_buffer_alloc (c->conn, qid, c->tx_bufs, rx, &tx, 0);
+      memset (c->tx_bufs, 0, sizeof (memif_buffer_t) * rx);
+      err = memif_buffer_alloc (c->conn, qid, c->tx_bufs, rx, &tx, 128);
       if ((err != MEMIF_ERR_SUCCESS) && (err != MEMIF_ERR_NOBUF_RING))
        {
          INFO ("memif_buffer_alloc: %s", memif_strerror (err));
          goto error;
        }
       j = 0;
-      c->tx_err_counter = rx - tx;
+      c->tx_err_counter += rx - tx;
 
-      /* process bufers */
       while (tx)
        {
-         while (tx > 2)
-           {
-             resolve_packet ((void *) (c->rx_bufs + i)->data,
-                             (c->rx_bufs + i)->data_len,
-                             (void *) (c->tx_bufs + j)->data,
-                             &(c->tx_bufs + j)->data_len, c->ip_addr);
-             resolve_packet ((void *) (c->rx_bufs + i + 1)->data,
-                             (c->rx_bufs + i + 1)->data_len,
-                             (void *) (c->tx_bufs + j + 1)->data,
-                             &(c->tx_bufs + j + 1)->data_len, c->ip_addr);
-
-             i += 2;
-             j += 2;
-             tx -= 2;
-           }
          resolve_packet ((void *) (c->rx_bufs + i)->data,
-                         (c->rx_bufs + i)->data_len,
+                         (c->rx_bufs + i)->len,
                          (void *) (c->tx_bufs + j)->data,
-                         &(c->tx_bufs + j)->data_len, c->ip_addr);
+                         &(c->tx_bufs + j)->len, c->ip_addr);
          i++;
          j++;
          tx--;
        }
-      /* mark memif buffers and shared memory buffers as free */
-      /* free processed buffers */
-      err = memif_buffer_free (c->conn, qid, c->rx_bufs, rx, &fb);
+
+      err = memif_refill_queue (c->conn, qid, rx, 0);
       if (err != MEMIF_ERR_SUCCESS)
        INFO ("memif_buffer_free: %s", memif_strerror (err));
-      rx -= fb;
+      rx -= rx;
 
       DBG ("freed %d buffers. %u/%u alloc/free buffers",
-          fb, rx, MAX_MEMIF_BUFS - rx);
+          rx, rx, MAX_MEMIF_BUFS - rx);
 
-      /* transmit allocated buffers */
       err = memif_tx_burst (c->conn, qid, c->tx_bufs, j, &tx);
       if (err != MEMIF_ERR_SUCCESS)
        {
@@ -434,10 +428,10 @@ on_interrupt (memif_conn_handle_t conn, void *private_ctx, uint16_t qid)
   return 0;
 
 error:
-  err = memif_buffer_free (c->conn, qid, c->rx_bufs, rx, &fb);
+  err = memif_refill_queue (c->conn, qid, rx, 0);
   if (err != MEMIF_ERR_SUCCESS)
     INFO ("memif_buffer_free: %s", memif_strerror (err));
-  c->rx_buf_num -= fb;
+  c->rx_buf_num -= rx;
   DBG ("freed %d buffers. %u/%u alloc/free buffers",
        fb, c->rx_buf_num, MAX_MEMIF_BUFS - c->rx_buf_num);
   return 0;
@@ -458,7 +452,7 @@ on_interrupt0 (memif_conn_handle_t conn, void *private_ctx, uint16_t qid)
     }
 
   int err = MEMIF_ERR_SUCCESS, ret_val;
-  uint16_t rx, tx;
+  uint16_t rx = 0, tx = 0;
   uint16_t fb;
   int i;                       /* rx buffer iterator */
   int j;                       /* tx bufferiterator */
@@ -484,7 +478,7 @@ on_interrupt0 (memif_conn_handle_t conn, void *private_ctx, uint16_t qid)
        {
 
          /* try to alloc required number of buffers buffers */
-         err = memif_buffer_alloc (c->conn, qid, c->tx_bufs, rx, &tx, 0);
+         err = memif_buffer_alloc (c->conn, qid, c->tx_bufs, rx, &tx, 128);
          if ((err != MEMIF_ERR_SUCCESS) && (err != MEMIF_ERR_NOBUF_RING))
            {
              INFO ("memif_buffer_alloc: %s", memif_strerror (err));
@@ -498,33 +492,32 @@ on_interrupt0 (memif_conn_handle_t conn, void *private_ctx, uint16_t qid)
              while (tx > 2)
                {
                  resolve_packet ((void *) (c->rx_bufs + i)->data,
-                                 (c->rx_bufs + i)->data_len,
+                                 (c->rx_bufs + i)->len,
                                  (void *) (c->tx_bufs + j)->data,
-                                 &(c->tx_bufs + j)->data_len, c->ip_addr);
+                                 &(c->tx_bufs + j)->len, c->ip_addr);
                  resolve_packet ((void *) (c->rx_bufs + i + 1)->data,
-                                 (c->rx_bufs + i + 1)->data_len,
+                                 (c->rx_bufs + i + 1)->len,
                                  (void *) (c->tx_bufs + j + 1)->data,
-                                 &(c->tx_bufs + j + 1)->data_len,
-                                 c->ip_addr);
+                                 &(c->tx_bufs + j + 1)->len, c->ip_addr);
 
                  i += 2;
                  j += 2;
                  tx -= 2;
                }
              resolve_packet ((void *) (c->rx_bufs + i)->data,
-                             (c->rx_bufs + i)->data_len,
+                             (c->rx_bufs + i)->len,
                              (void *) (c->tx_bufs + j)->data,
-                             &(c->tx_bufs + j)->data_len, c->ip_addr);
+                             &(c->tx_bufs + j)->len, c->ip_addr);
              i++;
              j++;
              tx--;
            }
          /* mark memif buffers and shared memory buffers as free */
          /* free processed buffers */
-         err = memif_buffer_free (c->conn, qid, c->rx_bufs + prev_i, j, &fb);
+         err = memif_refill_queue (c->conn, qid, j, 0);
          if (err != MEMIF_ERR_SUCCESS)
            INFO ("memif_buffer_free: %s", memif_strerror (err));
-         rx -= fb;
+         rx -= j;
          prev_i = i;
 
          DBG ("freed %d buffers. %u/%u alloc/free buffers",
@@ -547,10 +540,10 @@ on_interrupt0 (memif_conn_handle_t conn, void *private_ctx, uint16_t qid)
   return 0;
 
 error:
-  err = memif_buffer_free (c->conn, qid, c->rx_bufs, rx, &fb);
+  err = memif_refill_queue (c->conn, qid, rx, 0);
   if (err != MEMIF_ERR_SUCCESS)
     INFO ("memif_buffer_free: %s", memif_strerror (err));
-  c->rx_buf_num -= fb;
+  c->rx_buf_num -= rx;
   DBG ("freed %d buffers. %u/%u alloc/free buffers",
        fb, c->rx_buf_num, MAX_MEMIF_BUFS - c->rx_buf_num);
   return 0;
@@ -597,17 +590,17 @@ on_interrupt1 (memif_conn_handle_t conn, void *private_ctx, uint16_t qid)
              if (icmpr_buffer_alloc (c->index, 1, &tx, i, qid) < 0)
                break;
              resolve_packet ((void *) (c->rx_bufs + i)->data,
-                             (c->rx_bufs + i)->data_len,
+                             (c->rx_bufs + i)->len,
                              (void *) (c->tx_bufs + i)->data,
-                             &(c->tx_bufs + i)->data_len, c->ip_addr);
+                             &(c->tx_bufs + i)->len, c->ip_addr);
              icmpr_tx_burst (c->index, qid);
            }
        }
 
-      err = memif_buffer_free (c->conn, qid, c->rx_bufs, rx, &fb);
+      err = memif_refill_queue (c->conn, qid, rx, 0);
       if (err != MEMIF_ERR_SUCCESS)
        INFO ("memif_buffer_free: %s", memif_strerror (err));
-      c->rx_buf_num -= fb;
+      c->rx_buf_num -= rx;
 
 
     }
@@ -616,10 +609,10 @@ on_interrupt1 (memif_conn_handle_t conn, void *private_ctx, uint16_t qid)
   return 0;
 
 error:
-  err = memif_buffer_free (c->conn, qid, c->rx_bufs, rx, &fb);
+  err = memif_refill_queue (c->conn, qid, rx, 0);
   if (err != MEMIF_ERR_SUCCESS)
     INFO ("memif_buffer_free: %s", memif_strerror (err));
-  c->rx_buf_num -= fb;
+  c->rx_buf_num -= rx;
   DBG ("freed %d buffers. %u/%u alloc/free buffers",
        fb, c->rx_buf_num, MAX_MEMIF_BUFS - c->rx_buf_num);
   return 0;
@@ -647,10 +640,9 @@ icmpr_memif_create (long index, long mode, char *s)
   args.is_master = mode;
   args.log2_ring_size = 11;
   args.buffer_size = 2048;
-  args.num_s2m_rings = 2;
-  args.num_m2s_rings = 2;
+  args.num_s2m_rings = 1;
+  args.num_m2s_rings = 1;
   strncpy ((char *) args.interface_name, IF_NAME, strlen (IF_NAME));
-  strncpy ((char *) args.instance_name, APP_NAME, strlen (APP_NAME));
   args.mode = 0;
   /* socket filename is not specified, because this app is supposed to
      connect to VPP over memif. so default socket filename will be used */
@@ -771,7 +763,7 @@ print_help ()
   printf (" (debug)");
 #endif
   printf ("\n");
-  printf ("memif version: %d\n", MEMIF_VERSION);
+  printf ("memif version: %d\n", memif_get_version ());
   printf ("commands:\n");
   printf ("\thelp - prints this help\n");
   printf ("\texit - exit app\n");
@@ -960,7 +952,7 @@ icmpr_send_proc (void *data)
       i = 0;
       err = memif_buffer_alloc (c->conn, 0, c->tx_bufs,
                                MAX_MEMIF_BUFS >
-                               count ? count : MAX_MEMIF_BUFS, &tx, 0);
+                               count ? count : MAX_MEMIF_BUFS, &tx, 128);
       if ((err != MEMIF_ERR_SUCCESS) && (err != MEMIF_ERR_NOBUF_RING))
        {
          INFO ("memif_buffer_alloc: %s Thread exiting...\n",
@@ -974,16 +966,16 @@ icmpr_send_proc (void *data)
          while (tx > 2)
            {
              generate_packet ((void *) c->tx_bufs[i].data,
-                              &c->tx_bufs[i].data_len, c->ip_addr,
+                              &c->tx_bufs[i].len, c->ip_addr,
                               d->ip_daddr, d->hw_daddr, seq++);
              generate_packet ((void *) c->tx_bufs[i + 1].data,
-                              &c->tx_bufs[i + 1].data_len, c->ip_addr,
+                              &c->tx_bufs[i + 1].len, c->ip_addr,
                               d->ip_daddr, d->hw_daddr, seq++);
              i += 2;
              tx -= 2;
            }
          generate_packet ((void *) c->tx_bufs[i].data,
-                          &c->tx_bufs[i].data_len, c->ip_addr,
+                          &c->tx_bufs[i].len, c->ip_addr,
                           d->ip_daddr, d->hw_daddr, seq++);
          i++;
          tx--;
@@ -1213,7 +1205,7 @@ user_input_handler ()
     }
   else
     {
-      DBG ("unknown command: %s", ui);
+      INFO ("unknown command: %s", ui);
       goto done;
     }
 
@@ -1305,13 +1297,17 @@ main ()
   /* if valid callback is passed as argument, fd event polling will be done by user
      all file descriptors and events will be passed to user in this callback */
   /* if callback is set to NULL libmemif will handle fd event polling */
-  err = memif_init (control_fd_update, APP_NAME);
+  err = memif_init (control_fd_update, APP_NAME, NULL, NULL);
   if (err != MEMIF_ERR_SUCCESS)
-    INFO ("memif_init: %s", memif_strerror (err));
+    {
+      INFO ("memif_init: %s", memif_strerror (err));
+      icmpr_free ();
+      exit (-1);
+    }
 
   for (i = 0; i < MAX_CONNS; i++)
     {
-      memif_connection[i].conn = NULL;
+      memset (&memif_connection[i], 0, sizeof (memif_connection_t));
       ctx[i] = i;
     }
 
Vector Packet Processing