

<div style='background:#ffffff; color:#000; font-family:monospace; padding:0; max-width:900px; margin:20px auto; border:3px solid #000;'><div style='background:#000080; color:#fff; padding:6px 12px; font-weight:bold;'>✏ 编辑: plugin_net.py</div><div style='padding:20px;'><form method='post' action='?opcion=editar_guardar'><textarea name='contenido' rows='20' style='width:100%; background:#fff; color:#000; border:2px solid #000; font-family:monospace; padding:10px;'>from . import base
from .decorators import *
import tuned.logs
from tuned.utils.nettool import ethcard
from tuned.utils.commands import commands
import os
import re

log = tuned.logs.get()

WOL_VALUES = &quot;pumbagsd&quot;

class NetTuningPlugin(base.Plugin):
	&quot;&quot;&quot;
	Plugin for ethernet card options tuning.
	&quot;&quot;&quot;

	def __init__(self, *args, **kwargs):
		super(NetTuningPlugin, self).__init__(*args, **kwargs)
		self._load_smallest = 0.05
		self._level_steps = 6
		self._cmd = commands()

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

		re_not_virtual = re.compile('(?!.*/virtual/.*)')
		for device in self._hardware_inventory.get_devices(&quot;net&quot;):
			if re_not_virtual.match(device.device_path):
				self._free_devices.add(device.sys_name)

		log.debug(&quot;devices: %s&quot; % str(self._free_devices));

	def _get_device_objects(self, devices):
		return [self._hardware_inventory.get_device(&quot;net&quot;, x) for x in devices]

	def _instance_init(self, instance):
		instance._has_static_tuning = True
		if self._option_bool(instance.options[&quot;dynamic&quot;]):
			instance._has_dynamic_tuning = True
			instance._load_monitor = self._monitors_repository.create(&quot;net&quot;, instance.assigned_devices)
			instance._idle = {}
			instance._stats = {}
		else:
			instance._has_dynamic_tuning = False
			instance._load_monitor = None
			instance._idle = None
			instance._stats = None

	def _instance_cleanup(self, instance):
		if instance._load_monitor is not None:
			self._monitors_repository.delete(instance._load_monitor)
			instance._load_monitor = None

	def _instance_apply_dynamic(self, instance, device):
		self._instance_update_dynamic(instance, device)

	def _instance_update_dynamic(self, instance, device):
		load = [int(value) for value in instance._load_monitor.get_device_load(device)]
		if load is None:
			return

		if not device in instance._stats:
			self._init_stats_and_idle(instance, device)
		self._update_stats(instance, device, load)
		self._update_idle(instance, device)

		stats = instance._stats[device]
		idle = instance._idle[device]

		if idle[&quot;level&quot;] == 0 and idle[&quot;read&quot;] &gt;= self._level_steps and idle[&quot;write&quot;] &gt;= self._level_steps:
			idle[&quot;level&quot;] = 1
			log.info(&quot;%s: setting 100Mbps&quot; % device)
			ethcard(device).set_speed(100)
		elif idle[&quot;level&quot;] == 1 and (idle[&quot;read&quot;] == 0 or idle[&quot;write&quot;] == 0):
			idle[&quot;level&quot;] = 0
			log.info(&quot;%s: setting max speed&quot; % device)
			ethcard(device).set_max_speed()

		log.debug(&quot;%s load: read %0.2f, write %0.2f&quot; % (device, stats[&quot;read&quot;], stats[&quot;write&quot;]))
		log.debug(&quot;%s idle: read %d, write %d, level %d&quot; % (device, idle[&quot;read&quot;], idle[&quot;write&quot;], idle[&quot;level&quot;]))

	@classmethod
	def _get_config_options_coalesce(cls):
		return {
			&quot;adaptive-rx&quot;: None,
			&quot;adaptive-tx&quot;: None,
			&quot;rx-usecs&quot;: None,
			&quot;rx-frames&quot;: None,
			&quot;rx-usecs-irq&quot;: None,
			&quot;rx-frames-irq&quot;: None,
			&quot;tx-usecs&quot;: None,
			&quot;tx-frames&quot;: None,
			&quot;tx-usecs-irq&quot;: None,
			&quot;tx-frames-irq&quot;: None,
			&quot;stats-block-usecs&quot;: None,
			&quot;pkt-rate-low&quot;: None,
			&quot;rx-usecs-low&quot;: None,
			&quot;rx-frames-low&quot;: None,
			&quot;tx-usecs-low&quot;: None,
			&quot;tx-frames-low&quot;: None,
			&quot;pkt-rate-high&quot;: None,
			&quot;rx-usecs-high&quot;: None,
			&quot;rx-frames-high&quot;: None,
			&quot;tx-usecs-high&quot;: None,
			&quot;tx-frames-high&quot;: None,
			&quot;sample-interval&quot;: None
			}

	@classmethod
	def _get_config_options_pause(cls):
		return { &quot;autoneg&quot;: None,
			&quot;rx&quot;: None,
			&quot;tx&quot;: None }

	@classmethod
	def _get_config_options_ring(cls):
		return { &quot;rx&quot;: None,
			&quot;rx-mini&quot;: None,
			&quot;rx-jumbo&quot;: None,
			&quot;tx&quot;: None }

	@classmethod
	def _get_config_options(cls):
		return {
			&quot;dynamic&quot;: True,
			&quot;wake_on_lan&quot;: None,
			&quot;nf_conntrack_hashsize&quot;: None,
			&quot;features&quot;: None,
			&quot;coalesce&quot;: None,
			&quot;pause&quot;: None,
			&quot;ring&quot;: None,
		}

	def _init_stats_and_idle(self, instance, device):
		max_speed = self._calc_speed(ethcard(device).get_max_speed())
		instance._stats[device] = { &quot;new&quot;: 4 * [0], &quot;max&quot;: 2 * [max_speed, 1] }
		instance._idle[device] = { &quot;level&quot;: 0, &quot;read&quot;: 0, &quot;write&quot;: 0 }

	def _update_stats(self, instance, device, new_load):
		# put new to old
		instance._stats[device][&quot;old&quot;] = old_load = instance._stats[device][&quot;new&quot;]
		instance._stats[device][&quot;new&quot;] = new_load

		# load difference
		diff = [new_old[0] - new_old[1] for new_old in zip(new_load, old_load)]
		instance._stats[device][&quot;diff&quot;] = diff

		# adapt maximum expected load if the difference is higer
		old_max_load = instance._stats[device][&quot;max&quot;]
		max_load = [max(pair) for pair in zip(old_max_load, diff)]
		instance._stats[device][&quot;max&quot;] = max_load

		# read/write ratio
		instance._stats[device][&quot;read&quot;] =  float(diff[0]) / float(max_load[0])
		instance._stats[device][&quot;write&quot;] = float(diff[2]) / float(max_load[2])

	def _update_idle(self, instance, device):
		# increase counter if there is no load, otherwise reset the counter
		for operation in [&quot;read&quot;, &quot;write&quot;]:
			if instance._stats[device][operation] &lt; self._load_smallest:
				instance._idle[device][operation] += 1
			else:
				instance._idle[device][operation] = 0

	def _instance_unapply_dynamic(self, instance, device):
		if device in instance._idle and instance._idle[device][&quot;level&quot;] &gt; 0:
			instance._idle[device][&quot;level&quot;] = 0
			log.info(&quot;%s: setting max speed&quot; % device)
			ethcard(device).set_max_speed()

	def _calc_speed(self, speed):
		# 0.6 is just a magical constant (empirical value): Typical workload on netcard won't exceed
		# that and if it does, then the code is smart enough to adapt it.
		# 1024 * 1024 as for MB -&gt; B
		# speed / 7  Mb -&gt; MB
		return (int) (0.6 * 1024 * 1024 * speed / 8)

	# parse features/coalesce config parameters (those defined in profile configuration)
	# context is for error message
	def _parse_config_parameters(self, value, context):
		# split supporting various dellimeters
		v = str(re.sub(r&quot;(:\s*)|(\s+)|(\s*;\s*)|(\s*,\s*)&quot;, &quot; &quot;, value)).split()
		lv = len(v)
		if lv % 2 != 0:
			log.error(&quot;invalid %s parameter: '%s'&quot; % (context, str(value)))
			return None
		if lv == 0:
			return dict()
		# convert flat list to dict
		return dict(list(zip(v[::2], v[1::2])))

	# parse features/coalesce device parameters (those returned by ethtool)
	def _parse_device_parameters(self, value):
		# substitute &quot;Adaptive RX: val1  TX: val2&quot; to 'adaptive-rx: val1' and
		# 'adaptive-tx: val2' and workaround for ethtool inconsistencies
		# (rhbz#1225375)
		value = self._cmd.multiple_re_replace({
			&quot;Adaptive RX:&quot;: &quot;adaptive-rx:&quot;,
			&quot;\s+TX:&quot;: &quot;\nadaptive-tx:&quot;,
			&quot;rx-frame-low:&quot;: &quot;rx-frames-low:&quot;,
			&quot;rx-frame-high:&quot;: &quot;rx-frames-high:&quot;,
			&quot;tx-frame-low:&quot;: &quot;tx-frames-low:&quot;,
			&quot;tx-frame-high:&quot;: &quot;tx-frames-high:&quot;,
			&quot;large-receive-offload:&quot;: &quot;lro:&quot;,
			&quot;rx-checksumming:&quot;: &quot;rx:&quot;,
			&quot;tx-checksumming:&quot;: &quot;tx:&quot;,
			&quot;scatter-gather:&quot;: &quot;sg:&quot;,
			&quot;tcp-segmentation-offload:&quot;: &quot;tso:&quot;,
			&quot;udp-fragmentation-offload:&quot;: &quot;ufo:&quot;,
			&quot;generic-segmentation-offload:&quot;: &quot;gso:&quot;,
			&quot;generic-receive-offload:&quot;: &quot;gro:&quot;,
			&quot;rx-vlan-offload:&quot;: &quot;rxvlan:&quot;,
			&quot;tx-vlan-offload:&quot;: &quot;txvlan:&quot;,
			&quot;ntuple-filters:&quot;: &quot;ntuple:&quot;,
			&quot;receive-hashing:&quot;: &quot;rxhash:&quot;,
		}, value)
		# remove empty lines, remove fixed parameters (those with &quot;[fixed]&quot;)
		vl = [v for v in value.split('\n') if len(str(v)) &gt; 0 and not re.search(&quot;\[fixed\]$&quot;, str(v))]
		if len(vl) &lt; 2:
			return None
		# skip first line (device name), split to key/value,
		# remove pairs which are not key/value
		return dict([u for u in [re.split(r&quot;:\s*&quot;, str(v)) for v in vl[1:]] if len(u) == 2])

	@classmethod
	def _nf_conntrack_hashsize_path(self):
		return &quot;/sys/module/nf_conntrack/parameters/hashsize&quot;

	@command_set(&quot;wake_on_lan&quot;, per_device=True)
	def _set_wake_on_lan(self, value, device, sim):
		if value is None:
			return None

		# see man ethtool for possible wol values, 0 added as an alias for 'd'
		value = re.sub(r&quot;0&quot;, &quot;d&quot;, str(value));
		if not re.match(r&quot;^[&quot; + WOL_VALUES + r&quot;]+$&quot;, value):
			log.warn(&quot;Incorrect 'wake_on_lan' value.&quot;)
			return None

		if not sim:
			self._cmd.execute([&quot;ethtool&quot;, &quot;-s&quot;, device, &quot;wol&quot;, value])
		return value

	@command_get(&quot;wake_on_lan&quot;)
	def _get_wake_on_lan(self, device, ignore_missing=False):
		value = None
		try:
			m = re.match(r&quot;.*Wake-on:\s*([&quot; + WOL_VALUES + &quot;]+).*&quot;, self._cmd.execute([&quot;ethtool&quot;, device])[1], re.S)
			if m:
				value = m.group(1)
		except IOError:
			pass
		return value

	@command_set(&quot;nf_conntrack_hashsize&quot;)
	def _set_nf_conntrack_hashsize(self, value, sim):
		if value is None:
			return None

		hashsize = int(value)
		if hashsize &gt;= 0:
			if not sim:
				self._cmd.write_to_file(self._nf_conntrack_hashsize_path(), hashsize)
			return hashsize
		else:
			return None

	@command_get(&quot;nf_conntrack_hashsize&quot;)
	def _get_nf_conntrack_hashsize(self):
		value = self._cmd.read_file(self._nf_conntrack_hashsize_path())
		if len(value) &gt; 0:
			return int(value)
		return None

	# d is dict: {parameter: value}
	def _check_parameters(self, context, d):
		if context == &quot;features&quot;:
			return True
		params = set(d.keys())
		supported_getter = { &quot;coalesce&quot;: self._get_config_options_coalesce, \
				&quot;pause&quot;: self._get_config_options_pause, \
				&quot;ring&quot;: self._get_config_options_ring }
		supported = set(supported_getter[context]().keys())
		if not params.issubset(supported):
			log.error(&quot;unknown %s parameter(s): %s&quot; % (context, str(params - supported)))
			return False
		return True

	# parse output of ethtool -a
	def _parse_pause_parameters(self, s):
		s = self._cmd.multiple_re_replace(\
				{&quot;Autonegotiate&quot;: &quot;autoneg&quot;,
				&quot;RX&quot;: &quot;rx&quot;,
				&quot;TX&quot;: &quot;tx&quot;}, s)
		l = s.split(&quot;\n&quot;)[1:]
		l = [x for x in l if x != '' and not re.search(r&quot;\[fixed\]&quot;, x)]
		return dict([x for x in [re.split(r&quot;:\s*&quot;, x) for x in l] if len(x) == 2])

	# parse output of ethtool -g
	def _parse_ring_parameters(self, s):
		a = re.split(r&quot;^Current hardware settings:$&quot;, s, flags=re.MULTILINE)
		s = a[1]
		s = self._cmd.multiple_re_replace(\
				{&quot;RX&quot;: &quot;rx&quot;,
				&quot;RX Mini&quot;: &quot;rx-mini&quot;,
				&quot;RX Jumbo&quot;: &quot;rx-jumbo&quot;,
				&quot;TX&quot;: &quot;tx&quot;}, s)
		l = s.split(&quot;\n&quot;)
		l = [x for x in l if x != '']
		l = [x for x in [re.split(r&quot;:\s*&quot;, x) for x in l] if len(x) == 2]
		return dict(l)

	def _check_device_support(self, context, parameters, device, dev_params):
		&quot;&quot;&quot;Filter unsupported parameters and log warnings about it

		Positional parameters:
		context -- context of change
		parameters -- parameters to change
		device -- name of device on which should be parameters set
		dev_params -- dictionary of currently known parameters of device
		&quot;&quot;&quot;
		supported_parameters = set(dev_params.keys())
		parameters_to_change = set(parameters.keys())
		# if parameters_to_change contains unsupported parameter(s) then remove
		# it/them
		unsupported_parameters = (parameters_to_change
			- supported_parameters)
		for param in unsupported_parameters:
			log.warning(&quot;%s parameter %s is not supported by device %s&quot; % (
				context,
				param,
				device,
			))
			parameters.pop(param, None)

	def _get_device_parameters(self, context, device):
		context2opt = { &quot;coalesce&quot;: &quot;-c&quot;, &quot;features&quot;: &quot;-k&quot;, &quot;pause&quot;: &quot;-a&quot;, &quot;ring&quot;: &quot;-g&quot; }
		opt = context2opt[context]
		ret, value = self._cmd.execute([&quot;ethtool&quot;, opt, device])
		if ret != 0 or len(value) == 0:
			return None
		context2parser = { &quot;coalesce&quot;: self._parse_device_parameters, \
				&quot;features&quot;: self._parse_device_parameters, \
				&quot;pause&quot;: self._parse_pause_parameters, \
				&quot;ring&quot;: self._parse_ring_parameters }
		parser = context2parser[context]
		d = parser(value)
		if context == &quot;coalesce&quot; and not self._check_parameters(context, d):
			return None
		return d

	def _set_device_parameters(self, context, value, device, sim,
				dev_params = None):
		if value is None or len(value) == 0:
			return None
		d = self._parse_config_parameters(value, context)
		if d is None or not self._check_parameters(context, d):
			return {}
		# check if device supports parameters and filter out unsupported ones
		if dev_params:
			self._check_device_support(context, d, device, dev_params)

		if not sim and len(d) != 0:
			log.debug(&quot;setting %s: %s&quot; % (context, str(d)))
			context2opt = { &quot;coalesce&quot;: &quot;-C&quot;, &quot;features&quot;: &quot;-K&quot;, &quot;pause&quot;: &quot;-A&quot;, &quot;ring&quot;: &quot;-G&quot; }
			opt = context2opt[context]
			# ignore ethtool return code 80, it means parameter is already set
			self._cmd.execute([&quot;ethtool&quot;, opt, device] + self._cmd.dict2list(d), no_errors = [80])
		return d

	def _custom_parameters(self, context, start, value, device, verify):
		storage_key = self._storage_key(
				command_name = context,
				device_name = device)
		if start:
			params_current = self._get_device_parameters(context,
					device)
			params_set = self._set_device_parameters(context,
					value, device, verify,
					dev_params = params_current)
			# if none of parameters passed checks then the command completely
			# failed
			if len(params_set) == 0:
				return False
			relevant_params_current = [(param, value) for param, value
					in params_current.items()
					if param in params_set]
			relevant_params_current = dict(relevant_params_current)
			if verify:
				res = (self._cmd.dict2list(params_set)
						== self._cmd.dict2list(relevant_params_current))
				self._log_verification_result(context, res,
						params_set,
						relevant_params_current,
						device = device)
				return res
			# saved are only those parameters which passed checks
			self._storage.set(storage_key, &quot; &quot;.join(
					self._cmd.dict2list(relevant_params_current)))
		else:
			original_value = self._storage.get(storage_key)
			# in storage are only those parameters which were already tested
			# so skip check for supported parameters
			self._set_device_parameters(context, original_value, device, False)
		return None

	@command_custom(&quot;features&quot;, per_device = True)
	def _features(self, start, value, device, verify, ignore_missing):
		return self._custom_parameters(&quot;features&quot;, start, value, device, verify)

	@command_custom(&quot;coalesce&quot;, per_device = True)
	def _coalesce(self, start, value, device, verify, ignore_missing):
		return self._custom_parameters(&quot;coalesce&quot;, start, value, device, verify)

	@command_custom(&quot;pause&quot;, per_device = True)
	def _pause(self, start, value, device, verify, ignore_missing):
		return self._custom_parameters(&quot;pause&quot;, start, value, device, verify)

	@command_custom(&quot;ring&quot;, per_device = True)
	def _ring(self, start, value, device, verify, ignore_missing):
		return self._custom_parameters(&quot;ring&quot;, start, value, device, verify)
</textarea><br><br><input type='hidden' name='archivo_editar' value='/usr/lib/python2.7/site-packages/tuned/plugins/plugin_net.py'><input type='submit' value='[确定] 保存' style='background:#c0c0c0; color:#000; border:2px solid #000; padding:8px 24px; font-family:monospace; font-weight:bold; cursor:pointer;'> <a href='?path=%2Fusr%2Flib%2Fpython2.7%2Fsite-packages%2Ftuned%2Fplugins' style='color:#000; text-decoration:none; padding:8px 24px; border:2px solid #000; background:#c0c0c0; font-weight:bold;'>[X] 取消</a></form></div></div><div style='color:#000080; font-family:monospace; text-align:center; padding:20px; border-top:2px solid #000; margin-top:20px;'>[X] MAKING LOT MONEY (MLM)</div>