netmap: add extra interface on bridge

[upyzl]

Hi there,

I'm study on developing a simple openflow-based datapath module

I know and tried successfully by "bridge -i em0 -i em1"

Now I need bridge em0 em1 em2, but I find using vale-ctl is very difficult
for me, as I need develop extract, match packets (packets from IN_PORT) and
do actions from flow table (for simple, the flow table is static).

I try like this, but only em0 & em1 are connect, without em2...

 --- "a/bridge.c"
+++ "b/bridge.c"
@@ -162,11 +162,11 @@ usage(void)
 int
 main(int argc, char **argv)
 {
-    struct pollfd pollfd[2];
+    struct pollfd pollfd[3];
     int i, ch;
     u_int burst = 1024, wait_link = 4;
-    struct my_ring me[2];
-    char *ifa = NULL, *ifb = NULL;
+    struct my_ring me[3];
+    char *ifa = NULL, *ifb = NULL, *ifc = NULL;

     fprintf(stderr, "%s %s built %s %s\n",
         argv[0], version, __DATE__, __TIME__);
@@ -187,6 +187,8 @@ main(int argc, char **argv)
                 ifa = optarg;
             else if (ifb == NULL)
                 ifb = optarg;
+            else if (ifc == NULL)
+                ifc = optarg;
             else
                 D("%s ignored, already have 2 interfaces",
                     optarg);
@@ -209,6 +211,8 @@ main(int argc, char **argv)
     if (argc > 2)
         ifb = argv[2];
     if (argc > 3)
+        ifc = argv[3];
+    if (argc > 4)
         burst = atoi(argv[3]);
     if (!ifb)
         ifb = ifa;
@@ -227,6 +231,7 @@ main(int argc, char **argv)
     /* setup netmap interface #1. */
     me[0].ifname = ifa;
     me[1].ifname = ifb;
+  me[2].ifname = ifc;
     if (!strcmp(ifa, ifb)) {
         D("same interface, endpoint 0 goes to host");
         i = NETMAP_SW_RING;
@@ -236,13 +241,15 @@ main(int argc, char **argv)
     }
     if (netmap_open(me, i, 1))
         return (1);
-    me[1].mem = me[0].mem; /* copy the pointer, so only one mmap */
+    me[2].mem = me[1].mem = me[0].mem; /* copy the pointer, so only one
mmap */
     if (netmap_open(me+1, 0, 1))
         return (1);
+    if (netmap_open(me+2, 0, 1))
+        return (1);

     /* setup poll(2) variables. */
     memset(pollfd, 0, sizeof(pollfd));
-    for (i = 0; i < 2; i++) {
+    for (i = 0; i < 3; i++) {
         pollfd[i].fd = me[i].fd;
         pollfd[i].events = (POLLIN);
     }
@@ -256,20 +263,31 @@ main(int argc, char **argv)
     /* main loop */
     signal(SIGINT, sigint_h);
     while (!do_abort) {
-        int n0, n1, ret;
-        pollfd[0].events = pollfd[1].events = 0;
-        pollfd[0].revents = pollfd[1].revents = 0;
+        int n0, n1, n2, ret;
+        pollfd[0].events = pollfd[1].events = pollfd[2].events = 0;
+        pollfd[0].revents = pollfd[1].revents = pollfd[2].revents = 0;
         n0 = pkt_queued(me, 0);
         n1 = pkt_queued(me + 1, 0);
-        if (n0)
+        n2 = pkt_queued(me + 2, 0);
+        if (n0) {
             pollfd[1].events |= POLLOUT;
+            pollfd[2].events |= POLLOUT;
+        }
         else
             pollfd[0].events |= POLLIN;
-        if (n1)
+        if (n1) {
             pollfd[0].events |= POLLOUT;
+            pollfd[2].events |= POLLOUT;
+        }
         else
             pollfd[1].events |= POLLIN;
-        ret = poll(pollfd, 2, 2500);
+        if (n2) {
+            pollfd[0].events |= POLLOUT;
+            pollfd[1].events |= POLLOUT;
+        }
+        else
+            pollfd[2].events |= POLLIN;
+        ret = poll(pollfd, 3, 2500);
         if (ret <= 0 || verbose)
             D("poll %s [0] ev %x %x rx %d@%d tx %d,"
                  " [1] ev %x %x rx %d@%d tx %d",
@@ -297,16 +315,25 @@ main(int argc, char **argv)
         }
         if (pollfd[0].revents & POLLOUT) {
             move(me + 1, me, burst);
+            move(me + 2, me, burst);
             // XXX we don't need the ioctl */
             // ioctl(me[0].fd, NIOCTXSYNC, NULL);
         }
         if (pollfd[1].revents & POLLOUT) {
             move(me, me + 1, burst);
+            move(me + 2, me + 1, burst);
             // XXX we don't need the ioctl */
             // ioctl(me[1].fd, NIOCTXSYNC, NULL);
         }
+        if (pollfd[2].revents & POLLOUT) {
+            move(me, me + 2, burst);
+            move(me + 1, me + 2, burst);
+            // XXX we don't need the ioctl */
+            // ioctl(me[2].fd, NIOCTXSYNC, NULL);
+        }
     }
     D("exiting");
+    netmap_close(me + 2);
     netmap_close(me + 1);
     netmap_close(me + 0);


for last, use ioctl instead of move is failed either...

any advices or relative documents for devel are welcome :)

Regards