some help

Author: giuseppelettieri

forward.c

@@ -115,6 +115,20 @@ main_loop(const char *netmap_port_one, const char *netmap_port_two, int udp_port
     printf("zerocopy %sabled\n", zerocopy ? "en" : "dis");
 
     while (!stop) {
+	struct pollfd pfd[2];
+        pfd[0].fd = nmd_one->fd;
+	pfd[0].events = 0;
+        pfd[1].fd = nmd_two->fd;
+	pfd[1].events = 0;
+	/* if port one has RX packets then
+	 * POLLOUT on port two else POLLIN on
+         * port one */
+
+        poll(pfd, 2, 1000);
+
+	/* try to copy as many packets as possible
+         * from port 1 to port 2
+         */
     }
 
     nm_close(nmd_one);

sink.c

@@ -57,8 +57,32 @@ udp_port_match(const char *buf, unsigned len, int udp_port)
 static int
 main_loop(const char *netmap_port, int udp_port)
 {
+    struct nm_desc *nmd;
+
+    nmd = nm_open(netmap_port, NULL, 0, NULL);
+    /* check for errors */
 
     while (!stop) {
+       int r;
+       /* for each ring index from nmd->first_rx_ring to
+        * nmd->last_rx_ring (included)
+        */
+       /* synchronize! */
+       ioctl(nmd->fd, NIOCRXSYNC);
+       for (r = nmd->first_rx_ring; r <= nmd->last_rx_ring; r++) {
+           struct netmap_ring *ring = NETMAP_RXRING(nifp, r);
+       
+           /* for each packet from ring->head to ring->tail
+            * (excluded) */
+           for ( ; ring->head != ring->tail;
+                ring->head = nm_ring_next(ring, ring->head)) {
+                struct netmap_slot *slot = &ring->slot[ring->head];
+                void *buf = NETMAP_BUF(ring, slot->buf_idx);
+	       /* count if match */
+	   }
+	   /* update ring->head and ring->cur */
+	   ring->cur = ring->head;
+       }
     }