chore(IOError): Update IOError to OSError

In Python 3.3+, IOError is an alias of OSError[1]. Some call sites use
one or the other or both. Standardize on the OSError.

[1] https://docs.python.org/3/library/exceptions.html#IOError

cloudinit/cmd/cloud_id.py

@@ -76,7 +76,7 @@ def handle_args(name, args):
     try:
         with open(args.instance_data) as file:
             instance_data = json.load(file)
-    except IOError:
+    except OSError:
         return log_util.error(
             "File not found '%s'. Provide a path to instance data json file"
             " using --instance-data" % args.instance_data

cloudinit/cmd/devel/render.py

@@ -86,7 +86,7 @@ def render_template(user_data_path, instance_data_path=None, debug=False):
     try:
         with open(user_data_path) as stream:
             user_data = stream.read()
-    except IOError:
+    except OSError:
         LOG.error("Missing user-data file: %s", user_data_path)
         return 1
     try:

cloudinit/cmd/query.py

@@ -19,7 +19,6 @@
 import logging
 import os
 import sys
-from errno import EACCES
 
 from cloudinit import atomic_helper, util
 from cloudinit.cmd.devel import read_cfg_paths
@@ -147,7 +146,7 @@ def _read_instance_data(instance_data, user_data, vendor_data) -> dict:
     Non-root users will have redacted INSTANCE_JSON_FILE content and redacted
     vendordata and userdata values.
 
-    :raise: IOError/OSError on absence of instance-data.json file or invalid
+    :raise: OSError on absence of instance-data.json file or invalid
         access perms.
     """
     uid = os.getuid()
@@ -181,19 +180,19 @@ def _read_instance_data(instance_data, user_data, vendor_data) -> dict:
 
     try:
         instance_json = util.load_text_file(instance_data_fn)
-    except (IOError, OSError) as e:
-        if e.errno == EACCES:
-            LOG.error("No read permission on '%s'. Try sudo", instance_data_fn)
-        else:
-            LOG.error("Missing instance-data file: %s", instance_data_fn)
+    except PermissionError:
+        LOG.error("No read permission on '%s'. Try sudo", instance_data_fn)
+        raise
+    except OSError:
+        LOG.error("Missing instance-data file: %s", instance_data_fn)
         raise
 
     instance_data = util.load_json(instance_json)
     try:
         combined_cloud_config = util.load_json(
             util.load_text_file(combined_cloud_config_fn)
         )
-    except (IOError, OSError):
+    except OSError:
         # File will not yet be present in init-local stage.
         # It's created in `init` when vendor-data and user-data are processed.
         combined_cloud_config = None
@@ -274,7 +273,7 @@ def handle_args(name, args):
         instance_data = _read_instance_data(
             args.instance_data, args.user_data, args.vendor_data
         )
-    except (IOError, OSError):
+    except OSError:
         return 1
     if args.format:
         payload = "## template: jinja\n{fmt}".format(fmt=args.format)

cloudinit/config/cc_apt_configure.py

@@ -153,7 +153,7 @@ def apply_apt(cfg, cloud, gpg):
 
     try:
         apply_apt_config(cfg, APT_PROXY_FN, APT_CONFIG_FN)
-    except (IOError, OSError):
+    except OSError:
         LOG.exception("Failed to apply proxy or apt config info:")
 
     # Process 'apt_source -> sources {dict}'
@@ -733,7 +733,7 @@ def add_apt_sources(
                 omode = "w"
 
             util.write_file(sourcefn, contents, omode=omode)
-        except IOError as detail:
+        except OSError as detail:
             LOG.exception("failed write to file %s: %s", sourcefn, detail)
             raise
 

cloudinit/config/cc_mcollective.py

@@ -48,7 +48,7 @@ def configure(
     try:
         old_contents = util.load_binary_file(server_cfg, quiet=False)
         mcollective_config = ConfigObj(io.BytesIO(old_contents))
-    except IOError as e:
+    except OSError as e:
         if e.errno != errno.ENOENT:
             raise
         else:
@@ -85,7 +85,7 @@ def configure(
         # We got all our config as wanted we'll copy
         # the previous server.cfg and overwrite the old with our new one
         util.copy(server_cfg, "%s.old" % (server_cfg))
-    except IOError as e:
+    except OSError as e:
         if e.errno == errno.ENOENT:
             # Doesn't exist to copy...
             pass

cloudinit/config/cc_mounts.py

@@ -282,7 +282,7 @@ def setup_swapfile(fname, size=None, maxsize=None):
     if str(size).lower() == "auto":
         try:
             memsize = util.read_meminfo()["total"]
-        except IOError:
+        except OSError:
             LOG.debug("Not creating swap: failed to read meminfo")
             return
 

cloudinit/config/cc_power_state_change.py

@@ -48,7 +48,7 @@ def givecmdline(pid):
             return m.group(2)
         else:
             return util.load_text_file("/proc/%s/cmdline" % pid)
-    except IOError:
+    except OSError:
         return None
 
 
@@ -194,11 +194,11 @@ def fatal(msg):
                 msg = "cmdline changed for %s [now: %s]" % (pid, cmdline)
                 break
 
-        except IOError as ioerr:
+        except OSError as ioerr:
             if ioerr.errno in known_errnos:
                 msg = "pidfile gone [%d]" % ioerr.errno
             else:
-                fatal("IOError during wait: %s" % ioerr)
+                fatal("OSError during wait: %s" % ioerr)
             break
 
         except Exception as e:

cloudinit/config/cc_seed_random.py

@@ -39,7 +39,7 @@ def _decode(data, encoding=None):
     elif encoding.lower() in ["gzip", "gz"]:
         return util.decomp_gzip(data, quiet=False, decode=None)
     else:
-        raise IOError("Unknown random_seed encoding: %s" % (encoding))
+        raise OSError("Unknown random_seed encoding: %s" % (encoding))
 
 
 def handle_random_seed_command(command, required, update_env):

cloudinit/config/schema.py

@@ -1631,7 +1631,7 @@ def get_schema(schema_type: SchemaType = SchemaType.CLOUD_CONFIG) -> dict:
     full_schema = None
     try:
         full_schema = json.loads(load_text_file(schema_file))
-    except (IOError, OSError):
+    except OSError:
         LOG.warning(
             "Skipping %s schema validation. No JSON schema file found %s.",
             schema_type.value,
@@ -1771,7 +1771,7 @@ def get_processed_or_fallback_path(
 
     try:
         paths = read_cfg_paths(fetch_existing_datasource="trust")
-    except (IOError, OSError) as e:
+    except OSError as e:
         if e.errno == EACCES:
             LOG.debug(
                 "Using default instance-data/user-data paths for non-root user"

cloudinit/distros/__init__.py

@@ -378,7 +378,7 @@ def _write_network_state(self, network_state, renderer: Renderer):
     def _find_tz_file(self, tz):
         tz_file = os.path.join(self.tz_zone_dir, str(tz))
         if not os.path.isfile(tz_file):
-            raise IOError(
+            raise OSError(
                 "Invalid timezone %s, no file found at %s" % (tz, tz_file)
             )
         return tz_file
@@ -595,7 +595,7 @@ def update_hostname(self, hostname, fqdn, prev_hostname_fn):
         for fn in update_files:
             try:
                 self._write_hostname(hostname, fn)
-            except IOError:
+            except OSError:
                 util.logexc(
                     LOG, "Failed to write hostname %s to %s", hostname, fn
                 )
@@ -1169,14 +1169,14 @@ def write_doas_rules(self, user, rules, doas_file=None):
             contents = [util.make_header(), content]
             try:
                 util.write_file(doas_file, "\n".join(contents), mode=0o440)
-            except IOError as e:
+            except OSError as e:
                 util.logexc(LOG, "Failed to write doas file %s", doas_file)
                 raise e
         else:
             if content not in util.load_text_file(doas_file):
                 try:
                     util.append_file(doas_file, content)
-                except IOError as e:
+                except OSError as e:
                     util.logexc(
                         LOG, "Failed to append to doas file %s", doas_file
                     )
@@ -1231,7 +1231,7 @@ def ensure_sudo_dir(self, path, sudo_base="/etc/sudoers"):
                     sudoers_contents = "\n".join(lines)
                     util.append_file(sudo_base, sudoers_contents)
                 LOG.debug("Added '#includedir %s' to %s", path, sudo_base)
-            except IOError as e:
+            except OSError as e:
                 util.logexc(LOG, "Failed to write %s", sudo_base)
                 raise e
         util.ensure_dir(path, 0o750)
@@ -1264,14 +1264,14 @@ def write_sudo_rules(self, user, rules, sudo_file=None):
             ]
             try:
                 util.write_file(sudo_file, "\n".join(contents), 0o440)
-            except IOError as e:
+            except OSError as e:
                 util.logexc(LOG, "Failed to write sudoers file %s", sudo_file)
                 raise e
         else:
             if content not in util.load_text_file(sudo_file):
                 try:
                     util.append_file(sudo_file, content)
-                except IOError as e:
+                except OSError as e:
                     util.logexc(
                         LOG, "Failed to append to sudoers file %s", sudo_file
                     )
@@ -1493,7 +1493,7 @@ def _get_proc_stat_by_index(pid: int, field: int) -> Optional[int]:
                 )
                 return None
             return int(match.group(field))
-        except IOError as e:
+        except OSError as e:
             LOG.warning("Failed to load /proc/%s/stat. %s", pid, e)
         except IndexError:
             LOG.warning(

cloudinit/distros/alpine.py

@@ -88,7 +88,7 @@ def _write_hostname(self, hostname, filename):
             # Try to update the previous one
             # so lets see if we can read it first.
             conf = self._read_hostname_conf(filename)
-        except IOError:
+        except OSError:
             create_hostname_file = util.get_cfg_option_bool(
                 self._cfg, "create_hostname_file", True
             )
@@ -118,7 +118,7 @@ def _read_hostname(self, filename, default=None):
         try:
             conf = self._read_hostname_conf(filename)
             hostname = conf.hostname
-        except IOError:
+        except OSError:
             pass
         if not hostname:
             return default
@@ -412,7 +412,7 @@ def add_user(self, name, **kwargs) -> bool:
                 util.write_file(
                     shadow_file, shadow_contents, omode="w", preserve_mode=True
                 )
-            except IOError as e:
+            except OSError as e:
                 util.logexc(LOG, "Failed to update %s file", shadow_file)
                 raise e
         else:
@@ -530,7 +530,7 @@ def expire_passwd(self, user):
                         omode="w",
                         preserve_mode=True,
                     )
-                except IOError as e:
+                except OSError as e:
                     util.logexc(LOG, "Failed to update %s file", shadow_file)
                     raise e
             else:

cloudinit/distros/aosc.py

@@ -121,7 +121,7 @@ def read_locale_conf(sys_path):
     try:
         contents = util.load_text_file(sys_path).splitlines()
         exists = True
-    except IOError:
+    except OSError:
         contents = []
     return (exists, SysConf(contents))
 

cloudinit/distros/arch.py

@@ -64,7 +64,7 @@ def _write_hostname(self, hostname, filename):
             # Try to update the previous one
             # so lets see if we can read it first.
             conf = self._read_hostname_conf(filename)
-        except IOError:
+        except OSError:
             create_hostname_file = util.get_cfg_option_bool(
                 self._cfg, "create_hostname_file", True
             )
@@ -94,7 +94,7 @@ def _read_hostname(self, filename, default=None):
         try:
             conf = self._read_hostname_conf(filename)
             hostname = conf.hostname
-        except IOError:
+        except OSError:
             pass
         if not hostname:
             return default

cloudinit/distros/debian.py

@@ -129,7 +129,7 @@ def _write_hostname(self, hostname, filename):
             # Try to update the previous one
             # so lets see if we can read it first.
             conf = self._read_hostname_conf(filename)
-        except IOError:
+        except OSError:
             create_hostname_file = util.get_cfg_option_bool(
                 self._cfg, "create_hostname_file", True
             )
@@ -159,7 +159,7 @@ def _read_hostname(self, filename, default=None):
         try:
             conf = self._read_hostname_conf(filename)
             hostname = conf.hostname
-        except IOError:
+        except OSError:
             pass
         if not hostname:
             return default

cloudinit/distros/freebsd.py

@@ -219,7 +219,7 @@ def apply_locale(self, locale, out_fn=None):
             util.logexc(LOG, "Failed to apply locale %s", locale)
             try:
                 util.copy(self.login_conf_fn_bak, self.login_conf_fn)
-            except IOError:
+            except OSError:
                 util.logexc(
                     LOG, "Failed to restore %s backup", self.login_conf_fn
                 )

cloudinit/distros/gentoo.py

@@ -63,7 +63,7 @@ def _write_hostname(self, hostname, filename):
             # Try to update the previous one
             # so lets see if we can read it first.
             conf = self._read_hostname_conf(filename)
-        except IOError:
+        except OSError:
             create_hostname_file = util.get_cfg_option_bool(
                 self._cfg, "create_hostname_file", True
             )
@@ -98,7 +98,7 @@ def _read_hostname(self, filename, default=None):
         try:
             conf = self._read_hostname_conf(filename)
             hostname = conf.hostname
-        except IOError:
+        except OSError:
             pass
         if not hostname:
             return default

cloudinit/distros/opensuse.py

@@ -169,7 +169,7 @@ def _read_hostname(self, filename, default=None):
             try:
                 conf = self._read_hostname_conf(filename)
                 hostname = conf.hostname
-            except IOError:
+            except OSError:
                 pass
             if not hostname:
                 return default
@@ -242,7 +242,7 @@ def _write_hostname(self, hostname, filename):
                 # Try to update the previous one
                 # so lets see if we can read it first.
                 conf = self._read_hostname_conf(filename)
-            except IOError:
+            except OSError:
                 if create_hostname_file:
                     pass
                 else:

cloudinit/distros/parsers/hostname.py

@@ -71,5 +71,5 @@ def _parse(self, contents):
             entries.append(("hostname", [head, tail]))
             hostnames_found.add(head)
         if len(hostnames_found) > 1:
-            raise IOError("Multiple hostnames (%s) found!" % (hostnames_found))
+            raise OSError("Multiple hostnames (%s) found!" % (hostnames_found))
         return entries

cloudinit/distros/parsers/resolv_conf.py

@@ -148,7 +148,7 @@ def _parse(self, contents):
             try:
                 (cfg_opt, cfg_values) = head.split(None, 1)
             except (IndexError, ValueError) as e:
-                raise IOError(
+                raise OSError(
                     "Incorrectly formatted resolv.conf line %s" % (i + 1)
                 ) from e
             if cfg_opt not in [
@@ -158,6 +158,6 @@ def _parse(self, contents):
                 "sortlist",
                 "options",
             ]:
-                raise IOError("Unexpected resolv.conf option %s" % (cfg_opt))
+                raise OSError("Unexpected resolv.conf option %s" % (cfg_opt))
             entries.append(("option", [cfg_opt, cfg_values, tail]))
         return entries

cloudinit/distros/rhel_util.py

@@ -45,6 +45,6 @@ def read_sysconfig_file(fn):
     try:
         contents = util.load_text_file(fn).splitlines()
         exists = True
-    except IOError:
+    except OSError:
         contents = []
     return (exists, SysConf(contents))