Shadow Router:

This commit register a Shadow router to the netlink events and
implements the functions to handle netlink notifications
  - Route added to the namespace
  - Route removed from the namespace
  - Interface removed
  - New Address on the interface
Local traffic and ARP traffic of a Shadow router is managed by the namespace.
The setIP, setNetmask and setMac methods have been implemented on the router.

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

Author: francescomessina

src/services/pcn-router/src/CMakeLists.txt

@@ -7,6 +7,7 @@ aux_source_directory(default-src SRC_SOURCES)
 include_directories(serializer)
 include_directories(interface)
 include_directories(default-src)
+include_directories(/usr/include/libnl3)
 
 # Needed to load files as variables
 include_directories(${CMAKE_CURRENT_BINARY_DIR})

src/services/pcn-router/src/Ports.cpp

@@ -20,6 +20,9 @@
 #include "Router.h"
 #include "UtilityMethods.h"
 
+#include "../../../polycubed/src/utils/netlink.h"
+#include "../../../polycubed/src/utils/ns.h"
+
 Ports::Ports(polycube::service::Cube<Ports> &parent,
              std::shared_ptr<polycube::service::PortIface> port,
              const PortsJsonObject &conf)
@@ -142,7 +145,52 @@ std::string Ports::getIp() {
 
 void Ports::setIp(const std::string &value) {
   // This method set the ip value.
-  throw std::runtime_error("[Ports]: Method setIp not implemented");
+  if (ip_ != value) {
+    // unset old ip
+    if (parent_.get_shadow()) {
+      int prefix = get_netmask_length(getNetmask());
+      std::function<void()> doThis = [&]{parent_.netlink_instance_router_.unset_iface_ip(getName(), ip_, prefix);};
+      polycube::polycubed::Namespace namespace_ = polycube::polycubed::Namespace::open("pcn-" + parent_.get_name());
+      namespace_.execute(doThis);
+    }
+
+    setIp_Netlink(value);
+
+    // set new ip
+    if (parent_.get_shadow()) {
+      int prefix = get_netmask_length(getNetmask());
+      std::function<void()> doThis = [&]{parent_.netlink_instance_router_.set_iface_ip(getName(), value, prefix);};
+      polycube::polycubed::Namespace namespace_ = polycube::polycubed::Namespace::open("pcn-" + parent_.get_name());
+      namespace_.execute(doThis);
+    }
+  }
+}
+
+void Ports::setIp_Netlink(const std::string &value) {
+  // This method set the ip value.
+  if (ip_ != value) {
+    std::string new_ip = value;
+    /* Update the port in the datapath */
+    uint16_t index = this->index();
+    auto router_port = parent_.get_hash_table<uint16_t, r_port>("router_port");
+
+    try {
+      r_port value = router_port.get(index);
+      value.ip = utils::ip_string_to_be_uint(new_ip);
+    } catch (...) {
+      logger()->error("Port {0} not found in the data path", this->name());
+    }
+
+    logger()->debug(
+        "Updated IP port: {0} (index: {4}) [mac: {1} - ip: {2} - netmask: {3}]",
+        getName(), getMac(), new_ip, getNetmask(), index);
+
+    /* Update routes in the routing table */
+    parent_.remove_local_route(ip_, getNetmask(), getName());
+    parent_.add_local_route(new_ip, getNetmask(), getName(), index);
+
+    ip_ = new_ip;
+  }
 }
 
 std::string Ports::getNetmask() {
@@ -152,7 +200,52 @@ std::string Ports::getNetmask() {
 
 void Ports::setNetmask(const std::string &value) {
   // This method set the netmask value.
-  throw std::runtime_error("[Ports]: Method setNetmask not implemented");
+  if (netmask_ != value) {
+    // unset old netmask
+    if (parent_.get_shadow()) {
+      int prefix = get_netmask_length(netmask_);
+      std::function<void()> doThis = [&]{parent_.netlink_instance_router_.unset_iface_ip(getName(), ip_, prefix);};
+      polycube::polycubed::Namespace namespace_ = polycube::polycubed::Namespace::open("pcn-" + parent_.get_name());
+      namespace_.execute(doThis);
+    }
+
+    setNetmask_Netlink(value);
+
+    // set new netmask
+    if (parent_.get_shadow()) {
+      int prefix = get_netmask_length(value);
+      std::function<void()> doThis = [&]{parent_.netlink_instance_router_.set_iface_ip(getName(), getIp(), prefix);};
+      polycube::polycubed::Namespace namespace_ = polycube::polycubed::Namespace::open("pcn-" + parent_.get_name());
+      namespace_.execute(doThis);
+    }
+  }
+}
+
+void Ports::setNetmask_Netlink(const std::string &value) {
+  // This method set the netmask value.
+  if (netmask_ != value) {
+    std::string new_netmask = value;
+    /* Update the port in the datapath */
+    uint16_t index = this->index();
+    auto router_port = parent_.get_hash_table<uint16_t, r_port>("router_port");
+
+    try {
+      r_port value = router_port.get(index);
+      value.netmask = utils::ip_string_to_be_uint(new_netmask);
+    } catch (...) {
+      logger()->error("Port {0} not found in the data path", this->name());
+    }
+
+    logger()->debug(
+        "Updated netmask port: {0} (index: {4}) [mac: {1} - ip: {2} - netmask: {3}]",
+        getName(), getMac(), getIp(), new_netmask, index);
+
+    /* Update routes in the routing table */
+    parent_.remove_local_route(getIp(), netmask_, getName());
+    parent_.add_local_route(getIp(), new_netmask, getName(), index);
+
+    netmask_ = new_netmask;
+  }
 }
 
 std::string Ports::getMac() {
@@ -162,7 +255,30 @@ std::string Ports::getMac() {
 
 void Ports::setMac(const std::string &value) {
   // This method set the mac value.
-  throw std::runtime_error("[Ports]: Method setMac not implemented");
+  if (mac_ != value) {
+    std::string new_mac = value;
+    /* Update the port in the datapath */
+    uint16_t index = this->index();
+    auto router_port = parent_.get_hash_table<uint16_t, r_port>("router_port");
+
+    try {
+      r_port value = router_port.get(index);
+      value.mac = utils::mac_string_to_be_uint(new_mac);
+    } catch (...) {
+      logger()->error("Port {0} not found in the data path", this->name());
+    }
+
+    logger()->debug(
+        "Updated mac port: {0} (index: {4}) [mac: {1} - ip: {2} - netmask: {3}]",
+        getName(), new_mac, getIp(), getNetmask(), index);
+
+    mac_ = new_mac;
+  }
+  if (parent_.get_shadow()) {
+    std::function<void()> doThis = [&]{parent_.netlink_instance_router_.set_iface_mac(getName(), mac_);};
+    polycube::polycubed::Namespace namespace_ = polycube::polycubed::Namespace::open("pcn-" + parent_.get_name());
+    namespace_.execute(doThis);
+  }
 }
 
 std::shared_ptr<spdlog::logger> Ports::logger() {
@@ -259,4 +375,4 @@ void Ports::delSecondaryipList() {
     std::string netmask = tmp->getNetmask();
     delSecondaryip(ip, netmask);
   }
-}
+}

src/services/pcn-router/src/Ports.h

@@ -60,12 +60,14 @@ class Ports : public polycube::service::Port, public PortsInterface {
   /// </summary>
   std::string getIp() override;
   void setIp(const std::string &value) override;
+  void setIp_Netlink(const std::string &value);
 
   /// <summary>
   /// Netmask of the port
   /// </summary>
   std::string getNetmask() override;
   void setNetmask(const std::string &value) override;
+  void setNetmask_Netlink(const std::string &value);
 
   /// <summary>
   /// MAC address of the port