Signed-off-by: Ciprian Barbu <[email protected]>
---
 platform/linux-netmap/include/odp_packet_netmap.h |  2 --
 platform/linux-netmap/odp_packet_netmap.c         | 27 +++--------------------
 2 files changed, 3 insertions(+), 26 deletions(-)

diff --git a/platform/linux-netmap/include/odp_packet_netmap.h 
b/platform/linux-netmap/include/odp_packet_netmap.h
index 161b968..d4895ce 100644
--- a/platform/linux-netmap/include/odp_packet_netmap.h
+++ b/platform/linux-netmap/include/odp_packet_netmap.h
@@ -22,8 +22,6 @@
 #define ODP_NETMAP_RING_HW     0
 #define ODP_NETMAP_RING_SW     1
 
-#define NETMAP_BLOCKING_IO
-
 /** Packet socket using netmap mmaped rings for both Rx and Tx */
 typedef struct {
        odp_buffer_pool_t pool;
diff --git a/platform/linux-netmap/odp_packet_netmap.c 
b/platform/linux-netmap/odp_packet_netmap.c
index 6d5228d..91b7f68 100644
--- a/platform/linux-netmap/odp_packet_netmap.c
+++ b/platform/linux-netmap/odp_packet_netmap.c
@@ -214,25 +214,17 @@ int recv_pkt_netmap(pkt_netmap_t * const pkt_nm, 
odp_packet_t pkt_table[],
        uint32_t limit, rx;
        uint32_t ringid = pkt_nm->begin;
        odp_packet_t pkt = ODP_PACKET_INVALID;
-#ifdef NETMAP_BLOCKING_IO
        struct pollfd fds[1];
        int ret;
-#endif
 
        fd = pkt_nm->desc->fd;
-#ifdef NETMAP_BLOCKING_IO
        fds[0].fd = fd;
        fds[0].events = POLLIN;
-#endif
 
        while (nb_rx < len) {
-#ifdef NETMAP_BLOCKING_IO
-               ret = poll(&fds[0], 1, POLL_TMO);
+               ret = poll(fds, 1, POLL_TMO);
                if (ret <= 0 || (fds[0].revents & POLLERR))
                        break;
-#else
-               ioctl(fd, NIOCRXSYNC, NULL);
-#endif
 
                /* Find first ring not empty */
                while (nm_ring_empty(rxring)) {
@@ -324,26 +316,17 @@ int send_pkt_netmap(pkt_netmap_t * const pkt_nm, 
odp_packet_t pkt_table[],
        uint32_t            limit, tx;
        uint32_t            ringid = pkt_nm->begin;
        odp_packet_t        pkt;
-
-#ifdef NETMAP_BLOCKING_IO
-       struct pollfd fds[2];
+       struct pollfd fds[1];
        int ret;
-#endif
 
        fd = pkt_nm->desc->fd;
-#ifdef NETMAP_BLOCKING_IO
        fds[0].fd = fd;
        fds[0].events = POLLOUT;
-#endif
 
        while (nb_tx < len) {
-#ifdef NETMAP_BLOCKING_IO
-               ret = poll(&fds[0], 1, POLL_TMO);
+               ret = poll(fds, 1, POLL_TMO);
                if (ret <= 0 || (fds[0].revents & POLLERR))
                        break;
-#else
-               ioctl(fd, NIOCTXSYNC, NULL);
-#endif
 
                /* Find first ring not empty */
                while (nm_ring_empty(txring)) {
@@ -389,10 +372,6 @@ int send_pkt_netmap(pkt_netmap_t * const pkt_nm, 
odp_packet_t pkt_table[],
                }
        }
 
-#ifndef NETMAP_BLOCKING_IO
-       ioctl(fd, NIOCTXSYNC, NULL);
-#endif
-
        for (tx = 0; tx < len; tx++)
                odph_packet_free(pkt_table[tx]);
 
-- 
1.8.3.2


_______________________________________________
lng-odp mailing list
[email protected]
http://lists.linaro.org/mailman/listinfo/lng-odp

Reply via email to