Add method to send packets to the namespace from the slowpath

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

Author: francescomessina

src/libs/polycube/include/polycube/services/port.h

@@ -40,6 +40,7 @@ class Port {
   Port(std::shared_ptr<PortIface> port);
   ~Port();
   void send_packet_out(EthernetII &packet, bool recirculate = false);
+  void send_packet_ns(EthernetII &packet);
   int index() const;
   std::string name() const;
   void set_peer(const std::string &peer);

src/libs/polycube/include/polycube/services/port_iface.h

@@ -42,6 +42,7 @@ class PortIface {
  public:
   virtual void send_packet_out(const std::vector<uint8_t> &packet,
                                bool recirculate = false) = 0;
+  virtual void send_packet_ns(const std::vector<uint8_t> &packet) = 0;
   virtual uint16_t index() const = 0;
   virtual bool operator==(const PortIface &rhs) const = 0;
   virtual std::string name() const = 0;

src/libs/polycube/src/port.cpp

@@ -32,6 +32,7 @@ class Port::impl {
   impl(Port &op);
   ~impl();
   void send_packet_out(EthernetII &packet, bool recirculate);
+  void send_packet_ns(EthernetII &packet);
   int index() const;
   std::string name() const;
   void set_peer(const std::string &peer);
@@ -104,6 +105,10 @@ void Port::impl::send_packet_out(EthernetII &packet, bool recirculate) {
   port_->send_packet_out(packet.serialize(), recirculate);
 }
 
+void Port::impl::send_packet_ns(EthernetII &packet) {
+  port_->send_packet_ns(packet.serialize());
+}
+
 PortStatus Port::impl::get_status() const {
   return port_->get_status();
 }
@@ -129,6 +134,10 @@ void Port::send_packet_out(EthernetII &packet, bool recirculate) {
   return pimpl_->send_packet_out(packet, recirculate);
 }
 
+void Port::send_packet_ns(EthernetII &packet) {
+  return pimpl_->send_packet_ns(packet);
+}
+
 int Port::index() const {
   return pimpl_->index();
 }

src/polycubed/src/port.cpp

@@ -23,6 +23,8 @@
 #include "polycubed_core.h"
 extern polycube::polycubed::PolycubedCore *core;
 
+const std::string prefix_port = "ns_port_";
+
 namespace polycube {
 namespace polycubed {
 
@@ -199,6 +201,12 @@ void Port::send_packet_out(const std::vector<uint8_t> &packet,
   c.send_packet_to_cube(module, port, packet);
 }
 
+void Port::send_packet_ns(const std::vector<uint8_t> &packet) {
+  std::string name_ns_port = prefix_port + name_;
+  std::shared_ptr<PortIface> port_ns = parent_.get_port(name_ns_port);
+  port_ns->send_packet_out(packet);
+}
+
 void Port::update_indexes() {
   int i;
 

src/polycubed/src/port.h

@@ -70,6 +70,7 @@ class Port : public polycube::service::PortIface, public PeerIface {
   const std::string &peer() const;
   void send_packet_out(const std::vector<uint8_t> &packet,
                        bool recirculate = false);
+  void send_packet_ns(const std::vector<uint8_t> &packet);
   PortStatus get_status() const;
   PortType get_type() const;