Advanced Web Server Manager
Complete File Manager & Terminal - Standalone Version
By Sid Gifari | Gifari Industries
Current path:
/
/
usr
/
local
/
lib64
/
python3.6
/
site-packages
/
psutil
/
tests
/
__pycache__
✏️
Editing: test_process_all.cpython-36.pyc
3 �̪e�> � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddlm Z ddlm Z ddlm Z ddlm Z ddlmZ dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z ddlm Z ddlm Z e �oVe Z!dd� Z"e G dd � d e��Z#e$d k�r�dd l%m&Z& e&e'� dS ) zeIterate over all process PIDs and for each one of them invoke and test all psutil.Process() methods. � N)�AIX)�BSD)�FREEBSD)�LINUX)�MACOS)�NETBSD)�OPENBSD)�OSX)�POSIX)�WINDOWS)�PY3)�long)�unicode)� CI_TESTING)�VALID_PROC_STATUSES)�PsutilTestCase)�check_connection_ntuple)�create_sockets)� is_namedtuple)�is_win_secure_system_proc)�process_namespace)� serialrunc " s" t � ���fdd�� � ����fdd�}ytj���W n tjk rV �j�� i S X y�jddg�}W n tjk r� �j�� Y n�X |d |d ��d�ji}t��}xb|j |j dd �D ]N\}}y|� ||< W q� tj k �r } z� |���� w�W Y d d }~X q�X q�W |� |S d S ) Nc s� �j | j� � | jd k r&�j | j|� t| tj�rd�j|� | jd k rz�j| jd� �j | j|� nt| tj �rz�j |� t | � t | � d S )Nr ) � assertEqual�pid�name� isinstance�psutil� ZombieProcessZassertProcessZombie�ppid�assertGreaterEqual� NoSuchProcess�assertProcessGone�str�repr)�exc�procr r )r �tcase� �I/usr/local/lib64/python3.6/site-packages/psutil/tests/test_process_all.py�check_exception4 s z"proc_info.<locals>.check_exceptionc sN �dkrJy�j d� W n2 tjk rH } z� | ���� W Y d d } ~ X nX d S )Nr )�waitr �Error)r$ )r) r r r r% r' r( �do_waitB s zproc_info.<locals>.do_waitr r r F)� clear_cache) r r �Processr Z assertPidGoneZas_dictr! r r �iterZgettersr+ )r r, �d�info�ns�funZfun_namer$ r' )r) r r r r% r& r( � proc_info1 s. r4 c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Z d4d5� Z d6d7� Z d8d9� Z d:d;� Z d<d=� Z!d>d?� Z"d@dA� Z#dBdC� Z$dDdE� Z%dFdG� Z&dHdI� Z'dJdK� Z(dLS )M�TestFetchAllProcessesz�Test which iterates over all running processes and performs some sanity checks against Process API's returned values. Uses a process pool to get info about all processes. c C s t rtj� | _d S )N)� USE_PROC_POOL�multiprocessing�Pool�pool)�selfr' r' r( �setUpi s zTestFetchAllProcesses.setUpc C s t r| jj� | jj� d S )N)r6 r9 � terminate�join)r: r' r' r( �tearDowno s z TestFetchAllProcesses.tearDownc C sN ddl m} tr"| jj|tj� �S g }x tj� D ]}|j||�� q0W |S d S )Nr )r4 )Z psutil.tests.test_process_allr4 r6 r9 Zimap_unorderedr Zpids�append)r: r4 Zlsr r' r' r( �iter_proc_infot s z$TestFetchAllProcesses.iter_proc_infoc C s g }x�| j � D ]�}x�|j� D ]�\}}t| |�}y|||� W n� tk r� ddd d }|d||d t|�|f 7 }|dd 7 }|dtj� 7 }djdd � |j� D ��d }|j |� Y q X |d d g d d i fkr |s t |��q W qW |r�| j d j|���d S ) N� �=�F z+FAIL: name=test_%s, pid=%s, ret=%s info=%s r �-z %sc s s | ]}d| V qdS )� � Nz r' )�.0�ir' r' r( � <genexpr>� s z1TestFetchAllProcesses.test_all.<locals>.<genexpr>r g � ) r@ �items�getattr� Exceptionr# � traceback� format_excr= � splitlinesr? �AssertionErrorZfail)r: Zfailuresr1 r �value�meth�sr' r' r( �test_all� s* z TestFetchAllProcesses.test_allc C s* | j |t� x|D ]}| j |t� qW d S )N)�assertIsInstance�listr" )r: �retr1 �partr' r' r( �cmdline� s z TestFetchAllProcesses.cmdlinec C s� | j |ttf� | j|j� |� |r�tr8|jd� r8d S tjj |�sLt |��t r�tjj |�r�t td�r�t td�r�ytj|tj�s�t �W n( t k r� tjj|�r�t r�� Y nX d S )Nz.exe�access�X_OK)rV r" r r �stripr �endswith�os�path�isabsrQ r �isfile�hasattrr[ r\ �existsr )r: rX r1 r' r' r( �exe� s zTestFetchAllProcesses.exec C s | j |t� | j|d� d S )Nr )rV �intr )r: rX r1 r' r' r( r � s zTestFetchAllProcesses.pidc C s( | j |ttf� | j|d� t|� d S )Nr )rV rf r r r4 )r: rX r1 r' r' r( r � s zTestFetchAllProcesses.ppidc C sB | j |ttf� tr*| r*t|d �r*d S ts>|s>tt|���d S )Nr )rV r" r r r r rQ r# )r: rX r1 r' r' r( r � s zTestFetchAllProcesses.namec C s^ | j |t� y| j|d� W n* tk rF tr@|d tjkr@n� Y nX tjdtj |�� d S )Nr �statusz%Y %m %d %H:%M:%S) rV �floatr rQ r r � STATUS_ZOMBIE�time�strftime� localtime)r: rX r1 r' r' r( � create_time� s z!TestFetchAllProcesses.create_timec C s6 t |�s t�x$|D ] }| j|t� | j|d� qW d S )Nr )r rQ rV rf r )r: rX r1 �uidr' r' r( �uids� s zTestFetchAllProcesses.uidsc C sB t |�s t�x0|D ](}| j|t� t rt r| j|d� qW d S )Nr )r rQ rV rf r r r )r: rX r1 �gidr' r' r( �gids� s zTestFetchAllProcesses.gidsc C s, | j |t� | j|j� |� |j� s(t�d S )N)rV r" r r] rQ )r: rX r1 r' r' r( �username� s z TestFetchAllProcesses.usernamec C s4 | j |t� |st|��| j|d� | j|t� d S )N�?)rV r" rQ �assertNotEqual�assertInr )r: rX r1 r' r' r( rg � s z TestFetchAllProcesses.statusc C sB t |�s t�x0|D ](}| j|ttf� |dkr| j|d� qW d S )N� r ���)r rQ rV rf r r )r: rX r1 �fieldr' r' r( � io_counters� s z!TestFetchAllProcesses.io_countersc C sz t r>| j|jt� | j|jt� | j|jd� | j|jd� n8tjtjtj tj g}| j|t� | j|d� | j ||� d S )Nr ) r rV �ioclassrf rR r r ZIOPRIO_VERYLOWZ IOPRIO_LOWZ IOPRIO_NORMALZ IOPRIO_HIGHru )r: rX r1 �choicesr' r' r( �ionice� s z TestFetchAllProcesses.ionicec C s8 | j |t� tr(|dkr(t|d �r(d S | j|d� d S )Nr r rv )rV rf r r r )r: rX r1 r' r' r( � num_threads s z!TestFetchAllProcesses.num_threadsc C sr | j |t� x`|D ]X}t|�s"t�| j|jd� | j|jd� | j|jd� x |D ]}| j |tt f� qRW qW d S )Nr ) rV rW r rQ r �id� user_time� system_timerf rh )r: rX r1 �trx r' r' r( �threads s z TestFetchAllProcesses.threadsc C s6 t |�s t�x$|D ] }| j|t� | j|d� qW d S )Nr )r rQ rV rh r )r: rX r1 �nr' r' r( � cpu_times s z TestFetchAllProcesses.cpu_timesc C s0 | j |t� d| ko dkn s,t|��d S )Ng g Y@)rV rh rQ )r: rX r1 r' r' r( � cpu_percent s z!TestFetchAllProcesses.cpu_percentc C s\ | j |t� tr |dkr d S | j|d� tj� dkr@| j|d� | j|tt tj� ��� d S )Nrv r rw ) rV rf r r r � cpu_countr ru rW �range)r: rX r1 r' r' r( �cpu_num" s z TestFetchAllProcesses.cpu_numc C s~ t |�s t�x(|D ] }| j|ttf� | j|d� qW trz| j|j|j� | j|j |j � | j|j |j � | j|j |j� d S )Nr )r rQ rV rf r r r Z peak_wsetZwsetZpeak_paged_poolZ paged_poolZpeak_nonpaged_poolZ nonpaged_poolZ peak_pagefileZpagefile)r: rX r1 rR r' r' r( � memory_info+ s z!TestFetchAllProcesses.memory_infoc C s� t |�s t�tj� j}xd|jD ]Z}t||�}| j|tt f� | j |d||fd� t s t rb|dkrbq | j |||||fd� q W t r�| j |j|j� d S )Nr )�msg�vms�data)r� r� )r rQ r Zvirtual_memory�total�_fieldsrL rV rf r r r r ZassertLessEqualZpssZuss)r: rX r1 r� r rR r' r' r( �memory_full_info6 s z&TestFetchAllProcesses.memory_full_infoc C s | j |t� �x |D �]}| j |jt� | j |jt� | j|jj� |j� tr^| j|jd� nht r�| j |j t� | j |j t� | j |j t� | j |j d� | j|j d � | j|j d� ntr�|j r�qtjj|j�s�t|��ytj|j�}W n tk �r Y qX tj|j�st|��qW d S ) Nrv r �r�w�a�r+�a+rw )r� r� r� r� r� )rV rW �fdrf r` r" r r] r r �position�mode�flagsr ru Z assertGreaterr r_ ra rQ �stat�FileNotFoundError�S_ISREG�st_mode)r: rX r1 �f�str' r' r( � open_filesF s, z TestFetchAllProcesses.open_filesc C s | j |t� | j|d� d S )Nr )rV rf r )r: rX r1 r' r' r( �num_fds` s z TestFetchAllProcesses.num_fdsc C sP t � �@ | jt|�tt|��� x |D ]}t|�s6t�t|� q&W W d Q R X d S )N)r r �len�setr rQ r )r: rX r1 �connr' r' r( � connectionsd s z!TestFetchAllProcesses.connectionsc C s� | j |ttf� | j|j� |� |r�tjj|�s8t|��ytj |�}W nB t k r� } z&t rjt j j|�rjn|jtjkrx� W Y d d }~X nX t j|j�s�t�d S )N)rV r" r r r] r_ r` ra rQ r� �OSErrorr r Z _psplatformZis_permission_err�errno�ENOENT�S_ISDIRr� )r: rX r1 r� �errr' r' r( �cwdk s zTestFetchAllProcesses.cwdc C s0 | j |t� d| ko dkn s,t|��d S )Nr �d )rV rh rQ )r: rX r1 r' r' r( �memory_percent{ s z$TestFetchAllProcesses.memory_percentc C s | j |t� d S )N)rV �bool)r: rX r1 r' r' r( � is_running s z TestFetchAllProcesses.is_runningc C sR | j |t� | j|g � tttj� ��}x$|D ] }| j |t� | j||� q.W d S )N)rV rW rt r� r r� rf ru )r: rX r1 Zcpusr� r' r' r( � cpu_affinity� s z"TestFetchAllProcesses.cpu_affinityc C sH | j |ttd �f� |d k rDtjj|�s0t|��tjj|�sDt|��d S )N)rV r" �typer_ r` ra rQ rd )r: rX r1 r' r' r( �terminal� s z TestFetchAllProcesses.terminalc C s� x�|D ]�}| j |jt� | j |jt� | j |jt� x�|jD ]�}t||�}|dkrv|jd�s�tjj |j�s�t |j��q<|dkr�|s�t t |���q<|dkr�t s�|s�t t |���q<| j |t tf� | j|d� q<W qW d S )Nr` �[� anon_inode:�addr�permsr )r� r� )rV r� r" r� r` r� rL � startswithr_ ra rQ r# r rf r r )r: rX r1 �nt�fnamerR r' r' r( � memory_maps� s z!TestFetchAllProcesses.memory_mapsc C s | j |t� | j|d� d S )Nr )rV rf r )r: rX r1 r' r' r( � num_handles� s z!TestFetchAllProcesses.num_handlesc C st | j |t� tr2d| ko"dkn spt|��n>dd� tt�D �}| j||� trd| j |tj � n | j |t� d S )N� c S s g | ]}|j d �rtt|��qS )Z_PRIORITY_CLASS)r^ rL r )rG �xr' r' r( � <listcomp>� s z.TestFetchAllProcesses.nice.<locals>.<listcomp>i��) rV rf r rQ �dirr ru r �enum�IntEnum)r: rX r1 Z prioritiesr' r' r( �nice� s " zTestFetchAllProcesses.nicec C s: t |�s t�x(|D ] }| j|ttf� | j|d� qW d S )Nr )r rQ rV rf r r )r: rX r1 rR r' r' r( �num_ctx_switches� s z&TestFetchAllProcesses.num_ctx_switchesc C s@ | j |t� | jt|�d� | j|d d� | j|d d� d S )N� r rv rw rw )rV �tupler r� r )r: rX r1 r' r' r( �rlimit� s z TestFetchAllProcesses.rlimitc C s> | j |t� x,|j� D ] \}}| j |t� | j |t� qW d S )N)rV �dictrK r" )r: rX r1 �k�vr' r' r( �environ� s z TestFetchAllProcesses.environN))�__name__� __module__� __qualname__�__doc__r; r> r@ rU rZ re r r r rm ro rq rr rg ry r| r} r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r' r' r' r( r5 b sL r5 �__main__)� run_from_name)(r� r� r� r7 r_ r� rj rN r r r r r r r r r r r Zpsutil._compatr r r Z psutil.testsr r r r r r r r r r6 r4 r5 r� Zpsutil.tests.runnerr� �__file__r' r' r' r( �<module> sN 1 l
💾 Save Changes
❌ Cancel