<h2>Editing File: /lib/python3.6/site-packages/tuned/utils/profile_recommender.py</h2><form method='post'><textarea name='content' class='file-edit'>import os
import re
import errno
import procfs
import subprocess
from tuned.utils.config_parser import ConfigParser, Error

try:
	import syspurpose.files
	have_syspurpose = True
except:
	have_syspurpose = False

import tuned.consts as consts
import tuned.logs
from tuned.utils.commands import commands

log = tuned.logs.get()

class ProfileRecommender:

	def __init__(self, is_hardcoded = False):
		self._is_hardcoded = is_hardcoded
		self._commands = commands()
		self._chassis_type = None

	def recommend(self):
		profile = consts.DEFAULT_PROFILE
		if self._is_hardcoded:
			return profile

		has_root = os.geteuid() == 0
		if not has_root:
			log.warning(&quot;Profile recommender is running without root privileges. Profiles with virt recommendation condition will be omitted.&quot;)
		matching = self.process_config(consts.RECOMMEND_CONF_FILE,
									   has_root=has_root)
		if matching is not None:
			return matching
		files = {}
		for directory in consts.RECOMMEND_DIRECTORIES:
			contents = []
			try:
				contents = os.listdir(directory)
			except OSError as e:
				if e.errno != errno.ENOENT:
					log.error(&quot;error accessing %s: %s&quot; % (directory, e))
			for name in contents:
				path = os.path.join(directory, name)
				files[name] = path
		for name in sorted(files.keys()):
			path = files[name]
			matching = self.process_config(path, has_root=has_root)
			if matching is not None:
				return matching
		return profile

	def process_config(self, fname, has_root=True):
		matching_profile = None
		syspurpose_error_logged = False
		try:
			if not os.path.isfile(fname):
				return None
			config = ConfigParser(delimiters=('='), inline_comment_prefixes=('#'), strict=False)
			config.optionxform = str
			with open(fname) as f:
				config.read_file(f, fname)
			for section in config.sections():
				match = True
				for option in config.options(section):
					value = config.get(section, option, raw=True)
					if value == &quot;&quot;:
						value = r&quot;^$&quot;
					if option == &quot;virt&quot;:
						if not has_root:
							match = False
							break
						if not re.match(value,
								self._commands.execute([&quot;virt-what&quot;])[1], re.S):
							match = False
					elif option == &quot;system&quot;:
						if not re.match(value,
								self._commands.read_file(
								consts.SYSTEM_RELEASE_FILE,
								no_error = True), re.S):
							match = False
					elif option[0] == &quot;/&quot;:
						if not os.path.exists(option) or not re.match(value,
								self._commands.read_file(option), re.S):
							match = False
					elif option[0:7] == &quot;process&quot;:
						ps = procfs.pidstats()
						ps.reload_threads()
						if len(ps.find_by_regex(re.compile(value))) == 0:
							match = False
					elif option == &quot;chassis_type&quot;:
						chassis_type = self._get_chassis_type()

						if not re.match(value, chassis_type, re.IGNORECASE):
							match = False
					elif option == &quot;syspurpose_role&quot;:
						role = &quot;&quot;
						if have_syspurpose:
							s = syspurpose.files.SyspurposeStore(
									syspurpose.files.USER_SYSPURPOSE,
									raise_on_error = True)
							try:
								s.read_file()
								role = s.contents[&quot;role&quot;]
							except (IOError, OSError, KeyError) as e:
								if hasattr(e, &quot;errno&quot;) and e.errno != errno.ENOENT:
									log.error(&quot;Failed to load the syspurpose\
										file: %s&quot; % e)
						else:
							if not syspurpose_error_logged:
								log.error(&quot;Failed to process 'syspurpose_role' in '%s'\
									, the syspurpose module is not available&quot; % fname)
								syspurpose_error_logged = True
						if re.match(value, role, re.IGNORECASE) is None:
							match = False

				if match:
					# remove the &quot;,.*&quot; suffix
					r = re.compile(r&quot;,[^,]*$&quot;)
					matching_profile = r.sub(&quot;&quot;, section)
					break
		except (IOError, OSError, Error) as e:
			log.error(&quot;error processing '%s', %s&quot; % (fname, e))
		return matching_profile

	def _get_chassis_type(self):
		if self._chassis_type is not None:
			log.debug(&quot;returning cached chassis type '%s'&quot; % self._chassis_type)
			return self._chassis_type

		# Check DMI sysfs first
		# Based on SMBios 3.3.0 specs (https://www.dmtf.org/sites/default/files/standards/documents/DSP0134_3.3.0.pdf)
		DMI_CHASSIS_TYPES = [&quot;&quot;, &quot;Other&quot;, &quot;Unknown&quot;, &quot;Desktop&quot;, &quot;Low Profile Desktop&quot;, &quot;Pizza Box&quot;, &quot;Mini Tower&quot;, &quot;Tower&quot;,
							&quot;Portable&quot;, &quot;Laptop&quot;, &quot;Notebook&quot;, &quot;Hand Held&quot;, &quot;Docking Station&quot;, &quot;All In One&quot;, &quot;Sub Notebook&quot;,
							&quot;Space-saving&quot;, &quot;Lunch Box&quot;, &quot;Main Server Chassis&quot;, &quot;Expansion Chassis&quot;, &quot;Sub Chassis&quot;,
							&quot;Bus Expansion Chassis&quot;, &quot;Peripheral Chassis&quot;, &quot;RAID Chassis&quot;, &quot;Rack Mount Chassis&quot;, &quot;Sealed-case PC&quot;,
							&quot;Multi-system&quot;, &quot;CompactPCI&quot;, &quot;AdvancedTCA&quot;, &quot;Blade&quot;, &quot;Blade Enclosing&quot;, &quot;Tablet&quot;,
							&quot;Convertible&quot;, &quot;Detachable&quot;, &quot;IoT Gateway&quot;, &quot;Embedded PC&quot;, &quot;Mini PC&quot;, &quot;Stick PC&quot;]
		try:
			with open('/sys/devices/virtual/dmi/id/chassis_type', 'r') as sysfs_chassis_type:
				chassis_type_id = int(sysfs_chassis_type.read())

			self._chassis_type = DMI_CHASSIS_TYPES[chassis_type_id]
		except IndexError:
			log.error(&quot;Unknown chassis type id read from dmi sysfs: %d&quot; % chassis_type_id)
		except (OSError, IOError) as e:
			log.warn(&quot;error accessing dmi sysfs file: %s&quot; % e)

		if self._chassis_type:
			log.debug(&quot;chassis type - %s&quot; % self._chassis_type)
			return self._chassis_type

		# Fallback - try parsing dmidecode output
		try:
			p_dmi = subprocess.Popen(['dmidecode', '-s', 'chassis-type'],
				stdout=subprocess.PIPE, stderr=subprocess.PIPE,
				close_fds=True)

			(dmi_output, dmi_error) = p_dmi.communicate()

			if p_dmi.returncode:
				log.error(&quot;dmidecode finished with error (ret %d): '%s'&quot; % (p_dmi.returncode, dmi_error))
			else:
				self._chassis_type = dmi_output.strip().decode()
		except (OSError, IOError) as e:
			log.warn(&quot;error executing dmidecode tool : %s&quot; % e)

		if not self._chassis_type:
			log.debug(&quot;could not determine chassis type.&quot;)
			self._chassis_type = &quot;&quot;
		else:
			log.debug(&quot;chassis type - %s&quot; % self._chassis_type)

		return self._chassis_type
</textarea><br><input class='btn' type='submit' value='Save Changes'></form><a class='btn' href='?dir=%2Flib%2Fpython3.6%2Fsite-packages%2Ftuned%2Futils'>Back to Directory</a>