Merge branch 'master' into github-master

Author: giuseppelettieri

.gitignore

@@ -57,3 +57,4 @@ LINUX/veth.c
 *.sdf
 *.opensdf
 *~
+cscope.out

LINUX/configure

@@ -831,7 +831,7 @@ add_test 'have RX_HANDLER_RESULT' <<-EOF
 	#include <linux/netdevice.h>
 
 
-	static rx_handler_result_t dummy_rx_handler(struct sk_buf **pm)
+	static rx_handler_result_t dummy_rx_handler(struct sk_buff **pm)
 	{
 	        (void)pm;
 	        return RX_HANDLER_PASS;

LINUX/i40e_netmap_linux.h

@@ -60,18 +60,19 @@ extern int ix_rx_miss, ix_rx_miss_bufs, ix_crcstrip;
 /*
  * device-specific sysctl variables:
  *
- * ix_crcstrip: 0: keep CRC in rx frames (default), 1: strip it.
+ * ix_crcstrip: 0: NIC keeps CRC in rx frames (default), 1: NIC strips it.
  *	During regular operations the CRC is stripped, but on some
  *	hardware reception of frames not multiple of 64 is slower,
  *	so using crcstrip=0 helps in benchmarks.
+ *      The driver by default strips CRCs and we do not override it.
  *
  * ix_rx_miss, ix_rx_miss_bufs:
  *	count packets that might be missed due to lost interrupts.
  */
 SYSCTL_DECL(_dev_netmap);
-int ix_rx_miss, ix_rx_miss_bufs, ix_crcstrip;
+int ix_rx_miss = 0, ix_rx_miss_bufs = 0, ix_crcstrip = 1;
 SYSCTL_INT(_dev_netmap, OID_AUTO, ix_crcstrip,
-    CTLFLAG_RW, &ix_crcstrip, 1, "strip CRC on rx frames");
+    CTLFLAG_RW, &ix_crcstrip, 1, "NIC strips CRC on rx frames");
 SYSCTL_INT(_dev_netmap, OID_AUTO, ix_rx_miss,
     CTLFLAG_RW, &ix_rx_miss, 0, "potentially missed rx intr");
 SYSCTL_INT(_dev_netmap, OID_AUTO, ix_rx_miss_bufs,

apps/lb/.gitignore

@@ -0,0 +1 @@
+lb

apps/lb/lb.c

@@ -561,23 +561,23 @@ int main(int argc, char **argv)
 			while (!nm_ring_empty(rxring)) {
 				struct overflow_queue *q;
 				struct netmap_slot *rs = next_slot;
-				next_cur = nm_ring_next(rxring, next_cur);
-				next_slot = &rxring->slot[next_cur];
 
 				// CHOOSE THE CORRECT OUTPUT PIPE
-				next_buf = NETMAP_BUF(rxring, next_slot->buf_idx);
-				__builtin_prefetch(next_buf);
-				// 'B' is just a hashing seed
 				uint32_t hash = pkt_hdr_hash((const unsigned char *)next_buf, 4, 'B');
 				if (hash == 0)
 					non_ip++; // XXX ??
+				// prefetch the buffer for the next round
+				next_cur = nm_ring_next(rxring, next_cur);
+				next_slot = &rxring->slot[next_cur];
+				next_buf = NETMAP_BUF(rxring, next_slot->buf_idx);
+				__builtin_prefetch(next_buf);
+				// 'B' is just a hashing seed
 				uint32_t output_port = hash % glob_arg.output_rings;
 				struct port_des *port = &ports[output_port];
 				struct netmap_ring *ring = port->ring;
 				uint32_t free_buf;
 
 				// Move the packet to the output pipe.
-			retry:
 				if (nm_ring_space(ring)) {
 					struct netmap_slot *ts = &ring->slot[ring->cur];
 					free_buf = ts->buf_idx;
@@ -590,17 +590,6 @@ int main(int argc, char **argv)
 					goto forward;
 				}
 
-				/* try to push packets down to free some space
-				 * in the pipe (no more than once per loop on
-				 * the same pipe, to make sure that there is a
-				 * reasonable amount of time between syncs)
-				 */
-				if (port->last_sync != iter) {
-					port->last_sync = iter;
-					ioctl(port->nmd->fd, NIOCTXSYNC, NULL);
-					goto retry;
-				}
-
 				/* use the overflow queue, if available */
 				if (!oq) {
 					dropped++;

apps/nmreplay/.gitignore

@@ -0,0 +1 @@
+nmreplay

apps/tlem/.gitignore

@@ -0,0 +1 @@
+tlem

examples/ctrs.h

@@ -95,7 +95,7 @@ wait_for_next_report(struct timeval *prev, struct timeval *cur,
 
 	delta.tv_sec = report_interval/1000;
 	delta.tv_usec = (report_interval%1000)*1000;
-	if (select(0, NULL, NULL, NULL, &delta) < 0) {
+	if (select(0, NULL, NULL, NULL, &delta) < 0 && errno != EINTR) {
 		perror("select");
 		abort();
 	}

extra/python/README

@@ -95,6 +95,7 @@ language.
 
                 to see the available options.
 
-        (5.2) tx.py - An example packet generator using the lower level
-                      Python netmap bindings.
+        (5.2) tx.py - An minimal packet generator using the lower level
+                      Python netmap bindings, it is able to transmit
+                      more than 20 Mpps.
 

extra/python/netmap_desc.c

@@ -44,6 +44,7 @@ NetmapDesc_dealloc(NetmapDesc* self)
 
     if (self->nmd) {
         nm_close(self->nmd);
+        self->nmd = NULL;
     }
     self->ob_type->tp_free((PyObject*)self);
 }
@@ -170,6 +171,24 @@ static PyGetSetDef NetmapDesc_getseters[] = {
 
 /*########################## NetmapDesc methods ########################*/
 
+static PyObject *
+NetmapDesc_enter(NetmapDesc *self)
+{
+    Py_INCREF(self);
+    return (PyObject *)self;
+}
+
+static PyObject *
+NetmapDesc_exit(NetmapDesc *self, PyObject *args)
+{
+    if (self->nmd) {
+        nm_close(self->nmd);
+        self->nmd = NULL;
+    }
+
+    Py_RETURN_NONE;
+}
+
 static PyObject *
 NetmapDesc_xxsync(NetmapDesc *self, int iocmd)
 {
@@ -217,6 +236,12 @@ NetmapDesc_getflags(NetmapDesc *self)
 
 /* A container for the netmap methods. */
 static PyMethodDef NetmapDesc_methods[] = {
+    {"__enter__", (PyCFunction)NetmapDesc_enter, METH_NOARGS,
+        "__enter__ implementation to support with statement"
+    },
+    {"__exit__", (PyCFunction)NetmapDesc_exit, METH_VARARGS,
+        "__exit__ implementation to support with statement"
+    },
     {"txsync", (PyCFunction)NetmapDesc_txsync, METH_NOARGS,
         "Do a txsync on the registered rings"
     },