Google
Edit File: plugin_net.cpython-39.opt-1.pyc
a �]�i�i � @ sx d dl Z ddlmZ ddlT d dlZd dlmZ d dlm Z d dl Z d dl Z d dl Z ej �� ZdZG dd � d ej�ZdS ) � N� )�hotplug)�*)�ethcard)�commandsZpumbagsdc s� e Zd ZdZ� fdd�Z� fdd�Zdd� Zdd � Zd d � Zd d � Z � fdd�Z � fdd�Z � fdd�Z dd� Z dd� Zdd� Zdd� Zd d � Z� fd d �Zd d!� Z� fd"d#�Zd$d%� Zd&d'� Zed(d)� �Zed*d+� �Zed,d-� �Zed.d/� �Zed0d1� �Z d2d3� Z d4d5� Z d6d7� Z d8d9� Z d:d;� Z!d<d=� Z"d>d?� Z#ed@dA� �Z$e%dBdCdD�dEdF� �Z&e'dB�d�dHdI��Z(e%dJ�dKdL� �Z)e'dJ�dMdN� �Z*g fdOdP�Z+d�dRdS�Z,e%dTdCdD�dUdV� �Z-dWdX� Z.e'dT�d�dYdZ��Z/e%d[dCdD�d\d]� �Z0e'd[�d�d^d_��Z1d`da� Z2dbdc� Z3ddde� Z4dfdg� Z5dhdi� Z6djdk� Z7dldm� Z8d�dndo�Z9dpdq� Z:e;drdCdD�dsdt� �Z<e;dudCdD�dvdw� �Z=e;dxdCdD�dydz� �Z>e;d{dCdD�d|d}� �Z?e;d~dCdD�dd�� �Z@� ZAS )��NetTuningPluginaO Configures network driver, hardware and Netfilter settings. Dynamic change of the interface speed according to the interface utilization is also supported. The dynamic tuning is controlled by the [option]`dynamic` and the global [option]`dynamic_tuning` option in `tuned-main.conf`. `wake_on_lan`::: The [option]`wake_on_lan` option sets wake-on-lan to the specified value as when using the `ethtool` utility. + .Set Wake-on-LAN for device eth0 on MagicPacket(TM) ==== ---- [net] devices=eth0 wake_on_lan=g ---- ==== `coalesce`::: The [option]`coalesce` option allows changing coalescing settings for the specified network devices. The syntax is: + [subs="quotes"] ---- coalesce=__param1__ __value1__ __param2__ __value2__ ... __paramN__ __valueN__ ---- + Note that not all the coalescing parameters are supported by all network cards. For the list of coalescing parameters of your network device, use `ethtool -c device`. + .Setting coalescing parameters rx/tx-usecs for all network devices ==== ---- [net] coalesce=rx-usecs 3 tx-usecs 16 ---- ==== `features`::: The [option]`features` option allows changing the offload parameters and other features for the specified network devices. To query the features of your network device, use `ethtool -k device`. The syntax of the option is the same as the [option]`coalesce` option. + .Turn off TX checksumming, generic segmentation and receive offload ==== ---- [net] features=tx off gso off gro off ---- ==== `pause`::: The [option]`pause` option allows changing the pause parameters for the specified network devices. To query the pause parameters of your network device, use `ethtool -a device`. The syntax of the option is the same as the [option]`coalesce` option. + .Disable autonegotiation ==== ---- [net] pause=autoneg off ---- ==== `ring`::: The [option]`ring` option allows changing the rx/tx ring parameters for the specified network devices. To query the ring parameters of your network device, use `ethtool -g device`. The syntax of the option is the same as the [option]`coalesce` option. + .Change the number of ring entries for the Rx/Tx rings to 1024/512 respectively ===== ----- [net] ring=rx 1024 tx 512 ----- ===== `channels`::: The [option]`channels` option allows changing the numbers of channels for the specified network device. A channel is an IRQ and the set of queues that can trigger that IRQ. To query the channels parameters of your network device, use `ethtool -l device`. The syntax of the option is the same as the [option]`coalesce` option. + .Set the number of multi-purpose channels to 16 ===== ----- [net] channels=combined 16 ----- ===== + A network device either supports rx/tx or combined queue mode. The [option]`channels` option automatically adjusts the parameters based on the mode supported by the device as long as a valid configuration is requested. `nf_conntrack_hashsize`::: The [option]`nf_conntrack_hashsize` option sets the size of the hash table which stores lists of conntrack entries by writing to `/sys/module/nf_conntrack/parameters/hashsize`. + .Adjust the size of the conntrack hash table ==== ---- [net] nf_conntrack_hashsize=131072 ---- ==== `txqueuelen`::: The [option]`txqueuelen` option allows changing txqueuelen (the length of the transmit queue). It uses `ip` utility that is in package iproute recommended for TuneD, so the package needs to be installed for its correct functionality. To query the txqueuelen parameters of your network device use `ip link show` and the current value is shown after the qlen column. + .Adjust the length of the transmit queue ==== ---- [net] txqueuelen=5000 ---- ==== `mtu`::: The [option]`mtu` option allows changing MTU (Maximum Transmission Unit). It uses `ip` utility that is in package iproute recommended for TuneD, so the package needs to be installed for its correct functionality. To query the MTU parameters of your network device use `ip link show` and the current value is shown after the MTU column. + .Adjust the size of the MTU ==== ---- [net] mtu=9000 ---- ==== c sd t t| �j|i |�� d| _d| _t� | _i | _d| _t � d�| _ t t jd�rX| j| _n| j| _d S )Ng�������?� Tz(?!.*/virtual/.*)� properties)�superr �__init__�_load_smallest� _level_stepsr �_cmd�_re_ip_link_show�_use_ip�re�compile�re_not_virtual�hasattr�pyudevZDevice�_get_device_property_1�_get_device_property�_get_device_property_2)�self�args�kwargs�� __class__� �</usr/lib/python3.9/site-packages/tuned/plugins/plugin_net.pyr � s zNetTuningPlugin.__init__c sf t t| ��� d| _t� | _t� | _| j�d�D ] }| � |�r0| j� |j � q0t � dt| j� � d S )NT�netz devices: %s)r r � _init_devicesZ_devices_supported�setZ _free_devicesZ_assigned_devices�_hardware_inventoryZ get_devices�_device_is_supported�addZsys_name�log�debug�str�r �devicer r r r! � s z NetTuningPlugin._init_devicesc s � fdd�|D �S )Nc s g | ]}� j �d |��qS )r )r# � get_device��.0�x�r r r � <listcomp>� � z7NetTuningPlugin._get_device_objects.<locals>.<listcomp>r )r �devicesr r/ r �_get_device_objects� s z#NetTuningPlugin._get_device_objectsc C s | j �|j�S �N)r �matchZ device_pathr) r r r r$ � s z$NetTuningPlugin._device_is_supportedc C s | j �| d| j� d S �Nr )r# Z subscribe�_hardware_events_callbackr/ r r r �_hardware_events_init� s z%NetTuningPlugin._hardware_events_initc C s | j �| � d S r4 )r# Z unsubscriber/ r r r �_hardware_events_cleanup� s z(NetTuningPlugin._hardware_events_cleanupc s | � |�r tt| ��||� d S r4 )r$ r r r7 )r Zeventr* r r r r7 � s z)NetTuningPlugin._hardware_events_callbackc s, |j d ur|j �|� tt| ��||� d S r4 )� _load_monitorZ add_devicer r �_added_device_apply_tuning�r �instance� device_namer r r r; � s z*NetTuningPlugin._added_device_apply_tuningc s, |j d ur|j �|� tt| ��||� d S r4 )r: Z remove_devicer r � _removed_device_unapply_tuningr< r r r r? � s z.NetTuningPlugin._removed_device_unapply_tuningc C s |j �|�S r4 )r �get)r � pyudev_dev�propr r r r � s z&NetTuningPlugin._get_device_property_1c C s* z|� |�}W n ty$ d }Y n0 |S r4 )� __getitem__�KeyError)r rA rB �pr r r r � s z&NetTuningPlugin._get_device_property_2c C sp | j �d|�}|rl| �|d�}|rlt| j�� �D ]:\}}|j�|�}|r0t� d|||f � ||j |< qlq0d S )Nr �IFINDEXz?Rename device, ifindex: '%s', original name '%s', new name '%s') r# r+ r �listZ _instances�items� _ifmap_origr@ r& r' � _ifnamemap)r r> �d�iZ instance_namer= Zdevice_name_oldr r r � _move_device� s � z NetTuningPlugin._move_devicec s � fdd�}|S )Nc s � j �| �}|r|S | S r4 )rJ r@ )r* rK �r= r r �_get_curr_device� s zBNetTuningPlugin._get_curr_device_wrapper.<locals>._get_curr_devicer )r r= rO r rN r �_get_curr_device_wrapper� s z(NetTuningPlugin._get_curr_device_wrapperc C s@ d|_ d |_d |_d |_i |_| �|�|_| �|jd �|_ d S )NT�dynamic) Z_has_static_tuningr: �_idle�_statsrJ rP rO Z _option_bool�optionsZ_has_dynamic_tuning�r r= r r r �_instance_init� s z NetTuningPlugin._instance_initc sV t t| ��|� i |_|j}|D ]0}| j�d|�}|r | �|d�}|r ||j|< q d S )Nr rF )r r �assign_free_devicesrI �assigned_devicesr# r+ r )r r= r2 r* rK rL r r r rW s z#NetTuningPlugin.assign_free_devicesc C s" |j d ur | j�|j � d |_ d S r4 )r: �_monitors_repository�deleterU r r r �_instance_cleanup s z!NetTuningPlugin._instance_cleanupc s@ t t| ��|� i |_i |_| j�d|j�|_|j� |j � d S r6 ) r r �_instance_init_dynamicrR rS rY ZcreaterX r: Z _set_dev_maprO rU r r r r\ s z&NetTuningPlugin._instance_init_dynamicc C s | � ||� d S r4 )�_instance_update_dynamic�r r= r* r r r �_instance_apply_dynamic s z'NetTuningPlugin._instance_apply_dynamicc C s< dd� |j �|�D �}|d u r"d S ||jvr8| �||� | �|||� | �||� |j| }|j| }|d dkr�|d | jkr�|d | jkr�d|d< t� d| � t |�� d � nF|d dkr�|d dks�|d dkr�d|d< t� d | � t |�� � t� d ||d |d f � t� d ||d |d |d f � d S ) Nc S s g | ] }t |��qS r ��int)r- �valuer r r r0 r1 z<NetTuningPlugin._instance_update_dynamic.<locals>.<listcomp>�levelr �read�writer z%s: setting 100Mbps�d �%s: setting max speedz %s load: read %0.2f, write %0.2fz$%s idle: read %d, write %d, level %d)r: Zget_device_loadrS �_init_stats_and_idle� _update_stats� _update_idlerR r r& �infor Z set_speed� set_max_speedr' )r r= r* �loadZstatsZidler r r r] s& ($ z(NetTuningPlugin._instance_update_dynamicc C s4 d d d d d d d d d d d d d d d d d d d d d d d d�S )N)z adaptive-rxz adaptive-txz cqe-mode-rxzrx-usecsz rx-framesz rx-usecs-irqz rx-frames-irqztx-usecsz tx-framesz tx-usecs-irqz tx-frames-irqzstats-block-usecsz pkt-rate-lowz rx-usecs-lowz rx-frames-lowz tx-usecs-lowz tx-frames-lowz pkt-rate-highz rx-usecs-highzrx-frames-highz tx-usecs-highztx-frames-highzsample-intervalr ��clsr r r � _get_config_options_coalesce6 s0 �z,NetTuningPlugin._get_config_options_coalescec C s d d d d�S )N)�autoneg�rx�txr rn r r r �_get_config_options_pauseR s �z)NetTuningPlugin._get_config_options_pausec C s d d d d d�S )N)rr �rx-mini�rx-jumbors r rn r r r �_get_config_options_ringX s �z(NetTuningPlugin._get_config_options_ringc C s d d d d d�S )N)rr rs �other�combinedr rn r r r � _get_config_options_channels_ s �z,NetTuningPlugin._get_config_options_channelsc C s dd d d d d d d d d d� S )NT) rQ � wake_on_lan�nf_conntrack_hashsize�features�coalesce�pause�ring�channels� txqueuelen�mtur rn r r r �_get_config_optionsf s �z#NetTuningPlugin._get_config_optionsc C sL | � t|�|���� �}ddg d|dg d�|j|< dddd�|j|< d S )N� r � r )�new�max)rc rd re )� _calc_speedr rO Z get_max_speedrS rR )r r= r* Z max_speedr r r rh u s z$NetTuningPlugin._init_stats_and_idlec C s� |j | d |j | d< }||j | d< dd� t||�D �}||j | d< |j | d }dd� t||�D �}||j | d< t|d �t|d � |j | d < t|d �t|d � |j | d < d S ) Nr� �oldc S s g | ]}|d |d �qS )r r r )r- Znew_oldr r r r0 � r1 z1NetTuningPlugin._update_stats.<locals>.<listcomp>�diffr� c S s g | ] }t |��qS r )r� )r- Zpairr r r r0 � r1 r rd r� re )rS �zip�float)r r= r* Znew_loadZold_loadr� Z old_max_loadZmax_loadr r r ri z s "z NetTuningPlugin._update_statsc C sH dD ]>}|j | | | jk r4|j| | d7 < qd|j| |< qd S )N)rd re r r )rS r rR )r r= r* Z operationr r r rj � s z NetTuningPlugin._update_idlec C sN ||j v rJ|j | d dkrJd|j | d< t�d| � t|�|���� d S )Nrc r rg )rR r& rk r rO rl r^ r r r �_instance_unapply_dynamic� s z)NetTuningPlugin._instance_unapply_dynamicc C s t d| d �S )Ng333333#A� r` )r Zspeedr r r r� � s zNetTuningPlugin._calc_speedc C s� | j �|�}tt�dd|���� }t|�}|d dkrPt�d|t|�f � d S |dkr^t � S t t t |d d d� |dd d� ���S )Nz (:\s*)|(\s+)|(\s*;\s*)|(\s*,\s*)� r� r zinvalid %s parameter: '%s'r ) Z _variables�expandr( r �sub�split�lenr& �error�dictrG r� )r rb �context�v�lvr r r �_parse_config_parameters� s z(NetTuningPlugin._parse_config_parametersc C s~ | j �ddddddddd d d d d ddddddd�|�}dd� |�d�D �}t|�dk rZd S tdd� dd� |dd � D �D ��S ) Nz adaptive-rx:z adaptive-tx:z cqe-mode-rx:zrx-frames-low:zrx-frames-high:ztx-frames-low:ztx-frames-high:zlro:zrx:ztx:zsg:ztso:zufo:zgso:zgro:zrxvlan:ztxvlan:zntuple:zrxhash:)z Adaptive RX:z\s+TX:z CQE mode RX:z rx-frame-low:zrx-frame-high:z tx-frame-low:ztx-frame-high:zlarge-receive-offload:zrx-checksumming:ztx-checksumming:zscatter-gather:ztcp-segmentation-offload:zudp-fragmentation-offload:z generic-segmentation-offload:zgeneric-receive-offload:zrx-vlan-offload:ztx-vlan-offload:zntuple-filters:zreceive-hashing:c S s0 g | ](}t t|��d krt�dt|��s|�qS )r z \[fixed\]$)r� r( r �search�r- r� r r r r0 � r1 z<NetTuningPlugin._parse_device_parameters.<locals>.<listcomp>� r� c S s g | ]}t |�d kr|�qS �r� �r� )r- �ur r r r0 � r1 c S s g | ]}t �d t|���qS �z:\s*)r r� r( r� r r r r0 � r1 r )r �multiple_re_replacer� r� r� )r rb Zvlr r r �_parse_device_parameters� s6 �� z(NetTuningPlugin._parse_device_parametersc C s dS )Nz,/sys/module/nf_conntrack/parameters/hashsizer r/ r r r �_nf_conntrack_hashsize_path� s z+NetTuningPlugin._nf_conntrack_hashsize_pathr{ T)Z per_devicec C sd |d u r d S t �ddt|��}t �dt d |�s@t�d� d S |s`| j�dd|� |�d|g� |S ) N�0rK z^[z]+$z Incorrect 'wake_on_lan' value.�ethtoolz-sZwol) r r� r( r5 � WOL_VALUESr& �warningr �executerO )r rb r* r= �sim�remover r r �_set_wake_on_lan� s z NetTuningPlugin._set_wake_on_lanFc C s\ d }z@t �dt d | j�d|�|�g�d t j�}|rB|�d�}W n tyV Y n0 |S )Nz.*Wake-on:\s*([z]+).*r� r ) r r5 r� r r� rO �S�group�IOError)r r* r= �ignore_missingrb �mr r r �_get_wake_on_lan� s � z NetTuningPlugin._get_wake_on_lanr| c C sN |d u r d S t |�}|dkrF|sB| jj| �� ||r:tjgndd� |S d S d S )Nr F)Zno_error)ra r Z write_to_filer� �errno�ENOENT)r rb r= r� r� Zhashsizer r r �_set_nf_conntrack_hashsize� s �z*NetTuningPlugin._set_nf_conntrack_hashsizec C s( | j �| �� �}t|�dkr$t|�S d S )Nr )r Z read_filer� r� ra )r r= rb r r r �_get_nf_conntrack_hashsize s z*NetTuningPlugin._get_nf_conntrack_hashsizec C sz | j s d S ddg| }| jj|tjgdd�\}}}|tj krRt�d� d| _ d S |rvt�d� t�d||f � d S |S ) N�ip�linkT)� no_errorsZ return_errz0ip command not found, ignoring for other devicesFzProblem calling ip commandz(rc: %s, msg: '%s')) r r r� r� r� r& r� rk r' )r r �rc�out�err_msgr r r � _call_ip_link s z NetTuningPlugin._call_ip_linkNc C s dg}|r|� |� | �|�S )NZshow)�appendr� )r r* r r r r � _ip_link_show s z NetTuningPlugin._ip_link_showr� c C s~ |d u r d S z t |� W n" ty: t�d| � Y d S 0 |sz| �dd|�|�d|g�}|d u rzt�d|�|� � d S |S )Nz$txqueuelen value '%s' is not integerr" �devr� z%Cannot set txqueuelen for device '%s'�ra � ValueErrorr& r� r� rO �r rb r* r= r� r� �resr r r �_set_txqueuelen s z NetTuningPlugin._set_txqueuelenc C s( || j vr t�d| �| j |< | j | S )z@ Return regex for int arg value from "ip link show" command z.*\s+%s\s+(\d+))r r r )r �argr r r �_get_re_ip_link_show- s z$NetTuningPlugin._get_re_ip_link_showc C sr | � |�|��}|d u r4|s0t�d|�|� � d S | �d��|�}|d u rh|sdt�d|�|� � d S |�d�S )NzECannot get 'ip link show' result for txqueuelen value for device '%s'ZqlenzFCannot get txqueuelen value from 'ip link show' result for device '%s'r �r� rO r& rk r� r� r� �r r* r= r� r� r� r r r �_get_txqueuelen5 s ��z NetTuningPlugin._get_txqueuelenr� c C s~ |d u r d S z t |� W n" ty: t�d| � Y d S 0 |sz| �dd|�|�d|g�}|d u rzt�d|�|� � d S |S )Nz mtu value '%s' is not integerr" r� r� z Cannot set mtu for device '%s'r� r� r r r �_set_mtuF s zNetTuningPlugin._set_mtuc C sr | � |�|��}|d u r4|s0t�d|�|� � d S | �d��|�}|d u rh|sdt�d|�|� � d S |�d�S )Nz>Cannot get 'ip link show' result for mtu value for device '%s'r� z?Cannot get mtu value from 'ip link show' result for device '%s'r r� r� r r r �_get_mtuV s ��zNetTuningPlugin._get_mtuc C sl |dkr dS t |�� �}| j| j| j| jd�}t || � �� �}|�|�sht�d|t || �f � dS dS )Nr} T)r~ r r� r� zunknown %s parameter(s): %sF) r" �keysrp rt rw rz �issubsetr& r� r( )r r� rK �paramsZsupported_getterZ supportedr r r �_check_parametersh s � z!NetTuningPlugin._check_parametersc C sR | j �dddd�|�}|�d�dd � }dd� |D �}td d� d d� |D �D ��S ) Nrq rr rs )Z Autonegotiate�RX�TXr� r c S s$ g | ] }|d krt �d|�s|�qS )� z \[fixed\])r r� r, r r r r0 } r1 z;NetTuningPlugin._parse_pause_parameters.<locals>.<listcomp>c S s g | ]}t |�d kr|�qS r� r� r, r r r r0 ~ r1 c S s g | ]}t �d |��qS r� �r r� r, r r r r0 ~ r1 )r r� r� r� )r �s�lr r r �_parse_pause_parametersw s ��z'NetTuningPlugin._parse_pause_parametersc C sj t jd|t jd�}|d }| j�ddddd�|�}|�d �}d d � |D �}d d � d d � |D �D �}t|�S )N� ^Current hardware settings:$��flagsr rr ru rv rs )r� zRX MinizRX Jumbor� r� c S s g | ]}|d kr|�qS �r� r r, r r r r0 � r1 z:NetTuningPlugin._parse_ring_parameters.<locals>.<listcomp>c S s g | ]}t |�d kr|�qS r� r� r, r r r r0 � r1 c S s g | ]}t �d |��qS r� r� r, r r r r0 � r1 �r r� � MULTILINEr r� r� �r r� �ar� r r r �_parse_ring_parameters� s �� z&NetTuningPlugin._parse_ring_parametersc C sj t jd|t jd�}|d }| j�ddddd�|�}|�d �}d d � |D �}d d � d d � |D �D �}t|�S )Nr� r� r rr rs rx ry )r� r� ZOtherZCombinedr� c S s g | ]}|d kr|�qS r� r r, r r r r0 � r1 z>NetTuningPlugin._parse_channels_parameters.<locals>.<listcomp>c S s g | ]}t |�d kr|�qS r� r� r, r r r r0 � r1 c S s g | ]}t �d |��qS r� r� r, r r r r0 � r1 r� r� r r r �_parse_channels_parameters� s �� z*NetTuningPlugin._parse_channels_parametersc C sz g }d|v r(|� d|d d|d g� n,ttt|d �t|d ���}|� d|g� ttt|d d d� |dd d� ���S )Nry rr r rs � r� )�extendr( r� ra r� rG r� )r r� Z params_list� dev_paramsZmod_params_listZcntr r r � _replace_channels_parameters� s z,NetTuningPlugin._replace_channels_parametersc C sT t |�� �}t |�� �}|| }|D ]*} t�d|| |�|�f � |�| d� q$dS )a: Filter unsupported parameters and log warnings about it Positional parameters: instance -- instance calling it 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 z-%s parameter %s is not supported by device %sN)r" r� r& r� rO �pop) r r= r� � parametersr* r� Zsupported_parametersZparameters_to_changeZunsupported_parameters�paramr r r �_check_device_support� s ��z%NetTuningPlugin._check_device_supportc C s� dddddd�}|| }| j �d||�|�g�\}}|dksHt|�dkrLd S | j| j| j| j| jd�}|| } | |�} |d kr�| �|| �s�d S | S ) Nz-cz-kz-az-gz-l�r~ r} r r� r� r� r r~ ) r r� rO r� r� r� r� r� r� ) r r= r� r* � context2opt�opt�retrb Zcontext2parser�parserrK r r r �_get_device_parameters� s$ � �z&NetTuningPlugin._get_device_parametersc C s� |d u st |�dkrd S | �||�}|d u s8| �||�s<i S |r�| �|||||� |dkr�t|tt|�� �dv r�| �|| j� |�|�}|s�t |�dkr�t � d|t|�f � ddddd d �}|| } | jj d | |� |�g| j� |� d gd � |S )Nr r� )zn/ar� zsetting %s: %sz-Cz-Kz-Az-Gz-Lr� r� �P )r� )r� r� r� r� r( �next�iterr� r � dict2listr& r' r� rO ) r r= r� rb r* r� r� rK r� r� r r r �_set_device_parameters� s* � ��z&NetTuningPlugin._set_device_parametersc s� | j ||d�}|r�| �|||�}|d u s4t|�dkr8dS | j||||||d�� � d u sbt� �dkrfdS � fdd�|�� D �} t| �} |r�| j�� �| j�| �k} | j|| � | |� |�d� | S | j � |d� | j�| ��� n | j � |�} | �||| |d� d S ) N)Z command_namer> r F)r� c s g | ]\}}|� v r||f�qS r r )r- r� rb �Z params_setr r r0 � s �z6NetTuningPlugin._custom_parameters.<locals>.<listcomp>)r* r� )Z _storage_keyr� r� r� rH r� r r� Z_log_verification_resultrO Z_storager" �joinr@ ) r r� �startrb r* �verifyr= Z storage_keyZparams_currentZrelevant_params_currentr� �original_valuer r� r �_custom_parameters� sD �� � �� � z"NetTuningPlugin._custom_parametersr} c C s | � d|||||�S )Nr} �r� �r r� rb r* r� r� r= r r r � _features s zNetTuningPlugin._featuresr~ c C s | � d|||||�S )Nr~ r� r� r r r � _coalesce s zNetTuningPlugin._coalescer c C s | � d|||||�S )Nr r� r� r r r �_pause s zNetTuningPlugin._pauser� c C s | � d|||||�S )Nr� r� r� r r r �_ring s zNetTuningPlugin._ringr� c C s | � d|||||�S )Nr� r� r� r r r � _channels s zNetTuningPlugin._channels)F)N)F)F)N)B�__name__� __module__� __qualname__�__doc__r r! r3 r$ r8 r9 r7 r; r? r r rM rP rV rW r[ r\ r_ r] � classmethodrp rt rw rz r� rh ri rj r� r� r� r� r� Z command_setr� Z command_getr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� Zcommand_customr� r� r� r r � __classcell__r r r r r s� ! � % r )r� r� r Z decoratorsZ tuned.logsZtunedZtuned.utils.nettoolr Ztuned.utils.commandsr �osr r Zlogsr@ r& r� ZPluginr r r r r �<module> s