← Back
Editing: _psaix.cpython-36.pyc
3 ��JZ�K � @ s� d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z ddl m Z ddl mZ dd l mZ dd l mZ dd l mZ dd l mZ dd l mZ ddl mZ ddl mZ ddl mZ ddl mZ ddlmZ ddl m Z ddl m Z ddl m Z dgZ e!ed�Z"ej#d�Z$ej%Z%ej&e j'ej(e j)ej*e j+ej,e j+ej-e j.iZ/ej0e j1ej2e j3ej4e j5ej6e j7ej8e j9ej:e j;ej<e j=ej>e j?ej@e jAejBe jCejDe jEejFe jGi ZHeIdddddd d d d �ZJed d!d"g�ZKeKZLed#d$d%d&d'g�ZMed(d)d*d+d,d-g�ZNed.d/d!d0d1g�ZOed2d3d4jPeOjQ� �ZRd5d6� ZSd7d8� ZTd9d:� ZUd;d<� ZVd=d>� ZWd?d@� ZXdAdB� ZYdCdD� ZZej[Z[e j\Z\dXdFdG�Z]ej^Z^ej_Z_dZdHdI�Z`dJdK� ZadLdM� ZbdNdO� ZcdPdQ� ZddRdS� ZedTdU� ZfG dVdW� dWeg�ZhdS )[z AIX platform implementation.� N)� namedtuple)�AF_INET� )�_common)�_psposix)� _psutil_aix)� _psutil_posix)�AF_INET6)�memoize_when_activated)�NIC_DUPLEX_FULL)�NIC_DUPLEX_HALF)�NIC_DUPLEX_UNKNOWN)�sockfam_to_enum)�socktype_to_enum)� usage_percent)�PY3)� AccessDenied)� NoSuchProcess)� ZombieProcess� PROCFS_PATH� proc_threads� SC_PAGE_SIZE� � � � � � )�ppid�rss�vms� create_time�nice� num_threads�status�ttynr�pmemr r � scputimes�user�systemZidleZiowait�svmem�totalZ available�percent�used�free� pmmap_grouped�pathZanon�locked� pmmap_extz addr perms � c C s t jd jS )z+Return updated psutil.PROCFS_PATH constant.Zpsutil)�sys�modulesr � r6 r6 � /usr/lib64/python3.6/_psaix.py�get_procfs_pathl s r8 c C s4 t j� \} }}}}t| | | dd�}t| ||||�S )Nr )�_round)�cextZ virtual_memr r* )r+ Zavailr. ZpinnedZinuser, r6 r6 r7 �virtual_memoryv s r; c C s: t j� \} }}}| | }t|| dd�}tj| |||||�S )z=Swap system memory as a (total, used, free, sin, sout) tuple.r )r9 )r: Zswap_memr r Zsswap)r+ r. ZsinZsoutr- r, r6 r6 r7 � swap_memory| s r< c C s t j� } tdd� t| � D �� S )z-Return system-wide CPU times as a named tuplec S s g | ] }t |��qS r6 )�sum)�.0�xr6 r6 r7 � <listcomp>� s z cpu_times.<locals>.<listcomp>)r: � per_cpu_timesr' �zip)�retr6 r6 r7 � cpu_times� s rD c C s t j� } dd� | D �S )z5Return system per-CPU times as a list of named tuplesc S s g | ] }t |� �qS r6 )r' )r> r? r6 r6 r7 r@ � s z!per_cpu_times.<locals>.<listcomp>)r: rA )rC r6 r6 r7 rA � s rA c C s$ y t jd�S tk r dS X dS )z0Return the number of logical CPUs in the system.�SC_NPROCESSORS_ONLNN)�os�sysconf� ValueErrorr6 r6 r6 r7 �cpu_count_logical� s rI c C sr d} t j| dt jt jd�}|j� \}}tr@dd� ||fD �\}}|jdkrZtd| |f ��|j� j� }t |�ppd S )Nzlsdev -Cc processorT)�shell�stdout�stderrc S s g | ]}|j tjj��qS r6 )�decoder4 rK �encoding)r> r? r6 r6 r7 r@ � s z&cpu_count_physical.<locals>.<listcomp>r z%r command error %s) � subprocess�Popen�PIPE� communicater � returncode� RuntimeError�strip� splitlines�len)�cmd�prK rL Z processorsr6 r6 r7 �cpu_count_physical� s rZ c C s t j� \} }}}tj| |||�S )z*Return various CPU stats as a named tuple.)r: � cpu_statsr Z scpustats)Z ctx_switchesZ interruptsZsoft_interruptsZsyscallsr6 r6 r7 r[ � s r[ Fc C s` g }t j� }xN|D ]F}|\}}}}|dkr.d}| s>t|�js>qtj||||�}|j|� qW |S )z Return system disk partitions.Znone� )r: �disk_partitions� disk_usager+ r Z sdiskpart�append) �all�retlistZ partitions� partitionZdeviceZ mountpointZfstypeZopts�ntupler6 r6 r7 r] � s r] c C s t j}| |kr.td| djdd� |D ��f ��t j| \}}tj|�}t� }x�|D ]�}|\}} } } } } }| |krrqR| |kr|qRt| } | tt fkr�| r�t j | � } | r�t j | � } t | �} t | �} |dkr�t j || | | | | |�}nt j|| | | | | �}|j|� qRW t|�S )z�Return socket connections. If pid == -1 return system-wide connections (as opposed to connections opened by one process only). z+invalid %r kind argument; choose between %sz, c S s g | ] }t |��qS r6 )�repr)r> r? r6 r6 r7 r@ � s z#net_connections.<locals>.<listcomp>r ���)r Z conn_tmaprH �joinr: �net_connections�set� TCP_STATUSESr r Zaddrr r ZsconnZpconn�add�list)�kind�_pidZcmapZfamilies�types�rawlistrC �item�fdZfamZtype_ZladdrZraddrr$ �pid�ntr6 r6 r7 rg � s4 rg c C s� t td�} tdd� t� D ��}i }x�|D ]�}tj|�\}}d}d}tjdd|gtjtjd�}|j � \} } t r�d d� | | fD �\} } |j dkr�t j d | �} | d k r�t| jd ��}| jd �}| j|t�}tj||||�||< q(W |S )z)Get NIC stats (isup, duplex, speed, mtu).)ZFullZHalfc S s g | ] }|d �qS )r r6 )r> r? r6 r6 r7 r@ � s z net_if_stats.<locals>.<listcomp>r\ r z/usr/bin/entstatz-d)rK rL c S s g | ]}|j tjj��qS r6 )rM r4 rK rN )r> r? r6 r6 r7 r@ s z"Running: (\d+) Mbps.*?(\w+) DuplexNr r )r r rh � net_if_addrsr: � net_if_statsrO rP rQ rR r rS �re�search�int�group�getr r Z snicstats) Z duplex_map�namesrC �nameZisupZmtuZduplexZspeedrY rK rL Z re_resultr6 r6 r7 ru � s, ru c C s t j� S )z:The system boot time expressed in seconds since the epoch.)r: � boot_timer6 r6 r6 r7 r} s r} c C s` g } t j� }d}xJ|D ]B}|\}}}}}} |s0q||kr<d}tj||||| �} | j| � qW | S )z:Return currently connected users as a list of namedtuples.�:0.0�:0� localhost)r~ r )r: �usersr Zsuserr_ ) ra ro r� rp r( ZttyZhostnameZtstampZ user_processrr rs r6 r6 r7 r� $ s r� c C s dd� t jt� �D �S )z7Returns a list of PIDs currently running on the system.c S s g | ]}|j � rt|��qS r6 )�isdigitrx )r> r? r6 r6 r7 r@ > s zpids.<locals>.<listcomp>)rF �listdirr8 r6 r6 r6 r7 �pids< s r� c C s t jjt jjt� t| �d��S )z&Check for the existence of a unix pid.Zpsinfo)rF r0 �existsrf r8 �str)rr r6 r6 r7 � pid_existsA s r� c s � fdd�}|S )z�Call callable into a try/except clause and translate ENOENT, EACCES and EPERM in NoSuchProcess or AccessDenied exceptions. c s� y� | f|�|�S t k r� } z�td ks:td ks:td kr<� |jtjtjfkrzt| j�sht| j| j ��nt| j| j | j ��|jtj tj fkr�t| j| j ��� W Y d d }~X nX d S )N) �EnvironmentErrorr r r �errno�ENOENTZESRCHr� rr �_name�_ppidZEPERMZEACCES)�self�args�kwargs�err)�funr6 r7 �wrapperK s z wrap_exceptions.<locals>.wrapperr6 )r� r� r6 )r� r7 �wrap_exceptionsF s r� c @ sh e Zd ZdZddddgZdd� Zdd � Zd d � Zed d � �Z edd� �Z edd� �Z e dd� �Z e dd� �Ze dd� �Ze dd� �Ze dd� �Zer�e d d � �Ze d@d d ��Ze d!d"� �Ze d#d$� �Ze d%d&� �Ze d'd(� �Ze d)d*� �Ze d+d,� �Ze d-d.� �Ze d/d0� �Z e d1d2� �Z e Z e d3d4� �Z d5d6� Z e d7d8� �Z!e d9d:� �Z"e dAd<d=��Z#e d>d?� �Z$d;S )B�Processz1Wrapper class around underlying C implementation.rr r� r� � _procfs_pathc C s || _ d | _d | _t� | _d S )N)rr r� r� r8 r� )r� rr r6 r6 r7 �__init__f s zProcess.__init__c C s" | j j� | jj� | jj� d S )N)�_proc_name_and_argsZcache_activate�_proc_basic_info� _proc_cred)r� r6 r6 r7 � oneshot_enterl s zProcess.oneshot_enterc C s" | j j� | jj� | jj� d S )N)r� Zcache_deactivater� r� )r� r6 r6 r7 � oneshot_exitq s zProcess.oneshot_exitc C s t j| j| j�S )N)r: Zproc_name_and_argsrr r� )r� r6 r6 r7 r� v s zProcess._proc_name_and_argsc C s t j| j| j�S )N)r: Zproc_basic_inforr r� )r� r6 r6 r7 r� z s zProcess._proc_basic_infoc C s t j| j| j�S )N)r: Z proc_credrr r� )r� r6 r6 r7 r� ~ s zProcess._proc_credc C s | j dkrdS | j� d jd�S )Nr Zswapper� )rr r� �rstrip)r� r6 r6 r7 r| � s z Process.namec C s� | j � d }tjj|krttjj|�s>tjjtjj| j� |��}tjj|�rhtjj|�rhtj |tj �rh|S tjj |�}xLtj d j d�D ]8}tjjtjj||��}tjj|�r�tj |tj �r�|S q�W dS )Nr �PATH�:r\ )�cmdlinerF r0 �sep�isabs�abspathrf �cwd�isfile�access�X_OK�basename�environ�split)r� �exer0 Z possible_exer6 r6 r7 r� � s z Process.exec C s | j � d jd�S )Nr r3 )r� r� )r� r6 r6 r7 r� � s zProcess.cmdlinec C s | j � td S )Nr! )r� � proc_info_map)r� r6 r6 r7 r! � s zProcess.create_timec C s | j � td S )Nr# )r� r� )r� r6 r6 r7 r# � s zProcess.num_threadsc C sZ t j| j�}g }x*|D ]"\}}}tj|||�}|j|� qW |sVtjd| j| jf � |S )Nz%s/%s) r: r rr r Zpthreadr_ rF �statr� )r� ro ra Z thread_id�utimeZstimerc r6 r6 r7 �threads� s zProcess.threads�inetc C s, t || jd�}|s(tjd| j| jf � |S )N)rm z%s/%s)rg rr rF r� r� )r� rl rC r6 r6 r7 � connections� s zProcess.connectionsc C s t j| j�S )N)� cext_posix� getpriorityrr )r� r6 r6 r7 �nice_get� s zProcess.nice_getc C s t j| j|�S )N)r� � setpriorityrr )r� �valuer6 r6 r7 �nice_set� s zProcess.nice_setc C s | j � td | _| jS )Nr )r� r� r� )r� r6 r6 r7 r � s z Process.ppidc C s" | j � \}}}}}}tj|||�S )N)r� r �puids)r� �real� effective�saved�_r6 r6 r7 �uids� s z Process.uidsc C s" | j � \}}}}}}tj|||�S )N)r� r r� )r� r� r� r� r� r6 r6 r7 �gids� s z Process.gidsc C s t j| j| j�}tj|� S )N)r: Zproc_cpu_timesrr r� r Z pcputimes)r� rD r6 r6 r7 rD � s zProcess.cpu_timesc C sP | j � td }|d@ d? |d@ B }x&tjd�D ]}tj|�j|kr0|S q0W d S )Nr% l � � i�� z /dev/**/*)r� r� �globrF r� �st_rdev)r� ZttydevZdevr6 r6 r7 �terminal� s zProcess.terminalc C sr | j }y tjd|| jf �}|jd�S tk rl } z,|jtjkrZtjd|| jf � d S � W Y d d }~X nX d S )Nz %s/%s/cwd�/z%s/%s) r� rF �readlinkrr r� �OSErrorr� r� r� )r� Z procfs_path�resultr� r6 r6 r7 r� � s z Process.cwdc C s2 | j � }|td d }|td d }t||�S )Nr i r )r� r� r& )r� rC r r r6 r6 r7 � memory_info� s zProcess.memory_infoc C s | j � td }tj|d�S )Nr$ �?)r� r� � PROC_STATUSESrz )r� �coder6 r6 r7 r$ s zProcess.statusc C s� t jddt| j�gt jt jd�}|j� \}}trFdd� ||fD �\}}d|j� kr`t| j| j ��t j d|�}g }xR|D ]J\}}|j � }|j d�r�|d d � }|j� d kr�qv|jtj|t|��� qvW |S ) Nz/usr/bin/procfilesz-n)rK rL c S s g | ]}|j tjj��qS r6 )rM r4 rK rN )r> r? r6 r6 r7 r@ s z&Process.open_files.<locals>.<listcomp>zno such processz (\d+): S_IFREG.*\s*.*name:(.*) z//r zcannot be retrieved)rO rP r� rr rQ rR r �lowerr r� rv �findallrU � startswithr_ r Z popenfilerx )r� rY rK rL Z procfilesra rq r0 r6 r6 r7 � open_files s$ zProcess.open_filesc C s( | j dkrdS ttjd| j| j f ��S )Nr z%s/%s/fd)rr rW rF r� r� )r� r6 r6 r7 �num_fds$ s zProcess.num_fdsc C s t jtj| j�� S )N)r Zpctxswr: Zproc_num_ctx_switchesrr )r� r6 r6 r7 �num_ctx_switches* s zProcess.num_ctx_switchesNc C s t j| j|| j�S )N)r Zwait_pidrr r� )r� Ztimeoutr6 r6 r7 �wait/ s z Process.waitc C sX yt j| j�\}}}}W n. tk rF t| j�s@t| j| j��� Y nX tj||||�S )N) r: Zproc_io_countersrr r� r� r r� r Zpio)r� ZrcZwc�rb�wbr6 r6 r7 � io_counters3 s zProcess.io_counters)r� )N)%�__name__� __module__� __qualname__�__doc__� __slots__r� r� r� r r� r� r� r� r| r� r� r! r# � HAS_THREADSr� r� r� r� r r� r� rD r� r� r� Zmemory_full_infor$ r� r� r� r� r� r6 r6 r6 r7 r� a sD r� )Fre )re )ir� r� r� rF rv rO r4 � collectionsr Zsocketr r\ r r r r: r r� r r r r r r r r Z_compatr � _exceptionsr r r Z__extra__all__�hasattrr� rG Z PAGE_SIZEZAF_LINKZSIDLZ STATUS_IDLEZSZOMBZ STATUS_ZOMBIEZSACTIVEZSTATUS_RUNNINGZSSWAPZSSTOPZSTATUS_STOPPEDr� ZTCPS_ESTABLISHEDZCONN_ESTABLISHEDZ TCPS_SYN_SENTZ CONN_SYN_SENTZ TCPS_SYN_RCVDZ CONN_SYN_RECVZTCPS_FIN_WAIT_1ZCONN_FIN_WAIT1ZTCPS_FIN_WAIT_2ZCONN_FIN_WAIT2ZTCPS_TIME_WAITZCONN_TIME_WAITZ TCPS_CLOSEDZ CONN_CLOSEZTCPS_CLOSE_WAITZCONN_CLOSE_WAITZ TCPS_LAST_ACKZ CONN_LAST_ACKZ TCPS_LISTENZ CONN_LISTENZ TCPS_CLOSINGZ CONN_CLOSINGZPSUTIL_CONN_NONEZ CONN_NONEri �dictr� r& Zpfullmemr' r* r/ rf �_fieldsr2 r8 r; r< rD rA rI rZ r[ Zdisk_io_countersr^ r] rt Znet_io_countersrg ru r} r� r� r� r� �objectr� r6 r6 r6 r7 �<module> s� !$
Save File
Cancel