EVOLUTION-NINJA
Edit File: _pslinux.cpython-36.pyc
3 q��iɨ � @ s� d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl m Z ddlmZmZmZ ddlmZmZmZmZmZ ddlZddlZdd d d d d dddddddddddgZe ed�Z e �rx$e e�D ]Z e j d�r�ej!e � q�W ej"d�Z#ej"d �Z$da%e j&� Z'dZ(d Z)d Z*d Z+e j,e j-e j.e j/e j0e j1e j2e j2e j3e j4d � Z5e j6e j7e j8e j9e j:e j;e j<e j=e j>e j?e j@d!� ZAdZBdZCdZDd"d#� ZEed$eE� �ZFed%d&d'd(d)d*d+d,d-d.g �ZGed/d0�ZHed1d2d3d4d5d6d7d8d9d:d;d<g �ZIed=d>d?jJeIjK� �ZLd@dA� ZMdBdC� ZNedDdE�dFd� �ZOedGdE�dHd� �ZPdIdJ� ZQdKdL� ZRdMdN� ZSdOdP� ZTdQdR� ZUdSdT� ZVdUdV� ZWdWdX� ZXG dYdZ� dZ�ZYeY� ZZdid\d]�Z[d^d_� Z\d`da� Z]djdcdd�Z^e j_Z_dedf� Z`G dgdh� dhea�ZbdS )kz Linux platform implementation.� )�divisionN)�_common)�_psposix)� isfile_strict� usage_percent� deprecated)�PY3� namedtuple�wraps�b� defaultdict�IOPRIO_CLASS_NONE�IOPRIO_CLASS_RT�IOPRIO_CLASS_BE�IOPRIO_CLASS_IDLE�CONN_ESTABLISHED� CONN_SYN_SENT� CONN_SYN_RECV�CONN_FIN_WAIT1�CONN_FIN_WAIT2�CONN_TIME_WAIT� CONN_CLOSE�CONN_CLOSE_WAIT� CONN_LAST_ACK� CONN_LISTEN� CONN_CLOSING�phymem_buffers� cached_phymem� linux_prlimitZRLIM� SC_CLK_TCK� SC_PAGE_SIZE� � � ) �R�S�D�T�t�Z�X�x�K�W) Z01Z02Z03Z04Z05Z06Z07Z08Z09Z0AZ0Bc C s� t dd�} z| j� j� dd� }W d| j� X ddddd d d g}t|�}|d krZ|jd � |dkrl|jd� |dkr~|jd� |S )z�Return a namedtuple of variable fields depending on the CPU times available on this Linux kernel version which may be: (user, nice, system, idle, iowait, irq, softirq, [steal, [guest, [guest_nice]]]) z /proc/stat�rbr! N�user�nice�system�idleZiowaitZirqZsoftirq� Zsteal� Zguest� Z guest_nice)�open�readline�split�close�len�append)�f�values�fieldsZvlen� r? �1/usr/lib/fm-agent/dependencies/psutil/_pslinux.py�_get_cputimes_fieldsc s rA � scputimes�svmem�totalZ available�percent�used�free�active�inactive�buffers�cached�pextmemz"rss vms shared text lib data dirty� pmmap_grouped�path�rss�sizeZpssZ shared_cleanZ shared_dirtyZ private_cleanZ private_dirtyZ referencedZ anonymous�swap� pmmap_extz addr perms � c C s6 t j� \} }}}}}d } }}tdd�}td�td�td� } } } z�x�|D ]|} | j| �rrt| j� d �d }n>| j| �r�t| j� d �d }n | j| �r�t| j� d �d }|d k rN|d k rN|d k rNP qNW d} tj| t � d } }}W d |j � X || | }| | }t | | | dd �}t | ||||||||� S ) Nz /proc/meminfor. zCached:zActive:z Inactive:r! i zW'cached', 'active' and 'inactive' memory stats couldn't be determined and were set to 0r )�_round) �cext� linux_sysinfor6 r � startswith�intr8 �warnings�warn�RuntimeWarningr9 r rC )rD rG rJ �shared�_rK rH rI r< ZCACHEDZACTIVEZINACTIVE�line�msgZavailrF rE r? r? r@ �virtual_memory� s2 r` c C s� t j� \} } } } }}|| }t||dd�}tdd�}td�td� }}d }} z�x�|D ]h} | j|�r�t| jtd��d �d d }n(| j|�r�t| jtd��d �d d } |d k rV| d k rVP qVW d } tj | t � d }} W d |j � X t j |||||| �S ) Nr! )rT z /proc/vmstatr. ZpswpinZpswpoutrS � i zK'sin' and 'sout' swap memory stats couldn't be determined and were set to 0r )rU rV r r6 r rW rX r8 rY rZ r[ r9 r �sswap) r] rD rG rF rE r< ZSINZSOUT�sin�soutr^ r_ r? r? r@ � swap_memory� s& re z psutil.virtual_memory().cached)� replacementc C s t � jS )N)r` rK r? r? r? r@ r � s z psutil.virtual_memory().buffersc C s t � jS )N)r` rJ r? r? r? r@ r � s c C sR t dd�} z| j� j� }W d| j� X |dttj�d � }dd� |D �}t|� S )z�Return a named tuple representing the following system-wide CPU times: (user, nice, system, idle, iowait, irq, softirq [steal, [guest, [guest_nice]]]) Last 3 fields may not be available on all Linux kernel versions. z /proc/statr. Nr! c S s g | ]}t |�t �qS r? )�float� CLOCK_TICKS)�.0r+ r? r? r@ � <listcomp>� s z cpu_times.<locals>.<listcomp>)r6 r7 r8 r9 r: rB �_fields)r< r= r> r? r? r@ � cpu_times� s rl c C s� g } t dd�}zj|j� td�}xT|D ]L}|j|�r&|j� }|dttj�d � }dd� |D �}t|� }| j|� q&W | S |j � X dS )zfReturn a list of namedtuple representing the CPU times for every CPU available on the system. z /proc/statr. �cpur! c S s g | ]}t |�t �qS r? )rg rh )ri r+ r? r? r@ rj � s z!per_cpu_times.<locals>.<listcomp>N) r6 r7 r rW r8 r: rB rk r; r9 )�cpusr< ZCPUr^ r= r> �entryr? r? r@ � per_cpu_times� s rp c C s� y t jd�S tk rp d} tdd�}z |j� }W d|j� X td�}x"|D ]}|j� j|�rN| d7 } qNW Y nX | dkr�tdd �}z |j� }W d|j� X t j d �}x,|D ]$}|j d �d }|j |�r�| d7 } q�W | dkr�dS | S ) z0Return the number of logical CPUs in the system.�SC_NPROCESSORS_ONLNr z /proc/cpuinfor. N� processorr! z /proc/stat�rtzcpu\drS ) �os�sysconf� ValueErrorr6 � readlinesr9 r �lowerrW �re�compiler8 �match)�numr< �linesZ PROCESSORr^ �searchr? r? r@ �cpu_count_logical s2 r c C sn t dd�} z | j� }W d| j� X t� }td�}x(|D ] }|j� j|�r6|j|j� � q6W |rft |�S dS dS )z1Return the number of physical CPUs in the system.z /proc/cpuinfor. Nz physical id) r6 rw r9 �setr rx rW �add�stripr: )r< r} �foundZ PHYSICAL_IDr^ r? r? r@ �cpu_count_physical& s r� c C s\ g } t j� }xJ|D ]B}|\}}}}}|s*q|dkr6d}tj||pBd||�}| j|� qW | S )z:Return currently connected users as a list of namedtuples.z:0.0� localhostN)rU �usersr �suserr; ) �retlistZrawlist�itemr/ Ztty�hostnameZtstampZ user_process�ntr? r? r@ r� : s r� c C sb t dd�} zHtd�}x2| D ]*}|j|�rt|j� j� d �}|a|S qW td��W d| j� X dS )zAReturn the system boot time expressed in seconds since the epoch.z /proc/statr. Zbtimer! zline 'btime' not foundN) r6 r rW rg r� r8 � BOOT_TIME� RuntimeErrorr9 )r< ZBTIMEr^ �retr? r? r@ � boot_timeL s r� c C s dd� t jtd��D �S )z7Returns a list of PIDs currently running on the system.c S s g | ]}|j � rt|��qS r? )�isdigitrX )ri r+ r? r? r@ rj ` s zpids.<locals>.<listcomp>z/proc)rt �listdirr r? r? r? r@ �pids^ s r� c C s t j| �S )z&Check For the existence of a unix pid.)r � pid_exists)�pidr? r? r@ r� c s r� c @ sN e Zd ZdZdd� Zdd� Zdd� Zdd � Zdd d �Zdd d�Z ddd�Z d S )� Connectionsaw A wrapper on top of /proc/net/* files, retrieving per-process and system-wide open connections (TCP, UDP, UNIX) similarly to "netstat -an". Note: in case of UNIX sockets we're only able to determine the local endpoint/path, not the one it's connected to. According to [1] it would be possible but not easily. [1] http://serverfault.com/a/417946 c C s� dt jt jf}dt jt jf}dt jt jf}dt jt jf}dt jd f}|||||f||f|f|f||f|f|f|f||||f||f||fd� | _d S )N�tcp�tcp6�udp�udp6�unix) �allr� �tcp4r� r� �udp4r� r� �inet�inet4�inet6)�socket�AF_INET� SOCK_STREAM�AF_INET6� SOCK_DGRAM�AF_UNIX�tmap)�selfr� r� r� r� r� r? r? r@ �__init__v s zConnections.__init__c C s� t t�}xxtjd| �D ]f}ytjd||f �}W n tk rH wY qX |jd�r|dd � d d� }|| j|t|�f� qW |S )Nz /proc/%s/fdz/proc/%s/fd/%szsocket:[r3 r! ���) r �listrt r� �readlink�OSErrorrW r; rX )r� r� �inodes�fd�inoder? r? r@ �get_proc_inodes� s zConnections.get_proc_inodesc C sj i }x`t � D ]V}y|j| j|�� W q tk r` tj� d }|jtjtjtj tj fkr\� Y q X q W |S )Nr! ) r� �updater� r� �sys�exc_info�errno�ENOENT�ESRCH�EPERM�EACCES)r� r� r� �errr? r? r@ �get_all_inodes� s zConnections.get_all_inodesc C s� |j d�\}}t|d�}|s f S tr.|jd�}|tjkrttjdkr`tj|t j |�ddd � �}q�tj|t j |��}nVt j |�}tjdkr�tjtj t j d t jd|��� �}n tjtj t j d t jd|��� �}||fS ) a� Accept an "ip:port" address as displayed in /proc/net/* and convert it into a human readable form, like: "0500000A:0016" -> ("10.0.0.5", 22) "0000000000000000FFFF00000100007F:9E49" -> ("::ffff:127.0.0.1", 40521) The IP address portion is a little or big endian four-byte hexadecimal number; that is, the least significant byte is listed first, so we need to reverse the order of the bytes to convert it to an IP address. The port is represented as a two-byte hexadecimal number. Reference: http://linuxdevcenter.com/pub/a/linux/2000/11/16/LinuxAdmin.html �:� �ascii�littleNr! �>4I�<4Ir� )r� )r� )r8 rX r �encoder� r� r� � byteorder� inet_ntop�base64� b16decoder� �struct�pack�unpack)r� �addr�family�ip�portr? r? r@ �decode_address� s& zConnections.decode_addressNc c s |j d�r tjj|� r dS t|d�}|j� x�|D ]�}|j� dd� \ }} } } }}}}}} | |kr�t|| �dkr�|tj kr�t d��|| d \} }nd \} }|dk r�|| kr�q4q4|tj kr�t | } nt j} | j| |�} | j| |�} |||| | | | fV q4W |j� dS ) z.Parse /proc/net/tcp* and /proc/net/udp* files.�6Nrs r5 r! z,ambiguos inode with multiple PIDs referencesr r� )Nr� )�endswithrt rN �existsr6 r7 r8 r: r� r� rv r� � TCP_STATUSESr � CONN_NONEr� r9 )r� �filer� �type_r� � filter_pidr< r^ r] �laddr�raddr�statusr� r� r� r? r? r@ � process_inet� s( $ zConnections.process_inetc c s� t |d�}|j� x�|D ]�}|j� }|dd� \}}}}} }} | |krP|| } nd g} xd| D ]\\} } |dk rx|| krxq\q\t|�dkr�|d }nd}t| �} d}tj}| || |||| fV q\W qW |j� dS ) zParse /proc/net/unix files.rs r � Nr! r3 � r� )Nr� r� )r6 r7 r8 r: rX r r� r9 )r� r� r� r� r� r< r^ �tokensr] r� r� �pairsr� r� rN r� r� r? r? r@ � process_unix� s& zConnections.process_unixc C s || j kr,td|djdd� | j D ��f ��|d k rH| j|�}|sPg S n| j� }g }x�| j | D ]�\}}}|tjtjfkr�| jd| ||||d�}n| j d| |||d�}xT|D ]L\} }}} } } } |r�t j | ||| | | �}nt j | ||| | | | �}|j |� q�W q`W |S )Nz+invalid %r kind argument; choose between %sz, c S s g | ] }t |��qS r? )�repr)ri r+ r? r? r@ rj s z(Connections.retrieve.<locals>.<listcomp>z /proc/net/%s)r� )r� rv �joinr� r� r� r� r� r� r� r �pconn�sconnr; )r� �kindr� r� r� r< r� r� �lsr� r� r� r� Z bound_pid�connr? r? r@ �retrieve s. zConnections.retrieve)N)N)N) �__name__� __module__� __qualname__�__doc__r� r� r� r� r� r� r� r? r? r? r@ r� j s / r� r� c C s t j| �S )z$Return system-wide open connections.)� _connectionsr� )r� r? r? r@ �net_connections7 s r� c C s� t dd�} z | j� }W d| j� X i }x�|dd� D ]�}|jd�}|dksVtt|���|d|� j� }||d d� j� j� }t|d �}t|d �}t|d �} t|d �} t|d �} t|d �} t|d �} t|d �}| || || | | |f||< q4W |S ) zsReturn network I/O statistics for every network interface installed on the system as a dict of raw tuples. z /proc/net/devrs Nr" r� r r! r# r3 r4 r5 � ) r6 rw r9 �rfind�AssertionErrorr� r� r8 rX )r< r} �retdictr^ Zcolon�namer> � bytes_recv� packets_recv�errin�dropin� bytes_sent� packets_sent�errout�dropoutr? r? r@ �net_io_counters< s* r� c C sj d} g }t dd�}z|j� dd� }W d|j� X xXt|�D ]L}|j� \}}}}|d j� rh|j|� q<| s~|d j|� r<|j|� q<W i }t dd�}z |j� }W d|j� X x�|D ]�}|j� }t|�dkr�|dd � \ }}}} }} } } }} }n|\}}}} } } } d \} }||kr�t | �| } t | �| } t | �} t | �} t | �} t |�}| | | | | |f||< q�W |S )zcReturn disk I/O statistics for every disk installed on the system as a dict of raw tuples. i z/proc/partitionsrs r" Nr! z/proc/diskstatsr� r� r r� r� )r r ) r6 rw r9 �reversedr8 r� r; rW r: rX )Z SECTOR_SIZE� partitionsr< r} r^ r] r� r� r> Zreads�rbytesZrtimeZwrites�wbytesZwtimer? r? r@ �disk_io_counters[ s@ $ r Fc C s� g }t dd�}z*x$|D ] }|jd�s|j|j� � qW W d|j� X g }tj� }xT|D ]L}|\}}} } |dkrrd}| s�|dksV| |kr�qVtj||| | �} |j| � qVW |S )z6Return mounted disk partitions as a list of nameduplesz/proc/filesystems�rZnodevNZnoner� ) r6 rW r; r� r9 rU �disk_partitionsr � sdiskpart) r� Zphydevsr< r^ r� r� � partition�device� mountpoint�fstype�opts�ntupler? r? r@ r � s& r c s t � �� fdd��}|S )zlDecorator which translates bare OSError and IOError exceptions into NoSuchProcess and AccessDenied. c s� y� | f|�|�S t k r� td ks0td kr2� tj� d }|jtjtjfkr^t| j| j ��|jtj tj fkr~t| j| j ��� Y nX d S )Nr! ) �EnvironmentError� NoSuchProcess� AccessDeniedr� r� r� r� r� r� �_namer� r� )r� �args�kwargsr� )�funr? r@ �wrapper� s z wrap_exceptions.<locals>.wrapper)r )r r r? )r r@ �wrap_exceptions� s r c @ s� e Zd ZdZddgZdd� Zedd� �Zdd � Zed d � �Z ed d � �Z e j j de j� �rjedd� �Zndd� Zedd� �ZedGdd��Zedd� �Zedd� �Zedd � �Ze j j d e j� �r�d d � Znd d � Zed!d"� �Zed#d$� �Zed%d&� �Zed'd(� �Zed)d*� �Zed+d,� �Zed-d.� �Z ed/d0� �Z e e d1��rZed2d3� �Z ed4d5� �Z!e"�rnedHd6d7��Z#ed8d9� �Z$ed:d;� �Z%edId=d>��Z&ed?d@� �Z'edAdB� �Z(edCdD� �Z)edEdF� �Z*dS )J�Processz Linux process implementation.r� r c C s || _ d | _d S )N)r� r )r� r� r? r? r@ r� � s zProcess.__init__c C s^ d| j }tr t|dtd�}n t|d�}z&|j� jd�d jdd�jdd�}W d |j� X |S ) Nz /proc/%s/statrs )�encodingrS r! �(r� �))r� r r6 �DEFAULT_ENCODING�readr8 �replacer9 )r� �fnamer< r� r? r? r@ r� � s & z Process.namec C s� yt jd| j �}W n| ttfk r� tj� d }|jtjtj fkrjt j j d| j �r\dS t | j| j ��|jtjtjfkr�t| j| j ��� Y nX |jd�d }|jd�r�t j j|� r�|d d � }|S ) Nz /proc/%s/exer! z/proc/%sr� � r z (deleted)r5 i����)rt r� r� r� �IOErrorr� r� r� r� r� rN �lexistsr r r� r� r r8 r� r� )r� �exer� r? r? r@ r � s z Process.exec C sP d| j }tr t|dtd�}n t|d�}zdd� |j� jd�D �S |j� X d S )Nz/proc/%s/cmdliners )r c S s g | ] }|r|�qS r? r? )ri r+ r? r? r@ rj s z#Process.cmdline.<locals>.<listcomp>r )r� r r6 r r r8 r9 )r� r r< r? r? r@ �cmdline� s zProcess.cmdlinec C sd t j� }td| j d�}z t|j� jtd��d �}W d |j� X y|| S t k r^ d S X d S )Nz /proc/%s/statr. rS � ) r Z_get_terminal_mapr6 r� rX r r8 r r9 �KeyError)r� r� r< Ztty_nrr? r? r@ �terminal s zProcess.terminalz /proc/%s/ioc C s. d| j }t|d�}td�td� }}td�td� }}z�d } } } } x�|D ]�} |d krx| j|�rxt| j� d �}qP|d kr�| j|�r�t| j� d �}qP| d kr�| j|�r�t| j� d �} qP| d krP| j|�rPt| j� d �} qPW x(||| | fD ]} | d kr�td| ��q�W tj||| | �S |j � X d S ) Nz /proc/%s/ior. ZsyscrZsyscw� read_bytes� write_bytesr! z(couldn't read all necessary info from %r) r� r6 r rW rX r8 �NotImplementedErrorr �pior9 ) r� r r< ZSYSCRZSYSCWZ READ_BYTESZ WRITE_BYTESZrcountZwcountr� r� r^ r+ r? r? r@ � io_counters s* zProcess.io_countersc C s t d| j ��d S )Nz+couldn't find /proc/%s/io (kernel too old?))r% r� )r� r? r? r@ r' 1 s c C s� t d| j d�}z|j� j� }W d |j� X ||jtd��d d � }|jtd��}t|d �t }t|d �t }t j ||�S )Nz /proc/%s/statr. r r" rS r� � ) r6 r� r r� r9 �findr r8 rg rh r � pcputimes)r� r< �str= �utime�stimer? r? r@ rl 5 s zProcess.cpu_timesNc C sD yt j| j|�S t jk r> td kr*� t|| j| j��Y nX d S )N)r Zwait_pidr� �TimeoutExpiredr )r� �timeoutr? r? r@ �waitC s z Process.waitc C sr t d| j d�}z|j� j� }W d |j� X ||jtd��d d � }|jtd��}tp\t � }t |d �t | S )Nz /proc/%s/statr. r r" rS � ) r6 r� r r� r9 r� r r8 r� r� rg rh )r� r< r+ r= Zbtr? r? r@ � create_timeM s zProcess.create_timec C sT t d| j d�}z4|j� j� d d� \}}tjt|�t t|�t �S |j� X d S )Nz/proc/%s/statmr. r" ) r6 r� r7 r8 r �pmemrX �PAGESIZEr9 )r� r< �vmsrO r? r? r@ � memory_info_ s zProcess.memory_infoc C s` t d| j d�}z0dd� |j� j� d d� D �\}}}}}}}W d |j� X t|||||||�S )Nz/proc/%s/statmr. c S s g | ]}t |�t �qS r? )rX r4 )ri r+ r? r? r@ rj y s z*Process.memory_info_ex.<locals>.<listcomp>r� )r6 r� r7 r8 r9 rL ) r� r< r5 rO r\ �text�lib�dataZdirtyr? r? r@ �memory_info_exi s 0 zProcess.memory_info_exz/proc/%s/smapsc # s� d��y t d| j d���j� }|g� � �fdd�}|�rx�|� D ]�\}}|jdd�}y|\}}}} } } W n* tk r� |dg \}}}} } } Y nX | s�d} n| j� } ||| |d |jd d �|jd d �|jd d �|jdd �|jdd �|jdd �|jdd �|jdd �|jdd �f V qBW �j� W n� tk �r� �dk �rF�j� t j � d } | j t j t j fk�rtt| j| j��| j t jt jfk�r�t| j| j��� Y n �dk �r��j� � Y nX �j� dS )z�Return process's mapped memory regions as a list of nameduples. Fields are explained in 'man proc'; here is an updated (Apr 2012) version: http://goo.gl/fmebo Nz/proc/%s/smapsrs c 3 s� i } x��D ]�}|j d d�}|d jd�sB� j� | fV � j|� q y t|d �d | |d < W q tk r� |d jd�r�w n td| ��Y q X q W � j� | fV d S )N� r r� r! i zVmFlags:z#don't know how to interpret line %r)r8 r� �popr; rX rv rW )r9 r^ r> )� current_blockr< r? r@ � get_blocks� s z'Process.memory_maps.<locals>.get_blocksr; r� z[anon]zRss:zSize:r zPss:z Shared_Clean:z Shared_Dirty:zPrivate_Clean:zPrivate_Dirty:z Referenced:z Anonymous:zSwap:r! )r6 r� r7 r8 rv r� �getr9 r r� r� r� r� r� r r r� r� r ) r� � first_liner> �headerr9 Zhfieldsr� �perms�offset�devr� rN r� r? )r= r< r@ � memory_maps sT zProcess.memory_mapsc C s d| j }t|��d S )Nzfcouldn't find /proc/%s/smaps; kernel < 2.6.14 or CONFIG_MMU kernel configuration option is not enabled)r� r% )r� r_ r? r? r@ rE � s c C s t jd| j �}|jdd�S )Nz /proc/%s/cwdr r� )rt r� r� r )r� rN r? r? r@ �cwd� s z Process.cwdc C s� d }}t d| j d�}td�}td�}zrx^|D ]V}|j|�rPt|j� d �}n|j|�rjt|j� d �}|d k r0|d k r0tj||�S q0W td| j ��W d |j � X d S )Nz/proc/%s/statusr. Zvoluntary_ctxt_switchesZnonvoluntary_ctxt_switchesr! z�'voluntary_ctxt_switches' and 'nonvoluntary_ctxt_switches'fields were not found in /proc/%s/status; the kernel is probably older than 2.6.23) r6 r� r rW rX r8 r �pctxswr% r9 )r� ZvolZunvolr< Z VOLUNTARYZ NON_VOLUNTARYr^ r? r? r@ �num_ctx_switches� s zProcess.num_ctx_switchesc C s\ t d| j d�}z<td�}x&|D ] }|j|�r t|j� d �S q W td��W d |j� X d S )Nz/proc/%s/statusr. zThreads:r! zline not found)r6 r� r rW rX r8 r% r9 )r� r< ZTHREADSr^ r? r? r@ � num_threads� s zProcess.num_threadsc C s t jd| j �}|j� g }d}x�|D ]�}ytd| j|f d�}W n4 tk rv tj� d }|jtj krpd}w&� Y nX z|j � j � }W d |j � X ||j td��d d � }|jtd ��}t|d �t } t|d �t } tjt|�| | �} |j| � q&W |�rt jd | j � |S ) Nz /proc/%s/taskFz/proc/%s/task/%s/statr. r! Tr r" rS r� r( z/proc/%s)rt r� r� �sortr6 r r� r� r� r� r r� r9 r) r r8 rg rh r �pthreadrX r; �stat) r� Z thread_idsr� � hit_enoentZ thread_idr< r� r+ r= r, r- r r? r? r@ �threads� s2 zProcess.threadsc C s t j| j�S )N)� _psutil_posix� getpriorityr� )r� r? r? r@ �nice_get s zProcess.nice_getc C s t j| j|�S )N)rO � setpriorityr� )r� �valuer? r? r@ �nice_set% s zProcess.nice_setc C s t j| j�S )N)rU Zproc_cpu_affinity_getr� )r� r? r? r@ �cpu_affinity_get) s zProcess.cpu_affinity_getc C s~ yt j| j|� W nf tk rx tj� d }|jtjkrrtt t t � ���}x$|D ] }||krRt d||f ��qRW � Y nX d S )Nr! z#invalid CPU #%i (choose between %s)) rU Zproc_cpu_affinity_setr� r� r� r� r� �EINVAL�tuple�ranger: rp rv )r� rn r� Zallcpusrm r? r? r@ �cpu_affinity_set- s zProcess.cpu_affinity_set�proc_ioprio_getc C s t j| j�\}}tj||�S )N)rU rZ r� r �pionice)r� �ioclassrS r? r? r@ � ionice_get> s zProcess.ionice_getc C s� |t d fkr$|r d}t|��t }d}|ttfkr>|d kr`d}n"|tkr\|rVd}t|��d}nd}d| kordkn s�td��tj| j||�S )Nz*can't specify value with IOPRIO_CLASS_NONEr ra z*can't specify value with IOPRIO_CLASS_IDLEr3 z0value argument range expected is between 0 and 8)r rv r r r rU Zproc_ioprio_setr� )r� r\ rS r_ r? r? r@ � ionice_setC s& zProcess.ionice_setc C sZ | j dkrtd��|d kr(tj| j |�S t|�dkr<td��|\}}tj| j |||� d S )Nr z)can't use prlimit() against PID 0 processr" z,second argument must be a (soft, hard) tuple)r� rv rU r r: )r� �resource�limitsZsoftZhardr? r? r@ �rlimit[ s zProcess.rlimitc C sh t d| j d�}zHtd�}x:|D ]2}|j|�r |j� d }trF|j� }tj|d�S q W W d |j � X d S )Nz/proc/%s/statusr. zState:r! �?) r6 r� r rW r8 r �decode� PROC_STATUSESr? r9 )r� r< ZSTATEr^ Zletterr? r? r@ r� l s zProcess.statusc C s� g }t jd| j �}d}x�|D ]�}d| j|f }t jj|�r yt j|�}W n: tk r� tj� d }|j t j t j fkr~d}w � Y q X |j d�r t |�r tj|t|��}|j|� q W |r�t jd| j � |S )Nz /proc/%s/fdFz/proc/%s/fd/%sr! T�/z/proc/%s)rt r� r� rN �islinkr� r� r� r� r� r� r� rW r r � popenfilerX r; rL )r� r� �filesrM r� r� r� r r? r? r@ � open_files| s( zProcess.open_filesr� c C s" t j|| j�}tjd| j � |S )Nz/proc/%s)r� r� r� rt rL )r� r� r� r? r? r@ � connections� s zProcess.connectionsc C s t tjd| j ��S )Nz /proc/%s/fd)r: rt r� r� )r� r? r? r@ �num_fds� s zProcess.num_fdsc C s\ t d| j d�}z<td�}x&|D ] }|j|�r t|j� d �S q W td��W d |j� X d S )Nz/proc/%s/statusr. zPPid:r! zline not found)r6 r� r rW rX r8 r% r9 )r� r< ZPPIDr^ r? r? r@ �ppid� s z Process.ppidc C sx t d| j d�}zXtd�}xB|D ]:}|j|�r |j� \}}}}}tjt|�t|�t|��S q W td��W d |j � X d S )Nz/proc/%s/statusr. zUid:zline not found) r6 r� r rW r8 r �puidsrX r% r9 ) r� r< ZUIDr^ r] �real� effective�saved�fsr? r? r@ �uids� s z Process.uidsc C sx t d| j d�}zXtd�}xB|D ]:}|j|�r |j� \}}}}}tjt|�t|�t|��S q W td��W d |j � X d S )Nz/proc/%s/statusr. zGid:zline not found) r6 r� r rW r8 r �pgidsrX r% r9 ) r� r< ZGIDr^ r] rn ro rp rq r? r? r@ �gids� s z Process.gids)N)N)r� )+r� r� r� r� � __slots__r� r r� r r r" rt rN r� �getpidr' rl r0 r2 r6 r: rE rF rH rI rN rQ rT rU rY �hasattrrU r] r^ � HAS_PRLIMITra r� ri rj rk rl rr rt r? r? r? r@ r � sR J ! r )r� )F)cr� � __future__r r� r� rt ry r� r� r� rY �psutilr r �psutil._commonr r r �psutil._compatr r r r r � _psutil_linuxrU rO �__extra__all__rw rx �dirr� rW r; ru rh r4 r� �getdefaultencodingr r r r r �STATUS_RUNNING�STATUS_SLEEPING�STATUS_DISK_SLEEP�STATUS_STOPPED�STATUS_TRACING_STOP� STATUS_ZOMBIE� STATUS_DEAD�STATUS_WAKE_KILL� STATUS_WAKINGrd r r r r r r r r r r r r� r r r. rA rB rC rL rM r� rk rR r` re r r rl rp r r� r� r� r� r� r� r� r� r� r r � disk_usager �objectr r? r? r? r@ �<module> s� ! & K 9