00f9f416594b404c02f87cec85d405cad341d4ad,perfkitbenchmarker/providers/openstack/os_network.py,OpenStackFirewall,AllowPort,#OpenStackFirewall#Any#Any#Any#,83

Before Change

      if sec_group_rule in self.sec_group_rules_set:
        return
      for prot in ("tcp", "udp",):
        try:
            self.__nclient.security_group_rules.create(
                self.sec_group.id, ip_protocol=prot,
                from_port=port, to_port=to_port)
        except BadRequest:
            logging.debug("Rule %s:%d-%d already exists",
                          prot, port, to_port)

      self.sec_group_rules_set.add(sec_group_rule)

  def DisallowAllPorts(self):
    pass

After Change

    sec_group_rule = (port, to_port, vm.group_id)

    with self._lock:
      cmd = utils.OpenStackCLICommand(vm, "security group rule", "create",
                                      vm.group_id)
      cmd.flags["dst-port"] = "%d:%d" % (port, to_port)
      if sec_group_rule in self.sec_group_rules_set:
        return
      for prot in ("tcp", "udp",):
        cmd.flags["proto"] = prot
        cmd.Issue(suppress_warning=True)
      self.sec_group_rules_set.add(sec_group_rule)

  def DisallowAllPorts(self):
    Closes all ports on the firewall.

Instances