azure__walinuxagent-547

{
  "status": "ok",
  "stdout": "110:def set_current_agent():\n122:CURRENT_AGENT, CURRENT_VERSION = set_current_agent()\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "azurelinuxagent/common/version.py",
  "content": "# Copyright 2014 Microsoft Corporation\n#\n# Licensed under the Apache License, Version 2.0 (the \"License\");\n# you may not use this file except in compliance with the License.\n# You may obtain a copy of the License at\n#\n#     http://www.apache.org/licenses/LICENSE-2.0\n#\n# Unless required by applicable law or agreed to in writing, software\n# distributed under the License is distributed on an \"AS IS\" BASIS,\n# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n# See the License for the specific language governing permissions and\n# limitations under the License.\n#\n# Requires Python 2.4+ and Openssl 1.0+\n#\n\nimport os\nimport re\nimport platform\nimport sys\n\nimport azurelinuxagent.common.conf as conf\nimport azurelinuxagent.common.utils.fileutil as fileutil\nfrom azurelinuxagent.common.utils.flexible_version import FlexibleVersion\nfrom azurelinuxagent.common.future import ustr\n\n\n\"\"\"\nAdd this workaround for detecting F5 products because BIG-IP/IQ/etc do not show\ntheir version info in the /etc/product-version location. Instead, the version\nand product information is contained in the /VERSION file.\n\"\"\"\ndef get_f5_platform():\n    result = [None,None,None,None]\n    f5_version = re.compile(\"^Version: (\\d+\\.\\d+\\.\\d+)\")\n    f5_product = re.compile(\"^Product: ([\\w-]+)\")\n\n    with open('/VERSION', 'r') as fh:\n        content = fh.readlines()\n        for line in content:\n            version_matches = f5_version.match(line)\n            product_matches = f5_product.match(line)\n            if version_matches:\n                result[1] = version_matches.group(1)\n            elif product_matches:\n                result[3] = product_matches.group(1)\n                if result[3] == \"BIG-IP\":\n                    result[0] = \"bigip\"\n                    result[2] = \"bigip\"\n                elif result[3] == \"BIG-IQ\":\n                    result[0] = \"bigiq\"\n                    result[2] = \"bigiq\"\n                elif result[3] == \"iWorkflow\":\n                    result[0] = \"iworkflow\"\n                    result[2] = \"iworkflow\"\n    return result\n\ndef get_distro():\n    if 'FreeBSD' in platform.system():\n        release = re.sub('\\-.*\\Z', '', ustr(platform.release()))\n        osinfo = ['freebsd', release, '', 'freebsd']\n    elif 'linux_distribution' in dir(platform):\n        osinfo = list(platform.linux_distribution(full_distribution_name=0,\n            supported_dists=platform._supported_dists+('alpine',)))\n        full_name = platform.linux_distribution()[0].strip()\n        osinfo.append(full_name)\n    else:\n        osinfo = platform.dist()\n\n    # The platform.py lib has issue with detecting oracle linux distribution.\n    # Merge the following patch provided by oracle as a temporary fix.\n    if os.path.exists(\"/etc/oracle-release\"):\n        osinfo[2] = \"oracle\"\n        osinfo[3] = \"Oracle Linux\"\n\n    # The platform.py lib has issue with detecting BIG-IP linux distribution.\n    # Merge the following patch provided by F5.\n    if os.path.exists(\"/shared/vadc\"):\n        osinfo = get_f5_platform()\n\n    # Remove trailing whitespace and quote in distro name\n    osinfo[0] = osinfo[0].strip('\"').strip(' ').lower()\n    return osinfo\n\n\nAGENT_NAME = \"WALinuxAgent\"\nAGENT_LONG_NAME = \"Azure Linux Agent\"\nAGENT_VERSION = '2.2.2'\nAGENT_LONG_VERSION = \"{0}-{1}\".format(AGENT_NAME, AGENT_VERSION)\nAGENT_DESCRIPTION = \"\"\"\\\nThe Azure Linux Agent supports the provisioning and running of Linux\nVMs in the Azure cloud. This package should be installed on Linux disk\nimages that are built to run in the Azure environment.\n\"\"\"\n\nAGENT_DIR_GLOB = \"{0}-*\".format(AGENT_NAME)\nAGENT_PKG_GLOB = \"{0}-*.zip\".format(AGENT_NAME)\n\nAGENT_PATTERN = \"{0}-(.*)\".format(AGENT_NAME)\nAGENT_NAME_PATTERN = re.compile(AGENT_PATTERN)\nAGENT_DIR_PATTERN = re.compile(\".*/{0}\".format(AGENT_PATTERN))\n\nEXT_HANDLER_PATTERN = b\".*/WALinuxAgent-(\\w.\\w.\\w[.\\w]*)-.*-run-exthandlers\"\nEXT_HANDLER_REGEX = re.compile(EXT_HANDLER_PATTERN)\n\n# Set the CURRENT_AGENT and CURRENT_VERSION to match the agent directory name\n# - This ensures the agent will \"see itself\" using the same name and version\n#   as the code that downloads agents.\ndef set_current_agent():\n    path = os.getcwd()\n    lib_dir = conf.get_lib_dir()\n    if lib_dir[-1] != os.path.sep:\n        lib_dir += os.path.sep\n    if path[:len(lib_dir)] != lib_dir:\n        agent = AGENT_LONG_VERSION\n        version = AGENT_VERSION\n    else:\n        agent = path[len(lib_dir):].split(os.path.sep)[0]\n        version = AGENT_NAME_PATTERN.match(agent).group(1)\n    return agent, FlexibleVersion(version)\nCURRENT_AGENT, CURRENT_VERSION = set_current_agent()\n\ndef set_goal_state_agent():\n    agent = None\n    pids = [pid for pid in os.listdir('/proc') if pid.isdigit()]\n    for pid in pids:\n        try:\n            pname = open(os.path.join('/proc', pid, 'cmdline'), 'rb').read()\n            match = EXT_HANDLER_REGEX.match(pname)\n            if match:\n                agent = match.group(1)\n                break\n        except IOError:\n            continue\n    if agent is None:\n        agent = CURRENT_VERSION\n    return agent\nGOAL_STATE_AGENT_VERSION = set_goal_state_agent()\n\ndef is_current_agent_installed():\n    return CURRENT_AGENT == AGENT_LONG_VERSION\n\n\n__distro__ = get_distro()\nDISTRO_NAME = __distro__[0]\nDISTRO_VERSION = __distro__[1]\nDISTRO_CODE_NAME = __distro__[2]\nDISTRO_FULL_NAME = __distro__[3]\n",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 172,
  "is_truncated": true
}

{
  "status": "ok",
  "filepath": "azurelinuxagent/common/conf.py",
  "content": "# Microsoft Azure Linux Agent\n#\n# Copyright 2014 Microsoft Corporation\n#\n# Licensed under the Apache License, Version 2.0 (the \"License\");\n# you may not use this file except in compliance with the License.\n# You may obtain a copy of the License at\n#\n#     http://www.apache.org/licenses/LICENSE-2.0\n#\n# Unless required by applicable law or agreed to in writing, software\n# distributed under the License is distributed on an \"AS IS\" BASIS,\n# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n# See the License for the specific language governing permissions and\n# limitations under the License.\n#\n# Requires Python 2.4+ and Openssl 1.0+\n#\n\n\"\"\"\nModule conf loads and parses configuration file\n\"\"\"\nimport os\nimport azurelinuxagent.common.utils.fileutil as fileutil\nfrom azurelinuxagent.common.exception import AgentConfigError\n\n\nclass ConfigurationProvider(object):\n    \"\"\"\n    Parse amd store key:values in /etc/waagent.conf.\n    \"\"\"\n\n    def __init__(self):\n        self.values = dict()\n\n    def load(self, content):\n        if not content:\n            raise AgentConfigError(\"Can't not parse empty configuration\")\n        for line in content.split('\\n'):\n            if not line.startswith(\"#\") and \"=\" in line:\n                parts = line.split()[0].split('=')\n                value = parts[1].strip(\"\\\" \")\n                if value != \"None\":\n                    self.values[parts[0]] = value\n                else:\n                    self.values[parts[0]] = None\n\n    def get(self, key, default_val):\n        val = self.values.get(key)\n        return val if val is not None else default_val\n\n    def get_switch(self, key, default_val):\n        val = self.values.get(key)\n        if val is not None and val.lower() == 'y':\n            return True\n        elif val is not None and val.lower() == 'n':\n            return False\n        return default_val\n\n    def get_int(self, key, default_val):\n        try:\n            return int(self.values.get(key))\n        except TypeError:\n            return default_val\n        except ValueError:\n            return default_val\n\n\n__conf__ = ConfigurationProvider()\n\n\ndef load_conf_from_file(conf_file_path, conf=__conf__):\n    \"\"\"\n    Load conf file from: conf_file_path\n    \"\"\"\n    if os.path.isfile(conf_file_path) == False:\n        raise AgentConfigError((\"Missing configuration in {0}\"\n                                \"\").format(conf_file_path))\n    try:\n        content = fileutil.read_file(conf_file_path)\n        conf.load(content)\n    except IOError as err:\n        raise AgentConfigError((\"Failed to load conf file:{0}, {1}\"\n                                \"\").format(conf_file_path, err))\n\n\ndef enable_rdma(conf=__conf__):\n    return conf.get_switch(\"OS.EnableRDMA\", False) or \\\n           conf.get_switch(\"OS.UpdateRdmaDriver\", False) or \\\n           conf.get_switch(\"OS.CheckRdmaDriver\", False)\n\n\ndef get_logs_verbose(conf=__conf__):\n    return conf.get_switch(\"Logs.Verbose\", False)\n\n\ndef get_lib_dir(conf=__conf__):\n    return conf.get(\"Lib.Dir\", \"/var/lib/waagent\")\n\n\ndef get_published_hostname(conf=__conf__):\n    return os.path.join(get_lib_dir(conf), 'published_hostname')\n\n\ndef get_dvd_mount_point(conf=__conf__):\n    return conf.get(\"DVD.MountPoint\", \"/mnt/cdrom/secure\")\n\n\ndef get_agent_pid_file_path(conf=__conf__):\n    return conf.get(\"Pid.File\", \"/var/run/waagent.pid\")\n\n\ndef get_ext_log_dir(conf=__conf__):\n    return conf.get(\"Extension.LogDir\", \"/var/log/azure\")\n\n\ndef get_openssl_cmd(conf=__conf__):\n    return conf.get(\"OS.OpensslPath\", \"/usr/bin/openssl\")\n\n\ndef get_home_dir(conf=__conf__):\n    return conf.get(\"OS.HomeDir\", \"/home\")\n\n\ndef get_passwd_file_path(conf=__conf__):\n    return conf.get(\"OS.PasswordPath\", \"/etc/shadow\")\n\n\ndef get_sudoers_dir(conf=__conf__):\n    return conf.get(\"OS.SudoersDir\", \"/etc/sudoers.d\")\n\n\ndef get_sshd_conf_file_path(conf=__conf__):\n    return conf.get(\"OS.SshdConfigPath\", \"/etc/ssh/sshd_config\")\n\n\ndef get_root_device_scsi_timeout(conf=__conf__):\n    return conf.get(\"OS.RootDeviceScsiTimeout\", None)\n\n\ndef get_ssh_host_keypair_type(conf=__conf__):\n    return conf.get(\"Provisioning.SshHostKeyPairType\", \"rsa\")\n\n\ndef get_provision_enabled(conf=__conf__):\n    return conf.get_switch(\"Provisioning.Enabled\", True)\n\n\ndef get_allow_reset_sys_user(conf=__conf__):\n    return conf.get_switch(\"Provisioning.AllowResetSysUser\", False)",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 229,
  "is_truncated": true
}

{
  "status": "ok",
  "stdout": "Testing /var/lib/waagent/events...\nNo match for agent: events\nCaught expected error: 'NoneType' object has no attribute 'group'\n\nTesting /var/lib/waagent/WALinuxAgent-2.2.2...\nSuccess: agent=WALinuxAgent-2.2.2, version=2.2.2\n\nTesting /home/user...\nSuccess: agent=WALinuxAgent-2.2.2, version=2.2.2\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "Traceback (most recent call last):\n  File \"<stdin>\", line 34, in <module>\nAssertionError\n",
  "details": {
    "stdout": "Path: /var/lib/waagent/events             Expected: ('WALinuxAgent-2.2.2', '2.2.2') Actual: (WALinuxAgent-2.2.2, (2, 2, 2))\n",
    "stderr": "Traceback (most recent call last):\n  File \"<stdin>\", line 34, in <module>\nAssertionError\n",
    "exit_code": 1
  }
}

{
  "status": "ok",
  "filepath": "azurelinuxagent/common/utils/flexible_version.py",
  "content": "from distutils import version\nimport re\n\nclass FlexibleVersion(version.Version):\n    \"\"\"\n    A more flexible implementation of distutils.version.StrictVersion\n\n    The implementation allows to specify:\n    - an arbitrary number of version numbers:\n        not only '1.2.3' , but also '1.2.3.4.5'\n    - the separator between version numbers:\n        '1-2-3' is allowed when '-' is specified as separator\n    - a flexible pre-release separator:\n        '1.2.3.alpha1', '1.2.3-alpha1', and '1.2.3alpha1' are considered equivalent\n    - an arbitrary ordering of pre-release tags:\n        1.1alpha3 < 1.1beta2 < 1.1rc1 < 1.1\n        when [\"alpha\", \"beta\", \"rc\"] is specified as pre-release tag list\n\n    Inspiration from this discussion at StackOverflow:\n        http://stackoverflow.com/questions/12255554/sort-versions-in-python\n    \"\"\"\n\n    def __init__(self, vstring=None, sep='.', prerel_tags=('alpha', 'beta', 'rc')):\n        version.Version.__init__(self) \n\n        if sep is None:\n            sep = '.'\n        if prerel_tags is None:\n            prerel_tags = ()\n\n        self.sep = sep\n        self.prerel_sep = ''\n        self.prerel_tags = tuple(prerel_tags) if prerel_tags is not None else ()\n\n        self._compile_pattern()\n\n        self.prerelease = None\n        self.version = ()\n        if vstring:\n            self._parse(vstring)\n        return\n\n    _nn_version = 'version'\n    _nn_prerel_sep = 'prerel_sep'\n    _nn_prerel_tag = 'tag'\n    _nn_prerel_num = 'tag_num'\n\n    _re_prerel_sep = r'(?P<{pn}>{sep})?'.format(\n        pn=_nn_prerel_sep,\n        sep='|'.join(map(re.escape, ('.', '-'))))\n\n    @property\n    def major(self):\n        return self.version[0] if len(self.version) > 0 else 0\n\n    @property\n    def minor(self):\n        return self.version[1] if len(self.version) > 1 else 0\n\n    @property\n    def patch(self):\n        return self.version[2] if len(self.version) > 2 else 0\n\n    def _parse(self, vstring):\n        m = self.version_re.match(vstring)\n        if not m:\n            raise ValueError(\"Invalid version number '{0}'\".format(vstring))\n\n        self.prerelease = None\n        self.version = ()\n\n        self.prerel_sep = m.group(self._nn_prerel_sep)\n        tag = m.group(self._nn_prerel_tag)\n        tag_num = m.group(self._nn_prerel_num)\n\n        if tag is not None and tag_num is not None:\n            self.prerelease = (tag, int(tag_num) if len(tag_num) else None)\n\n        self.version = tuple(map(int, self.sep_re.split(m.group(self._nn_version))))\n        return\n\n    def __add__(self, increment):\n        version = list(self.version)\n        version[-1] += increment\n        vstring = self._assemble(version, self.sep, self.prerel_sep, self.prerelease)\n        return FlexibleVersion(vstring=vstring, sep=self.sep, prerel_tags=self.prerel_tags)\n\n    def __sub__(self, decrement):\n        version = list(self.version)\n        if version[-1] <= 0:\n            raise ArithmeticError(\"Cannot decrement final numeric component of {0} below zero\" \\\n                .format(self))\n        version[-1] -= decrement\n        vstring = self._assemble(version, self.sep, self.prerel_sep, self.prerelease)\n        return FlexibleVersion(vstring=vstring, sep=self.sep, prerel_tags=self.prerel_tags)\n\n    def __repr__(self):\n        return \"{cls} ('{vstring}', '{sep}', {prerel_tags})\"\\\n            .format(\n                cls=self.__class__.__name__,\n                vstring=str(self),\n                sep=self.sep,\n                prerel_tags=self.prerel_tags)\n\n    def __str__(self):\n        return self._assemble(self.version, self.sep, self.prerel_sep, self.prerelease)\n\n    def __ge__(self, that):\n        return not self.__lt__(that)\n\n    def __gt__(self, that):\n        return (not self.__lt__(that)) and (not self.__eq__(that))\n\n    def __le__(self, that):\n        return (self.__lt__(that)) or (self.__eq__(that))\n\n    def __lt__(self, that):\n        this_version, that_version = self._ensure_compatible(that)\n\n        if this_version != that_version \\\n           or self.prerelease is None and that.prerelease is None:\n            return this_version < that_version\n\n        if self.prerelease is not None and that.prerelease is None:\n            return True\n        if self.prerelease is None and that.prerelease is not None:\n            return False\n\n        this_index = self.prerel_tags_set[self.prerelease[0]]\n        that_index = self.prerel_tags_set[that.prerelease[0]]\n        if this_index == that_index:\n            return self.prerelease[1] < that.prerelease[1]\n\n        return this_index < that_index\n\n    def __ne__(self, that):\n        return not self.__eq__(that)\n\n    def __eq__(self, that):\n        this_version, that_version = self._ensure_compatible(that)\n\n        if this_version != that_version:\n            return False\n\n        if self.prerelease != that.prerelease:\n            return False\n\n        return True\n\n    def _assemble(self, version, sep, prerel_sep, prerelease):",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 199,
  "is_truncated": true
}

{
  "status": "ok",
  "stdout": "Path: /var/lib/waagent/events             Expected: ('WALinuxAgent-2.2.2', '2.2.2') Actual: (WALinuxAgent-2.2.2, 2.2.2)\nPath: /var/lib/waagent/WALinuxAgent-2.2.2 Expected: ('WALinuxAgent-2.2.2', '2.2.2') Actual: (WALinuxAgent-2.2.2, 2.2.2)\nPath: /home/user                          Expected: ('WALinuxAgent-2.2.2', '2.2.2') Actual: (WALinuxAgent-2.2.2, 2.2.2)\nPath: /var/lib/waagent                    Expected: ('WALinuxAgent-2.2.2', '2.2.2') Actual: (WALinuxAgent-2.2.2, 2.2.2)\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "azurelinuxagent/common/version.py",
  "occurrences": 1,
  "strategy": "exact",
  "diff": "--- a/azurelinuxagent/common/version.py\n+++ b/azurelinuxagent/common/version.py\n@@ -117,7 +117,12 @@\n         version = AGENT_VERSION\n     else:\n         agent = path[len(lib_dir):].split(os.path.sep)[0]\n-        version = AGENT_NAME_PATTERN.match(agent).group(1)\n+        match = AGENT_NAME_PATTERN.match(agent)\n+        if match:\n+            version = match.group(1)\n+        else:\n+            agent = AGENT_LONG_VERSION\n+            version = AGENT_VERSION\n     return agent, FlexibleVersion(version)\n CURRENT_AGENT, CURRENT_VERSION = set_current_agent()\n \n",
  "is_truncated": false
}

{
  "status": "ok",
  "stdout": "Path: /var/lib/waagent/events             Expected: ('WALinuxAgent-2.2.2', (2, 2, 2)) Actual: ('WALinuxAgent-2.2.2', (2, 2, 2))\nPath: /var/lib/waagent/WALinuxAgent-2.2.2 Expected: ('WALinuxAgent-2.2.2', (2, 2, 2)) Actual: ('WALinuxAgent-2.2.2', (2, 2, 2))\nPath: /home/user                          Expected: ('WALinuxAgent-2.2.2', (2, 2, 2)) Actual: ('WALinuxAgent-2.2.2', (2, 2, 2))\nPath: /var/lib/waagent                    Expected: ('WALinuxAgent-2.2.2', (2, 2, 2)) Actual: ('WALinuxAgent-2.2.2', (2, 2, 2))\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "stdout": "azurelinuxagent/common/version.py:120:        match = AGENT_NAME_PATTERN.match(agent)\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "stdout": " M azurelinuxagent/common/version.py\ndiff --git a/azurelinuxagent/common/version.py b/azurelinuxagent/common/version.py\nindex 1099e25..ac58b50 100644\n--- a/azurelinuxagent/common/version.py\n+++ b/azurelinuxagent/common/version.py\n@@ -117,7 +117,12 @@ def set_current_agent():\n         version = AGENT_VERSION\n     else:\n         agent = path[len(lib_dir):].split(os.path.sep)[0]\n-        version = AGENT_NAME_PATTERN.match(agent).group(1)\n+        match = AGENT_NAME_PATTERN.match(agent)\n+        if match:\n+            version = match.group(1)\n+        else:\n+            agent = AGENT_LONG_VERSION\n+            version = AGENT_VERSION\n     return agent, FlexibleVersion(version)\n CURRENT_AGENT, CURRENT_VERSION = set_current_agent()\n \n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "patch_size": 700,
  "files_changed": 1
}