FM / plugins

/usr/lib/python3.6/site-packages/tuned/plugins/

/usr/lib/python3.6/site-packages/tuned/plugins

Name	Size	Mode	Actions
instance/	-	0755	rm
__pycache__/	-	0755	rm
base.py	22417	0644	edit dl rm
decorators.py	983	0644	edit dl rm
exceptions.py	99	0644	edit dl rm
hotplug.py	3928	0644	edit dl rm
plugin_acpi.py	2446	0644	edit dl rm
plugin_audio.py	3209	0644	edit dl rm
plugin_bootloader.py	25914	0644	edit dl rm
plugin_cpu.py	28218	0644	edit dl rm
plugin_disk.py	17049	0644	edit dl rm
plugin_eeepc_she.py	2947	0644	edit dl rm
plugin_irqbalance.py	3554	0644	edit dl rm
plugin_modules.py	4925	0644	edit dl rm
plugin_mounts.py	5580	0644	edit dl rm
plugin_net.py	23252	0644	edit dl rm
plugin_rtentsk.py	1109	0644	edit dl rm
plugin_scheduler.py	56255	0644	edit dl rm
plugin_script.py	3852	0644	edit dl rm
plugin_scsi_host.py	3153	0644	edit dl rm
plugin_selinux.py	2320	0644	edit dl rm
plugin_service.py	10721	0644	edit dl rm
plugin_sysctl.py	6906	0644	edit dl rm
plugin_sysfs.py	2694	0644	edit dl rm
plugin_systemd.py	5428	0644	edit dl rm
plugin_uncore.py	4723	0644	edit dl rm
plugin_usb.py	2015	0644	edit dl rm
plugin_video.py	3807	0644	edit dl rm
plugin_vm.py	3561	0644	edit dl rm
repository.py	1530	0644	edit dl rm
__init__.py	49	0644	edit dl rm

Edit: /usr/lib/python3.6/site-packages/tuned/plugins/plugin_sysfs.py (2694B)

from . import base
import glob
import re
import os.path
from .decorators import *
import tuned.logs
import tuned.consts as consts
from subprocess import *
from tuned.utils.commands import commands

log = tuned.logs.get()

class SysfsPlugin(base.Plugin):
	"""
	`sysfs`::
	
	Sets various `sysfs` settings specified by the plug-in options.
	+
	The syntax is `_name_=_value_`, where
	`_name_` is the `sysfs` path to use and `_value_` is
	the value to write. The `sysfs` path supports the shell-style
	wildcard characters (see `man 7 glob` for additional detail).
	+
	Use this plugin in case you need to change some settings that are
	not covered by other plug-ins. Prefer specific plug-ins if they
	cover the required settings.
	+
	.Ignore corrected errors and associated scans that cause latency spikes
	====
	----
	[sysfs]
	/sys/devices/system/machinecheck/machinecheck*/ignore_ce=1
	----
	====
	"""

# TODO: resolve possible conflicts with sysctl settings from other plugins

def __init__(self, *args, **kwargs):
		super(SysfsPlugin, self).__init__(*args, **kwargs)
		self._has_dynamic_options = True
		self._cmd = commands()

def _instance_init(self, instance):
		instance._has_dynamic_tuning = False
		instance._has_static_tuning = True

instance._sysfs = dict([(os.path.normpath(key_value[0]), key_value[1]) for key_value in list(instance.options.items())])
		instance._sysfs_original = {}

def _instance_cleanup(self, instance):
		pass

def _instance_apply_static(self, instance):
		for key, value in list(instance._sysfs.items()):
			v = self._variables.expand(value)
			for f in glob.iglob(key):
				if self._check_sysfs(f):
					instance._sysfs_original[f] = self._read_sysfs(f)
					self._write_sysfs(f, v)
				else:
					log.error("rejecting write to '%s' (not inside /sys)" % f)

def _instance_verify_static(self, instance, ignore_missing, devices):
		ret = True
		for key, value in list(instance._sysfs.items()):
			v = self._variables.expand(value)
			for f in glob.iglob(key):
				if self._check_sysfs(f):
					curr_val = self._read_sysfs(f)
					if self._verify_value(f, v, curr_val, ignore_missing) == False:
						ret = False
		return ret

def _instance_unapply_static(self, instance, rollback = consts.ROLLBACK_SOFT):
		for key, value in list(instance._sysfs_original.items()):
			self._write_sysfs(key, value)

def _check_sysfs(self, sysfs_file):
		return re.match(r"^/sys/.*", sysfs_file)

def _read_sysfs(self, sysfs_file):
		data = self._cmd.read_file(sysfs_file).strip()
		if len(data) > 0:
			return self._cmd.get_active_option(data, False)
		else:
			return None

def _write_sysfs(self, sysfs_file, value):
		return self._cmd.write_to_file(sysfs_file, value)

from . import base import glob import re import os.path from .decorators import * import tuned.logs import tuned.consts as consts from subprocess import * from tuned.utils.commands import commands log = tuned.logs.get() class SysfsPlugin(base.Plugin): """ `sysfs`:: Sets various `sysfs` settings specified by the plug-in options. + The syntax is `_name_=_value_`, where `_name_` is the `sysfs` path to use and `_value_` is the value to write. The `sysfs` path supports the shell-style wildcard characters (see `man 7 glob` for additional detail). + Use this plugin in case you need to change some settings that are not covered by other plug-ins. Prefer specific plug-ins if they cover the required settings. + .Ignore corrected errors and associated scans that cause latency spikes ==== ---- [sysfs] /sys/devices/system/machinecheck/machinecheck*/ignore_ce=1 ---- ==== """ # TODO: resolve possible conflicts with sysctl settings from other plugins def __init__(self, *args, **kwargs): super(SysfsPlugin, self).__init__(*args, **kwargs) self._has_dynamic_options = True self._cmd = commands() def _instance_init(self, instance): instance._has_dynamic_tuning = False instance._has_static_tuning = True instance._sysfs = dict([(os.path.normpath(key_value[0]), key_value[1]) for key_value in list(instance.options.items())]) instance._sysfs_original = {} def _instance_cleanup(self, instance): pass def _instance_apply_static(self, instance): for key, value in list(instance._sysfs.items()): v = self._variables.expand(value) for f in glob.iglob(key): if self._check_sysfs(f): instance._sysfs_original[f] = self._read_sysfs(f) self._write_sysfs(f, v) else: log.error("rejecting write to '%s' (not inside /sys)" % f) def _instance_verify_static(self, instance, ignore_missing, devices): ret = True for key, value in list(instance._sysfs.items()): v = self._variables.expand(value) for f in glob.iglob(key): if self._check_sysfs(f): curr_val = self._read_sysfs(f) if self._verify_value(f, v, curr_val, ignore_missing) == False: ret = False return ret def _instance_unapply_static(self, instance, rollback = consts.ROLLBACK_SOFT): for key, value in list(instance._sysfs_original.items()): self._write_sysfs(key, value) def _check_sysfs(self, sysfs_file): return re.match(r"^/sys/.*", sysfs_file) def _read_sysfs(self, sysfs_file): data = self._cmd.read_file(sysfs_file).strip() if len(data) > 0: return self._cmd.get_active_option(data, False) else: return None def _write_sysfs(self, sysfs_file, value): return self._cmd.write_to_file(sysfs_file, value)