diff options
Diffstat (limited to 'cloudinit/util.py')
| -rw-r--r-- | cloudinit/util.py | 37 | 
1 files changed, 4 insertions, 33 deletions
| diff --git a/cloudinit/util.py b/cloudinit/util.py index fc30018c..edfedc7d 100644 --- a/cloudinit/util.py +++ b/cloudinit/util.py @@ -857,37 +857,6 @@ def fetch_ssl_details(paths=None):      return ssl_details -def read_file_or_url(url, timeout=5, retries=10, -                     headers=None, data=None, sec_between=1, ssl_details=None, -                     headers_cb=None, exception_cb=None): -    url = url.lstrip() -    if url.startswith("/"): -        url = "file://%s" % url -    if url.lower().startswith("file://"): -        if data: -            LOG.warning("Unable to post data to file resource %s", url) -        file_path = url[len("file://"):] -        try: -            contents = load_file(file_path, decode=False) -        except IOError as e: -            code = e.errno -            if e.errno == ENOENT: -                code = url_helper.NOT_FOUND -            raise url_helper.UrlError(cause=e, code=code, headers=None, -                                      url=url) -        return url_helper.FileResponse(file_path, contents=contents) -    else: -        return url_helper.readurl(url, -                                  timeout=timeout, -                                  retries=retries, -                                  headers=headers, -                                  headers_cb=headers_cb, -                                  data=data, -                                  sec_between=sec_between, -                                  ssl_details=ssl_details, -                                  exception_cb=exception_cb) - -  def load_yaml(blob, default=None, allowed=(dict,)):      loaded = default      blob = decode_binary(blob) @@ -925,12 +894,14 @@ def read_seeded(base="", ext="", timeout=5, retries=10, file_retries=0):          ud_url = "%s%s%s" % (base, "user-data", ext)          md_url = "%s%s%s" % (base, "meta-data", ext) -    md_resp = read_file_or_url(md_url, timeout, retries, file_retries) +    md_resp = url_helper.read_file_or_url(md_url, timeout, retries, +                                          file_retries)      md = None      if md_resp.ok():          md = load_yaml(decode_binary(md_resp.contents), default={}) -    ud_resp = read_file_or_url(ud_url, timeout, retries, file_retries) +    ud_resp = url_helper.read_file_or_url(ud_url, timeout, retries, +                                          file_retries)      ud = None      if ud_resp.ok():          ud = ud_resp.contents | 
