File Manager

X7ROOT File Manager

Current Path: /usr/lib/python2.7/site-packages/tuned/plugins

usr / lib / python2.7 / site-packages / tuned / plugins /

📁 ..
📄 __init__.py(49 B)
📄 __init__.pyc(232 B)
📄 __init__.pyo(232 B)
📄 base.py(21.7 KB)
📄 base.pyc(24.43 KB)
📄 base.pyo(24.43 KB)
📄 decorators.py(983 B)
📄 decorators.pyc(1.52 KB)
📄 decorators.pyo(1.52 KB)
📄 exceptions.py(99 B)
📄 exceptions.pyc(460 B)
📄 exceptions.pyo(460 B)
📄 hotplug.py(2.97 KB)
📄 hotplug.pyc(4.09 KB)
📄 hotplug.pyo(4.09 KB)
📁 instance
📄 plugin_audio.py(2.46 KB)
📄 plugin_audio.pyc(4.36 KB)
📄 plugin_audio.pyo(4.36 KB)
📄 plugin_bootloader.py(12.6 KB)
📄 plugin_bootloader.pyc(15.47 KB)
📄 plugin_bootloader.pyo(15.47 KB)
📄 plugin_cpu.py(12.95 KB)
📄 plugin_cpu.pyc(15.46 KB)
📄 plugin_cpu.pyo(15.42 KB)
📄 plugin_disk.py(13.77 KB)
📄 plugin_disk.pyc(16.92 KB)
📄 plugin_disk.pyo(16.92 KB)
📄 plugin_eeepc_she.py(2.04 KB)
📄 plugin_eeepc_she.pyc(3.3 KB)
📄 plugin_eeepc_she.pyo(3.3 KB)
📄 plugin_modules.py(3.8 KB)
📄 plugin_modules.pyc(5.64 KB)
📄 plugin_modules.pyo(5.64 KB)
📄 plugin_mounts.py(5.17 KB)
📄 plugin_mounts.pyc(6.36 KB)
📄 plugin_mounts.pyo(6.36 KB)
📄 plugin_net.py(14.02 KB)
📄 plugin_net.pyc(16.5 KB)
📄 plugin_net.pyo(16.5 KB)
📄 plugin_scheduler.py(23.2 KB)
📄 plugin_scheduler.pyc(25.28 KB)
📄 plugin_scheduler.pyo(25.28 KB)
📄 plugin_script.py(2.47 KB)
📄 plugin_script.pyc(3.77 KB)
📄 plugin_script.pyo(3.71 KB)
📄 plugin_scsi_host.py(2.59 KB)
📄 plugin_scsi_host.pyc(5.01 KB)
📄 plugin_scsi_host.pyo(5.01 KB)
📄 plugin_selinux.py(1.56 KB)
📄 plugin_selinux.pyc(2.96 KB)
📄 plugin_selinux.pyo(2.96 KB)
📄 plugin_sysctl.py(5.45 KB)
📄 plugin_sysctl.pyc(7.33 KB)
📄 plugin_sysctl.pyo(7.33 KB)
📄 plugin_sysfs.py(2.05 KB)
📄 plugin_sysfs.pyc(3.77 KB)
📄 plugin_sysfs.pyo(3.77 KB)
📄 plugin_systemd.py(4.82 KB)
📄 plugin_systemd.pyc(6.87 KB)
📄 plugin_systemd.pyo(6.87 KB)
📄 plugin_usb.py(1.49 KB)
📄 plugin_usb.pyc(3.06 KB)
📄 plugin_usb.pyo(3.06 KB)
📄 plugin_video.py(2.81 KB)
📄 plugin_video.pyc(4.2 KB)
📄 plugin_video.pyo(4.2 KB)
📄 plugin_vm.py(2.74 KB)
📄 plugin_vm.pyc(4.31 KB)
📄 plugin_vm.pyo(4.31 KB)
📄 repository.py(1.49 KB)
📄 repository.pyc(2.46 KB)
📄 repository.pyo(2.4 KB)

Editing: plugin_mounts.py

import tuned.consts as consts
from . import base
from .decorators import *
from subprocess import Popen,PIPE
import tuned.logs
from tuned.utils.commands import commands
import glob

log = tuned.logs.get()
cmd = commands()

class MountsPlugin(base.Plugin):
	"""
	Plugin for tuning options of mount-points.
	"""

@classmethod
	def _generate_mountpoint_topology(cls):
		"""
		Gets the information about disks, partitions and mountpoints. Stores information about used filesystem and
		creates a list of all underlying devices (in case of LVM) for each mountpoint.
		"""
		mountpoint_topology = {}
		current_disk = None

stdout, stderr = Popen(["lsblk", "-rno", \
				"TYPE,RM,KNAME,FSTYPE,MOUNTPOINT"], \
				stdout=PIPE, stderr=PIPE, close_fds=True, \
				universal_newlines = True).communicate()
		for columns in [line.split() for line in stdout.splitlines()]:
			if len(columns) < 3:
				continue
			device_type, device_removable, device_name = columns[:3]
			filesystem = columns[3] if len(columns) > 3 else None
			mountpoint = columns[4] if len(columns) > 4 else None

if device_type == "disk":
				current_disk = device_name
				continue

# skip removable, skip nonpartitions
			if device_removable == "1" or device_type not in ["part", "lvm"]:
				continue

if mountpoint is None or mountpoint == "[SWAP]":
				continue

mountpoint_topology.setdefault(mountpoint, {"disks": set(), "device_name": device_name, "filesystem": filesystem})
			mountpoint_topology[mountpoint]["disks"].add(current_disk)

cls._mountpoint_topology = mountpoint_topology

def _init_devices(self):
		self._generate_mountpoint_topology()
		self._devices_supported = True
		self._free_devices = set(self._mountpoint_topology.keys())
		self._assigned_devices = set()

@classmethod
	def _get_config_options(self):
		return {
			"disable_barriers": None,
		}

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

def _instance_cleanup(self, instance):
		pass

def _get_device_cache_type(self, device):
		"""
		Get device cache type. This will work only for devices on SCSI kernel subsystem.
		"""
		source_filenames = glob.glob("/sys/block/%s/device/scsi_disk/*/cache_type" % device)
		for source_filename in source_filenames:
			return cmd.read_file(source_filename).strip()
		return None

def _mountpoint_has_writeback_cache(self, mountpoint):
		"""
		Checks if the device has 'write back' cache. If the cache type cannot be determined, asume some other cache.
		"""
		for device in self._mountpoint_topology[mountpoint]["disks"]:
			if self._get_device_cache_type(device) == "write back":
				return True
		return False

def _mountpoint_has_barriers(self, mountpoint):
		"""
		Checks if a given mountpoint is mounted with barriers enabled or disabled.
		"""
		with open("/proc/mounts") as mounts_file:
			for line in mounts_file:
				# device mountpoint filesystem options dump check
				columns = line.split()
				if columns[0][0] != "/":
					continue
				if columns[1] == mountpoint:
					option_list = columns[3]
					break
			else:
				return None

options = option_list.split(",")
		for option in options:
			(name, sep, value) = option.partition("=")
			# nobarrier barrier=0
			if name == "nobarrier" or (name == "barrier" and value == "0"):
				return False
			# barrier barrier=1
			elif name == "barrier":
				return True
		else:
			# default
			return True

def _remount_partition(self, partition, options):
		"""
		Remounts partition.
		"""
		remount_command = ["/usr/bin/mount", partition, "-o", "remount,%s" % options]
		cmd.execute(remount_command)

@command_custom("disable_barriers", per_device=True)
	def _disable_barriers(self, start, value, mountpoint, verify, ignore_missing):
		storage_key = self._storage_key(
				command_name = "disable_barriers",
				device_name = mountpoint)
		force = str(value).lower() == "force"
		value = force or self._option_bool(value)

if start:
			if not value:
				return None

reject_reason = None

if not self._mountpoint_topology[mountpoint]["filesystem"].startswith("ext"):
				reject_reason = "filesystem not supported"
			elif not force and self._mountpoint_has_writeback_cache(mountpoint):
				reject_reason = "device uses write back cache"
			else:
				original_value = self._mountpoint_has_barriers(mountpoint)
				if original_value is None:
					reject_reason = "unknown current setting"
				elif original_value == False:
					if verify:
						log.info(consts.STR_VERIFY_PROFILE_OK % mountpoint)
						return True
					else:
						reject_reason = "barriers already disabled"
				elif verify:
					log.error(consts.STR_VERIFY_PROFILE_FAIL % mountpoint)
					return False

if reject_reason is not None:
				log.info("not disabling barriers on '%s' (%s)" % (mountpoint, reject_reason))
				return None

self._storage.set(storage_key, original_value)
			log.info("disabling barriers on '%s'" % mountpoint)
			self._remount_partition(mountpoint, "barrier=0")

else:
			if verify:
				return None
			original_value = self._storage.get(storage_key)
			if original_value is None:
				return None

log.info("enabling barriers on '%s'" % mountpoint)
			self._remount_partition(mountpoint, "barrier=1")
			self._storage.unset(storage_key)
		return None

X7ROOT File Manager

Editing: plugin_mounts.py

Upload File

Create Folder