FM / functions

/usr/lib/python3.6/site-packages/tuned/profiles/functions/

/usr/lib/python3.6/site-packages/tuned/profiles/functions

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
base.py	1040	0644	edit dl rm
functions.py	2146	0644	edit dl rm
function_assertion.py	767	0644	edit dl rm
function_assertion_non_equal.py	811	0644	edit dl rm
function_calc_isolated_cores.py	1643	0644	edit dl rm
function_check_net_queue_count.py	650	0644	edit dl rm
function_cpuinfo_check.py	1011	0644	edit dl rm
function_cpulist2devs.py	460	0644	edit dl rm
function_cpulist2hex.py	470	0644	edit dl rm
function_cpulist2hex_invert.py	624	0644	edit dl rm
function_cpulist_invert.py	659	0644	edit dl rm
function_cpulist_online.py	651	0644	edit dl rm
function_cpulist_pack.py	637	0644	edit dl rm
function_cpulist_present.py	691	0644	edit dl rm
function_cpulist_unpack.py	511	0644	edit dl rm
function_exec.py	487	0644	edit dl rm
function_hex2cpulist.py	472	0644	edit dl rm
function_kb2s.py	405	0644	edit dl rm
function_regex_search_ternary.py	554	0644	edit dl rm
function_s2kb.py	417	0644	edit dl rm
function_strip.py	406	0644	edit dl rm
function_virt_check.py	595	0644	edit dl rm
repository.py	1284	0644	edit dl rm
__init__.py	35	0644	edit dl rm

Edit: /usr/lib/python3.6/site-packages/tuned/profiles/functions/function_calc_isolated_cores.py (1643B)

import os
import glob
import tuned.logs
from . import base
import tuned.consts as consts

log = tuned.logs.get()

class calc_isolated_cores(base.Function):
	"""
	Calculates and returns isolated cores. The argument specifies how many
	cores per socket reserve for housekeeping. If not specified, 1 core
	per socket is reserved for housekeeping and the rest is isolated.
	"""
	def __init__(self):
		# max 1 argument
		super(calc_isolated_cores, self).__init__("calc_isolated_cores", 1)

def execute(self, args):
		if not super(calc_isolated_cores, self).execute(args):
			return None
		cpus_reserve = 1
		if len(args) > 0:
			if not args[0].isdecimal() or int(args[0]) < 0:
				log.error("invalid argument '%s' for builtin function '%s', it must be non-negative integer" %
					(args[0], self._name))
				return None
			else:
				cpus_reserve = int(args[0])

topo = {}
		for cpu in glob.iglob(os.path.join(consts.SYSFS_CPUS_PATH, "cpu*")):
			cpuid = os.path.basename(cpu)[3:]
			if cpuid.isdecimal():
				physical_package_id = os.path.join(cpu, "topology/physical_package_id")
				# Show no errors when the physical_package_id file does not exist -- the CPU may be offline.
				if not os.path.exists(physical_package_id):
					log.debug("file '%s' does not exist, cpu%s offline?" % (physical_package_id, cpuid))
					continue
				socket = self._cmd.read_file(physical_package_id).strip()
				if socket.isdecimal():
					topo[socket] = topo.get(socket, []) + [cpuid]

isol_cpus = []
		for cpus in topo.values():
			cpus.sort(key = int)
			isol_cpus = isol_cpus + cpus[cpus_reserve:]
		isol_cpus.sort(key = int)
		return ",".join(isol_cpus)

import os import glob import tuned.logs from . import base import tuned.consts as consts log = tuned.logs.get() class calc_isolated_cores(base.Function): """ Calculates and returns isolated cores. The argument specifies how many cores per socket reserve for housekeeping. If not specified, 1 core per socket is reserved for housekeeping and the rest is isolated. """ def __init__(self): # max 1 argument super(calc_isolated_cores, self).__init__("calc_isolated_cores", 1) def execute(self, args): if not super(calc_isolated_cores, self).execute(args): return None cpus_reserve = 1 if len(args) > 0: if not args[0].isdecimal() or int(args[0]) < 0: log.error("invalid argument '%s' for builtin function '%s', it must be non-negative integer" % (args[0], self._name)) return None else: cpus_reserve = int(args[0]) topo = {} for cpu in glob.iglob(os.path.join(consts.SYSFS_CPUS_PATH, "cpu*")): cpuid = os.path.basename(cpu)[3:] if cpuid.isdecimal(): physical_package_id = os.path.join(cpu, "topology/physical_package_id") # Show no errors when the physical_package_id file does not exist -- the CPU may be offline. if not os.path.exists(physical_package_id): log.debug("file '%s' does not exist, cpu%s offline?" % (physical_package_id, cpuid)) continue socket = self._cmd.read_file(physical_package_id).strip() if socket.isdecimal(): topo[socket] = topo.get(socket, []) + [cpuid] isol_cpus = [] for cpus in topo.values(): cpus.sort(key = int) isol_cpus = isol_cpus + cpus[cpus_reserve:] isol_cpus.sort(key = int) return ",".join(isol_cpus)