[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[Minios-devel] [UNIKRAFT PATCH 14/15] plat/driver: Support tap_netdev_xmit



Transmit a network packet from the tap device.

Signed-off-by: Sharan Santhanam <sharan.santhanam@xxxxxxxxx>
---
 plat/drivers/tap/tap.c           | 13 ++++++++++++-
 plat/linuxu/include/linuxu/tap.h |  1 +
 plat/linuxu/tap_io.c             | 20 ++++++++++++++++++++
 3 files changed, 33 insertions(+), 1 deletion(-)

diff --git a/plat/drivers/tap/tap.c b/plat/drivers/tap/tap.c
index 69a042a..1765a0a 100644
--- a/plat/drivers/tap/tap.c
+++ b/plat/drivers/tap/tap.c
@@ -275,7 +275,6 @@ static int tap_netdev_recv(struct uk_netdev *dev,
                uk_pr_err(DRIVER_NAME": Failed(%d) to read the packet\n", rc);
                goto err_exit;
        }
-       uk_pr_debug("setting the buf %p\n", *pkt);
 
        *pkt = _pkt;
 
@@ -294,10 +293,22 @@ static int tap_netdev_xmit(struct uk_netdev *dev,
                           struct uk_netbuf *pkt)
 {
        int rc = -EINVAL;
+       struct tap_net_dev *tdev __unused;
 
        UK_ASSERT(dev);
        UK_ASSERT(queue && pkt);
 
+       tdev = to_tapnetdev(dev);
+
+       rc = tap_write(queue->fd, pkt->data, pkt->len);
+       if (rc > 0) {
+               uk_pr_debug(DRIVER_NAME": Send packet of size %d\n", rc);
+               rc = UK_NETDEV_STATUS_SUCCESS | UK_NETDEV_STATUS_MORE;
+       } else if (rc == -EWOULDBLOCK || rc == -EAGAIN) {
+               uk_pr_debug(DRIVER_NAME": The send queue is full\n");
+               rc = 0;
+       }
+
        return rc;
 }
 
diff --git a/plat/linuxu/include/linuxu/tap.h b/plat/linuxu/include/linuxu/tap.h
index fd1c773..5c10123 100644
--- a/plat/linuxu/include/linuxu/tap.h
+++ b/plat/linuxu/include/linuxu/tap.h
@@ -154,5 +154,6 @@ int tap_close(int fd);
 int tap_dev_configure(int fd, __u32 feature_flags, void *arg);
 int tap_netif_configure(int fd, __u32 request, void *arg);
 __ssz tap_read(int fd, void *buf, size_t count);
+__ssz tap_write(int fd, const void *buf, size_t count);
 
 #endif /* LINUXU_TAP_H */
diff --git a/plat/linuxu/tap_io.c b/plat/linuxu/tap_io.c
index c29dfe7..44c6135 100644
--- a/plat/linuxu/tap_io.c
+++ b/plat/linuxu/tap_io.c
@@ -118,6 +118,26 @@ ssize_t tap_read(int fd, void *buf, size_t count)
        return rc;
 }
 
+ssize_t tap_write(int fd, const void *buf, size_t count)
+{
+       ssize_t rc = -EINTR;
+       int written = 0;
+
+       while (count > 0) {
+               rc = sys_write(fd, buf, count);
+               if (rc == -EINTR)
+                       continue;
+               else if (rc < 0) {
+                       uk_pr_err("Failed(%ld) to write to the tap device\n",
+                                 rc);
+                       return rc;
+               }
+               count -= rc;
+               written += rc;
+       }
+       return written;
+}
+
 int tap_close(int fd)
 {
        return sys_close(fd);
-- 
2.7.4


_______________________________________________
Minios-devel mailing list
Minios-devel@xxxxxxxxxxxxxxxxxxxx
https://lists.xenproject.org/mailman/listinfo/minios-devel

 


Rackspace

Lists.xenproject.org is hosted with RackSpace, monitoring our
servers 24x7x365 and backed by RackSpace's Fanatical Support®.