Commit c08d20fc authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Device component - Ryu Driver: 

- Fixed parsing of config rules
parent e1a188fc

src/device/service/drivers/ryu/RyuDriver.py

+6 −6
Original line number Diff line number Diff line
@@ -91,8 +91,8 @@ class RyuDriver(_Driver): 
                        dpid = int(resource_value_dict["dpid"], 16)

                        in_port = int(resource_value_dict["in-port"].split("-")[1][3:])

                        out_port = int(resource_value_dict["out-port"].split("-")[1][3:])

                        ip_src_addr = resource_value_dict.get("ip_address_source", "")

                        ip_dst_addr = resource_value_dict.get("ip_address_destination", "")

                        src_ip_addr = resource_value_dict.get("src-ip-addr", "")

                        dst_ip_addr = resource_value_dict.get("dst-ip-addr", "")



                        if "h1-h3" in resource_key:

                            priority = 1000
@@ -111,7 +111,7 @@ class RyuDriver(_Driver): 
                        continue



                    results.append(self.rac.add_flow_rule(

                        dpid, in_port, out_port, 0x0800, ip_src_addr, ip_dst_addr,

                        dpid, in_port, out_port, 0x0800, src_ip_addr, dst_ip_addr,

                        priority=priority

                    ))

                except Exception as e:
@@ -143,8 +143,8 @@ class RyuDriver(_Driver): 
                        dpid = int(resource_value_dict["dpid"], 16)

                        in_port = int(resource_value_dict["in-port"].split("-")[1][3:])

                        out_port = int(resource_value_dict["out-port"].split("-")[1][3:])

                        ip_src_addr = resource_value_dict.get("ip_address_source", "")

                        ip_dst_addr = resource_value_dict.get("ip_address_destination", "")

                        src_ip_addr = resource_value_dict.get("src-ip-addr", "")

                        dst_ip_addr = resource_value_dict.get("dst-ip-addr", "")



                        if "h1-h3" in resource_key:

                            priority = 1000
@@ -163,7 +163,7 @@ class RyuDriver(_Driver): 
                        continue



                    results.append(self.rac.del_flow_rule(

                        dpid, in_port, out_port, 0x0800, ip_src_addr, ip_dst_addr,

                        dpid, in_port, out_port, 0x0800, src_ip_addr, dst_ip_addr,

                        priority=priority

                    ))

                except Exception as e: