Add support for ipv6

Signed-off-by: francescomessina <francescomessina92@hotmail.com>

Author: francescomessina

src/polycubed/src/utils/netlink.cpp

@@ -668,6 +668,26 @@ struct nlmsghdr* Netlink::netlink_ip_alloc() {
   return nlmsg;
 }
 
+struct nlmsghdr* Netlink::netlink_ipv6_alloc() {
+  size_t len = NLMSG_ALIGN(SIZE_ALIGN) + NLMSG_ALIGN(sizeof(struct nlmsghdr *));
+  struct nlmsghdr *nlmsg = (struct nlmsghdr *) malloc(len);
+  memset(nlmsg, 0, len);
+
+  struct nl_ipreq *uni = (struct nl_ipreq *)nlmsg;
+  uni->ifaddrmsg.ifa_family = AF_INET6;
+  uni->ifaddrmsg.ifa_scope = 0;
+
+  nlmsg->nlmsg_len = NLMSG_LENGTH(sizeof(struct ifaddrmsg));
+  nlmsg->nlmsg_type = RTM_NEWADDR;
+  // NLM_F_REQUEST   Must be set on all request messages
+  // NLM_F_ACK       Request for an acknowledgment on success
+  // NLM_F_CREATE    Create object if it doesn't already exist
+  // NLM_F_EXCL      Don't replace if the object already exists
+  nlmsg->nlmsg_flags = NLM_F_REQUEST|NLM_F_ACK|NLM_F_CREATE|NLM_F_EXCL;
+
+  return nlmsg;
+}
+
 int Netlink::netlink_nl_send(struct nlmsghdr *nlmsg) {
   struct sockaddr_nl nladdr;
   struct iovec iov = {
@@ -825,6 +845,41 @@ void Netlink::set_iface_ip(const std::string &iface, const std::string &ip, int
   netlink_nl_send(nlmsg);
 }
 
+void Netlink::set_iface_ipv6(const std::string &iface, const std::string &ipv6) {
+  struct nlmsghdr *nlmsg = netlink_ipv6_alloc();
+  struct nl_ipreq *uni = (struct nl_ipreq *)nlmsg;
+  struct rtattr *rta;
+  struct in6_addr ia;
+
+  int index = get_iface_index(iface);
+  if (index == -1) {
+    logger->error("set_iface_ipv6: iface {0} does not exist", iface);
+    throw std::runtime_error("set_iface_ipv6: iface does not exist");
+  }
+
+  uni->ifaddrmsg.ifa_index = index;
+
+  if (inet_pton(AF_INET6, ipv6.c_str(), &ia) <= 0) {
+    free(nlmsg);
+    logger->error("set_iface_ipv6: Error in inet_pton");
+    throw std::runtime_error("set_iface_ipv6: Error in inet_pton");
+  }
+
+  rta = NLMSG_TAIL(nlmsg);
+  rta->rta_type = IFA_LOCAL;
+  rta->rta_len = RTA_LENGTH(sizeof(struct in6_addr));
+  memcpy(RTA_DATA(rta), &ia, sizeof(struct in6_addr));
+  nlmsg->nlmsg_len = NLMSG_ALIGN(nlmsg->nlmsg_len) + RTA_ALIGN(rta->rta_len);
+
+  rta = NLMSG_TAIL(nlmsg);
+  rta->rta_type = IFA_ADDRESS;
+  rta->rta_len = RTA_LENGTH(sizeof(struct in6_addr));
+  memcpy(RTA_DATA(rta), &ia, sizeof(struct in6_addr));
+  nlmsg->nlmsg_len = NLMSG_ALIGN(nlmsg->nlmsg_len) + RTA_ALIGN(rta->rta_len);
+
+  netlink_nl_send(nlmsg);
+}
+
 void Netlink::move_iface_into_ns(const std::string &iface, int fd) {
   struct nlmsghdr *nlmsg = netlink_alloc();
   struct nl_req *unr = (struct nl_req *)nlmsg;

src/polycubed/src/utils/netlink.h

@@ -80,6 +80,7 @@ class Netlink {
   void set_iface_status(const std::string &iface, IFACE_STATUS status);
   void set_iface_mac(const std::string &iface, const std::string &mac);
   void set_iface_ip(const std::string &iface, const std::string &ip, int prefix);
+  void set_iface_ipv6(const std::string &iface, const std::string &ip);
   void move_iface_into_ns(const std::string &iface, int fd);
 
   template <typename Observer>
@@ -122,6 +123,7 @@ class Netlink {
 
   struct nlmsghdr* netlink_alloc();
   struct nlmsghdr* netlink_ip_alloc();
+  struct nlmsghdr* netlink_ipv6_alloc();
   int netlink_nl_send(struct nlmsghdr *nlmsg);
 
   std::shared_ptr<spdlog::logger> logger;

src/polycubed/src/utils/veth.cpp

@@ -80,6 +80,17 @@ void VethPeer::set_ip(const std::string &ip, const int prefix) {
   }
 }
 
+void VethPeer::set_ipv6(const std::string &ipv6) {
+  if (!ns_.empty()) {
+    /* exec set_iface_ipv6 into namespace */
+    std::function<void()> doThis = [&]{Netlink::getInstance().set_iface_ipv6(name_, ipv6);};
+    Namespace namespace_ = Namespace::open(ns_);
+    namespace_.execute(doThis);
+  } else {
+    Netlink::getInstance().set_iface_ipv6(name_, ipv6);
+  }
+}
+
 /* Class Veth */
 Veth Veth::create(const std::string &peerA, const std::string &peerB) {
   struct rtnl_link *link;

src/polycubed/src/utils/veth.h

@@ -37,6 +37,7 @@ class VethPeer {
     void set_status(IFACE_STATUS status);
     void set_mac(const std::string &mac);
     void set_ip(const std::string &ip, const int prefix);
+    void set_ipv6(const std::string &ipv6);
 
   private:
     std::string name_;