X-Git-Url: http://git.cascardo.eti.br/?a=blobdiff_plain;f=vtep%2Fovs-vtep;h=97397b0ca23ac4e7464d41b64260edee6fa1a3f6;hb=HEAD;hp=07856c410e9ca5cf696d7e1fcf1d8269fcc9ef79;hpb=603e325fa56392a4a139ba00aff5dd416d1c512e;p=cascardo%2Fovs.git diff --git a/vtep/ovs-vtep b/vtep/ovs-vtep index 07856c410..97397b0ca 100755 --- a/vtep/ovs-vtep +++ b/vtep/ovs-vtep @@ -29,6 +29,8 @@ import ovs.util import ovs.daemon import ovs.unixctl.server import ovs.vlog +from six.moves import range +import six VERSION = "0.99" @@ -126,11 +128,11 @@ class Logical_Switch(object): ovs_ofctl("add-flow %s priority=0,action=drop" % self.short_name) def cleanup_ls(self): - for port_no, tun_name, remote_ip in self.tunnels.itervalues(): + for port_no, tun_name, remote_ip in six.itervalues(self.tunnels): del_bfd(remote_ip) def update_flood(self): - flood_ports = self.ports.values() + flood_ports = list(self.ports.values()) # Traffic flowing from one 'unknown-dst' should not be flooded to # port belonging to another 'unknown-dst'. @@ -165,7 +167,7 @@ class Logical_Switch(object): def del_lbinding(self, lbinding): vlog.info("removing %s binding from %s" % (lbinding, self.name)) port_no = self.ports[lbinding] - ovs_ofctl("del-flows %s in_port=%s" % (self.short_name, port_no)); + ovs_ofctl("del-flows %s in_port=%s" % (self.short_name, port_no)) del self.ports[lbinding] self.update_flood() @@ -281,11 +283,11 @@ class Logical_Switch(object): for tunnel in old_tunnels.difference(tunnels): self.del_tunnel(tunnel) - for mac in remote_macs.keys(): + for mac in six.iterkeys(remote_macs): if (self.remote_macs.get(mac) != remote_macs[mac]): self.add_remote_mac(mac, remote_macs[mac]) - for mac in self.remote_macs.keys(): + for mac in six.iterkeys(self.remote_macs): if mac not in remote_macs: self.del_remote_mac(mac) @@ -307,7 +309,7 @@ class Logical_Switch(object): # Go through all the logical switch's interfaces that end with "-l" # and copy the statistics to logical_binding_stats. - for interface in self.ports.iterkeys(): + for interface in six.iterkeys(self.ports): if not interface.endswith("-l"): continue # Physical ports can have a '-' as part of its name. @@ -318,7 +320,7 @@ class Logical_Switch(object): if not uuid: continue - for (mapfrom, mapto) in stats_map.iteritems(): + for mapfrom, mapto in six.iteritems(stats_map): value = ovs_vsctl("get interface %s statistics:%s" % (interface, mapfrom)).strip('"') vtep_ctl("set logical_binding_stats %s %s=%s" @@ -434,7 +436,7 @@ def run_bfd(): 'bfd_params:check_tnl_key': 'false'} bfd_params_values = {} - for key, default in bfd_params_default.iteritems(): + for key, default in six.iteritems(bfd_params_default): column = vtep_ctl("--if-exists get tunnel %s %s" % (tunnel, key)) if not column: @@ -442,7 +444,7 @@ def run_bfd(): else: bfd_params_values[key] = column - for key, value in bfd_params_values.iteritems(): + for key, value in six.iteritems(bfd_params_values): new_key = key.replace('_params', '') ovs_vsctl("set interface %s %s=%s" % (port, new_key, value)) @@ -464,7 +466,7 @@ def run_bfd(): bfd_lconf_default = {'bfd_config_local:bfd_dst_ip': '169.254.1.0', 'bfd_config_local:bfd_dst_mac': '00:23:20:00:00:01'} - for key, value in bfd_lconf_default.iteritems(): + for key, value in six.iteritems(bfd_lconf_default): vtep_ctl("set tunnel %s %s=%s" % (tunnel, key, value)) # bfd_config_remote options from VTEP DB should be populated to @@ -520,9 +522,9 @@ def add_binding(binding, ls): # Create a logical_bindings_stats record. if not vlan_: vlan_ = "0" - vtep_ctl("set physical_port %s vlan_stats:%s=@stats --\ - --id=@stats create logical_binding_stats packets_from_local=0"\ - % (pp_name, vlan_)) + vtep_ctl("set physical_port %s vlan_stats:%s=@stats -- " + "--id=@stats create logical_binding_stats packets_from_local=0" + % (pp_name, vlan_)) ls.add_lbinding(lbinding) Bindings[binding] = ls.name @@ -712,7 +714,7 @@ def main(): handle_physical() - for ls_name, ls in Lswitches.items(): + for ls_name, ls in six.iteritems(Lswitches): ls.run() run_bfd()