File manager - Edit - /home/u478019808/domains/bestandroidphones.store/public_html/static/img/logo/iotop.tar
Back
__pycache__/vmstat.cpython-39.opt-1.pyc 0000644 00000002132 15025012261 0013652 0 ustar 00 a B��Q � @ s G d d� de �ZdS )c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�VmStatc C s t d�| _| �� | _d S )Nz /proc/vmstat)�open� vmstat_file�read�vmstat)�self� r �0/usr/lib/python3.9/site-packages/iotop/vmstat.py�__init__ s zVmStat.__init__c C s` dd� }| j D ]}|�d�r||�} q*q| j D ]}|�d�r0||�} qLq0| j �d� ||fS )Nc S s t | �� d �d S )N� i )�int�split)�liner r r �extract s z VmStat.read.<locals>.extractzpgpgin zpgpgout � )r � startswith�seek)r r r ZpgpginZpgpgoutr r r r s z VmStat.readc C s6 | � � }|d | jd |d | jd f}|| _|S )Nr r )r r )r Znow�deltar r r r ) s $z VmStat.deltaN)�__name__� __module__� __qualname__r r r r r r r r s r N)�objectr r r r r �<module> � __pycache__/ioprio.cpython-39.pyc 0000644 00000007633 15025012261 0012711 0 ustar 00 a B��Qw � @ sd d dl Z d dlZd dlZd dlZg d�Zg d�Zdd� ZG dd� de�Zee�Z ee�Z ze j ddd �Z W n e y� e � d�Z Y n0 e jZg d �Zd Zd Zd e> d Zd d� Zdd� Zdd� Ze jZed�\ZZZZZ Z e j Z d Z dd� Z dd� Z!dd� Z"dd� Z#d d � Z$e%d k�r`d dl&Z&e'e&j(�d k�r@e)e&j(d �Z*ne�+� Z*e,d e*� e,d!e!e*�� dS )"� N) )�alpha�*i� )�arm*r i; )�i*86r �" )�ia64*r i� )�parisc*r i )�powerpc*r i )�s390*r i )�sparc*r �� )�sh*r �! )�x86_64*�32bitr )r �64bit� ) )r r i� )r r i: )r r r )r r i� )r r i )r r i )r r i )r r �� )r r i )r r r )r r � c C sL t �� d }t�� d }| D ]*\}}}t�||�r t�||�r | S q d S )N� r )�os�uname�platformZ architecture�fnmatch)Z syscall_listZarch�bitsZcandidate_archZcandidate_bitsZ syscall_nr� r �0/usr/lib/python3.9/site-packages/iotop/ioprio.py�find_ioprio_syscall_number9 s �r c @ s e Zd Zdd� ZdS )�IoprioSetErrorc C s. zt �|�| _W n ty( || _Y n0 d S �N)r �strerror�err� TypeError)�selfr! r r r �__init__C s zIoprioSetError.__init__N)�__name__� __module__� __qualname__r$ r r r r r B s r T�Z use_errno)NZrt�be�idle� � c C s8 zt �| �} W n ty* t �d �} Y n0 | t> |B S r )�PRIORITY_CLASSES�index� ValueError�IOPRIO_CLASS_SHIFT)� ioprio_class� ioprio_datar r r � ioprio_valueY s r3 c C s t | t? S r )r- r0 ��ioprior r r r1 ` s r1 c C s | t @ S r )�IOPRIO_PRIO_MASKr4 r r r r2 c s r2 � c C sJ t | �}tt| �}|d d }|ttfv r2d| S |tkr>dS d| S d S )N� � zrt/%dr* zbe/%d)�sched_getscheduler� getpriority� PRIO_PROCESS� SCHED_FIFO�SCHED_RR� SCHED_IDLE)�pidZ scheduler�niceZ ioprio_nicer r r �get_ioprio_from_schedl s rB c C sT t d u r dS tt t| �}|dk r$dS t|�}|s8t| �S |dkrD|S d|t|�f S )Nz?sysr z?errr* z%s/%d)�__NR_ioprio_get�syscall�IOPRIO_WHO_PROCESSr1 rB r2 )r@ r5 Z prio_classr r r �getx s rF c C sd t d u rtd��t||�}tt | ||dd�}|dk r`z t�� }W n tyV d}Y n0 t|��d S )NzNo ioprio_set syscall foundTr( r z<Unknown error (errno support not available before Python2.6))�__NR_ioprio_setr r3 rD �ctypesZ get_errno�AttributeError)�whichZwhor1 r2 Z ioprio_val�retr! r r r � set_ioprio� s rL c C st | d dkrt | d � S d| v rT| �d�r2d}n| �d�r@d}t| �d�d �}n| dkrdd}d}d|t > | S ) Nr �?r+ �/zrt/zbe/r* � )�ord� startswith�int�splitr0 )�key�shiftZprior r r �sort_key� s rV c C s6 d| v r&| � d�}|d t|d �fS | dkr2dS dS )NrN r r+ r* )r* r )NN)rS rR )Z ioprio_strrS r r r �to_class_and_data� s rW �__main__rO zpid:zioprio:)-rH r r r ZIOPRIO_GET_ARCH_SYSCALLZIOPRIO_SET_ARCH_SYSCALLr � Exceptionr rC rG ZCDLLZ ctypes_handler" rD r- rE r0 r6 r3 r1 r2 r: �range� SCHED_OTHERr= r> � SCHED_BATCHZ SCHED_ISOr? r; r< rB rF rL rV rW r% �sys�len�argvrR r@ �getpid�printr r r r �<module> sJ __pycache__/vmstat.cpython-39.pyc 0000644 00000002132 15025012261 0012713 0 ustar 00 a B��Q � @ s G d d� de �ZdS )c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�VmStatc C s t d�| _| �� | _d S )Nz /proc/vmstat)�open� vmstat_file�read�vmstat)�self� r �0/usr/lib/python3.9/site-packages/iotop/vmstat.py�__init__ s zVmStat.__init__c C s` dd� }| j D ]}|�d�r||�} q*q| j D ]}|�d�r0||�} qLq0| j �d� ||fS )Nc S s t | �� d �d S )N� i )�int�split)�liner r r �extract s z VmStat.read.<locals>.extractzpgpgin zpgpgout � )r � startswith�seek)r r r ZpgpginZpgpgoutr r r r s z VmStat.readc C s6 | � � }|d | jd |d | jd f}|| _|S )Nr r )r r )r Znow�deltar r r r ) s $z VmStat.deltaN)�__name__� __module__� __qualname__r r r r r r r r s r N)�objectr r r r r �<module> � __pycache__/ui.cpython-39.opt-1.pyc 0000644 00000050606 15025012261 0012762 0 ustar 00 a ��Jc�b � @ sp d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl m Z mZmZmZmZ d dl mZ d dlmZ d dlmZ d dlmZ g d�Zd d � Zd d � Zd d� Z dd� Z dd� Z e � Z G dd� de �Z!G dd� de �Z"G dd� de �Z#G dd� de �Z$G dd � d e �Z%G d d � d e&�Z'd d � Z(d!d"� Z)d#d$� Z*d%e j+d Z,d&d'� Z-dS )(� )�print_functionN)� find_uids�TaskStatsNetlink� ProcessList�Stats�sysctl_task_delayacct)� ThreadInfo)�VERSION)�ioprio)�IoprioSetError)�B�K�M�G�T�P�Ec C s` | dkrd}n| dk r"d}| } ndS t t�| d d�d �}d|t| �dd| > t| f S ) Nr � �-z0.00 B� � z %s%.2f %s� )�int�math�log�float�UNITS)�size�signZexpo� r �,/usr/lib/python3.9/site-packages/iotop/ui.py� human_size- s r! c C s | j rd|d S t|�S )Nz%.2f Kg �@)� kilobytesr! )�options�bytesr r r � format_size9 s r% c C s t | |ot|�| �d S )Nz/s)r% r )r# r �durationr r r �format_bandwidth> s r' c s� � fdd�}�j r4|j}�fdd�}t�� |j � n|j}�fdd�}||j�}||j�}||j� �}|j|j } t d| �} || � �} |||| fS )Nc s dt d| � d � S )Nz%.2f %%g��(\�X@g �cA)�min)Zdelay)r& r r � delay2percentD s z#format_stats.<locals>.delay2percentc s t � | �S �N)r% �r r& �r# r r �<lambda>H � z format_stats.<locals>.<lambda>c s t � | |�S r* )r' r+ r, r r r- L s �r ) � accumulated� stats_accum�timeZstats_accum_timestamp� stats_delta�blkio_delay_total�swapin_delay_total� read_bytes� write_bytes�cancelled_write_bytes�max) r# Zprocessr& r) �statsZdisplay_format�io_delay� swapin_delayr5 Z written_bytesr6 r )r& r# r � format_statsA s r< c C sJ zt td��� �� �W S tyD } zt| � W Y d } ~ dS d } ~ 0 0 d S )Nz/proc/sys/kernel/pid_max� )�len�open�read�strip� Exception�print)�er r r �get_max_pid_widthV s rE c @ s e Zd ZdS )� CancelInputN��__name__� __module__� __qualname__r r r r rF d r. rF c @ s e Zd ZdS )� InvalidIntNrG r r r r rK e r. rK c @ s e Zd ZdS )� InvalidPidNrG r r r r rL f r. rL c @ s e Zd ZdS )� InvalidTidNrG r r r r rM g r. rM c @ s e Zd ZdS )�InvalidIoprioDataNrG r r r r rN h r. rN c @ s� e Zd Zdd� dfdd� dfdd� dfdd� dfdd� dfd d� dfd d� dfd d� dfgZd d � Zdd� Zdd� Zdd� Zdd� Zd0dd�Z d1dd�Z dd � Z d d � Z d d � Z d!d"� Zd2d#d$�Zd3d&d'�Zd(d)� Zd*d+� Zd,d-� Zd.d/� ZdS )4�IOTopUIc C s | j S r* )�pid��p�sr r r r- q r. zIOTopUI.<lambda>Fc C s | � � S r* )Zioprio_sort_keyrQ r r r r- r r. c C s | � � S r* )�get_userrQ r r r r- s r. c C s |j S r* )r5 rQ r r r r- t r. Tc C s |j |j S r* )r6 r7 rQ r r r r- u r. c C s |j S r* )r4 rQ r r r r- v r. c C s |j pt|jp|j �S r* )r3 r r5 r6 rQ r r r r- y s c C s | � � S r* )� get_cmdlinerQ r r r r- { r. c C sr || _ || _d| _tj| j d | _| jjsn|| _| �� z t � � t � � t � d� W n t j yl Y n0 d S )N� r r )� process_listr# � sorting_keyrO � sorting_keys�sorting_reverse�batch�win�resize�cursesZuse_default_colorsZ start_color�curs_set�error)�selfr\ rW r# r r r �__init__~ s zIOTopUI.__init__c C s | j �� \| _| _d S r* )r\ Zgetmaxyx�height�width�ra r r r r] � s zIOTopUI.resizec C sX d}t �� }| jjs.|�tj�� t jt j B � | jj d u sH|| jj k �rT| j � � \}}| � |dk||| j j� | jj d ur�|d7 }|| jj kr��qTn |dkr�d}z|�| jjd �}W nD t jy� } z*|jr�|jd tjkr�g }n� W Y d }~n d }~0 0 |D ]&\}}|t jt jB @ �r t�d� �q | jj�s:| �� |r.| j�� } | �| � q.d S )Nr r g @�@)�select�pollr# r[ �register�sys�stdin�filenoZPOLLINZPOLLPRI� iterationsrW �refresh_processes�refresh_displayr& � delay_secondsr` �args�errnoZEINTRZPOLLERRZPOLLHUP�exitr] r\ �getch� handle_key) ra rl rg �total�actualZeventsrD �fdZevent�keyr r r �run� s> �� z IOTopUI.runc C s | j | _ d S r* )rZ re r r r �reverse_sorting� s zIOTopUI.reverse_sortingc C s� | j }| j |7 _ td| j �| _ tttj�d | j �| _ | jsh| j dv rh|dkrZd| _ n|dkrhd| _ || j kr�tj| j d | _d S )Nr r �r= rV � � )rX r8 r( r> rO rY � has_swapin_iorZ )ra ZdeltaZorig_sorting_keyr r r �adjust_sorting_key� s zIOTopUI.adjust_sorting_keyNc C s� | j �ddtd�tjB | j� | j �dd|tj� | j �� t� � t� d� | j � dt |��}t� d� t� � |dvr~|S |r�t� �|S )Nr r � )Nr )r\ �hline�ordr^ �A_NORMALrd �addstr�A_BOLD�refreshZechor_ Zgetstrr> ZnoechorF �ra �prompt�defaultZempty_is_cancel�inpr r r � prompt_str� s zIOTopUI.prompt_strc C s6 | � |||�}z t|�W S ty0 t� �Y n0 d S r* )r� r � ValueErrorrK r� r r r � prompt_int� s zIOTopUI.prompt_intc C s< z | � d�W S ty$ t� �Y n ty6 � Y n0 d S )NzPID to ionice: )r� rK rL rF re r r r � prompt_pid� s zIOTopUI.prompt_pidc C s< z | � d�W S ty$ t� �Y n ty6 � Y n0 d S )NzTID to ionice: )r� rK rM rF re r r r � prompt_tid� s zIOTopUI.prompt_tidc C sb z.|d ur | � d| |d�}n| � dd d�}W n tyF t� �Y n0 |dk sX|dkr^t� �|S )Nz'I/O priority data (0-7, currently %s): FzI/O priority data (0-7): r r} )r� rK rN )ra � ioprio_datar� r r r � prompt_data� s �� zIOTopUI.prompt_datac C sf z|� |�}W n ty$ d}Y n0 t|�d }| j�ddtd�tjB | j� | j� dd|tj � t|�}t |�D ]D\}}d| } ||u r�tj } ntj} | j� d|| | � |t| �7 }qt| j� � } | tjtd�fv r�|dkr�|d8 }q2q�| tjtd�fv �r||k �r|d7 }q2q�| tjtd�td �fv �r6|| S | d tjtjtjtd �td �fv r�t� �q�q2d S ) N���r r r� � %s �l�r� � � �q�Q)�indexr� r> r\ r� r� r^ r� rd �insstrr� � enumerate� A_REVERSErs �KEY_LEFT� KEY_RIGHTZ KEY_ENTERZ KEY_CANCELZ KEY_CLOSEZKEY_EXITrF ) ra r� Z display_listZret_listZselectedZset_len�offset�i�itemZdisplay�attrrx r r r � prompt_set� s8 �zIOTopUI.prompt_setc C s4 d}g d�}g d�}|d u r d}| � ||||�}|S )NzI/O priority class: )z Real-timez Best-effortZIdle)Zrt�be�idler )r� )ra � ioprio_classr� Zclasses_promptZ classes_retr� r r r � prompt_class s zIOTopUI.prompt_class�Error!c C sN | j �ddtd�tjB | j� | j �ddd| tj� | j �� t � d� d S )Nr r r� z %s ) r\ r� r� r^ r� rd r� r� r� r1 �sleep)ra r` r r r � prompt_error" s zIOTopUI.prompt_errorc C s, | j �ddtd�tjB | j� | j �� d S )Nr r r� )r\ r� r� r^ r� rd r� re r r r � prompt_clear( s zIOTopUI.prompt_clearc " s� � fdd�}� fdd�}� fdd�}� fdd�}t d �d d � t d �d d � t d�� fdd �t d�� fdd �t d�|t d�|t d�|t d�|t d�|t d�|t d�|t d�|tj� fdd �tj� fdd �tj� fd d �tj� fd d �i}|�|d d � �}|� d S ) Nc s � j jdN _d S �NT)r# r/ r re r r �toggle_accumulated- s z.IOTopUI.handle_key.<locals>.toggle_accumulatedc s � j jdN _d S r� )r# �onlyr re r r �toggle_only_io/ s z*IOTopUI.handle_key.<locals>.toggle_only_ioc s( � j jdN _� j�� � j�� d S r� )r# � processesrW �clearrm r re r r �toggle_processes1 s z,IOTopUI.handle_key.<locals>.toggle_processesc sX z�� j jr � �� } � j�| �}n� �� }t|� jj�}|�� }t � |�\}}� � |�}|dkrdd}n � � |�}|� ||� � j�� � j�� W n� ty� } z � �d|j � W Y d }~n�d }~0 ty� � �d� Y nv ty� � �d� Y n\ t�y � �d� Y n@ t�y0 � �d� Y n$ t�yJ � �� Y n 0 � �� d S )Nr� r z Error setting I/O priority: %szInvalid process id!zInvalid thread id!zInvalid I/O priority data!zInvalid integer!)r# r� r� rW Z get_processr� r �taskstats_connection� get_ioprior Zto_class_and_datar� r� Z set_ioprior� rm r r� �errrL rM rN rK rF r� )rP Z exec_unit�tidZ ioprio_valuer� r� rD re r r �ionice5 s> �� $ z"IOTopUI.handle_key.<locals>.ionicer� c S s t �d�S �Nr �ri rr r r r r r- Z r. z$IOTopUI.handle_key.<locals>.<lambda>r� c S s t �d�S r� r� r r r r r- \ r. r� c s � � � S r* �rz r re r r r- ^ r. �Rc s � � � S r* r� r re r r r- ` r. �a�A�o�OrR r r� �Ic s � � d�S )Nr� �r r re r r r- r r. c s � � d�S )Nr r� r re r r r- t r. c s � � ttj� �S r* �r r> rO rY r re r r r- v r. c s � � ttj��S r* r� r re r r r- x r. c S s d S r* r r r r r r- { r. )r� r^ r� r� ZKEY_HOMEZKEY_END�get)ra rx r� r� r� r� Z key_bindings�actionr re r rt , sN $ �#zIOTopUI.handle_keyc s� �fdd�}�fdd�}t t|�jj�� ��}tj�j d � �jj rPdd� �ndd� �|j � �fd d��j d � �jj s�|�j d d �= t t||��S ) Nc sR t � j| � jj�}|\}}}}dt }| jf}|d7 }|| �� f7 }|d7 }|| �� d d� f7 }|d7 }|||f7 }� jr�|d7 }|||f7 }n� jj r�|d7 }|d7 }|d 7 }|| }| � � } � jj �s.� j t |� } d | k r�t | �k �r.n n6| d d } | | d } | d | � d | | d � } || 7 }� jj �sN|d � j � }|S ) Nz%%%ddz %4sz %-8s� z %11s %11sz %7s %7sr� )z ?unavailable?r� r r �~) r< r# rW r& � MAX_PID_WIDTHrP r� rT r~ r[ rU rd r> ) rR r9 r: r; r5 r6 �format�params�lineZcmdlineZremaining_lengthZlen1Zoffset2re r r r� s: z IOTopUI.get_data.<locals>.formatc s � j j p| �� j j�S r* )r# r� Z did_some_ior/ �rR re r r � should_format� s �z'IOTopUI.get_data.<locals>.should_formatr c S s | j S r* )r0 r� r r r r- � r. z"IOTopUI.get_data.<locals>.<lambda>c S s | j S r* )r2 r� r r r r- � r. c s � | �| ��S r* r r� )rx � stats_lambdar r r- � r. )rx �reverser )�list�filterrW r� �valuesrO rY rX r# r/ �sortrZ r[ rc �map)ra r� r� r� r )rx ra r� r �get_data~ s � �zIOTopUI.get_datac sl dt �j|d |��d�t �j|d |��d�f dt �j|d |��d�t �j|d |��d�f g�tdtd �d }�jjr�|d7 }n|d 7 }|d d d d dddg}tj�_�jr�t � dkr�d�_�� d� �� � }�jj �rdg| }t � d�� � fdd�|D �}� fdd��D ���jj�r��jjdk�rf�D ]}t|� �q6�jjt|�k�rftd�|�� |D ]} t| �d�� �qjtj�� �nڈj�� t��D ]$\�}�j��d|d �j� � �q��j� t ��dt d�t j B �j� �j} t!t |��D ]���j�s�dv �r�q�t j } |� } ��j"k�r:| dd � } ��j"k�rf| t j#O } | �j$�r`d�pbd 7 } | d | � } | t | �8 } �j�| | � �q��jdu�r�d } nd } t%t |��j&d tt'| �� �}t!|�D ]j�zL���fd d �}z||� � W n& t(�y ||� �d�� Y n0 W n t j)�y4 Y n0 �q�| �r^�j�*�j&t �� d| t j#� �j�+� d S ) Nz,Total DISK READ : %s | Total DISK WRITE : %sr � r z,Actual DISK READ: %s | Actual DISK WRITE: %s� r� �PIDZTIDz PRIOz USERz DISK READz DISK WRITEz SWAPINz IOz COMMANDFz TIMEz %H:%M:%S c s g | ] }� | �qS r r )�.0r� �� current_timer r � <listcomp>� r. z+IOTopUI.refresh_display.<locals>.<listcomp>c s g | ] }� | �qS r r )r� rS r� r r r� � r. r r zutf-8r{ �>�<zoCONFIG_TASK_DELAY_ACCT and kernel.task_delayacct sysctl not enabled in kernel, cannot determine SWAPIN and IO %c s �j �� t�� d d| � d S )Nr r )r\ r� r> )r� )r� ra �summaryr r � print_line� s z+IOTopUI.refresh_display.<locals>.print_line),r' r# �rjustr8 r� r� r Zhas_blkio_delay_totalr~ r r r� r1 �strftimer[ �quietrC r �join�encoderi �stdout�flushr\ Zeraser� r� rd r� r> r� r^ r� �rangerX r� rZ r( rc �bool�UnicodeEncodeErrorr` r� r� )ra Z first_timeru rv r& rP Ztitles�linesrS r� Zremaining_colsr� �titleZ status_msgZ num_linesr� r )r� r� ra r� r rn � s� ��� � � �zIOTopUI.refresh_display)NT)NT)N)r� )rH rI rJ rY rb r] ry rz r r� r� r� r� r� r� r� r� r� rt r� rn r r r r rO n s8 � �! R1rO c C sf |j rt�tjtj� n$dd� }t�tj|� t�tj|� t|�}t||�}t| ||�}|� � d S )Nc _ s t �d� d S r� r� )rp �kwargsr r r � clean_exit s z$run_iotop_window.<locals>.clean_exit) r[ �signal�SIGPIPE�SIG_DFL�SIGINT�SIGTERMr r rO ry )r\ r# r� r� rW Zuir r r �run_iotop_window s r� c C s� z$| j rtd | �W S t�t| �W S W n� ty~ } zB|jtjkrht|tj d� tdtj d� t� d� n� W Y d }~ndd }~0 tj y� } zBt |�}|� d�dkr�|� d�dks�|� d�dkr�n� W Y d }~n d }~0 0 d S )N)�filea� The Linux kernel interfaces that iotop relies on now require root priviliges or the NET_ADMIN capability. This change occured because a security issue (CVE-2011-2494) was found that allows leakage of sensitive data across user boundaries. If you require the ability to run iotop as a non-root user, please configure sudo to allow you to run iotop as root. Please do not file bugs on iotop about this.r ZERRr z nocbreak()zendwin())r[ r� r^ �wrapper�OSErrorrq �EPERMrC ri �stderrrr r` �str�find)r# rD Zstrer r r � run_iotop s* � � �r� c C s� d}z:dd l }dd l}td� |�dt� t� |� |�|�}W nV ty� dd l}dd l }|j |dd�}td� |� | � |� � |j �|�}Y n0 |�� |�dd � |�d � |�d � t�|� d S ) Nz iotop.profr zProfiling using cProfilezcontinuation()r )Z lineeventszProfiling using hotshotr1 Zcalls�2 )�cProfile�pstatsrC Zrunctx�globals�localsr � ImportError�hotshotZ hotshot.statsZProfileZruncall�closer9 �loadZ strip_dirsZ sort_statsZ print_statsZ print_callees�os�remove)Z continuationZ prof_filer� r r9 r Zprofr r r �_profile6 s( r aF %s [OPTIONS] DISK READ and DISK WRITE are the block I/O bandwidth used during the sampling period. SWAPIN and IO are the percentages of time the thread spent respectively while swapping in and waiting on I/O more generally. PRIO is the I/O priority at which the thread is running (set using the ionice command). Controls: left and right arrows to change the sorting column, r to invert the sorting order, o to toggle the --only option, p to toggle the --processes option, a to toggle the --accumulated option, i to change I/O priority, q to quit, any other key to force a refresh.c s� zt �t jd� W n t jy. td� Y n0 tjtdt d�} | j ddddd d d � | j d d dddd� | j ddddddd� | j ddddd d d d � | j d d!dd"d#d$d%d&� | j d'd(d)d*d#d+d,d&� | j d-d.dd/d d0d � | j d1d2dd3d d4d � | j d5d6dd7d d8d � | j d9d:dd;d<d� | j d=d>d?d@dAdBd � | j dCddDd tj d � | � � \�}|�rr| � dEdF� |� � t�� �j�p�g �_�j�p��j�p��j�_�fdGdH�� �j�rʇ fdIdJ�}t|� n� � d S )KNr z8unable to set locale, falling back to the default localeziotop )�usage�versionz-oz--only� store_truer� Fz1only show processes or threads actually doing I/O)r� �destr� �helpz-bz--batchr[ znon-interactive mode)r� r r z-nz--iterr rl ZNUMz-number of iterations before ending [infinite])�typer �metavarr z-dz--delayr ro z#delay between iterations [1 second]ZSECr )r r r r r� z-pz--pid�pids�appendz"processes/threads to monitor [all]r� )r r r� r r z-uz--userr� Zuserszusers to monitor [all]ZUSERz-Pz --processesr� z$only show processes, not all threadsz-az --accumulatedr/ z)show accumulated I/O instead of bandwidthz-kz --kilobytesr" z.use kilobytes instead of a human friendly unitz-tz--timer1 z.add a timestamp on each line (implies --batch)z-qz--quiet�countr� r z/suppress some lines of header (implies --batch)z --profile�profilezUnexpected arguments: r� c s t � �S r* )r� r r, r r r- � r. zmain.<locals>.<lambda>c s z � � W n Y n0 d S r* r r )� main_loopr r �safe_main_loop� s z main.<locals>.safe_main_loop)�locale� setlocale�LC_ALL�ErrorrC �optparseZ OptionParser�USAGEr Z add_optionZ SUPPRESS_HELP� parse_argsr` r� r r r[ r1 r� r r )�parserrp r r )r r# r �main\ st � � � ��� � � � �� � r ).Z __future__r r^ rq r r r r rf r� ri r1 Z iotop.datar r r r r r Z iotop.versionr Ziotopr Z iotop.ioprior r r! r% r' r< rE r� rB rF rK rL rM rN �objectrO r� r� r �argvr r r r r r �<module> sL $ � __pycache__/data.cpython-39.pyc 0000644 00000031663 15025012261 0012321 0 ustar 00 a ��Jc,; � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z ej � d�Z zd dl mZ e� ZW n dZY n0 dZe r�es�ed� ed� e s�ed � es�ed � e�d � d d lmZmZ d d lmZmZmZmZ d dlm Z m Z G dd� de �Z G dd� de �Z d Z!d Z"dZ#d Z$dZ%G dd� de �Z&dd� Z'dd� Z(dd � Z)G d d � d e �Z*G d d � d e �Z+G d!d"� d"e �Z,d#d$� Z-dS )%� )�print_functionNz /proc/self/io)�VmStatFTz<Could not run iotop as some of the requirements are not met:z- Linux >= 2.6.20 withz~ - I/O accounting support (CONFIG_TASKSTATS, CONFIG_TASK_DELAY_ACCT, CONFIG_TASK_IO_ACCOUNTING, kernel.task_delayacct sysctl)z0 - VM event counters (CONFIG_VM_EVENT_COUNTERS)� )�ioprio�vmstat)� Connection�NETLINK_GENERIC�U32Attr� NLM_F_REQUEST)� Controller� GeNlMessagec @ s e Zd ZdZdd� ZdS )�DumpableObjectzFBase class for all objects that allows easy introspection when printedc C s$ dt t| ��d d� t�| j�f S )Nz%s: %s>���)�str�type�pprintZpformat�__dict__��self� r �./usr/lib/python3.9/site-packages/iotop/data.py�__repr__> s zDumpableObject.__repr__N)�__name__� __module__� __qualname__�__doc__r r r r r r < s r c @ sF e Zd Zg d�ZdZdd� Zddd�Zdd � Zd d � Ze d d � �Z dS )�Stats))�blkio_delay_total�( )�swapin_delay_total�8 )� read_bytes� )� write_bytes� )Zcancelled_write_bytesi Nc C sL | j }tjD ],\}}|||d � }t�d|�d ||< q tjsHt� t_d S )N� �Qr )r r �members_offsets�struct�unpack�has_blkio_delay_total�sysctl_task_delayacct)r Ztask_stats_buffer�sd�name�offset�datar r r �__init__Q s zStats.__init__r c C s> |j }| j }|j }tjD ] \}}|| ||| ||< qdS )z3Update destination from operator(self, other_stats)N�r r r' ) r � other_stats� destination�coeff�ddr, Zod�memberr. r r r � accumulate\ s zStats.accumulatec C s | j ||dd�S )z*Update destination with self - other_statsr )r4 )r7 )r r2 r3 r r r �deltad s z Stats.deltac C s, | j }tjD ]\}}|| dkr dS q dS )Nr FTr1 )r r, r- r. r r r � is_all_zeroh s zStats.is_all_zeroc C s, t �t �} | j}t jD ]\}}d||< q| S )Nr )r �__new__r r' )�statsZstdr- r. r r r �build_all_zeroo s zStats.build_all_zero)r ) r r r r' r* r0 r7 r8 r9 � staticmethodr< r r r r r F s r � � c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�TaskStatsNetlinkc C s* || _ tt�| _t| j�}|�d�| _d S )NZ TASKSTATS)�optionsr r � connectionr Z get_family_id� family_id)r rA Z controllerr r r r0 � s zTaskStatsNetlink.__init__c C s t | jttt|�gtd�S )N)�cmd�attrs�flags)r rC �TASKSTATS_CMD_GETr �TASKSTATS_CMD_ATTR_PIDr )r �tidr r r � build_request� s �z TaskStatsNetlink.build_requestc C s� |j �| j� zt�| j�}W n@ ty^ } z(|jtjkrHW Y d }~d S � W Y d }~n d }~0 0 |j� � D ] \}}|t krj|� � } q�qjd S |t j }t|�dk r�d S t�d|d d� �d }|dks�J �t|�S )Ni �H� r r> )�task_stats_request�sendrB r Zrecv�OSError�errnoZESRCHrE �items�TASKSTATS_TYPE_AGGR_PID�nested�TASKSTATS_TYPE_STATSr/ �lenr( r) r )r �threadZreply�eZ attr_typeZ attr_valueZtaskstats_dataZtaskstats_versionr r r �get_single_task_stats� s$ z&TaskStatsNetlink.get_single_task_statsN)r r r r0 rJ rX r r r r r@ � s r@ c C s� g | _ d}| jpg D ]p}z t|�}W nN tyr zt�|�}W n& tyf td|tj d� d}Y n0 |j }Y n0 |s| j � |� q|r�t� d� dS )zDBuild options.uids from options.users by resolving usernames to UIDsFz Unknown user:)�fileTr N) �uidsZusers�int� ValueError�pwd�getpwnam�KeyError�print�sys�stderr�pw_uid�append�exit)rA �error�u�uid�passwdr r r � find_uids� s rj c C sN i }z2t d| �D ] }|�dd�\}}|�� ||< qW n tyH Y n0 |S )Nz/proc/%d/statusz: r )�open�split�strip�IOError)�pidZ result_dict�line�key�valuer r r �parse_proc_pid_status� s rs c C sB z | � d�W S ty( | �d� Y S ty< | Y S 0 d S )Nzutf-8Z string_escape)�decode�UnicodeDecodeError�encode�AttributeError)�sr r r �safe_utf8_decode� s ry c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) � ThreadInfozStats for a single threadc C s. || _ d| _d | _t�t�| _|�|�| _d S )NT)rI �mark� stats_totalr r: � stats_deltarJ rM )r rI �taskstats_connectionr r r r0 � s zThreadInfo.__init__c C s t �| j�S �N)r �getrI r r r r � get_ioprio� s zThreadInfo.get_ioprioc C s t �t j| j||�S r )r � set_ioprioZIOPRIO_WHO_PROCESSrI )r � ioprio_class� ioprio_datar r r r� � s �zThreadInfo.set_ioprioc C s& | j s || _ |�| j | j� || _ d S r )r| r8 r} )r r; r r r � update_stats� s zThreadInfo.update_statsN)r r r r r0 r� r� r� r r r r rz � s rz c @ sh e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� ZdS )� ProcessInfoz�Stats for a single process (a single line in the output): if options.processes is set, it is a collection of threads, otherwise a single thread.c C s: || _ d | _d | _i | _t�� | _t�� | _t�� | _ d S r ) ro rh �user�threadsr r< r} � stats_accum�timeZstats_accum_timestamp)r ro r r r r0 � s zProcessInfo.__init__c C s8 |j r |js | j|j vr dS |jr4| �� |jvr4dS dS )NFT)�pids� processesro rZ �get_uid)r rA r r r � is_monitored� s �zProcessInfo.is_monitoredc C sX | j r | j S zt�d| j �tj }W n ty< d }Y n0 || j krTd | _|| _ |S )Nz/proc/%d)rh �os�statro �ST_UIDrO r� �r rh r r r r� s zProcessInfo.get_uidc C sX | � � }|d urN| jsNztt�|�j�| _W n ttfyL t|�| _Y n0 | jpVdS )Nz{none}) r� r� ry r] �getpwuid�pw_namer_ rw r r� r r r �get_user s zProcessInfo.get_userc C s z t d| j �}|�d�}W n ty0 Y dS 0 t| j�}|sb|�dd�}|rZd| }nd}|S d}t|�d| j��}|| jkr�t|��dd�}|�dd�}||kr�|d | 7 }|�d �} | d �d �r�| d � d �d } | d | d � | d < d� | �� � }t || �S )Nz/proc/%d/cmdlinei z{no such process}�Name� z[%s]z {no name}ZTgidz [%s]� r �/r � ) rk ro �readrn rs r� r[ rl � startswith�rfind�joinrm ry ) r Z proc_cmdlineZcmdlineZ proc_statusZproc_status_name�suffix�tgidZ tgid_nameZ thread_name�partsZfirst_command_charr r r � get_cmdline s2 zProcessInfo.get_cmdlinec C s4 |r| j �� S | j�� D ]}|j�� s dS qdS )NTF)r� r9 r� �valuesr} )r Z accumulated�tr r r � did_some_io; s zProcessInfo.did_some_ioc C s0 t dd� | j�� D ��}t|�dkr,|�� S dS )Nc s s | ]}|� � V qd S r )r� )�.0r� r r r � <genexpr>D � z)ProcessInfo.get_ioprio.<locals>.<genexpr>r z?dif)�setr� r� rU �pop)r Z prioritiesr r r r� C s zProcessInfo.get_ioprioc C s | j �� D ]}|�||� q d S r )r� r� r� )r r� r� rV r r r r� I s zProcessInfo.set_ioprioc C s t �| �� �S r )r Zsort_keyr� r r r r �ioprio_sort_keyM s zProcessInfo.ioprio_sort_keyc C s* | j �|d �}|s&t||�}|| j |< |S r )r� r� rz )r rI r~ rV r r r � get_threadP s zProcessInfo.get_threadc C s� t �� }| j�� D ] \}}|js|�|j|� qtdd� | j�� D ��| _t| j�}|s\dS | j | _ | j | _ || _| j �| j| j � dS )Nc S s g | ]\}}|j s||f�qS r )r{ )r� rI rV r r r � <listcomp>\ s �z,ProcessInfo.update_stats.<locals>.<listcomp>FT) r r< r� rQ r{ r7 r} �dictrU r r r� )r r} rI rV Z nr_threadsr r r r� W s � zProcessInfo.update_statsN)r r r r r0 r� r� r� r� r� r� r� r� r� r� r r r r r� � s r� c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )� ProcessListc C s2 i | _ || _|| _t�� | _t�� | _| �� d S r )r� r~ rA r� � timestampr r �update_process_counts)r r~ rA r r r r0 l s zProcessList.__init__c C s8 | j �|d�}|s$t|�}|| j |< |�| j�r4|S dS )zyEither get the specified PID from self.processes or build a new ProcessInfo if we see this PID for the first timeN)r� r� r� r� rA )r ro �processr r r � get_processw s zProcessList.get_processc C s� | j jr| j jS t�d�}| j jr0dd� |D �S g }|D ]V}d|d krTdkr8n q8z"|�ttt�d| d ��� W q8 ty� Y q80 q8|S ) Nz/procc S s0 g | ](}d |d kr dkrn qt |��qS )�0r �9)r[ )r� r� r r r r� � r� z*ProcessList.list_tgids.<locals>.<listcomp>r� r r� z/proc/z/task) rA r� r� �listdirr� �extend�mapr[ rO )r Ztgids�tidsr� r r r � list_tgids� s " zProcessList.list_tgidsc C sh | j js|gS z tttt�d| ���}W n ty@ g Y S 0 | j jrdtt | j j�� t |���}|S )Nz /proc/%d/task) rA r� �listr� r[ r� r� rO r� r� � intersection)r r� r� r r r � list_tids� s zProcessList.list_tidsc C s� t � � }|| j | _|| _d }}| �� D ]l}| �|�}|s>q*| �|�D ]L}|�|| j�}| j�|�}|rH|� |� |j } || j 7 }|| j 7 }d|_ qHq*||f| j�� fS )Nr F)r� r� Zdurationr� r� r� r� r~ rX r� r} r! r# r{ r r8 ) r Z new_timestampZ total_readZ total_writer� r� rI rV r; r8 r r r r� � s$ z!ProcessList.update_process_countsc C sL | j �� D ]}|j�� D ] }d|_qq | �� }tdd� | j �� D ��| _ |S )NTc S s g | ]\}}|� � r||f�qS r )r� )r� ro r� r r r r� � s �z1ProcessList.refresh_processes.<locals>.<listcomp>)r� r� r� r{ r� r� rQ )r r� rV Ztotal_read_and_writer r r �refresh_processes� s � z ProcessList.refresh_processesc C s i | _ d S r )r� r r r r �clear� s zProcessList.clearN) r r r r0 r� r� r� r� r� r� r r r r r� k s r� c C s\ zBt d��&} tt| �� �� ��W d � W S 1 s60 Y W n tyV Y d S 0 d S )Nz /proc/sys/kernel/task_delayacct)rk �boolr[ r� rm �FileNotFoundError)�fr r r r+ � s 8 r+ ).Z __future__r rP r� r r] r� r( ra r� �path�existsZ ioaccountingZ iotop.vmstatr Zvmstat_fZvm_event_countersr` re Ziotopr r Z iotop.netlinkr r r r Ziotop.genetlinkr r �objectr r rG rH rR ZTASKSTATS_TYPE_PIDrT r@ rj rs ry rz r� r� r+ r r r r �<module> sT 5) ^ __pycache__/genetlink.cpython-39.pyc 0000644 00000005374 15025012261 0013370 0 ustar 00 a B��Q� � @ s� d Z ddlZddlmZmZmZmZ ddlmZmZm Z dZ dZ dZ dZ dZd Zd ZdZdZdZdZdZd Zd ZG d d � d �Zd d� ZeZG dd� de�ZG dd� d�Z ee �Z e e �Z dS )z� Netlink message generation/parsing Copyright 2007 Johannes Berg <johannes@sipsolutions.net> GPLv2+; See copying for details. � N)� NLM_F_REQUEST�NLMSG_MIN_TYPE�Message�parse_attributes)� NulStrAttr� Connection�NETLINK_GENERIC� � � � � � c @ s e Zd Zddd�Zdd� ZdS )�GenlHdrr c C s || _ || _d S �N)�cmd�version)�selfr r � r �3/usr/lib/python3.9/site-packages/iotop/genetlink.py�__init__ s zGenlHdr.__init__c C s t �d| j| j�S �NZBBxx)�struct�packr r )r r r r �_dump! s z GenlHdr._dumpN)r )�__name__� __module__� __qualname__r r r r r r r s r c C s t t�d| �� S r )r r �unpack)�datar r r �_genl_hdr_parse$ s r c @ s& e Zd Zg dfdd�Zedd� �ZdS )� GeNlMessager c C s4 || _ || _|| _tj| ||t| j �g| d� d S )N)�flags�payload)r �attrs�familyr r r )r r% r r$ r" r r r r * s �zGeNlMessage.__init__c C sP | � � }|j}t|d d� �}t|j|jg |j�}t|dd � �|_|j |_ |S )Nr ) �recvr# r r! �typer r" r r$ r )�conn�msgZpacketZhdrZgenlmsgr r r r& 1 s zGeNlMessage.recvN)r r r r � staticmethodr& r r r r r! ) s r! c @ s e Zd Zdd� Zdd� ZdS )� Controllerc C s || _ d S r )r( )r r( r r r r > s zController.__init__c C sB t t|�}tttt|gd�}|�| j� t�| j�}|j t � � S )N)r" r$ ) r �CTRL_ATTR_FAMILY_NAMEr! � GENL_ID_CTRL�CTRL_CMD_GETFAMILYr �sendr( r& r$ �CTRL_ATTR_FAMILY_ID�u16)r r% �a�mr r r � get_family_id@ s � zController.get_family_idN)r r r r r4 r r r r r+ = s r+ ) �__doc__r Z iotop.netlinkr r r r r r r ZCTRL_CMD_UNSPECZCTRL_CMD_NEWFAMILYZCTRL_CMD_DELFAMILYr. ZCTRL_CMD_NEWOPSZCTRL_CMD_DELOPSZCTRL_CMD_GETOPSZCTRL_ATTR_UNSPECr0 r, ZCTRL_ATTR_VERSIONZCTRL_ATTR_HDRSIZEZCTRL_ATTR_MAXATTRZ CTRL_ATTR_OPSr r r- r! r+ Z connectionZ controllerr r r r �<module> s0 __pycache__/__init__.cpython-39.pyc 0000644 00000000215 15025012261 0013134 0 ustar 00 a B��Q � @ s d S )N� r r r �2/usr/lib/python3.9/site-packages/iotop/__init__.py�<module> � __pycache__/genetlink.cpython-39.opt-1.pyc 0000644 00000005374 15025012261 0014327 0 ustar 00 a B��Q� � @ s� d Z ddlZddlmZmZmZmZ ddlmZmZm Z dZ dZ dZ dZ dZd Zd ZdZdZdZdZdZd Zd ZG d d � d �Zd d� ZeZG dd� de�ZG dd� d�Z ee �Z e e �Z dS )z� Netlink message generation/parsing Copyright 2007 Johannes Berg <johannes@sipsolutions.net> GPLv2+; See copying for details. � N)� NLM_F_REQUEST�NLMSG_MIN_TYPE�Message�parse_attributes)� NulStrAttr� Connection�NETLINK_GENERIC� � � � � � c @ s e Zd Zddd�Zdd� ZdS )�GenlHdrr c C s || _ || _d S �N)�cmd�version)�selfr r � r �3/usr/lib/python3.9/site-packages/iotop/genetlink.py�__init__ s zGenlHdr.__init__c C s t �d| j| j�S �NZBBxx)�struct�packr r )r r r r �_dump! s z GenlHdr._dumpN)r )�__name__� __module__� __qualname__r r r r r r r s r c C s t t�d| �� S r )r r �unpack)�datar r r �_genl_hdr_parse$ s r c @ s& e Zd Zg dfdd�Zedd� �ZdS )� GeNlMessager c C s4 || _ || _|| _tj| ||t| j �g| d� d S )N)�flags�payload)r �attrs�familyr r r )r r% r r$ r" r r r r * s �zGeNlMessage.__init__c C sP | � � }|j}t|d d� �}t|j|jg |j�}t|dd � �|_|j |_ |S )Nr ) �recvr# r r! �typer r" r r$ r )�conn�msgZpacketZhdrZgenlmsgr r r r& 1 s zGeNlMessage.recvN)r r r r � staticmethodr& r r r r r! ) s r! c @ s e Zd Zdd� Zdd� ZdS )� Controllerc C s || _ d S r )r( )r r( r r r r > s zController.__init__c C sB t t|�}tttt|gd�}|�| j� t�| j�}|j t � � S )N)r" r$ ) r �CTRL_ATTR_FAMILY_NAMEr! � GENL_ID_CTRL�CTRL_CMD_GETFAMILYr �sendr( r& r$ �CTRL_ATTR_FAMILY_ID�u16)r r% �a�mr r r � get_family_id@ s � zController.get_family_idN)r r r r r4 r r r r r+ = s r+ ) �__doc__r Z iotop.netlinkr r r r r r r ZCTRL_CMD_UNSPECZCTRL_CMD_NEWFAMILYZCTRL_CMD_DELFAMILYr. ZCTRL_CMD_NEWOPSZCTRL_CMD_DELOPSZCTRL_CMD_GETOPSZCTRL_ATTR_UNSPECr0 r, ZCTRL_ATTR_VERSIONZCTRL_ATTR_HDRSIZEZCTRL_ATTR_MAXATTRZ CTRL_ATTR_OPSr r r- r! r+ Z connectionZ controllerr r r r �<module> s0 __pycache__/data.cpython-39.opt-1.pyc 0000644 00000031640 15025012261 0013253 0 ustar 00 a ��Jc,; � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z ej � d�Z zd dl mZ e� ZW n dZY n0 dZe r�es�ed� ed� e s�ed � es�ed � e�d � d d lmZmZ d d lmZmZmZmZ d dlm Z m Z G dd� de �Z G dd� de �Z d Z!d Z"dZ#d Z$dZ%G dd� de �Z&dd� Z'dd� Z(dd � Z)G d d � d e �Z*G d d � d e �Z+G d!d"� d"e �Z,d#d$� Z-dS )%� )�print_functionNz /proc/self/io)�VmStatFTz<Could not run iotop as some of the requirements are not met:z- Linux >= 2.6.20 withz~ - I/O accounting support (CONFIG_TASKSTATS, CONFIG_TASK_DELAY_ACCT, CONFIG_TASK_IO_ACCOUNTING, kernel.task_delayacct sysctl)z0 - VM event counters (CONFIG_VM_EVENT_COUNTERS)� )�ioprio�vmstat)� Connection�NETLINK_GENERIC�U32Attr� NLM_F_REQUEST)� Controller� GeNlMessagec @ s e Zd ZdZdd� ZdS )�DumpableObjectzFBase class for all objects that allows easy introspection when printedc C s$ dt t| ��d d� t�| j�f S )Nz%s: %s>���)�str�type�pprintZpformat�__dict__��self� r �./usr/lib/python3.9/site-packages/iotop/data.py�__repr__> s zDumpableObject.__repr__N)�__name__� __module__� __qualname__�__doc__r r r r r r < s r c @ sF e Zd Zg d�ZdZdd� Zddd�Zdd � Zd d � Ze d d � �Z dS )�Stats))�blkio_delay_total�( )�swapin_delay_total�8 )� read_bytes� )� write_bytes� )Zcancelled_write_bytesi Nc C sL | j }tjD ],\}}|||d � }t�d|�d ||< q tjsHt� t_d S )N� �Qr )r r �members_offsets�struct�unpack�has_blkio_delay_total�sysctl_task_delayacct)r Ztask_stats_buffer�sd�name�offset�datar r r �__init__Q s zStats.__init__r c C s> |j }| j }|j }tjD ] \}}|| ||| ||< qdS )z3Update destination from operator(self, other_stats)N�r r r' ) r � other_stats� destination�coeff�ddr, Zod�memberr. r r r � accumulate\ s zStats.accumulatec C s | j ||dd�S )z*Update destination with self - other_statsr )r4 )r7 )r r2 r3 r r r �deltad s z Stats.deltac C s, | j }tjD ]\}}|| dkr dS q dS )Nr FTr1 )r r, r- r. r r r � is_all_zeroh s zStats.is_all_zeroc C s, t �t �} | j}t jD ]\}}d||< q| S )Nr )r �__new__r r' )�statsZstdr- r. r r r �build_all_zeroo s zStats.build_all_zero)r ) r r r r' r* r0 r7 r8 r9 � staticmethodr< r r r r r F s r � � c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�TaskStatsNetlinkc C s* || _ tt�| _t| j�}|�d�| _d S )NZ TASKSTATS)�optionsr r � connectionr Z get_family_id� family_id)r rA Z controllerr r r r0 � s zTaskStatsNetlink.__init__c C s t | jttt|�gtd�S )N)�cmd�attrs�flags)r rC �TASKSTATS_CMD_GETr �TASKSTATS_CMD_ATTR_PIDr )r �tidr r r � build_request� s �z TaskStatsNetlink.build_requestc C s� |j �| j� zt�| j�}W n@ ty^ } z(|jtjkrHW Y d }~d S � W Y d }~n d }~0 0 |j� � D ] \}}|t krj|� � } q�qjd S |t j }t|�dk r�d S t�d|d d� �d }t|�S )Ni �H� r )�task_stats_request�sendrB r Zrecv�OSError�errnoZESRCHrE �items�TASKSTATS_TYPE_AGGR_PID�nested�TASKSTATS_TYPE_STATSr/ �lenr( r) r )r �threadZreply�eZ attr_typeZ attr_valueZtaskstats_dataZtaskstats_versionr r r �get_single_task_stats� s" z&TaskStatsNetlink.get_single_task_statsN)r r r r0 rJ rX r r r r r@ � s r@ c C s� g | _ d}| jpg D ]p}z t|�}W nN tyr zt�|�}W n& tyf td|tj d� d}Y n0 |j }Y n0 |s| j � |� q|r�t� d� dS )zDBuild options.uids from options.users by resolving usernames to UIDsFz Unknown user:)�fileTr N) �uidsZusers�int� ValueError�pwd�getpwnam�KeyError�print�sys�stderr�pw_uid�append�exit)rA �error�u�uid�passwdr r r � find_uids� s rj c C sN i }z2t d| �D ] }|�dd�\}}|�� ||< qW n tyH Y n0 |S )Nz/proc/%d/statusz: r )�open�split�strip�IOError)�pidZ result_dict�line�key�valuer r r �parse_proc_pid_status� s rs c C sB z | � d�W S ty( | �d� Y S ty< | Y S 0 d S )Nzutf-8Z string_escape)�decode�UnicodeDecodeError�encode�AttributeError)�sr r r �safe_utf8_decode� s ry c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) � ThreadInfozStats for a single threadc C s. || _ d| _d | _t�t�| _|�|�| _d S )NT)rI �mark� stats_totalr r: � stats_deltarJ rM )r rI �taskstats_connectionr r r r0 � s zThreadInfo.__init__c C s t �| j�S �N)r �getrI r r r r � get_ioprio� s zThreadInfo.get_ioprioc C s t �t j| j||�S r )r � set_ioprioZIOPRIO_WHO_PROCESSrI )r � ioprio_class� ioprio_datar r r r� � s �zThreadInfo.set_ioprioc C s& | j s || _ |�| j | j� || _ d S r )r| r8 r} )r r; r r r � update_stats� s zThreadInfo.update_statsN)r r r r r0 r� r� r� r r r r rz � s rz c @ sh e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� ZdS )� ProcessInfoz�Stats for a single process (a single line in the output): if options.processes is set, it is a collection of threads, otherwise a single thread.c C s: || _ d | _d | _i | _t�� | _t�� | _t�� | _ d S r ) ro rh �user�threadsr r< r} � stats_accum�timeZstats_accum_timestamp)r ro r r r r0 � s zProcessInfo.__init__c C s8 |j r |js | j|j vr dS |jr4| �� |jvr4dS dS )NFT)�pids� processesro rZ �get_uid)r rA r r r � is_monitored� s �zProcessInfo.is_monitoredc C sX | j r | j S zt�d| j �tj }W n ty< d }Y n0 || j krTd | _|| _ |S )Nz/proc/%d)rh �os�statro �ST_UIDrO r� �r rh r r r r� s zProcessInfo.get_uidc C sX | � � }|d urN| jsNztt�|�j�| _W n ttfyL t|�| _Y n0 | jpVdS )Nz{none}) r� r� ry r] �getpwuid�pw_namer_ rw r r� r r r �get_user s zProcessInfo.get_userc C s z t d| j �}|�d�}W n ty0 Y dS 0 t| j�}|sb|�dd�}|rZd| }nd}|S d}t|�d| j��}|| jkr�t|��dd�}|�dd�}||kr�|d | 7 }|�d �} | d �d �r�| d � d �d } | d | d � | d < d� | �� � }t || �S )Nz/proc/%d/cmdlinei z{no such process}�Name� z[%s]z {no name}ZTgidz [%s]� r �/r � ) rk ro �readrn rs r� r[ rl � startswith�rfind�joinrm ry ) r Z proc_cmdlineZcmdlineZ proc_statusZproc_status_name�suffix�tgidZ tgid_nameZ thread_name�partsZfirst_command_charr r r � get_cmdline s2 zProcessInfo.get_cmdlinec C s4 |r| j �� S | j�� D ]}|j�� s dS qdS )NTF)r� r9 r� �valuesr} )r Z accumulated�tr r r � did_some_io; s zProcessInfo.did_some_ioc C s0 t dd� | j�� D ��}t|�dkr,|�� S dS )Nc s s | ]}|� � V qd S r )r� )�.0r� r r r � <genexpr>D � z)ProcessInfo.get_ioprio.<locals>.<genexpr>r z?dif)�setr� r� rU �pop)r Z prioritiesr r r r� C s zProcessInfo.get_ioprioc C s | j �� D ]}|�||� q d S r )r� r� r� )r r� r� rV r r r r� I s zProcessInfo.set_ioprioc C s t �| �� �S r )r Zsort_keyr� r r r r �ioprio_sort_keyM s zProcessInfo.ioprio_sort_keyc C s* | j �|d �}|s&t||�}|| j |< |S r )r� r� rz )r rI r~ rV r r r � get_threadP s zProcessInfo.get_threadc C s� t �� }| j�� D ] \}}|js|�|j|� qtdd� | j�� D ��| _t| j�}|s\dS | j | _ | j | _ || _| j �| j| j � dS )Nc S s g | ]\}}|j s||f�qS r )r{ )r� rI rV r r r � <listcomp>\ s �z,ProcessInfo.update_stats.<locals>.<listcomp>FT) r r< r� rQ r{ r7 r} �dictrU r r r� )r r} rI rV Z nr_threadsr r r r� W s � zProcessInfo.update_statsN)r r r r r0 r� r� r� r� r� r� r� r� r� r� r r r r r� � s r� c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )� ProcessListc C s2 i | _ || _|| _t�� | _t�� | _| �� d S r )r� r~ rA r� � timestampr r �update_process_counts)r r~ rA r r r r0 l s zProcessList.__init__c C s8 | j �|d�}|s$t|�}|| j |< |�| j�r4|S dS )zyEither get the specified PID from self.processes or build a new ProcessInfo if we see this PID for the first timeN)r� r� r� r� rA )r ro �processr r r � get_processw s zProcessList.get_processc C s� | j jr| j jS t�d�}| j jr0dd� |D �S g }|D ]V}d|d krTdkr8n q8z"|�ttt�d| d ��� W q8 ty� Y q80 q8|S ) Nz/procc S s0 g | ](}d |d kr dkrn qt |��qS )�0r �9)r[ )r� r� r r r r� � r� z*ProcessList.list_tgids.<locals>.<listcomp>r� r r� z/proc/z/task) rA r� r� �listdirr� �extend�mapr[ rO )r Ztgids�tidsr� r r r � list_tgids� s " zProcessList.list_tgidsc C sh | j js|gS z tttt�d| ���}W n ty@ g Y S 0 | j jrdtt | j j�� t |���}|S )Nz /proc/%d/task) rA r� �listr� r[ r� r� rO r� r� � intersection)r r� r� r r r � list_tids� s zProcessList.list_tidsc C s� t � � }|| j | _|| _d }}| �� D ]l}| �|�}|s>q*| �|�D ]L}|�|| j�}| j�|�}|rH|� |� |j } || j 7 }|| j 7 }d|_ qHq*||f| j�� fS )Nr F)r� r� Zdurationr� r� r� r� r~ rX r� r} r! r# r{ r r8 ) r Z new_timestampZ total_readZ total_writer� r� rI rV r; r8 r r r r� � s$ z!ProcessList.update_process_countsc C sL | j �� D ]}|j�� D ] }d|_qq | �� }tdd� | j �� D ��| _ |S )NTc S s g | ]\}}|� � r||f�qS r )r� )r� ro r� r r r r� � s �z1ProcessList.refresh_processes.<locals>.<listcomp>)r� r� r� r{ r� r� rQ )r r� rV Ztotal_read_and_writer r r �refresh_processes� s � z ProcessList.refresh_processesc C s i | _ d S r )r� r r r r �clear� s zProcessList.clearN) r r r r0 r� r� r� r� r� r� r r r r r� k s r� c C s\ zBt d��&} tt| �� �� ��W d � W S 1 s60 Y W n tyV Y d S 0 d S )Nz /proc/sys/kernel/task_delayacct)rk �boolr[ r� rm �FileNotFoundError)�fr r r r+ � s 8 r+ ).Z __future__r rP r� r r] r� r( ra r� �path�existsZ ioaccountingZ iotop.vmstatr Zvmstat_fZvm_event_countersr` re Ziotopr r Z iotop.netlinkr r r r Ziotop.genetlinkr r �objectr r rG rH rR ZTASKSTATS_TYPE_PIDrT r@ rj rs ry rz r� r� r+ r r r r �<module> sT 5) ^ __pycache__/netlink.cpython-39.pyc 0000644 00000022073 15025012261 0013047 0 ustar 00 a B��Q� � @ s� d Z ddlZddlZddlZzDe�ejejd�Ze�d� [dd� Zdd� Z dd � Z d9d d �Z W n� ej � y� z.ddl Z d d� Zdd� Z dd � Z d:dd �Z W nX ey� ddlZe�d�ZG dd� dej�Zdd� Zdd� Z dd � Z d;dd �Z Y n0 Y n0 dZdZdZdZdZdZdZdZd Z G d d � d �Z G d d � d e �Z G d!d"� d"e �Z G d#d$� d$e �Z G d%d&� d&e �Z!G d'd(� d(e �Z"dZ#dZ$dZ%dZ&dZ'd)Z(d*Z)d+Z*dZ+d,Z,d-Z-d.Z.d/Z/d0Z0d1Z1d2Z2d Z3G d3d4� d4�Z4G d5d6� d6�Z5d7d8� Z6dS )<z� Netlink message generation/parsing Copyright 2007 Johannes Berg <johannes@sipsolutions.net> GPLv2+; See copying for details. � N)r r c C s | � |� d S �N)�bind�� descriptor�addr� r �1/usr/lib/python3.9/site-packages/iotop/netlink.py�_nl_bind s r c C s | � � S r )� getsockname�r r r r �_nl_getsockname s r c C s | � |� d S r )�send�r �msgr r r �_nl_send s r � @ c C s | � |�S r )�recvfrom�r �bufsr r r �_nl_recv s r c C s t �| �� |d � d S �N� )�_netlinkr �filenor r r r r s c C s t �| �� �S r )r r r r r r r r s c C s t �| �� |� d S r )r r r r r r r r " s c C s t �| �� |�S r )r r r r r r r r $ s c @ s0 e Zd ZdejfdejfdejfdejfgZdS )� SOCKADDR_NLZ nl_familyZnl_pad�nl_pid� nl_groupsN)�__name__� __module__� __qualname__�ctypesZc_ushort�c_intZ_fields_r r r r r , s �r c C s2 t tjdt�� d�}t�| �� t� |�t� |��S �Nr ) r �socket� AF_NETLINK�os�getpid�libcr r r �pointer�sizeofr r r r r 2 s �c C sH t dddd�}t�t�|��}t�| �� t�|�t�|�� |j|j fS r" ) r r r! r) r' r r r( r r )r r �lenr r r r 8 s �c C s t �| �� |t|�d�S r" )r' r r r* r r r r r @ s c C sn t dddd�}t�t�|��}t�|�}t�| �� ||dt�|�t�|��}t� t�|�|�}||j |j ffS r" ) r r r! r) Zcreate_string_bufferr' r r r( Z string_atr r )r r r r* �buf�r�retr r r r C s �r � � � � � c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dS )�Attrc G s. || _ t|�r$tj|g|�R � | _n|| _d S r )�typer* �struct�pack�data)�self� attr_typer7 �valuesr r r �__init__^ s z Attr.__init__c C sJ t �dt| j�d | j�}t| j�}|d d d@ | }|| j d| S )N�HHr/ r ���� )r5 r6 r* r7 r4 )r8 �hdr�lengthZpadr r r �_dumpe s z Attr._dumpc C s d| j t| j�f S )Nz<Attr type %d, data "%s">)r4 �reprr7 �r8 r r r �__repr__k s z Attr.__repr__c C s t �d| j�d S )N�Hr �r5 �unpackr7 rC r r r �u16n s zAttr.u16c C s t �d| j�d S )N�hr rF rC r r r �s16p s zAttr.s16c C s t �d| j�d S )N�Ir rF rC r r r �u32r s zAttr.u32c C s t �d| j�d S )N�ir rF rC r r r �s32t s zAttr.s32c C s | j S r )r7 rC r r r �strv s zAttr.strc C s | j �d�d S )N� r )r7 �splitrC r r r �nulstrx s z Attr.nulstrc C s t | j�S r )�parse_attributesr7 rC r r r �nestedz s z Attr.nestedN) r r r r; rA rD rH rJ rL rN rO rR rT r r r r r3 ] s r3 c @ s e Zd Zdd� ZdS )�StrAttrc C s" t �| |dt|� |�d�� d S )Nz%ds�utf-8�r3 r; r* �encode�r8 r9 r7 r r r r; ~ s zStrAttr.__init__N�r r r r; r r r r rU } s rU c @ s e Zd Zdd� ZdS )� NulStrAttrc C s$ t �| |dt|� |�d�d� d S )Nz%dsBrV r rW rY r r r r; � s zNulStrAttr.__init__NrZ r r r r r[ � s r[ c @ s e Zd Zdd� ZdS )�U32Attrc C s t �| |d|� d S )NrK �r3 r; �r8 r9 �valr r r r; � s zU32Attr.__init__NrZ r r r r r\ � s r\ c @ s e Zd Zdd� ZdS )�U8Attrc C s t �| |d|� d S )N�Br] r^ r r r r; � s zU8Attr.__init__NrZ r r r r r` � s r` c @ s e Zd Zdd� Zdd� ZdS )�Nestedc C s || _ || _d S r )�attrsr4 )r8 r9 rc r r r r; � s zNested.__init__c C sL g }| j D ]}|�|�� � q d�|�}t|�}t�d|d | j�}|| S )N� r< r/ )rc �appendrA �joinr* r5 r6 r4 )r8 �contents�attrr@ r? r r r rA � s z Nested._dumpN)r r r r; rA r r r r rb � s rb � � � � � � � � � � c @ s& e Zd Zd dd�Zdd� Zdd � ZdS ) �Messager ���Nc C s^ || _ || _|| _d| _|p g }t|t�rTg }|D ]}|�|�� � q2d�|�| _ n|| _ d S )Nrt � ) r4 �flags�seq�pid� isinstance�listre rA rf �payload)r8 �msg_typerv rw r{ rg rh r r r r; � s zMessage.__init__c C sZ | j dkr|� � | _ |j| _t| j�}t�d|d | j| j| j | j�}|�|| j � d S )Nrt �IHHIIr2 ) rw rx r* r{ r5 r6 r4 rv r )r8 Zconnr@ r? r r r r � s �z Message.sendc C s d| j | j| j| jt| j�f S )Nz:<netlink.Message type=%d, pid=%d, seq=%d, flags=0x%x "%s">)r4 rx rw rv rB r{ rC r r r rD � s �zMessage.__repr__)r rt N)r r r r; r rD r r r r rs � s rs c @ s. e Zd Zd dd�Zdd� Zdd� Zd d � ZdS ) � Connectionr Nc C sn t � t jt j|�| _| j�t jt jd� | j�t jt jd� t| jd|f� t | j�\| _ | _ d| _ || _ d S )Ni r )r# r$ �SOCK_RAWr Z setsockoptZ SOL_SOCKETZ SO_SNDBUFZ SO_RCVBUFr r rx �groups�_seqZ unexpected)r8 Znltyper� Zunexpected_msg_handlerr r r r; � s �zConnection.__init__c C s t | j|� d S r )r r )r8 r r r r r � s zConnection.sendc C s� t | j�\}\}}t�d|d d� �\}}}}}t||||dd � �} || _| jtkr�t�d| jd d� �d } | dkr�t dt � | �| f �} | | _ | �| S )Nr} r2 rM r/ r zNetlink error: %s (%d)) r r r5 rG rs rx r4 � NLMSG_ERRORr{ �OSErrorr% �strerror�errno) r8 rg ZnlpidZnlgrpsZmsglenr| rv rw rx r r� �errr r r �recv� s � �zConnection.recvc C s | j d7 _ | j S r )r� rC r r r rw � s zConnection.seq)r N)r r r r; r r� rw r r r r r~ � s r~ c C s\ i }t | �rXt�d| d d� �\}}t|| d|� �||< |d d d@ }| |d � } q|S )Nr< r/ r r= )r* r5 rG r3 )r7 rc Zattr_lenr9 r r r rS � s rS )r )r )r )7�__doc__r% r# r5 r$ r Z _dummysockr r r r r �errorr � ImportErrorr ZCDLLr' Z Structurer Z NLM_F_REQUESTZ NLM_F_MULTIZ NLM_F_ACKZ NLM_F_ECHOZ NLMSG_NOOPr� Z NLMSG_DONEZ NLMSG_OVERRUNZNLMSG_MIN_TYPEr3 rU r[ r\ r` rb Z NETLINK_ROUTEZNETLINK_UNUSEDZNETLINK_USERSOCKZNETLINK_FIREWALLZNETLINK_INET_DIAGZ NETLINK_NFLOGZ NETLINK_XFRMZNETLINK_SELINUXZ NETLINK_ISCSIZ NETLINK_AUDITZNETLINK_FIB_LOOKUPZNETLINK_CONNECTORZNETLINK_NETFILTERZNETLINK_IP6_FWZNETLINK_DNRTMSGZNETLINK_KOBJECT_UEVENTZNETLINK_GENERICrs r~ rS r r r r �<module> sz __pycache__/ui.cpython-39.pyc 0000644 00000050606 15025012261 0012023 0 ustar 00 a ��Jc�b � @ sp d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl m Z mZmZmZmZ d dl mZ d dlmZ d dlmZ d dlmZ g d�Zd d � Zd d � Zd d� Z dd� Z dd� Z e � Z G dd� de �Z!G dd� de �Z"G dd� de �Z#G dd� de �Z$G dd � d e �Z%G d d � d e&�Z'd d � Z(d!d"� Z)d#d$� Z*d%e j+d Z,d&d'� Z-dS )(� )�print_functionN)� find_uids�TaskStatsNetlink� ProcessList�Stats�sysctl_task_delayacct)� ThreadInfo)�VERSION)�ioprio)�IoprioSetError)�B�K�M�G�T�P�Ec C s` | dkrd}n| dk r"d}| } ndS t t�| d d�d �}d|t| �dd| > t| f S ) Nr � �-z0.00 B� � z %s%.2f %s� )�int�math�log�float�UNITS)�size�signZexpo� r �,/usr/lib/python3.9/site-packages/iotop/ui.py� human_size- s r! c C s | j rd|d S t|�S )Nz%.2f Kg �@)� kilobytesr! )�options�bytesr r r � format_size9 s r% c C s t | |ot|�| �d S )Nz/s)r% r )r# r �durationr r r �format_bandwidth> s r' c s� � fdd�}�j r4|j}�fdd�}t�� |j � n|j}�fdd�}||j�}||j�}||j� �}|j|j } t d| �} || � �} |||| fS )Nc s dt d| � d � S )Nz%.2f %%g��(\�X@g �cA)�min)Zdelay)r& r r � delay2percentD s z#format_stats.<locals>.delay2percentc s t � | �S �N)r% �r r& �r# r r �<lambda>H � z format_stats.<locals>.<lambda>c s t � | |�S r* )r' r+ r, r r r- L s �r ) � accumulated� stats_accum�timeZstats_accum_timestamp� stats_delta�blkio_delay_total�swapin_delay_total� read_bytes� write_bytes�cancelled_write_bytes�max) r# Zprocessr& r) �statsZdisplay_format�io_delay� swapin_delayr5 Z written_bytesr6 r )r& r# r � format_statsA s r< c C sJ zt td��� �� �W S tyD } zt| � W Y d } ~ dS d } ~ 0 0 d S )Nz/proc/sys/kernel/pid_max� )�len�open�read�strip� Exception�print)�er r r �get_max_pid_widthV s rE c @ s e Zd ZdS )� CancelInputN��__name__� __module__� __qualname__r r r r rF d r. rF c @ s e Zd ZdS )� InvalidIntNrG r r r r rK e r. rK c @ s e Zd ZdS )� InvalidPidNrG r r r r rL f r. rL c @ s e Zd ZdS )� InvalidTidNrG r r r r rM g r. rM c @ s e Zd ZdS )�InvalidIoprioDataNrG r r r r rN h r. rN c @ s� e Zd Zdd� dfdd� dfdd� dfdd� dfdd� dfd d� dfd d� dfd d� dfgZd d � Zdd� Zdd� Zdd� Zdd� Zd0dd�Z d1dd�Z dd � Z d d � Z d d � Z d!d"� Zd2d#d$�Zd3d&d'�Zd(d)� Zd*d+� Zd,d-� Zd.d/� ZdS )4�IOTopUIc C s | j S r* )�pid��p�sr r r r- q r. zIOTopUI.<lambda>Fc C s | � � S r* )Zioprio_sort_keyrQ r r r r- r r. c C s | � � S r* )�get_userrQ r r r r- s r. c C s |j S r* )r5 rQ r r r r- t r. Tc C s |j |j S r* )r6 r7 rQ r r r r- u r. c C s |j S r* )r4 rQ r r r r- v r. c C s |j pt|jp|j �S r* )r3 r r5 r6 rQ r r r r- y s c C s | � � S r* )� get_cmdlinerQ r r r r- { r. c C sr || _ || _d| _tj| j d | _| jjsn|| _| �� z t � � t � � t � d� W n t j yl Y n0 d S )N� r r )� process_listr# � sorting_keyrO � sorting_keys�sorting_reverse�batch�win�resize�cursesZuse_default_colorsZ start_color�curs_set�error)�selfr\ rW r# r r r �__init__~ s zIOTopUI.__init__c C s | j �� \| _| _d S r* )r\ Zgetmaxyx�height�width�ra r r r r] � s zIOTopUI.resizec C sX d}t �� }| jjs.|�tj�� t jt j B � | jj d u sH|| jj k �rT| j � � \}}| � |dk||| j j� | jj d ur�|d7 }|| jj kr��qTn |dkr�d}z|�| jjd �}W nD t jy� } z*|jr�|jd tjkr�g }n� W Y d }~n d }~0 0 |D ]&\}}|t jt jB @ �r t�d� �q | jj�s:| �� |r.| j�� } | �| � q.d S )Nr r g @�@)�select�pollr# r[ �register�sys�stdin�filenoZPOLLINZPOLLPRI� iterationsrW �refresh_processes�refresh_displayr& � delay_secondsr` �args�errnoZEINTRZPOLLERRZPOLLHUP�exitr] r\ �getch� handle_key) ra rl rg �total�actualZeventsrD �fdZevent�keyr r r �run� s> �� z IOTopUI.runc C s | j | _ d S r* )rZ re r r r �reverse_sorting� s zIOTopUI.reverse_sortingc C s� | j }| j |7 _ td| j �| _ tttj�d | j �| _ | jsh| j dv rh|dkrZd| _ n|dkrhd| _ || j kr�tj| j d | _d S )Nr r �r= rV � � )rX r8 r( r> rO rY � has_swapin_iorZ )ra ZdeltaZorig_sorting_keyr r r �adjust_sorting_key� s zIOTopUI.adjust_sorting_keyNc C s� | j �ddtd�tjB | j� | j �dd|tj� | j �� t� � t� d� | j � dt |��}t� d� t� � |dvr~|S |r�t� �|S )Nr r � )Nr )r\ �hline�ordr^ �A_NORMALrd �addstr�A_BOLD�refreshZechor_ Zgetstrr> ZnoechorF �ra �prompt�defaultZempty_is_cancel�inpr r r � prompt_str� s zIOTopUI.prompt_strc C s6 | � |||�}z t|�W S ty0 t� �Y n0 d S r* )r� r � ValueErrorrK r� r r r � prompt_int� s zIOTopUI.prompt_intc C s< z | � d�W S ty$ t� �Y n ty6 � Y n0 d S )NzPID to ionice: )r� rK rL rF re r r r � prompt_pid� s zIOTopUI.prompt_pidc C s< z | � d�W S ty$ t� �Y n ty6 � Y n0 d S )NzTID to ionice: )r� rK rM rF re r r r � prompt_tid� s zIOTopUI.prompt_tidc C sb z.|d ur | � d| |d�}n| � dd d�}W n tyF t� �Y n0 |dk sX|dkr^t� �|S )Nz'I/O priority data (0-7, currently %s): FzI/O priority data (0-7): r r} )r� rK rN )ra � ioprio_datar� r r r � prompt_data� s �� zIOTopUI.prompt_datac C sf z|� |�}W n ty$ d}Y n0 t|�d }| j�ddtd�tjB | j� | j� dd|tj � t|�}t |�D ]D\}}d| } ||u r�tj } ntj} | j� d|| | � |t| �7 }qt| j� � } | tjtd�fv r�|dkr�|d8 }q2q�| tjtd�fv �r||k �r|d7 }q2q�| tjtd�td �fv �r6|| S | d tjtjtjtd �td �fv r�t� �q�q2d S ) N���r r r� � %s �l�r� � � �q�Q)�indexr� r> r\ r� r� r^ r� rd �insstrr� � enumerate� A_REVERSErs �KEY_LEFT� KEY_RIGHTZ KEY_ENTERZ KEY_CANCELZ KEY_CLOSEZKEY_EXITrF ) ra r� Z display_listZret_listZselectedZset_len�offset�i�itemZdisplay�attrrx r r r � prompt_set� s8 �zIOTopUI.prompt_setc C s4 d}g d�}g d�}|d u r d}| � ||||�}|S )NzI/O priority class: )z Real-timez Best-effortZIdle)Zrt�be�idler )r� )ra � ioprio_classr� Zclasses_promptZ classes_retr� r r r � prompt_class s zIOTopUI.prompt_class�Error!c C sN | j �ddtd�tjB | j� | j �ddd| tj� | j �� t � d� d S )Nr r r� z %s ) r\ r� r� r^ r� rd r� r� r� r1 �sleep)ra r` r r r � prompt_error" s zIOTopUI.prompt_errorc C s, | j �ddtd�tjB | j� | j �� d S )Nr r r� )r\ r� r� r^ r� rd r� re r r r � prompt_clear( s zIOTopUI.prompt_clearc " s� � fdd�}� fdd�}� fdd�}� fdd�}t d �d d � t d �d d � t d�� fdd �t d�� fdd �t d�|t d�|t d�|t d�|t d�|t d�|t d�|t d�|tj� fdd �tj� fdd �tj� fd d �tj� fd d �i}|�|d d � �}|� d S ) Nc s � j jdN _d S �NT)r# r/ r re r r �toggle_accumulated- s z.IOTopUI.handle_key.<locals>.toggle_accumulatedc s � j jdN _d S r� )r# �onlyr re r r �toggle_only_io/ s z*IOTopUI.handle_key.<locals>.toggle_only_ioc s( � j jdN _� j�� � j�� d S r� )r# � processesrW �clearrm r re r r �toggle_processes1 s z,IOTopUI.handle_key.<locals>.toggle_processesc sX z�� j jr � �� } � j�| �}n� �� }t|� jj�}|�� }t � |�\}}� � |�}|dkrdd}n � � |�}|� ||� � j�� � j�� W n� ty� } z � �d|j � W Y d }~n�d }~0 ty� � �d� Y nv ty� � �d� Y n\ t�y � �d� Y n@ t�y0 � �d� Y n$ t�yJ � �� Y n 0 � �� d S )Nr� r z Error setting I/O priority: %szInvalid process id!zInvalid thread id!zInvalid I/O priority data!zInvalid integer!)r# r� r� rW Z get_processr� r �taskstats_connection� get_ioprior Zto_class_and_datar� r� Z set_ioprior� rm r r� �errrL rM rN rK rF r� )rP Z exec_unit�tidZ ioprio_valuer� r� rD re r r �ionice5 s> �� $ z"IOTopUI.handle_key.<locals>.ionicer� c S s t �d�S �Nr �ri rr r r r r r- Z r. z$IOTopUI.handle_key.<locals>.<lambda>r� c S s t �d�S r� r� r r r r r- \ r. r� c s � � � S r* �rz r re r r r- ^ r. �Rc s � � � S r* r� r re r r r- ` r. �a�A�o�OrR r r� �Ic s � � d�S )Nr� �r r re r r r- r r. c s � � d�S )Nr r� r re r r r- t r. c s � � ttj� �S r* �r r> rO rY r re r r r- v r. c s � � ttj��S r* r� r re r r r- x r. c S s d S r* r r r r r r- { r. )r� r^ r� r� ZKEY_HOMEZKEY_END�get)ra rx r� r� r� r� Z key_bindings�actionr re r rt , sN $ �#zIOTopUI.handle_keyc s� �fdd�}�fdd�}t t|�jj�� ��}tj�j d � �jj rPdd� �ndd� �|j � �fd d��j d � �jj s�|�j d d �= t t||��S ) Nc sR t � j| � jj�}|\}}}}dt }| jf}|d7 }|| �� f7 }|d7 }|| �� d d� f7 }|d7 }|||f7 }� jr�|d7 }|||f7 }n� jj r�|d7 }|d7 }|d 7 }|| }| � � } � jj �s.� j t |� } d | k r�t | �k �r.n n6| d d } | | d } | d | � d | | d � } || 7 }� jj �sN|d � j � }|S ) Nz%%%ddz %4sz %-8s� z %11s %11sz %7s %7sr� )z ?unavailable?r� r r �~) r< r# rW r& � MAX_PID_WIDTHrP r� rT r~ r[ rU rd r> ) rR r9 r: r; r5 r6 �format�params�lineZcmdlineZremaining_lengthZlen1Zoffset2re r r r� s: z IOTopUI.get_data.<locals>.formatc s � j j p| �� j j�S r* )r# r� Z did_some_ior/ �rR re r r � should_format� s �z'IOTopUI.get_data.<locals>.should_formatr c S s | j S r* )r0 r� r r r r- � r. z"IOTopUI.get_data.<locals>.<lambda>c S s | j S r* )r2 r� r r r r- � r. c s � | �| ��S r* r r� )rx � stats_lambdar r r- � r. )rx �reverser )�list�filterrW r� �valuesrO rY rX r# r/ �sortrZ r[ rc �map)ra r� r� r� r )rx ra r� r �get_data~ s � �zIOTopUI.get_datac sl dt �j|d |��d�t �j|d |��d�f dt �j|d |��d�t �j|d |��d�f g�tdtd �d }�jjr�|d7 }n|d 7 }|d d d d dddg}tj�_�jr�t � dkr�d�_�� d� �� � }�jj �rdg| }t � d�� � fdd�|D �}� fdd��D ���jj�r��jjdk�rf�D ]}t|� �q6�jjt|�k�rftd�|�� |D ]} t| �d�� �qjtj�� �nڈj�� t��D ]$\�}�j��d|d �j� � �q��j� t ��dt d�t j B �j� �j} t!t |��D ]���j�s�dv �r�q�t j } |� } ��j"k�r:| dd � } ��j"k�rf| t j#O } | �j$�r`d�pbd 7 } | d | � } | t | �8 } �j�| | � �q��jdu�r�d } nd } t%t |��j&d tt'| �� �}t!|�D ]j�zL���fd d �}z||� � W n& t(�y ||� �d�� Y n0 W n t j)�y4 Y n0 �q�| �r^�j�*�j&t �� d| t j#� �j�+� d S ) Nz,Total DISK READ : %s | Total DISK WRITE : %sr � r z,Actual DISK READ: %s | Actual DISK WRITE: %s� r� �PIDZTIDz PRIOz USERz DISK READz DISK WRITEz SWAPINz IOz COMMANDFz TIMEz %H:%M:%S c s g | ] }� | �qS r r )�.0r� �� current_timer r � <listcomp>� r. z+IOTopUI.refresh_display.<locals>.<listcomp>c s g | ] }� | �qS r r )r� rS r� r r r� � r. r r zutf-8r{ �>�<zoCONFIG_TASK_DELAY_ACCT and kernel.task_delayacct sysctl not enabled in kernel, cannot determine SWAPIN and IO %c s �j �� t�� d d| � d S )Nr r )r\ r� r> )r� )r� ra �summaryr r � print_line� s z+IOTopUI.refresh_display.<locals>.print_line),r' r# �rjustr8 r� r� r Zhas_blkio_delay_totalr~ r r r� r1 �strftimer[ �quietrC r �join�encoderi �stdout�flushr\ Zeraser� r� rd r� r> r� r^ r� �rangerX r� rZ r( rc �bool�UnicodeEncodeErrorr` r� r� )ra Z first_timeru rv r& rP Ztitles�linesrS r� Zremaining_colsr� �titleZ status_msgZ num_linesr� r )r� r� ra r� r rn � s� ��� � � �zIOTopUI.refresh_display)NT)NT)N)r� )rH rI rJ rY rb r] ry rz r r� r� r� r� r� r� r� r� r� rt r� rn r r r r rO n s8 � �! R1rO c C sf |j rt�tjtj� n$dd� }t�tj|� t�tj|� t|�}t||�}t| ||�}|� � d S )Nc _ s t �d� d S r� r� )rp �kwargsr r r � clean_exit s z$run_iotop_window.<locals>.clean_exit) r[ �signal�SIGPIPE�SIG_DFL�SIGINT�SIGTERMr r rO ry )r\ r# r� r� rW Zuir r r �run_iotop_window s r� c C s� z$| j rtd | �W S t�t| �W S W n� ty~ } zB|jtjkrht|tj d� tdtj d� t� d� n� W Y d }~ndd }~0 tj y� } zBt |�}|� d�dkr�|� d�dks�|� d�dkr�n� W Y d }~n d }~0 0 d S )N)�filea� The Linux kernel interfaces that iotop relies on now require root priviliges or the NET_ADMIN capability. This change occured because a security issue (CVE-2011-2494) was found that allows leakage of sensitive data across user boundaries. If you require the ability to run iotop as a non-root user, please configure sudo to allow you to run iotop as root. Please do not file bugs on iotop about this.r ZERRr z nocbreak()zendwin())r[ r� r^ �wrapper�OSErrorrq �EPERMrC ri �stderrrr r` �str�find)r# rD Zstrer r r � run_iotop s* � � �r� c C s� d}z:dd l }dd l}td� |�dt� t� |� |�|�}W nV ty� dd l}dd l }|j |dd�}td� |� | � |� � |j �|�}Y n0 |�� |�dd � |�d � |�d � t�|� d S ) Nz iotop.profr zProfiling using cProfilezcontinuation()r )Z lineeventszProfiling using hotshotr1 Zcalls�2 )�cProfile�pstatsrC Zrunctx�globals�localsr � ImportError�hotshotZ hotshot.statsZProfileZruncall�closer9 �loadZ strip_dirsZ sort_statsZ print_statsZ print_callees�os�remove)Z continuationZ prof_filer� r r9 r Zprofr r r �_profile6 s( r aF %s [OPTIONS] DISK READ and DISK WRITE are the block I/O bandwidth used during the sampling period. SWAPIN and IO are the percentages of time the thread spent respectively while swapping in and waiting on I/O more generally. PRIO is the I/O priority at which the thread is running (set using the ionice command). Controls: left and right arrows to change the sorting column, r to invert the sorting order, o to toggle the --only option, p to toggle the --processes option, a to toggle the --accumulated option, i to change I/O priority, q to quit, any other key to force a refresh.c s� zt �t jd� W n t jy. td� Y n0 tjtdt d�} | j ddddd d d � | j d d dddd� | j ddddddd� | j ddddd d d d � | j d d!dd"d#d$d%d&� | j d'd(d)d*d#d+d,d&� | j d-d.dd/d d0d � | j d1d2dd3d d4d � | j d5d6dd7d d8d � | j d9d:dd;d<d� | j d=d>d?d@dAdBd � | j dCddDd tj d � | � � \�}|�rr| � dEdF� |� � t�� �j�p�g �_�j�p��j�p��j�_�fdGdH�� �j�rʇ fdIdJ�}t|� n� � d S )KNr z8unable to set locale, falling back to the default localeziotop )�usage�versionz-oz--only� store_truer� Fz1only show processes or threads actually doing I/O)r� �destr� �helpz-bz--batchr[ znon-interactive mode)r� r r z-nz--iterr rl ZNUMz-number of iterations before ending [infinite])�typer �metavarr z-dz--delayr ro z#delay between iterations [1 second]ZSECr )r r r r r� z-pz--pid�pids�appendz"processes/threads to monitor [all]r� )r r r� r r z-uz--userr� Zuserszusers to monitor [all]ZUSERz-Pz --processesr� z$only show processes, not all threadsz-az --accumulatedr/ z)show accumulated I/O instead of bandwidthz-kz --kilobytesr" z.use kilobytes instead of a human friendly unitz-tz--timer1 z.add a timestamp on each line (implies --batch)z-qz--quiet�countr� r z/suppress some lines of header (implies --batch)z --profile�profilezUnexpected arguments: r� c s t � �S r* )r� r r, r r r- � r. zmain.<locals>.<lambda>c s z � � W n Y n0 d S r* r r )� main_loopr r �safe_main_loop� s z main.<locals>.safe_main_loop)�locale� setlocale�LC_ALL�ErrorrC �optparseZ OptionParser�USAGEr Z add_optionZ SUPPRESS_HELP� parse_argsr` r� r r r[ r1 r� r r )�parserrp r r )r r# r �main\ st � � � ��� � � � �� � r ).Z __future__r r^ rq r r r r rf r� ri r1 Z iotop.datar r r r r r Z iotop.versionr Ziotopr Z iotop.ioprior r r! r% r' r< rE r� rB rF rK rL rM rN �objectrO r� r� r �argvr r r r r r �<module> sL $ � __pycache__/version.cpython-39.opt-1.pyc 0000644 00000000233 15025012261 0014021 0 ustar 00 a B��Q � @ s d Z dS )z0.6N)ZVERSION� r r �1/usr/lib/python3.9/site-packages/iotop/version.py�<module> � __pycache__/netlink.cpython-39.opt-1.pyc 0000644 00000022073 15025012261 0014006 0 ustar 00 a B��Q� � @ s� d Z ddlZddlZddlZzDe�ejejd�Ze�d� [dd� Zdd� Z dd � Z d9d d �Z W n� ej � y� z.ddl Z d d� Zdd� Z dd � Z d:dd �Z W nX ey� ddlZe�d�ZG dd� dej�Zdd� Zdd� Z dd � Z d;dd �Z Y n0 Y n0 dZdZdZdZdZdZdZdZd Z G d d � d �Z G d d � d e �Z G d!d"� d"e �Z G d#d$� d$e �Z G d%d&� d&e �Z!G d'd(� d(e �Z"dZ#dZ$dZ%dZ&dZ'd)Z(d*Z)d+Z*dZ+d,Z,d-Z-d.Z.d/Z/d0Z0d1Z1d2Z2d Z3G d3d4� d4�Z4G d5d6� d6�Z5d7d8� Z6dS )<z� Netlink message generation/parsing Copyright 2007 Johannes Berg <johannes@sipsolutions.net> GPLv2+; See copying for details. � N)r r c C s | � |� d S �N)�bind�� descriptor�addr� r �1/usr/lib/python3.9/site-packages/iotop/netlink.py�_nl_bind s r c C s | � � S r )� getsockname�r r r r �_nl_getsockname s r c C s | � |� d S r )�send�r �msgr r r �_nl_send s r � @ c C s | � |�S r )�recvfrom�r �bufsr r r �_nl_recv s r c C s t �| �� |d � d S �N� )�_netlinkr �filenor r r r r s c C s t �| �� �S r )r r r r r r r r s c C s t �| �� |� d S r )r r r r r r r r " s c C s t �| �� |�S r )r r r r r r r r $ s c @ s0 e Zd ZdejfdejfdejfdejfgZdS )� SOCKADDR_NLZ nl_familyZnl_pad�nl_pid� nl_groupsN)�__name__� __module__� __qualname__�ctypesZc_ushort�c_intZ_fields_r r r r r , s �r c C s2 t tjdt�� d�}t�| �� t� |�t� |��S �Nr ) r �socket� AF_NETLINK�os�getpid�libcr r r �pointer�sizeofr r r r r 2 s �c C sH t dddd�}t�t�|��}t�| �� t�|�t�|�� |j|j fS r" ) r r r! r) r' r r r( r r )r r �lenr r r r 8 s �c C s t �| �� |t|�d�S r" )r' r r r* r r r r r @ s c C sn t dddd�}t�t�|��}t�|�}t�| �� ||dt�|�t�|��}t� t�|�|�}||j |j ffS r" ) r r r! r) Zcreate_string_bufferr' r r r( Z string_atr r )r r r r* �buf�r�retr r r r C s �r � � � � � c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dS )�Attrc G s. || _ t|�r$tj|g|�R � | _n|| _d S r )�typer* �struct�pack�data)�self� attr_typer7 �valuesr r r �__init__^ s z Attr.__init__c C sJ t �dt| j�d | j�}t| j�}|d d d@ | }|| j d| S )N�HHr/ r ���� )r5 r6 r* r7 r4 )r8 �hdr�lengthZpadr r r �_dumpe s z Attr._dumpc C s d| j t| j�f S )Nz<Attr type %d, data "%s">)r4 �reprr7 �r8 r r r �__repr__k s z Attr.__repr__c C s t �d| j�d S )N�Hr �r5 �unpackr7 rC r r r �u16n s zAttr.u16c C s t �d| j�d S )N�hr rF rC r r r �s16p s zAttr.s16c C s t �d| j�d S )N�Ir rF rC r r r �u32r s zAttr.u32c C s t �d| j�d S )N�ir rF rC r r r �s32t s zAttr.s32c C s | j S r )r7 rC r r r �strv s zAttr.strc C s | j �d�d S )N� r )r7 �splitrC r r r �nulstrx s z Attr.nulstrc C s t | j�S r )�parse_attributesr7 rC r r r �nestedz s z Attr.nestedN) r r r r; rA rD rH rJ rL rN rO rR rT r r r r r3 ] s r3 c @ s e Zd Zdd� ZdS )�StrAttrc C s" t �| |dt|� |�d�� d S )Nz%ds�utf-8�r3 r; r* �encode�r8 r9 r7 r r r r; ~ s zStrAttr.__init__N�r r r r; r r r r rU } s rU c @ s e Zd Zdd� ZdS )� NulStrAttrc C s$ t �| |dt|� |�d�d� d S )Nz%dsBrV r rW rY r r r r; � s zNulStrAttr.__init__NrZ r r r r r[ � s r[ c @ s e Zd Zdd� ZdS )�U32Attrc C s t �| |d|� d S )NrK �r3 r; �r8 r9 �valr r r r; � s zU32Attr.__init__NrZ r r r r r\ � s r\ c @ s e Zd Zdd� ZdS )�U8Attrc C s t �| |d|� d S )N�Br] r^ r r r r; � s zU8Attr.__init__NrZ r r r r r` � s r` c @ s e Zd Zdd� Zdd� ZdS )�Nestedc C s || _ || _d S r )�attrsr4 )r8 r9 rc r r r r; � s zNested.__init__c C sL g }| j D ]}|�|�� � q d�|�}t|�}t�d|d | j�}|| S )N� r< r/ )rc �appendrA �joinr* r5 r6 r4 )r8 �contents�attrr@ r? r r r rA � s z Nested._dumpN)r r r r; rA r r r r rb � s rb � � � � � � � � � � c @ s& e Zd Zd dd�Zdd� Zdd � ZdS ) �Messager ���Nc C s^ || _ || _|| _d| _|p g }t|t�rTg }|D ]}|�|�� � q2d�|�| _ n|| _ d S )Nrt � ) r4 �flags�seq�pid� isinstance�listre rA rf �payload)r8 �msg_typerv rw r{ rg rh r r r r; � s zMessage.__init__c C sZ | j dkr|� � | _ |j| _t| j�}t�d|d | j| j| j | j�}|�|| j � d S )Nrt �IHHIIr2 ) rw rx r* r{ r5 r6 r4 rv r )r8 Zconnr@ r? r r r r � s �z Message.sendc C s d| j | j| j| jt| j�f S )Nz:<netlink.Message type=%d, pid=%d, seq=%d, flags=0x%x "%s">)r4 rx rw rv rB r{ rC r r r rD � s �zMessage.__repr__)r rt N)r r r r; r rD r r r r rs � s rs c @ s. e Zd Zd dd�Zdd� Zdd� Zd d � ZdS ) � Connectionr Nc C sn t � t jt j|�| _| j�t jt jd� | j�t jt jd� t| jd|f� t | j�\| _ | _ d| _ || _ d S )Ni r )r# r$ �SOCK_RAWr Z setsockoptZ SOL_SOCKETZ SO_SNDBUFZ SO_RCVBUFr r rx �groups�_seqZ unexpected)r8 Znltyper� Zunexpected_msg_handlerr r r r; � s �zConnection.__init__c C s t | j|� d S r )r r )r8 r r r r r � s zConnection.sendc C s� t | j�\}\}}t�d|d d� �\}}}}}t||||dd � �} || _| jtkr�t�d| jd d� �d } | dkr�t dt � | �| f �} | | _ | �| S )Nr} r2 rM r/ r zNetlink error: %s (%d)) r r r5 rG rs rx r4 � NLMSG_ERRORr{ �OSErrorr% �strerror�errno) r8 rg ZnlpidZnlgrpsZmsglenr| rv rw rx r r� �errr r r �recv� s � �zConnection.recvc C s | j d7 _ | j S r )r� rC r r r rw � s zConnection.seq)r N)r r r r; r r� rw r r r r r~ � s r~ c C s\ i }t | �rXt�d| d d� �\}}t|| d|� �||< |d d d@ }| |d � } q|S )Nr< r/ r r= )r* r5 rG r3 )r7 rc Zattr_lenr9 r r r rS � s rS )r )r )r )7�__doc__r% r# r5 r$ r Z _dummysockr r r r r �errorr � ImportErrorr ZCDLLr' Z Structurer Z NLM_F_REQUESTZ NLM_F_MULTIZ NLM_F_ACKZ NLM_F_ECHOZ NLMSG_NOOPr� Z NLMSG_DONEZ NLMSG_OVERRUNZNLMSG_MIN_TYPEr3 rU r[ r\ r` rb Z NETLINK_ROUTEZNETLINK_UNUSEDZNETLINK_USERSOCKZNETLINK_FIREWALLZNETLINK_INET_DIAGZ NETLINK_NFLOGZ NETLINK_XFRMZNETLINK_SELINUXZ NETLINK_ISCSIZ NETLINK_AUDITZNETLINK_FIB_LOOKUPZNETLINK_CONNECTORZNETLINK_NETFILTERZNETLINK_IP6_FWZNETLINK_DNRTMSGZNETLINK_KOBJECT_UEVENTZNETLINK_GENERICrs r~ rS r r r r �<module> sz __pycache__/ioprio.cpython-39.opt-1.pyc 0000644 00000007633 15025012261 0013650 0 ustar 00 a B��Qw � @ sd d dl Z d dlZd dlZd dlZg d�Zg d�Zdd� ZG dd� de�Zee�Z ee�Z ze j ddd �Z W n e y� e � d�Z Y n0 e jZg d �Zd Zd Zd e> d Zd d� Zdd� Zdd� Ze jZed�\ZZZZZ Z e j Z d Z dd� Z dd� Z!dd� Z"dd� Z#d d � Z$e%d k�r`d dl&Z&e'e&j(�d k�r@e)e&j(d �Z*ne�+� Z*e,d e*� e,d!e!e*�� dS )"� N) )�alpha�*i� )�arm*r i; )�i*86r �" )�ia64*r i� )�parisc*r i )�powerpc*r i )�s390*r i )�sparc*r �� )�sh*r �! )�x86_64*�32bitr )r �64bit� ) )r r i� )r r i: )r r r )r r i� )r r i )r r i )r r i )r r �� )r r i )r r r )r r � c C sL t �� d }t�� d }| D ]*\}}}t�||�r t�||�r | S q d S )N� r )�os�uname�platformZ architecture�fnmatch)Z syscall_listZarch�bitsZcandidate_archZcandidate_bitsZ syscall_nr� r �0/usr/lib/python3.9/site-packages/iotop/ioprio.py�find_ioprio_syscall_number9 s �r c @ s e Zd Zdd� ZdS )�IoprioSetErrorc C s. zt �|�| _W n ty( || _Y n0 d S �N)r �strerror�err� TypeError)�selfr! r r r �__init__C s zIoprioSetError.__init__N)�__name__� __module__� __qualname__r$ r r r r r B s r T�Z use_errno)NZrt�be�idle� � c C s8 zt �| �} W n ty* t �d �} Y n0 | t> |B S r )�PRIORITY_CLASSES�index� ValueError�IOPRIO_CLASS_SHIFT)� ioprio_class� ioprio_datar r r � ioprio_valueY s r3 c C s t | t? S r )r- r0 ��ioprior r r r1 ` s r1 c C s | t @ S r )�IOPRIO_PRIO_MASKr4 r r r r2 c s r2 � c C sJ t | �}tt| �}|d d }|ttfv r2d| S |tkr>dS d| S d S )N� � zrt/%dr* zbe/%d)�sched_getscheduler� getpriority� PRIO_PROCESS� SCHED_FIFO�SCHED_RR� SCHED_IDLE)�pidZ scheduler�niceZ ioprio_nicer r r �get_ioprio_from_schedl s rB c C sT t d u r dS tt t| �}|dk r$dS t|�}|s8t| �S |dkrD|S d|t|�f S )Nz?sysr z?errr* z%s/%d)�__NR_ioprio_get�syscall�IOPRIO_WHO_PROCESSr1 rB r2 )r@ r5 Z prio_classr r r �getx s rF c C sd t d u rtd��t||�}tt | ||dd�}|dk r`z t�� }W n tyV d}Y n0 t|��d S )NzNo ioprio_set syscall foundTr( r z<Unknown error (errno support not available before Python2.6))�__NR_ioprio_setr r3 rD �ctypesZ get_errno�AttributeError)�whichZwhor1 r2 Z ioprio_val�retr! r r r � set_ioprio� s rL c C st | d dkrt | d � S d| v rT| �d�r2d}n| �d�r@d}t| �d�d �}n| dkrdd}d}d|t > | S ) Nr �?r+ �/zrt/zbe/r* � )�ord� startswith�int�splitr0 )�key�shiftZprior r r �sort_key� s rV c C s6 d| v r&| � d�}|d t|d �fS | dkr2dS dS )NrN r r+ r* )r* r )NN)rS rR )Z ioprio_strrS r r r �to_class_and_data� s rW �__main__rO zpid:zioprio:)-rH r r r ZIOPRIO_GET_ARCH_SYSCALLZIOPRIO_SET_ARCH_SYSCALLr � Exceptionr rC rG ZCDLLZ ctypes_handler" rD r- rE r0 r6 r3 r1 r2 r: �range� SCHED_OTHERr= r> � SCHED_BATCHZ SCHED_ISOr? r; r< rB rF rL rV rW r% �sys�len�argvrR r@ �getpid�printr r r r �<module> sJ __pycache__/__init__.cpython-39.opt-1.pyc 0000644 00000000215 15025012261 0014073 0 ustar 00 a B��Q � @ s d S )N� r r r �2/usr/lib/python3.9/site-packages/iotop/__init__.py�<module> � __pycache__/version.cpython-39.pyc 0000644 00000000233 15025012261 0013062 0 ustar 00 a B��Q � @ s d Z dS )z0.6N)ZVERSION� r r �1/usr/lib/python3.9/site-packages/iotop/version.py�<module> � ioprio.py 0000644 00000012567 15025012261 0006424 0 ustar 00 # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU Library General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program; if not, write to the Free Software # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA # # See the COPYING file for license information. # # Copyright (c) 2007 Guillaume Chazarain <guichaz@gmail.com> import ctypes import fnmatch import os import platform # From http://git.kernel.org/?p=utils/util-linux-ng/util-linux-ng.git;a=blob; # f=configure.ac;h=770eb45ae85d32757fc3cff1d70a7808a627f9f7;hb=HEAD#l354 # i386 bit userspace under an x86_64 kernel will have its uname() appear as # 'x86_64' but it will use the i386 syscall number, that's why we consider both # the architecture name and the word size. IOPRIO_GET_ARCH_SYSCALL = [ ('alpha', '*', 443), ('arm*', '*', 315), ('i*86', '*', 290), ('ia64*', '*', 1275), ('parisc*', '*', 268), ('powerpc*', '*', 274), ('s390*', '*', 283), ('sparc*', '*', 218), ('sh*', '*', 289), ('x86_64*', '32bit', 290), ('x86_64*', '64bit', 252), ] IOPRIO_SET_ARCH_SYSCALL = [ ('alpha', '*', 442), ('arm*', '*', 314), ('i*86', '*', 289), ('ia64*', '*', 1274), ('parisc*', '*', 267), ('powerpc*', '*', 273), ('s390*', '*', 282), ('sparc*', '*', 196), ('sh*', '*', 288), ('x86_64*', '32bit', 289), ('x86_64*', '64bit', 251), ] def find_ioprio_syscall_number(syscall_list): arch = os.uname()[4] bits = platform.architecture()[0] for candidate_arch, candidate_bits, syscall_nr in syscall_list: if fnmatch.fnmatch(arch, candidate_arch) and \ fnmatch.fnmatch(bits, candidate_bits): return syscall_nr class IoprioSetError(Exception): def __init__(self, err): try: self.err = os.strerror(err) except TypeError: self.err = err __NR_ioprio_get = find_ioprio_syscall_number(IOPRIO_GET_ARCH_SYSCALL) __NR_ioprio_set = find_ioprio_syscall_number(IOPRIO_SET_ARCH_SYSCALL) try: ctypes_handle = ctypes.CDLL(None, use_errno=True) except TypeError: ctypes_handle = ctypes.CDLL(None) syscall = ctypes_handle.syscall PRIORITY_CLASSES = [None, 'rt', 'be', 'idle'] IOPRIO_WHO_PROCESS = 1 IOPRIO_CLASS_SHIFT = 13 IOPRIO_PRIO_MASK = (1 << IOPRIO_CLASS_SHIFT) - 1 def ioprio_value(ioprio_class, ioprio_data): try: ioprio_class = PRIORITY_CLASSES.index(ioprio_class) except ValueError: ioprio_class = PRIORITY_CLASSES.index(None) return (ioprio_class << IOPRIO_CLASS_SHIFT) | ioprio_data def ioprio_class(ioprio): return PRIORITY_CLASSES[ioprio >> IOPRIO_CLASS_SHIFT] def ioprio_data(ioprio): return ioprio & IOPRIO_PRIO_MASK sched_getscheduler = ctypes_handle.sched_getscheduler SCHED_OTHER, SCHED_FIFO, SCHED_RR, SCHED_BATCH, SCHED_ISO, SCHED_IDLE = range(6) getpriority = ctypes_handle.getpriority PRIO_PROCESS = 0 def get_ioprio_from_sched(pid): scheduler = sched_getscheduler(pid) nice = getpriority(PRIO_PROCESS, pid) ioprio_nice = (nice + 20) / 5 if scheduler in (SCHED_FIFO, SCHED_RR): return 'rt/%d' % ioprio_nice elif scheduler == SCHED_IDLE: return 'idle' else: return 'be/%d' % ioprio_nice def get(pid): if __NR_ioprio_get is None: return '?sys' ioprio = syscall(__NR_ioprio_get, IOPRIO_WHO_PROCESS, pid) if ioprio < 0: return '?err' prio_class = ioprio_class(ioprio) if not prio_class: return get_ioprio_from_sched(pid) if prio_class == 'idle': return prio_class return '%s/%d' % (prio_class, ioprio_data(ioprio)) def set_ioprio(which, who, ioprio_class, ioprio_data): if __NR_ioprio_set is None: raise IoprioSetError('No ioprio_set syscall found') ioprio_val = ioprio_value(ioprio_class, ioprio_data) ret = syscall(__NR_ioprio_set, which, who, ioprio_val, use_errno=True) if ret < 0: try: err = ctypes.get_errno() except AttributeError: err = 'Unknown error (errno support not available before Python2.6)' raise IoprioSetError(err) def sort_key(key): if key[0] == '?': return -ord(key[1]) if '/' in key: if key.startswith('rt/'): shift = 0 elif key.startswith('be/'): shift = 1 prio = int(key.split('/')[1]) elif key == 'idle': shift = 2 prio = 0 return (1 << (shift * IOPRIO_CLASS_SHIFT)) + prio def to_class_and_data(ioprio_str): if '/' in ioprio_str: split = ioprio_str.split('/') return (split[0], int(split[1])) elif ioprio_str == 'idle': return ('idle', 0) return (None, None) if __name__ == '__main__': import sys if len(sys.argv) == 2: pid = int(sys.argv[1]) else: pid = os.getpid() print('pid:', pid) print('ioprio:', get(pid)) genetlink.py 0000644 00000003774 15025012261 0007103 0 ustar 00 ''' Netlink message generation/parsing Copyright 2007 Johannes Berg <johannes@sipsolutions.net> GPLv2+; See copying for details. ''' import struct from iotop.netlink import NLM_F_REQUEST, NLMSG_MIN_TYPE, Message, parse_attributes from iotop.netlink import NulStrAttr, Connection, NETLINK_GENERIC CTRL_CMD_UNSPEC = 0 CTRL_CMD_NEWFAMILY = 1 CTRL_CMD_DELFAMILY = 2 CTRL_CMD_GETFAMILY = 3 CTRL_CMD_NEWOPS = 4 CTRL_CMD_DELOPS = 5 CTRL_CMD_GETOPS = 6 CTRL_ATTR_UNSPEC = 0 CTRL_ATTR_FAMILY_ID = 1 CTRL_ATTR_FAMILY_NAME = 2 CTRL_ATTR_VERSION = 3 CTRL_ATTR_HDRSIZE = 4 CTRL_ATTR_MAXATTR = 5 CTRL_ATTR_OPS = 6 class GenlHdr: def __init__(self, cmd, version = 0): self.cmd = cmd self.version = version def _dump(self): return struct.pack("BBxx", self.cmd, self.version) def _genl_hdr_parse(data): return GenlHdr(*struct.unpack("BBxx", data)) GENL_ID_CTRL = NLMSG_MIN_TYPE class GeNlMessage(Message): def __init__(self, family, cmd, attrs=[], flags=0): self.cmd = cmd self.attrs = attrs self.family = family Message.__init__(self, family, flags=flags, payload=[GenlHdr(self.cmd)]+attrs) @staticmethod def recv(conn): msg = conn.recv() packet = msg.payload hdr = _genl_hdr_parse(packet[:4]) genlmsg = GeNlMessage(msg.type, hdr.cmd, [], msg.flags) genlmsg.attrs = parse_attributes(packet[4:]) genlmsg.version = hdr.version return genlmsg class Controller: def __init__(self, conn): self.conn = conn def get_family_id(self, family): a = NulStrAttr(CTRL_ATTR_FAMILY_NAME, family) m = GeNlMessage(GENL_ID_CTRL, CTRL_CMD_GETFAMILY, flags=NLM_F_REQUEST, attrs=[a]) m.send(self.conn) m = GeNlMessage.recv(self.conn) return m.attrs[CTRL_ATTR_FAMILY_ID].u16() connection = Connection(NETLINK_GENERIC) controller = Controller(connection) data.py 0000644 00000035454 15025012261 0006034 0 ustar 00 # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU Library General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program; if not, write to the Free Software # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA # # See the COPYING file for license information. # # Copyright (c) 2007 Guillaume Chazarain <guichaz@gmail.com> # Allow printing with same syntax in Python 2/3 from __future__ import print_function import errno import os import pprint import pwd import stat import struct import sys import time # # Check for requirements: # o Linux >= 2.6.20 with I/O accounting and VM event counters # ioaccounting = os.path.exists('/proc/self/io') try: from iotop.vmstat import VmStat vmstat_f = VmStat() except: vm_event_counters = False else: vm_event_counters = True if not ioaccounting or not vm_event_counters: print('Could not run iotop as some of the requirements are not met:') print('- Linux >= 2.6.20 with') if not ioaccounting: print(' - I/O accounting support ' \ '(CONFIG_TASKSTATS, CONFIG_TASK_DELAY_ACCT, ' \ 'CONFIG_TASK_IO_ACCOUNTING, kernel.task_delayacct sysctl)') if not vm_event_counters: print(' - VM event counters (CONFIG_VM_EVENT_COUNTERS)') sys.exit(1) from iotop import ioprio, vmstat from iotop.netlink import Connection, NETLINK_GENERIC, U32Attr, NLM_F_REQUEST from iotop.genetlink import Controller, GeNlMessage class DumpableObject(object): """Base class for all objects that allows easy introspection when printed""" def __repr__(self): return '%s: %s>' % (str(type(self))[:-1], pprint.pformat(self.__dict__)) # # Interesting fields in a taskstats output # class Stats(DumpableObject): members_offsets = [ ('blkio_delay_total', 40), ('swapin_delay_total', 56), ('read_bytes', 248), ('write_bytes', 256), ('cancelled_write_bytes', 264) ] has_blkio_delay_total = None def __init__(self, task_stats_buffer): sd = self.__dict__ for name, offset in Stats.members_offsets: data = task_stats_buffer[offset:offset + 8] sd[name] = struct.unpack('Q', data)[0] # This is a heuristic to detect if CONFIG_TASK_DELAY_ACCT is enabled in # the kernel. if not Stats.has_blkio_delay_total: Stats.has_blkio_delay_total = sysctl_task_delayacct() def accumulate(self, other_stats, destination, coeff=1): """Update destination from operator(self, other_stats)""" dd = destination.__dict__ sd = self.__dict__ od = other_stats.__dict__ for member, offset in Stats.members_offsets: dd[member] = sd[member] + coeff * od[member] def delta(self, other_stats, destination): """Update destination with self - other_stats""" return self.accumulate(other_stats, destination, coeff=-1) def is_all_zero(self): sd = self.__dict__ for name, offset in Stats.members_offsets: if sd[name] != 0: return False return True @staticmethod def build_all_zero(): stats = Stats.__new__(Stats) std = stats.__dict__ for name, offset in Stats.members_offsets: std[name] = 0 return stats # # Netlink usage for taskstats # TASKSTATS_CMD_GET = 1 TASKSTATS_CMD_ATTR_PID = 1 TASKSTATS_TYPE_AGGR_PID = 4 TASKSTATS_TYPE_PID = 1 TASKSTATS_TYPE_STATS = 3 class TaskStatsNetlink(object): # Keep in sync with format_stats() and pinfo.did_some_io() def __init__(self, options): self.options = options self.connection = Connection(NETLINK_GENERIC) controller = Controller(self.connection) self.family_id = controller.get_family_id('TASKSTATS') def build_request(self, tid): return GeNlMessage(self.family_id, cmd=TASKSTATS_CMD_GET, attrs=[U32Attr(TASKSTATS_CMD_ATTR_PID, tid)], flags=NLM_F_REQUEST) def get_single_task_stats(self, thread): thread.task_stats_request.send(self.connection) try: reply = GeNlMessage.recv(self.connection) except OSError as e: if e.errno == errno.ESRCH: # OSError: Netlink error: No such process (3) return raise for attr_type, attr_value in reply.attrs.items(): if attr_type == TASKSTATS_TYPE_AGGR_PID: reply = attr_value.nested() break else: return taskstats_data = reply[TASKSTATS_TYPE_STATS].data if len(taskstats_data) < 272: # Short reply return taskstats_version = struct.unpack('H', taskstats_data[:2])[0] assert taskstats_version >= 4 return Stats(taskstats_data) # # PIDs manipulations # def find_uids(options): """Build options.uids from options.users by resolving usernames to UIDs""" options.uids = [] error = False for u in options.users or []: try: uid = int(u) except ValueError: try: passwd = pwd.getpwnam(u) except KeyError: print('Unknown user:', u, file=sys.stderr) error = True else: uid = passwd.pw_uid if not error: options.uids.append(uid) if error: sys.exit(1) def parse_proc_pid_status(pid): result_dict = {} try: for line in open('/proc/%d/status' % pid): key, value = line.split(':\t', 1) result_dict[key] = value.strip() except IOError: pass # No such process return result_dict def safe_utf8_decode(s): try: return s.decode('utf-8') except UnicodeDecodeError: return s.encode('string_escape') except AttributeError: return s class ThreadInfo(DumpableObject): """Stats for a single thread""" def __init__(self, tid, taskstats_connection): self.tid = tid self.mark = True self.stats_total = None self.stats_delta = Stats.__new__(Stats) self.task_stats_request = taskstats_connection.build_request(tid) def get_ioprio(self): return ioprio.get(self.tid) def set_ioprio(self, ioprio_class, ioprio_data): return ioprio.set_ioprio(ioprio.IOPRIO_WHO_PROCESS, self.tid, ioprio_class, ioprio_data) def update_stats(self, stats): if not self.stats_total: self.stats_total = stats stats.delta(self.stats_total, self.stats_delta) self.stats_total = stats class ProcessInfo(DumpableObject): """Stats for a single process (a single line in the output): if options.processes is set, it is a collection of threads, otherwise a single thread.""" def __init__(self, pid): self.pid = pid self.uid = None self.user = None self.threads = {} # {tid: ThreadInfo} self.stats_delta = Stats.build_all_zero() self.stats_accum = Stats.build_all_zero() self.stats_accum_timestamp = time.time() def is_monitored(self, options): if (options.pids and not options.processes and self.pid not in options.pids): # We only monitor some threads, not this one return False if options.uids and self.get_uid() not in options.uids: # We only monitor some users, not this one return False return True def get_uid(self): if self.uid: return self.uid # uid in (None, 0) means either we don't know the UID yet or the process # runs as root so it can change its UID. In both cases it means we have # to find out its current UID. try: uid = os.stat('/proc/%d' % self.pid)[stat.ST_UID] except OSError: # The process disappeared uid = None if uid != self.uid: # Maybe the process called setuid() self.user = None self.uid = uid return uid def get_user(self): uid = self.get_uid() if uid is not None and not self.user: try: self.user = safe_utf8_decode(pwd.getpwuid(uid).pw_name) except (KeyError, AttributeError): self.user = str(uid) return self.user or '{none}' def get_cmdline(self): # A process may exec, so we must always reread its cmdline try: proc_cmdline = open('/proc/%d/cmdline' % self.pid) cmdline = proc_cmdline.read(4096) except IOError: return '{no such process}' proc_status = parse_proc_pid_status(self.pid) if not cmdline: # Probably a kernel thread, get its name from /proc/PID/status proc_status_name = proc_status.get('Name', '') if proc_status_name: proc_status_name = '[%s]' % proc_status_name else: proc_status_name = '{no name}' return proc_status_name suffix = '' tgid = int(proc_status.get('Tgid', self.pid)) if tgid != self.pid: # Not the main thread, maybe it has a custom name tgid_name = parse_proc_pid_status(tgid).get('Name', '') thread_name = proc_status.get('Name', '') if thread_name != tgid_name: suffix += ' [%s]' % thread_name parts = cmdline.split('\0') if parts[0].startswith('/'): first_command_char = parts[0].rfind('/') + 1 parts[0] = parts[0][first_command_char:] cmdline = ' '.join(parts).strip() return safe_utf8_decode(cmdline + suffix) def did_some_io(self, accumulated): if accumulated: return not self.stats_accum.is_all_zero() for t in self.threads.values(): if not t.stats_delta.is_all_zero(): return True return False def get_ioprio(self): priorities = set(t.get_ioprio() for t in self.threads.values()) if len(priorities) == 1: return priorities.pop() return '?dif' def set_ioprio(self, ioprio_class, ioprio_data): for thread in self.threads.values(): thread.set_ioprio(ioprio_class, ioprio_data) def ioprio_sort_key(self): return ioprio.sort_key(self.get_ioprio()) def get_thread(self, tid, taskstats_connection): thread = self.threads.get(tid, None) if not thread: thread = ThreadInfo(tid, taskstats_connection) self.threads[tid] = thread return thread def update_stats(self): stats_delta = Stats.build_all_zero() for tid, thread in self.threads.items(): if not thread.mark: stats_delta.accumulate(thread.stats_delta, stats_delta) self.threads = dict([(tid, thread) for tid, thread in self.threads.items() if not thread.mark]) nr_threads = len(self.threads) if not nr_threads: return False stats_delta.blkio_delay_total /= nr_threads stats_delta.swapin_delay_total /= nr_threads self.stats_delta = stats_delta self.stats_accum.accumulate(self.stats_delta, self.stats_accum) return True class ProcessList(DumpableObject): def __init__(self, taskstats_connection, options): # {pid: ProcessInfo} self.processes = {} self.taskstats_connection = taskstats_connection self.options = options self.timestamp = time.time() self.vmstat = vmstat.VmStat() # A first time as we are interested in the delta self.update_process_counts() def get_process(self, pid): """Either get the specified PID from self.processes or build a new ProcessInfo if we see this PID for the first time""" process = self.processes.get(pid, None) if not process: process = ProcessInfo(pid) self.processes[pid] = process if process.is_monitored(self.options): return process def list_tgids(self): if self.options.pids: return self.options.pids tgids = os.listdir('/proc') if self.options.processes: return [int(tgid) for tgid in tgids if '0' <= tgid[0] <= '9'] tids = [] for tgid in tgids: if '0' <= tgid[0] <= '9': try: tids.extend(map(int, os.listdir('/proc/' + tgid + '/task'))) except OSError: # The PID went away pass return tids def list_tids(self, tgid): if not self.options.processes: return [tgid] try: tids = list(map(int, os.listdir('/proc/%d/task' % tgid))) except OSError: return [] if self.options.pids: tids = list(set(self.options.pids).intersection(set(tids))) return tids def update_process_counts(self): new_timestamp = time.time() self.duration = new_timestamp - self.timestamp self.timestamp = new_timestamp total_read = total_write = 0 for tgid in self.list_tgids(): process = self.get_process(tgid) if not process: continue for tid in self.list_tids(tgid): thread = process.get_thread(tid, self.taskstats_connection) stats = self.taskstats_connection.get_single_task_stats(thread) if stats: thread.update_stats(stats) delta = thread.stats_delta total_read += delta.read_bytes total_write += delta.write_bytes thread.mark = False return (total_read, total_write), self.vmstat.delta() def refresh_processes(self): for process in self.processes.values(): for thread in process.threads.values(): thread.mark = True total_read_and_write = self.update_process_counts() self.processes = dict([(pid, process) for pid, process in self.processes.items() if process.update_stats()]) return total_read_and_write def clear(self): self.processes = {} def sysctl_task_delayacct(): try: with open('/proc/sys/kernel/task_delayacct') as f: return bool(int(f.read().strip())) except FileNotFoundError: return None version.py 0000644 00000000020 15025012261 0006565 0 ustar 00 VERSION = '0.6' ui.py 0000644 00000061261 15025012261 0005533 0 ustar 00 # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU Library General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program; if not, write to the Free Software # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA # # See the COPYING file for license information. # # Copyright (c) 2007 Guillaume Chazarain <guichaz@gmail.com> # Allow printing with same syntax in Python 2/3 from __future__ import print_function import curses import errno import locale import math import optparse import os import select import signal import sys import time from iotop.data import find_uids, TaskStatsNetlink, ProcessList, Stats, sysctl_task_delayacct from iotop.data import ThreadInfo from iotop.version import VERSION from iotop import ioprio from iotop.ioprio import IoprioSetError # # Utility functions for the UI # UNITS = ['B', 'K', 'M', 'G', 'T', 'P', 'E'] def human_size(size): if size > 0: sign = '' elif size < 0: sign = '-' size = -size else: return '0.00 B' expo = int(math.log(size / 2, 2) / 10) return '%s%.2f %s' % (sign, (float(size) / (1 << (10 * expo))), UNITS[expo]) def format_size(options, bytes): if options.kilobytes: return '%.2f K' % (bytes / 1024.0) return human_size(bytes) def format_bandwidth(options, size, duration): return format_size(options, size and float(size) / duration) + '/s' def format_stats(options, process, duration): # Keep in sync with TaskStatsNetlink.members_offsets and # IOTopUI.get_data(self) def delay2percent(delay): # delay in ns, duration in s return '%.2f %%' % min(99.99, delay / (duration * 10000000.0)) if options.accumulated: stats = process.stats_accum display_format = lambda size, duration: format_size(options, size) duration = time.time() - process.stats_accum_timestamp else: stats = process.stats_delta display_format = lambda size, duration: format_bandwidth( options, size, duration) io_delay = delay2percent(stats.blkio_delay_total) swapin_delay = delay2percent(stats.swapin_delay_total) read_bytes = display_format(stats.read_bytes, duration) written_bytes = stats.write_bytes - stats.cancelled_write_bytes written_bytes = max(0, written_bytes) write_bytes = display_format(written_bytes, duration) return io_delay, swapin_delay, read_bytes, write_bytes def get_max_pid_width(): try: return len(open('/proc/sys/kernel/pid_max').read().strip()) except Exception as e: print(e) # Reasonable default in case something fails return 5 MAX_PID_WIDTH = get_max_pid_width() # # UI Exceptions # class CancelInput(Exception): pass class InvalidInt(Exception): pass class InvalidPid(Exception): pass class InvalidTid(Exception): pass class InvalidIoprioData(Exception): pass # # The UI # class IOTopUI(object): # key, reverse sorting_keys = [ (lambda p, s: p.pid, False), (lambda p, s: p.ioprio_sort_key(), False), (lambda p, s: p.get_user(), False), (lambda p, s: s.read_bytes, True), (lambda p, s: s.write_bytes - s.cancelled_write_bytes, True), (lambda p, s: s.swapin_delay_total, True), # The default sorting (by I/O % time) should show processes doing # only writes, without waiting on them (lambda p, s: s.blkio_delay_total or int(not(not(s.read_bytes or s.write_bytes))), True), (lambda p, s: p.get_cmdline(), False), ] def __init__(self, win, process_list, options): self.process_list = process_list self.options = options self.sorting_key = 6 self.sorting_reverse = IOTopUI.sorting_keys[self.sorting_key][1] if not self.options.batch: self.win = win self.resize() try: curses.use_default_colors() curses.start_color() curses.curs_set(0) except curses.error: # This call can fail with misconfigured terminals, for example # TERM=xterm-color. This is harmless pass def resize(self): self.height, self.width = self.win.getmaxyx() def run(self): iterations = 0 poll = select.poll() if not self.options.batch: poll.register(sys.stdin.fileno(), select.POLLIN|select.POLLPRI) while self.options.iterations is None or \ iterations < self.options.iterations: total, actual = self.process_list.refresh_processes() self.refresh_display(iterations == 0, total, actual, self.process_list.duration) if self.options.iterations is not None: iterations += 1 if iterations >= self.options.iterations: break elif iterations == 0: iterations = 1 try: events = poll.poll(self.options.delay_seconds * 1000.0) except select.error as e: if e.args and e.args[0] == errno.EINTR: events = [] else: raise for (fd, event) in events: if event & (select.POLLERR | select.POLLHUP): sys.exit(1) if not self.options.batch: self.resize() if events: key = self.win.getch() self.handle_key(key) def reverse_sorting(self): self.sorting_reverse = not self.sorting_reverse def adjust_sorting_key(self, delta): orig_sorting_key = self.sorting_key self.sorting_key += delta self.sorting_key = max(0, self.sorting_key) self.sorting_key = min(len(IOTopUI.sorting_keys) - 1, self.sorting_key) if not self.has_swapin_io: if self.sorting_key in (5, 6): if delta <= 0: self.sorting_key = 4 elif delta > 0: self.sorting_key = 7 if orig_sorting_key != self.sorting_key: self.sorting_reverse = IOTopUI.sorting_keys[self.sorting_key][1] # I wonder if switching to urwid for the display would be better here def prompt_str(self, prompt, default=None, empty_is_cancel=True): self.win.hline(1, 0, ord(' ') | curses.A_NORMAL, self.width) self.win.addstr(1, 0, prompt, curses.A_BOLD) self.win.refresh() curses.echo() curses.curs_set(1) inp = self.win.getstr(1, len(prompt)) curses.curs_set(0) curses.noecho() if inp not in (None, ''): return inp if empty_is_cancel: raise CancelInput() return default def prompt_int(self, prompt, default = None, empty_is_cancel = True): inp = self.prompt_str(prompt, default, empty_is_cancel) try: return int(inp) except ValueError: raise InvalidInt() def prompt_pid(self): try: return self.prompt_int('PID to ionice: ') except InvalidInt: raise InvalidPid() except CancelInput: raise def prompt_tid(self): try: return self.prompt_int('TID to ionice: ') except InvalidInt: raise InvalidTid() except CancelInput: raise def prompt_data(self, ioprio_data): try: if ioprio_data is not None: inp = self.prompt_int('I/O priority data (0-7, currently %s): ' % ioprio_data, ioprio_data, False) else: inp = self.prompt_int('I/O priority data (0-7): ', None, False) except InvalidInt: raise InvalidIoprioData() if inp < 0 or inp > 7: raise InvalidIoprioData() return inp def prompt_set(self, prompt, display_list, ret_list, selected): try: selected = ret_list.index(selected) except ValueError: selected = -1 set_len = len(display_list) - 1 while True: self.win.hline(1, 0, ord(' ') | curses.A_NORMAL, self.width) self.win.insstr(1, 0, prompt, curses.A_BOLD) offset = len(prompt) for i, item in enumerate(display_list): display = ' %s ' % item if i is selected: attr = curses.A_REVERSE else: attr = curses.A_NORMAL self.win.insstr(1, offset, display, attr) offset += len(display) while True: key = self.win.getch() if key in (curses.KEY_LEFT, ord('l')) and selected > 0: selected -= 1 break elif key in (curses.KEY_RIGHT, ord('r')) and selected < set_len: selected += 1 break elif key in (curses.KEY_ENTER, ord('\n'), ord('\r')): return ret_list[selected] elif key in (27, curses.KEY_CANCEL, curses.KEY_CLOSE, curses.KEY_EXIT, ord('q'), ord('Q')): raise CancelInput() def prompt_class(self, ioprio_class=None): prompt = 'I/O priority class: ' classes_prompt = ['Real-time', 'Best-effort', 'Idle'] classes_ret = ['rt', 'be', 'idle'] if ioprio_class is None: ioprio_class = 2 inp = self.prompt_set(prompt, classes_prompt, classes_ret, ioprio_class) return inp def prompt_error(self, error = 'Error!'): self.win.hline(1, 0, ord(' ') | curses.A_NORMAL, self.width) self.win.insstr(1, 0, ' %s ' % error, curses.A_REVERSE) self.win.refresh() time.sleep(1) def prompt_clear(self): self.win.hline(1, 0, ord(' ') | curses.A_NORMAL, self.width) self.win.refresh() def handle_key(self, key): def toggle_accumulated(): self.options.accumulated ^= True def toggle_only_io(): self.options.only ^= True def toggle_processes(): self.options.processes ^= True self.process_list.clear() self.process_list.refresh_processes() def ionice(): try: if self.options.processes: pid = self.prompt_pid() exec_unit = self.process_list.get_process(pid) else: tid = self.prompt_tid() exec_unit = ThreadInfo(tid, self.process_list.taskstats_connection) ioprio_value = exec_unit.get_ioprio() (ioprio_class, ioprio_data) = \ ioprio.to_class_and_data(ioprio_value) ioprio_class = self.prompt_class(ioprio_class) if ioprio_class == 'idle': ioprio_data = 0 else: ioprio_data = self.prompt_data(ioprio_data) exec_unit.set_ioprio(ioprio_class, ioprio_data) self.process_list.clear() self.process_list.refresh_processes() except IoprioSetError as e: self.prompt_error('Error setting I/O priority: %s' % e.err) except InvalidPid: self.prompt_error('Invalid process id!') except InvalidTid: self.prompt_error('Invalid thread id!') except InvalidIoprioData: self.prompt_error('Invalid I/O priority data!') except InvalidInt: self.prompt_error('Invalid integer!') except CancelInput: self.prompt_clear() else: self.prompt_clear() key_bindings = { ord('q'): lambda: sys.exit(0), ord('Q'): lambda: sys.exit(0), ord('r'): lambda: self.reverse_sorting(), ord('R'): lambda: self.reverse_sorting(), ord('a'): toggle_accumulated, ord('A'): toggle_accumulated, ord('o'): toggle_only_io, ord('O'): toggle_only_io, ord('p'): toggle_processes, ord('P'): toggle_processes, ord('i'): ionice, ord('I'): ionice, curses.KEY_LEFT: lambda: self.adjust_sorting_key(-1), curses.KEY_RIGHT: lambda: self.adjust_sorting_key(1), curses.KEY_HOME: lambda: self.adjust_sorting_key(-len(IOTopUI.sorting_keys)), curses.KEY_END: lambda: self.adjust_sorting_key(len(IOTopUI.sorting_keys)) } action = key_bindings.get(key, lambda: None) action() def get_data(self): def format(p): stats = format_stats(self.options, p, self.process_list.duration) io_delay, swapin_delay, read_bytes, write_bytes = stats format = '%%%dd' % MAX_PID_WIDTH params = p.pid, format += ' %4s' params += p.get_ioprio(), format += ' %-8s' params += p.get_user()[:8], format += ' %11s %11s' params += read_bytes, write_bytes if self.has_swapin_io: format += ' %7s %7s' params += swapin_delay, io_delay elif self.options.batch: format += ' %s ' params += '?unavailable?', format += ' ' line = format % (params) cmdline = p.get_cmdline() if not self.options.batch: remaining_length = self.width - len(line) if 2 < remaining_length < len(cmdline): len1 = (remaining_length - 1) // 2 offset2 = -(remaining_length - len1 - 1) cmdline = cmdline[:len1] + '~' + cmdline[offset2:] line += cmdline if not self.options.batch: line = line[:self.width] return line def should_format(p): return not self.options.only or \ p.did_some_io(self.options.accumulated) processes = list(filter(should_format, self.process_list.processes.values())) key = IOTopUI.sorting_keys[self.sorting_key][0] if self.options.accumulated: stats_lambda = lambda p: p.stats_accum else: stats_lambda = lambda p: p.stats_delta processes.sort(key=lambda p: key(p, stats_lambda(p)), reverse=self.sorting_reverse) if not self.options.batch: del processes[self.height - 2:] return list(map(format, processes)) def refresh_display(self, first_time, total, actual, duration): summary = [ 'Total DISK READ : %s | Total DISK WRITE : %s' % ( format_bandwidth(self.options, total[0], duration).rjust(14), format_bandwidth(self.options, total[1], duration).rjust(14)), 'Actual DISK READ: %s | Actual DISK WRITE: %s' % ( format_bandwidth(self.options, actual[0], duration).rjust(14), format_bandwidth(self.options, actual[1], duration).rjust(14)) ] pid = max(0, (MAX_PID_WIDTH - 3)) * ' ' if self.options.processes: pid += 'PID' else: pid += 'TID' titles = [pid, ' PRIO', ' USER', ' DISK READ', ' DISK WRITE', ' SWAPIN', ' IO', ' COMMAND'] self.has_swapin_io = Stats.has_blkio_delay_total if self.has_swapin_io: # Linux kernels without the sysctl return None and # iotop just uses the heuristic for those versions. # Linux kernels with the sysctl return True or False # and iotop then uses the sysctl value instead. if sysctl_task_delayacct() == False: self.has_swapin_io = False self.adjust_sorting_key(0) lines = self.get_data() if self.options.time: titles = [' TIME'] + titles current_time = time.strftime('%H:%M:%S ') lines = [current_time + l for l in lines] summary = [current_time + s for s in summary] if self.options.batch: if self.options.quiet <= 2: for s in summary: print(s) if self.options.quiet <= int(first_time): print(''.join(titles)) for l in lines: print(l.encode('utf-8')) sys.stdout.flush() else: self.win.erase() for i, s in enumerate(summary): self.win.addstr(i, 0, s[:self.width]) self.win.hline(len(summary), 0, ord(' ') | curses.A_REVERSE, self.width) remaining_cols = self.width for i in range(len(titles)): if not self.has_swapin_io and i in (5, 6): continue attr = curses.A_REVERSE title = titles[i] if i == self.sorting_key: title = title[1:] if i == self.sorting_key: attr |= curses.A_BOLD title += self.sorting_reverse and '>' or '<' title = title[:remaining_cols] remaining_cols -= len(title) self.win.addstr(title, attr) if self.has_swapin_io is not False: status_msg = None else: status_msg = ('CONFIG_TASK_DELAY_ACCT ' 'and kernel.task_delayacct sysctl ' 'not enabled in kernel, ' 'cannot determine SWAPIN and IO %') num_lines = min(len(lines), self.height - 2 - int(bool(status_msg))) for i in range(num_lines): try: def print_line(line): self.win.addstr(i + len(summary) + 1, 0, line) try: print_line(lines[i]) except UnicodeEncodeError: # Python2: 'ascii' codec can't encode character ... # http://bugs.debian.org/708252 print_line(lines[i].encode('utf-8')) except curses.error: pass if status_msg: self.win.insstr(self.height - len(summary), 0, status_msg, curses.A_BOLD) self.win.refresh() def run_iotop_window(win, options): if options.batch: signal.signal(signal.SIGPIPE, signal.SIG_DFL) else: def clean_exit(*args, **kwargs): sys.exit(0) signal.signal(signal.SIGINT, clean_exit) signal.signal(signal.SIGTERM, clean_exit) taskstats_connection = TaskStatsNetlink(options) process_list = ProcessList(taskstats_connection, options) ui = IOTopUI(win, process_list, options) ui.run() def run_iotop(options): try: if options.batch: return run_iotop_window(None, options) else: return curses.wrapper(run_iotop_window, options) except OSError as e: if e.errno == errno.EPERM: print(e, file=sys.stderr) print(''' The Linux kernel interfaces that iotop relies on now require root priviliges or the NET_ADMIN capability. This change occured because a security issue (CVE-2011-2494) was found that allows leakage of sensitive data across user boundaries. If you require the ability to run iotop as a non-root user, please configure sudo to allow you to run iotop as root. Please do not file bugs on iotop about this.''', file=sys.stderr) sys.exit(1) else: raise except curses.error as e: stre = str(e) if stre.find('ERR')>=0 and ( stre.find('nocbreak()')>=0 or stre.find('endwin()')>=0 ): pass # endwin and nocbreak can cause error (and raise hard to catch # exception) if iotop was running in the terminal and that # terminal got closed while iotop was still running else: raise # # Profiling # def _profile(continuation): prof_file = 'iotop.prof' try: import cProfile import pstats print('Profiling using cProfile') cProfile.runctx('continuation()', globals(), locals(), prof_file) stats = pstats.Stats(prof_file) except ImportError: import hotshot import hotshot.stats prof = hotshot.Profile(prof_file, lineevents=1) print('Profiling using hotshot') prof.runcall(continuation) prof.close() stats = hotshot.stats.load(prof_file) stats.strip_dirs() stats.sort_stats('time', 'calls') stats.print_stats(50) stats.print_callees(50) os.remove(prof_file) # # Main program # USAGE = '''%s [OPTIONS] DISK READ and DISK WRITE are the block I/O bandwidth used during the sampling period. SWAPIN and IO are the percentages of time the thread spent respectively while swapping in and waiting on I/O more generally. PRIO is the I/O priority at which the thread is running (set using the ionice command). Controls: left and right arrows to change the sorting column, r to invert the sorting order, o to toggle the --only option, p to toggle the --processes option, a to toggle the --accumulated option, i to change I/O priority, q to quit, any other key to force a refresh.''' % sys.argv[0] def main(): try: locale.setlocale(locale.LC_ALL, '') except locale.Error: print('unable to set locale, falling back to the default locale') parser = optparse.OptionParser(usage=USAGE, version='iotop ' + VERSION) parser.add_option('-o', '--only', action='store_true', dest='only', default=False, help='only show processes or threads actually doing I/O') parser.add_option('-b', '--batch', action='store_true', dest='batch', help='non-interactive mode') parser.add_option('-n', '--iter', type='int', dest='iterations', metavar='NUM', help='number of iterations before ending [infinite]') parser.add_option('-d', '--delay', type='float', dest='delay_seconds', help='delay between iterations [1 second]', metavar='SEC', default=1) parser.add_option('-p', '--pid', type='int', dest='pids', action='append', help='processes/threads to monitor [all]', metavar='PID') parser.add_option('-u', '--user', type='str', dest='users', action='append', help='users to monitor [all]', metavar='USER') parser.add_option('-P', '--processes', action='store_true', dest='processes', default=False, help='only show processes, not all threads') parser.add_option('-a', '--accumulated', action='store_true', dest='accumulated', default=False, help='show accumulated I/O instead of bandwidth') parser.add_option('-k', '--kilobytes', action='store_true', dest='kilobytes', default=False, help='use kilobytes instead of a human friendly unit') parser.add_option('-t', '--time', action='store_true', dest='time', help='add a timestamp on each line (implies --batch)') parser.add_option('-q', '--quiet', action='count', dest='quiet', default=0, help='suppress some lines of header (implies --batch)') parser.add_option('--profile', action='store_true', dest='profile', default=False, help=optparse.SUPPRESS_HELP) options, args = parser.parse_args() if args: parser.error('Unexpected arguments: ' + ' '.join(args)) find_uids(options) options.pids = options.pids or [] options.batch = options.batch or options.time or options.quiet main_loop = lambda: run_iotop(options) if options.profile: def safe_main_loop(): try: main_loop() except: pass _profile(safe_main_loop) else: main_loop() __init__.py 0000644 00000000000 15025012261 0006635 0 ustar 00 netlink.py 0000644 00000017323 15025012261 0006562 0 ustar 00 ''' Netlink message generation/parsing Copyright 2007 Johannes Berg <johannes@sipsolutions.net> GPLv2+; See copying for details. ''' import os import socket import struct try: # try to use python 2.5's netlink support _dummysock = socket.socket(socket.AF_NETLINK, socket.SOCK_RAW, 0) _dummysock.bind((0, 0)) del _dummysock def _nl_bind(descriptor, addr): descriptor.bind(addr) def _nl_getsockname(descriptor): return descriptor.getsockname() def _nl_send(descriptor, msg): descriptor.send(msg) def _nl_recv(descriptor, bufs=16384): return descriptor.recvfrom(bufs) except socket.error: # or fall back to the _netlink C module try: import _netlink def _nl_bind(descriptor, addr): _netlink.bind(descriptor.fileno(), addr[1]) def _nl_getsockname(descriptor): return _netlink.getsockname(descriptor.fileno()) def _nl_send(descriptor, msg): _netlink.send(descriptor.fileno(), msg) def _nl_recv(descriptor, bufs=16384): return _netlink.recvfrom(descriptor.fileno(), bufs) except ImportError: # or fall back to the ctypes module import ctypes libc = ctypes.CDLL(None) class SOCKADDR_NL(ctypes.Structure): _fields_ = [("nl_family", ctypes.c_ushort), ("nl_pad", ctypes.c_ushort), ("nl_pid", ctypes.c_int), ("nl_groups", ctypes.c_int)] def _nl_bind(descriptor, addr): addr = SOCKADDR_NL(socket.AF_NETLINK, 0, os.getpid(), 0) return libc.bind(descriptor.fileno(), ctypes.pointer(addr), ctypes.sizeof(addr)) def _nl_getsockname(descriptor): addr = SOCKADDR_NL(0, 0, 0, 0) len = ctypes.c_int(ctypes.sizeof(addr)); libc.getsockname(descriptor.fileno(), ctypes.pointer(addr), ctypes.pointer(len)) return addr.nl_pid, addr.nl_groups; def _nl_send(descriptor, msg): return libc.send(descriptor.fileno(), msg, len(msg), 0); def _nl_recv(descriptor, bufs=16384): addr = SOCKADDR_NL(0, 0, 0, 0) len = ctypes.c_int(ctypes.sizeof(addr)) buf = ctypes.create_string_buffer(bufs) r = libc.recvfrom(descriptor.fileno(), buf, bufs, 0, ctypes.pointer(addr), ctypes.pointer(len)) ret = ctypes.string_at(ctypes.pointer(buf), r) return ret, (addr.nl_pid, addr.nl_groups) # flags NLM_F_REQUEST = 1 NLM_F_MULTI = 2 NLM_F_ACK = 4 NLM_F_ECHO = 8 # types NLMSG_NOOP = 1 NLMSG_ERROR = 2 NLMSG_DONE = 3 NLMSG_OVERRUN = 4 NLMSG_MIN_TYPE = 0x10 class Attr: def __init__(self, attr_type, data, *values): self.type = attr_type if len(values): self.data = struct.pack(data, *values) else: self.data = data def _dump(self): hdr = struct.pack("HH", len(self.data)+4, self.type) length = len(self.data) pad = ((length + 4 - 1) & ~3 ) - length return hdr + self.data + b'\0' * pad def __repr__(self): return '<Attr type %d, data "%s">' % (self.type, repr(self.data)) def u16(self): return struct.unpack('H', self.data)[0] def s16(self): return struct.unpack('h', self.data)[0] def u32(self): return struct.unpack('I', self.data)[0] def s32(self): return struct.unpack('i', self.data)[0] def str(self): return self.data def nulstr(self): return self.data.split('\0')[0] def nested(self): return parse_attributes(self.data) class StrAttr(Attr): def __init__(self, attr_type, data): Attr.__init__(self, attr_type, "%ds" % len(data), data.encode('utf-8')) class NulStrAttr(Attr): def __init__(self, attr_type, data): Attr.__init__(self, attr_type, "%dsB" % len(data), data.encode('utf-8'), 0) class U32Attr(Attr): def __init__(self, attr_type, val): Attr.__init__(self, attr_type, "I", val) class U8Attr(Attr): def __init__(self, attr_type, val): Attr.__init__(self, attr_type, "B", val) class Nested(Attr): def __init__(self, attr_type, attrs): self.attrs = attrs self.type = attr_type def _dump(self): contents = [] for attr in self.attrs: contents.append(attr._dump()) contents = ''.join(contents) length = len(contents) hdr = struct.pack("HH", length+4, self.type) return hdr + contents NETLINK_ROUTE = 0 NETLINK_UNUSED = 1 NETLINK_USERSOCK = 2 NETLINK_FIREWALL = 3 NETLINK_INET_DIAG = 4 NETLINK_NFLOG = 5 NETLINK_XFRM = 6 NETLINK_SELINUX = 7 NETLINK_ISCSI = 8 NETLINK_AUDIT = 9 NETLINK_FIB_LOOKUP = 10 NETLINK_CONNECTOR = 11 NETLINK_NETFILTER = 12 NETLINK_IP6_FW = 13 NETLINK_DNRTMSG = 14 NETLINK_KOBJECT_UEVENT = 15 NETLINK_GENERIC = 16 class Message: def __init__(self, msg_type, flags=0, seq=-1, payload=None): self.type = msg_type self.flags = flags self.seq = seq self.pid = -1 payload = payload or [] if isinstance(payload, list): contents = [] for attr in payload: contents.append(attr._dump()) self.payload = b''.join(contents) else: self.payload = payload def send(self, conn): if self.seq == -1: self.seq = conn.seq() self.pid = conn.pid length = len(self.payload) hdr = struct.pack("IHHII", length + 4*4, self.type, self.flags, self.seq, self.pid) conn.send(hdr + self.payload) def __repr__(self): return '<netlink.Message type=%d, pid=%d, seq=%d, flags=0x%x "%s">' % ( self.type, self.pid, self.seq, self.flags, repr(self.payload)) class Connection: def __init__(self, nltype, groups=0, unexpected_msg_handler=None): self.descriptor = socket.socket(socket.AF_NETLINK, socket.SOCK_RAW, nltype) self.descriptor.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF, 65536) self.descriptor.setsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF, 65536) _nl_bind(self.descriptor, (0, groups)) self.pid, self.groups = _nl_getsockname(self.descriptor) self._seq = 0 self.unexpected = unexpected_msg_handler def send(self, msg): _nl_send(self.descriptor, msg) def recv(self): contents, (nlpid, nlgrps) = _nl_recv(self.descriptor) # XXX: python doesn't give us message flags, check # len(contents) vs. msglen for TRUNC msglen, msg_type, flags, seq, pid = struct.unpack("IHHII", contents[:16]) msg = Message(msg_type, flags, seq, contents[16:]) msg.pid = pid if msg.type == NLMSG_ERROR: errno = -struct.unpack("i", msg.payload[:4])[0] if errno != 0: err = OSError("Netlink error: %s (%d)" % ( os.strerror(errno), errno)) err.errno = errno raise err return msg def seq(self): self._seq += 1 return self._seq def parse_attributes(data): attrs = {} while len(data): attr_len, attr_type = struct.unpack("HH", data[:4]) attrs[attr_type] = Attr(attr_type, data[4:attr_len]) attr_len = ((attr_len + 4 - 1) & ~3 ) data = data[attr_len:] return attrs vmstat.py 0000644 00000003027 15025012261 0006430 0 ustar 00 # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU Library General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program; if not, write to the Free Software # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA # # See the COPYING file for license information. # # Copyright (c) 2007 Guillaume Chazarain <guichaz@gmail.com> class VmStat(object): def __init__(self): self.vmstat_file = open('/proc/vmstat') self.vmstat = self.read() def read(self): def extract(line): return int(line.split()[1]) * 1024 for line in self.vmstat_file: if line.startswith('pgpgin '): pgpgin = extract(line) break for line in self.vmstat_file: if line.startswith('pgpgout '): pgpgout = extract(line) break self.vmstat_file.seek(0) return pgpgin, pgpgout def delta(self): now = self.read() delta = now[0] - self.vmstat[0], now[1] - self.vmstat[1] self.vmstat = now return delta
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.03 |
proxy
|
phpinfo
|
Settings