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: __init__.cpython-36.pyc
3 �֪e� � U @ s( d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddlm Z ddlm Z ddl Z ddl m Z ddl m!Z! dd l m"Z" dd l m#Z# dd l m$Z$ dd l m%Z% dd l m&Z& ddl m'Z' ddl(m)Z) ddl(m*Z* ddl(m+Z+ ddl(m,Z, ddl(m-Z- ddl.m/Z/ ddl.m0Z0 ddl.m1Z1 ddl.m2Z2 ddl.m3Z3 ddl.m4Z4 ddl.m5Z5 ddl.m6Z6 ydd lm7Z7 W n< e8k �rL ej9� � ej:d � ddl7Z7W dQ R X Y nX e/�r^ddl;Z;ndZ;e%�rtdd l<m=Z= d d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfgHZ>dgej?kZ@d e jAkZBdhe jAk�p0die jAkZCeB�p:eCZDdje jAkZEejFd�kZGe+dmdn� �ZHe"�rxeH� d�kZIeH� d�kZJndrZIdrZJdoZKd�ZLd�ZMdsZNeD�r�eKdu9 ZKeNdu9 ZNeLdv9 ZLeMdu9 ZMe jOdwk�r�dxe jP� ZQn dye jP� ZQe4dz�ZRe/�r�d{jSd|d}�ZTnd~ZTejU� jV� d�kZWe jXjYe jXjZe jXj[e\�d�d���Z]e jAj^d�e jXjZe]d���Z_e jXjYe jXj[e\��Z`e%�obe& Zaebe jcd��Zdebe d��Zeebe d��Zfebe jcd��Zgebe jcd��Zhebe jcd��Ziebe d��Zjebe jcd��Zkebe jcd��Zlebe jcd��Zmebe d��Znyen�o�eoe jp� �ZqW n erk �r drZqY nX ebe d��Zsebe d��Ztebe jcd��Zue"�s>e �oHe jv� dkZwd�d�� Zxex� \ZyZze{e j|d��Z}ej~e}j� d�d�� e�e �D �Z�e�ed�e�� �Z�e�� Z�e�� Z�G d�dE� dEej��Z�d�d�� Z�e�d�d�dB��Z�e�d�dD� �Z�d�dC� Z�e�d�d?� �Z�e�d�d�� �Z�ej�eNfd�d@�Z�d�d�dA�Z�d�dV� Z�d�dU� Z�G d�d�� d��Z�e�e j�deNd�d��d�dX� �Z�e�e1e�fdeNd�d��d�d�dY��Z�e�e�deNd�d��d�dW� �Z�d�dQ� Z�d�d�� Z�ej�d�dP� �Z�d�dR� Z�d�d�dS�Z�d�d�dT�Z�G d�d�� d�ej��Z�e�e_�G d�dK� dKe��Z�ej�e@d��G d�dJ� dJe���Z�d�dN� Z�d�dO� Z�d�d�� Z�G d�dL� dL�Z�G d�dM� dM�Z�d�d�� Z�eKfd�dI�Z�d�d�dG�Z�d�d�dH�Z�d�d�d\�Z�e e dfd�d]�Z�ej fd�d^�Z�d�d�d_�Z�d�d`� Z�ej�d�da� �Z�d�dZ� Z�d�d΄ Z�d�d[� Z�d�db� Z�d�dc� Z�d�dd� Z�d�df� Z�e%�r�ej�d�d�de��Z�nej�d�d�de��Z�ej~d�dׄ �Z�e%�r$ejej�d�dل � dS )�zTest utilities.� )�print_functionN)�AF_INET)�AF_INET6)� SOCK_STREAM)�AIX)�LINUX)�MACOS)�NETBSD)�OPENBSD)�POSIX)�SUNOS)�WINDOWS)� bytes2human)�debug)�memoize)� print_color)� supports_ipv6)�PY3)�FileExistsError)�FileNotFoundError)�range)�super)�u)�unicode)�which)�mock�ignore)�wait_pid�APPVEYOR�DEVNULL�GLOBAL_TIMEOUT�TOLERANCE_SYS_MEM� NO_RETRIES�PYPY� PYTHON_EXE�PYTHON_EXE_ENV�ROOT_DIR� SCRIPTS_DIR� TESTFN_PREFIX�UNICODE_SUFFIX�INVALID_UNICODE_SUFFIX� CI_TESTING�VALID_PROC_STATUSES�TOLERANCE_DISK_USAGE�IS_64BIT�HAS_CPU_AFFINITY� HAS_CPU_FREQ� HAS_ENVIRON�HAS_PROC_IO_COUNTERS� HAS_IONICE�HAS_MEMORY_MAPS�HAS_PROC_CPU_NUM� HAS_RLIMIT�HAS_SENSORS_BATTERY� HAS_BATTERY�HAS_SENSORS_FANS�HAS_SENSORS_TEMPERATURES� MACOS_11PLUS� MACOS_12PLUS�COVERAGE�pyrun� terminate� reap_children�spawn_testproc� spawn_zombie�spawn_children_pair� ThreadTask�unittest�skip_on_access_denied�skip_on_not_implemented�retry_on_failure�TestMemoryLeak�PsutilTestCase�process_namespace�system_namespace� print_sysinfo�is_win_secure_system_proc�chdir� safe_rmpath� create_py_exe� create_c_exe� get_testfn� get_winver�kernel_version� call_until� wait_for_pid� wait_for_file�check_net_address�filter_proc_connections� get_free_port� bind_socket�bind_unix_socket�tcp_socketpair�unix_socketpair�create_sockets� reload_module�import_module_by_path�warn�copyload_shared_lib� is_namedtuple�__pypy__�GITHUB_ACTIONS� CIBUILDWHEELZ COVERAGE_RUN� � c C sn t j� d } ttt| jd�d d� ��}|d krjtjtj dddgd d id d �} ttt| jd�d d� ��}|S )Nr �.ri � � z-sSz-cz-import platform; print(platform.mac_ver()[0])ZSYSTEM_VERSION_COMPAT�0T)�env�universal_newlines)rl rm ) �platform�mac_ver�tuple�map�int�split� subprocess� check_output�sys� executable)� version_str�version� r} �A/usr/local/lib64/python3.6/site-packages/psutil/tests/__init__.py� macos_version� s r rl � � F� i � � �javaz $psutil-%s-z @psutil-%s-u -ƒőős f���utf8�surrogateescapeu fÀ�ascii�us-asciiz..ZPSUTIL_SCRIPTS_DIR�scripts� cpu_affinity�cpu_freq� getloadavg�environ�ionice� memory_maps�net_io_counters�cpu_num� io_counters�rlimit�sensors_battery� sensors_fans�sensors_temperatures�threadsc C s� dd� } t jj� }ttdd �}trFtjd krF|d k rFtj|d< ||fS trTtj|fS t r�| tj�p�| t j j tj��p�| t dtjd d� ��p�| t j� j� �}|s�td ��||fS t j j tj�}t j j|�s�t|��||fS d S ) Nc S s< y t j| dgt jt jd� W n t jk r2 d S X | S d S )Nz-V)�stdout�stderr)rw � check_call�PIPE�CalledProcessError)�exer} r} r~ �attempt� s z _get_py_exe.<locals>.attemptZ_base_executabler� � �__PYVENV_LAUNCHER__z python%s.%sri z"can't find python exe real abspath)r� r� )�osr� �copy�getattrry r � version_inforz rg r �path�realpathr �psutil�Processr� � ValueError�exists�AssertionError)r� ro �baser� r} r} r~ � _get_py_exe� s& r� zr+c C s g | ]}|j d �rtt|��qS )ZSTATUS_)� startswithr� r� )�.0�xr} r} r~ � <listcomp> s r� �AF_UNIXc sP e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z � Z S )rD z6A thread task which does nothing expect staying alive.c s$ t � j� d| _d| _tj� | _d S )NFg����MbP?)r �__init__�_running� _interval� threading�Event�_flag)�self)� __class__r} r~ r� ( s zThreadTask.__init__c C s | j j}d|| jt| �f S )Nz<%s running=%s at %#x>)r� �__name__r� �id)r� �namer} r} r~ �__repr__. s zThreadTask.__repr__c C s | j � | S )N)�start)r� r} r} r~ � __enter__2 s zThreadTask.__enter__c O s | j � d S )N)�stop)r� �args�kwargsr} r} r~ �__exit__6 s zThreadTask.__exit__c C s( | j rtd��tjj| � | jj� dS )zStart thread and keep it running until an explicit stop() request. Polls for shutdown every 'timeout' seconds. zalready startedN)r� r� r� �Threadr� r� �wait)r� r} r} r~ r� 9 s zThreadTask.startc C s, d| _ | jj� x| j r&tj| j� qW d S )NT)r� r� �set�time�sleepr� )r� r} r} r~ �runB s zThreadTask.runc C s | j std��d| _ | j� dS )z8Stop thread execution and and waits until it is stopped.zalready stoppedFN)r� r� �join)r� r} r} r~ r� H s zThreadTask.stop) r� � __module__� __qualname__�__doc__r� r� r� r� r� r� r� � __classcell__r} r} )r� r~ rD % s c s t j� �� fdd��}|S )Nc s, y � | |�S t k r& t� � Y nX d S )N)� Exceptionr@ )r� r� )�funr} r~ �wrapperV s z&_reap_children_on_err.<locals>.wrapper)� functools�wraps)r� r� r} )r� r~ �_reap_children_on_errU s r� c K s� |j dt� |j dt� |j dtj� � |j dt� trHd}|j d|� | dkr�ttj� d�}zLt|� d d | d }td |g} t j | f|�}t j |� t |d d d� W dt|� X n"t j | f|�}t j |� t|j� |S )a Create a python subprocess which does nothing for some secs and return it as a subprocess.Popen instance. If "cmd" is specified that is used instead of python. By default stdin and stdout are redirected to /dev/null. It also attempts to make sure the process is in a reasonably initialized state. The process is registered for cleanup on reap_children(). �stdinr� �cwdro i � creationflagsN)�dirz import time;zopen(r'%s', 'w').close();z&[time.sleep(0.1) for x in range(100)];z-cT)�delete�empty)� setdefaultr r� �getcwdr% r rS rP r$ rw �Popen�_subprocesses_started�addrX rW �pid)�cmd�kwdsZCREATE_NO_WINDOW�testfnZpyline�sprocr} r} r~ rA a s* c C s� d} t tj� d�}zvtjdtjj|�tf �}trDt |dd�\}} n t |�\}} t j |j �}t t|ddd��}tj|� t j |�}||fS t|� | dk r�t| � X dS ) a Create a subprocess which creates another one as in: A (us) -> B (child) -> C (grandchild). Return a (child, grandchild) tuple. The 2 processes are fully initialized and will live for 60 secs and are registered for cleanup on reap_children(). N)r� a; import subprocess, os, sys, time s = "import os, time;" s += "f = open('%s', 'w');" s += "f.write(str(os.getpid()));" s += "f.close();" s += "time.sleep(60);" p = subprocess.Popen([r'%s', '-c', s]) p.wait() r )r� TF)r� r� )rS r� r� �textwrap�dedentr� �basenamer$ r r> r� r� r� ru rX � _pids_startedr� rP )�tfiler� �s�subp�childZgrandchild_pidZ grandchildr} r} r~ rC � s c C s� t js t�t� } tjd| �}d}t| �}z~|jt� t |�\}}|j � \}}zLt j |j � gg g t� t |jd��}tj|� t j|�}t|jd� ||fS |j� X W d|j� t| � |dk r�t|� X dS )z�Create a zombie process and return a (parent, zombie) process tuple. In order to kill the zombie parent must be terminate()d first, then zombie must be wait()ed on. a import os, sys, time, socket, contextlib child_pid = os.fork() if child_pid > 0: time.sleep(3000) else: # this is the zombie process s = socket.socket(socket.AF_UNIX) with contextlib.closing(s): s.connect('%s') if sys.version_info < (3, ): pid = str(os.getpid()) else: pid = bytes(str(os.getpid()), 'ascii') s.sendall(pid) Ni zret == psutil.STATUS_ZOMBIE)r� r r� rS r� r� r] � settimeoutr r> �accept�select�filenoru �recvr� r� r� rV �status�closerP ) Z unix_file�srcr� �sock�parent�conn�_Zzpid�zombier} r} r~ rB � s, c K s� |j dd� |j dd� t� }yDt|d��}|j| � W dQ R X tt|jgf|�}t|j� ||fS t k r� t |� � Y nX dS )z�Run python 'src' code string in a separate interpreter. Returns a subprocess.Popen instance and the test file where the source code was written. r� Nr� �w) r� rS �open�writerA r$ r� rW r� r� rP )r� r� �srcfile�fr� r} r} r~ r> � s c K s� t rdnd}|jdtj� |jdtj� |jdd� |jd|� t| t�rTtj| �} tj| f|�}t j |� t r�|j t d�\}}n |j � \}}|jdkr�t|��|r�t|� |jd �r�|d d � }|S ) zURun cmd in a subprocess and return its output. raises RuntimeError on error. i r r� r� rp Tr� )�timeout� N� ���)r r� rw r� � isinstance�str�shlexrv r� r� r� r � communicater � returncode� RuntimeErrorrc �endswith)r� r� �flags�pr� r� r} r} r~ �sh� s& r c s� dd� �dd� � � ��fdd�}� ��fdd���fd d �}d d � }| }zVt |t�r^|||�S t |tjtjf�rz�||�S t |tj�r�|||�S td | ��W dt |tjtjf�r�||� t |t�r�|n|j}tj|� s�t |��X dS )a� Terminate a process and wait() for it. Process can be a PID or an instance of psutil.Process(), subprocess.Popen() or psutil.Popen(). If it's a subprocess.Popen() or psutil.Popen() instance also closes its stdin / stdout / stderr fds. PID is wait()ed even if the process is already gone (kills zombies). Does nothing if the process does not exist. Return process exit status. c S sd t | tj�r t r | j� n | j|� tr`t | tj�r`ytj| j�j|�S tj k r^ Y nX d S )N) r rw r� r r� r r� r� r� � NoSuchProcess)�procr r} r} r~ r� s zterminate.<locals>.waitc S s6 t rtrtj}tr(|tjkr(| jtj� | j|� d S )N)r rg �signal�SIGKILLr � send_signal�SIGCONT)r �sigr} r} r~ �sendsig& s zterminate.<locals>.sendsigc sZ y� | �� W n@ t k rN } z$tr0|jdkr0n|jtjkr>� W Y d d }~X nX �| |�S )N� )�OSErrorr �winerror�errnoZESRCH)r r �err)r r r� r} r~ �term_subprocess_proc0 s z'terminate.<locals>.term_subprocess_procc s0 y� | �� W n t jk r$ Y nX �| |�S )N)r� r )r r )r r r� r} r~ �term_psutil_proc: s z#terminate.<locals>.term_psutil_procc sB yt j| �}W n$ t jk r2 tr.t| |�S Y n X � ||�S d S )N)r� r� r r r )r� r r )r r} r~ �term_pidA s zterminate.<locals>.term_pidc S s4 | j r| j j� | jr | jj� | jr0| jj� d S )N)r� r� r� r� )r r} r} r~ � flush_popenK s z terminate.<locals>.flush_popenz wrong type %rN) r ru r� r� r� rw � TypeErrorr� � pid_existsr� )Z proc_or_pidr � wait_timeoutr r r r r� r} )r r r r� r~ r? s& c C s� t j� j| d�}xtr(tj� }t|� qW xtrBtj� }t|� q,W |r�x|D ]}t|dd� qNW t j|td�\}}x&|D ] }t d| � t|t j d� qzW dS )a Terminate and wait() any subprocess started by this test suite and any children currently running, ensuring that no processes stick around to hog resources. If recursive is True it also tries to terminate and wait() all grandchildren started by this process. )� recursiveN)r" )r z0couldn't terminate process %r; attempting kill())r ) r� r� �childrenr� �popr? r� � wait_procsr rc r r )r# r$ r� r� r r� �aliver} r} r~ r@ e s c C s� t s td��d} tj� d }x(|D ] }|j� s6|dkr@| |7 } q"P q"W | sVtd| ��d}d}| jd�}t|d �}t|�dkr�t|d �}t|�dkr�t|d �}|||fS ) z"Return a tuple such as (2, 6, 36).z not POSIX� ri rk zcan't parse %rr r r� ) r �NotImplementedErrorr� �uname�isdigitr� rv ru �len)r� r* �c�minor�micro�nums�majorr} r} r~ rU � s& c C sb t s td��tj� } t| d�r*| jp&d}n&tjd| d �}|rLt|j d��nd}| d | d |fS )Nz not WINDOWS�service_pack_majorr z\s\d$r� r ) r r) ry �getwindowsversion�hasattrr2 �re�searchru �group)Zwv�sp�rr} r} r~ rT � s c @ s< e Zd ZdZeddddfdd�Zdd� Zdd � Zd d � ZdS ) �retryzA retry decorator.Ng����MbP?c C s2 |r|rt d��|| _|| _|| _|| _|| _d S )Nz/timeout and retries args are mutually exclusive)r� � exceptionr �retries�interval�logfun)r� r; r r< r= r> r} r} r~ r� � s zretry.__init__c c s` | j r.tj� | j }xFtj� |k r*d V qW n.| jrPx&t| j�D ] }d V q@W n x d V qRW d S )N)r r� r< r )r� �stop_atr� r} r} r~ �__iter__� s zretry.__iter__c C s | j d k rtj| j � d S )N)r= r� r� )r� r} r} r~ r� � s z retry.sleepc s" t j� �� �fdd��}�|_|S )Nc st d }x^�D ]V}y � | |�S �j k r^ } z(|}�jd k rD�j|� �j� w W Y d d }~X q X q W trn|�n� d S )N)r; r> r� r )r� r� �excr� )r� r� r} r~ r� � s z retry.__call__.<locals>.wrapper)r� r� � decorator)r� r� r� r} )r� r� r~ �__call__� s zretry.__call__) r� r� r� r� r� r� r@ r� rC r} r} r} r~ r: � s r: g����MbP?)r; r> r r= c C s$ | t j� krt j| ��t j| � dS )z�Wait for pid to show up in the process list then return. Used in the test suite to give time the sub process to initialize. N)r� �pidsr r� )r� r} r} r~ rW � s Tc C s: t | d��}|j� }W dQ R X |s*|s*t�|r6t| � |S )z8Wait for a file to be written on disk with some content.�rbN)r� �readr� rP )�fnamer� r� r �datar} r} r~ rX � s c C s | � }t |�st�|S )zVKeep calling function for timeout secs and exit if eval() expression is True. )�evalr� )r� �expr�retr} r} r~ rV s c C sn dd� }yLt j| �}tj|j�r0tjtj| �}ntjt j| �}t rJ|� n||� W n t k rh Y nX dS )z?Convenience function for removing temporary test files or dirs.c S s� t j � t }xjt j � |k rvy| � S tk r4 Y n6 tk rh } z|}tdt|� � W Y d d }~X nX t jd� qW |�d S )Nz ignoring %sg{�G�z�?)r� r r Z WindowsErrorrc r r� )r� r? r� r r} r} r~ � retry_fun% s "z safe_rmpath.<locals>.retry_funN) r� �stat�S_ISDIR�st_moder� �partial�shutil�rmtree�remover r )r� rL �str� r} r} r~ rP " s c C s( yt j| � W n tk r" Y nX dS )z.Convenience function for creating a directory.N)r� �mkdirr )r� r} r} r~ � safe_mkdirD s rV c c s. t j� }zt j| � dV W dt j|� X dS )z@Context manager which temporarily changes the current directory.N)r� r� rO )�dirname�curdirr} r} r~ rO L s c C sT t jj| � st| ��tjt| � tjt | � t rPt j | �}t j | |j t jB � | S )z6Create a Python executable file in the given location.)r� r� r� r� �atexit�registerrP rQ �copyfiler$ r rM �chmodrO �S_IEXEC)r� rT r} r} r~ rQ W s c C s� t jj| � st| ��td�s(tjd��|dkr<tjd�}nt |t �sNt|��t j t | � ttdd�d��}|j|� W dQ R X ztjd|jd| g� W dt |j� X | S ) z5Create a compiled C executable in the given location.�gcczgcc is not installedNz� #include <unistd.h> int main() { pause(); return 1; } z.c)�suffixr� z-o)r� r� r� r� r rE �SkipTestr� r� r r rY rZ rP r� rS r� rw r� r� )r� �c_coder r} r} r~ rR b s r( c C sB x<t jt| |d�}tjj|�stjj|�}tjt |� |S qW dS )z�Return an absolute pathname of a file or dir that did not exist at the time this call is made. Also schedule it for safe deletion at interpreter exit. It's technically racy but probably not really due to the time variant. )�prefixr_ r� N) �tempfile�mktempr( r� r� r� r� rY rZ rP )r_ r� r� r� r} r} r~ rS | s c @ sB e Zd Zdd� Zeejd�s$ejjZe s>dd� Z e j dd� �Z dS ) �TestCasec C s. | j j}|jd�sd| }d|| j j| jf S )Nzpsutil.z psutil.tests.z%s.%s.%s)r� r� r� r� Z_testMethodName)r� Zfqmodr} r} r~ �__str__� s zTestCase.__str__�assertRaisesRegexc C s d S )Nr} )r� r} r} r~ �runTest� s zTestCase.runTestc o s d V d S )Nr} )r� r� �kwr} r} r~ �subTest� s zTestCase.subTestN)r� r� r� rf r4 rE re ZassertRaisesRegexprg r rh � contextlib�contextmanagerrj r} r} r} r~ re � s re c @ sZ e Zd ZdZddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z dS )rJ zUTest class providing auto-cleanup wrappers on top of process test utilities. r( Nc C s t ||d�}| jt|� |S )N)r_ r� )rS � addCleanuprP )r� r_ r� rG r} r} r~ rS � s zPsutilTestCase.get_testfnc O s t ||�}| jt|� |S )N)rA rm r? )r� r� r� r� r} r} r~ rA � s z PsutilTestCase.spawn_testprocc C s* t � \}}| jt|� | jt|� ||fS )N)rC rm r? )r� Zchild1Zchild2r} r} r~ rC � s z"PsutilTestCase.spawn_children_pairc C s* t � \}}| jt|� | jt|� ||fS )N)rB rm r? )r� r� r� r} r} r~ rB � s zPsutilTestCase.spawn_zombiec O s* t ||�\}}| jt|� | jt|� |S )N)r> rm rP r? )r� r� r� r� r� r} r} r~ r> � s zPsutilTestCase.pyrunc C s� | j |tj� | j|j|j� | j|j|j� |jrB| j|jd� t|tj �rv| j|j |j � |j d k rv| j |j d� t |� t|� d S )Nr( r )ZassertIsInstancer� �Error� assertEqualr� r� �_nameZassertNotEqualr � ZombieProcess�ppidZ_ppidZassertGreaterEqualr �repr)r� r rA r} r} r~ �_check_proc_exc� s z PsutilTestCase._check_proc_excc C s� | j tj��4}ytj|� W n tjk r: td��Y nX W d Q R X | j|jj|� | j|jj d � tj |� szt|��| j |tj � � | j |dd� tj � D �� d S )Nz&wasn't supposed to raise ZombieProcessc S s g | ] }|j �qS r} )r� )r� r� r} r} r~ r� � s z0PsutilTestCase.assertPidGone.<locals>.<listcomp>)� assertRaisesr� r r� rq r� ro r; r� r� r! Z assertNotInrD � process_iter)r� r� �cmr} r} r~ � assertPidGone� s z PsutilTestCase.assertPidGonec C s� | j |j� t|�}x�|j|jdd�D ]�\}}| j||d��l y |� }W nF tjk r` � Y nD tjk r� } z| j ||� W Y d d }~X nX d||f }t |��W d Q R X q&W |j dd� d S )NT)� clear_cache)r r� z-Process.%s() didn't raise NSP and returned %rr )r ) rx r� rK �iter�allrj r� rq r rt r� r� )r� r �nsr� r� rK rA �msgr} r} r~ �assertProcessGone� s z PsutilTestCase.assertProcessGonec C sb t j|j�}| j||� tp ts4| jt|�t|�� | j|j� t j� |j � sRt �t j |j�sbt �|j � | j |jt j� � | j |jdd� t j� D �� i t _| j |jdd� t j� D �� t|�}xz|j|jdd�D ]f\}}| j||d��J y |� W n8 t jt jfk �r. } z| j||� W Y d d }~X nX W d Q R X q�W t�r�| jt j��}|j� W d Q R X | j||j� | jt j��}|j � W d Q R X | j||j� | jt j��}|j � W d Q R X | j||j� |j � |j � |j � |j!� |j � �s�t �t j |j��st �| j |jt j� � | j |jdd� t j� D �� i t _| j |jdd� t j� D �� d S ) Nc S s g | ] }|j �qS r} )r� )r� r� r} r} r~ r� s z6PsutilTestCase.assertProcessZombie.<locals>.<listcomp>c S s g | ] }|j �qS r} )r� )r� r� r} r} r~ r� s T)ry )r r� c S s g | ] }|j �qS r} )r� )r� r� r} r} r~ r� . s c S s g | ] }|j �qS r} )r� )r� r� r} r} r~ r� 0 s )"r� r� r� ro r r �hashr� � STATUS_ZOMBIE� is_runningr� r! �as_dictZassertInrD rv Z_pmaprK rz r{ rj rq � AccessDeniedrt r ru �cmdliner; r� r� �suspend�resumer? �kill)r� r �cloner| r� r� rA rw r} r} r~ �assertProcessZombie� sN , z"PsutilTestCase.assertProcessZombie)r( N) r� r� r� r� rS rA rC rB r> rt rx r~ r� r} r} r} r~ rJ � s zunreliable on PYPYc @ s� e Zd ZdZdZdZdZer dndZdZ e j � Z e ejd��Zedd � �Zed d � �Zd d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd dd �Zd d � Z dS ) rI a� Test framework class for detecting function memory leaks, typically functions implemented in C which forgot to free() memory from the heap. It does so by checking whether the process memory usage increased before and after calling the function many times. Note that this is hard (probably impossible) to do reliably, due to how the OS handles memory, the GC and so on (memory can even decrease!). In order to avoid false positives, in case of failure (mem > 0) we retry the test for up to 5 times, increasing call repetitions each time. If the memory keeps increasing then it's a failure. If available (Linux, OSX, Windows), USS memory is used for comparison, since it's supposed to be more precise, see: https://gmpy.dev/blog/2016/real-process-memory-and-environ-in-python If not, RSS memory is used. mallinfo() on Linux and _heapwalk() on Windows may give even more precision, but at the moment are not implemented. PyPy appears to be completely unstable for this framework, probably because of its JIT, so tests on PYPY are skipped. Usage: class TestLeaks(psutil.tests.TestMemoryLeak): def test_fun(self): self.execute(some_function) �� rl r r� T� PSUTIL_DEBUGc C s t jd� d S )NF)r� � _set_debug)�clsr} r} r~ � setUpClassj s zTestMemoryLeak.setUpClassc C s t j| j� d S )N)r� r� �_psutil_debug_orig)r� r} r} r~ � tearDownClassn s z TestMemoryLeak.tearDownClassc C s | j j� }t|d|j�S )NZuss)� _thisproc�memory_full_infor� Zrss)r� �memr} r} r~ �_get_memr s zTestMemoryLeak._get_memc C s t r| jj� S | jj� S d S )N)r r� �num_fds� num_handles)r� r} r} r~ � _get_num_fdsx s zTestMemoryLeak._get_num_fdsc C s | j rt|dtjd� d S )N�yellow)�color�file)�verboser ry r� )r� r} r} r} r~ �_log~ s zTestMemoryLeak._logc C sx | j � }| j|� | j � }|| }|dk r8| jd| ��|dkrttrHdnd}|dkr\|d7 }d|||f }| j|��dS ) z�Makes sure num_fds() (POSIX) or num_handles() (Windows) does not increase after calling a function. Used to discover forgotten close(2) and CloseHandle syscalls. r zHnegative diff %r (gc probably collected a resource from a previous test)�fd�handler r� z %s unclosed %s after calling %rN)r� �call�failr )r� r� �before�after�diff�type_r} r} r} r~ � _check_fds� s zTestMemoryLeak._check_fdsc C sb t jdd� | j� }x t|�D ]}| j|�}~~q W t jdd� | j� }| jt jg � || }|S )z�Get 2 distinct memory samples, before and after having called fun repeatedly, and return the memory difference. r )Z generation)�gcZcollectr� r r� ro Zgarbage)r� r� �timesZmem1r� rK Zmem2r� r} r} r~ � _call_ntimes� s zTestMemoryLeak._call_ntimesc C s� g }d}|}x�t d|d �D ]�}| j||�} d|t| �t| | �|f } |j| � | |kp`| |k} | r||dkrx| j| � d S |dkr�t� | j| � ||7 }| }q W | jdj|���d S )Nr r z,Run #%s: extra-mem=%s, per-call=%s, calls=%sz. )r r� r �appendr� �printr� r� ) r� r� r� r< � tolerance�messagesZprev_memZincrease�idxr� r} �successr} r} r~ � _check_mem� s, zTestMemoryLeak._check_memc C s |� S )Nr} )r� r� r} r} r~ r� � s zTestMemoryLeak.callNc C s� |dk r |n| j }|dk r |n| j}|dk r0|n| j}|dk rB|n| j}yD|dksZtd��|dksjtd��|dksztd��|dks�td��W n. tk r� } ztt|���W Y dd}~X nX | j||� | j|� | j ||||d� dS ) zTest a callable.Nr ztimes must be >= 1r zwarmup_times must be >= 0zretries must be >= 0ztolerance must be >= 0)r� r< r� ) r� � warmup_timesr< r� r� r� r r� r� r� )r� r� r� r� r< r� r r} r} r~ �execute� s zTestMemoryLeak.executec s" � ��fdd�}�j |f|� dS )znConvenience method to test a callable while making sure it raises an exception on every call. c s �j � �� d S )N)ru r} )rA r� r� r} r~ r� � s z*TestMemoryLeak.execute_w_exc.<locals>.callN)r� )r� rA r� r� r� r} )rA r� r� r~ � execute_w_exc� s z TestMemoryLeak.execute_w_exc)NNNN) r� r� r� r� r� r� r� r+ r< r� r� r� r� �boolr� �getenvr� � classmethodr� r� r� r� r� r� r� r� r� r� r� r} r} r} r~ rI A s& c C s� dd l } dd l}dd l}dd l}dd l}y dd l}W n tk rL d }Y nX y dd l}W n tk rr d }Y nX | j� }t j r�t d�r�t d�|d< nzt j r�dtj� d |d< n^t jr�ddjtttj� �� |d< ttd�r�|d d tj� 7 < nd tj� tj� f |d< d jttj� �tj� g �|d < t j �rJtj � d |d < d jtj � tj � tj � g�|d< t!|dd�|d< |d k �r�|d d|j" 7 < t j �r�t d��r�t ddg�}t|�j#d�d |d< nd|d< tj$� d } | �r�| |d< t%j&� |d< |j'� } d| d | d f |d< |jj(t j)� �j*d�|d < |jj+� j*d�|d < |j,� |d < t-j.j/d �|d < t-j0� |d!< t1|d"< tj2� |d#< t-j3� |d$< t j4� |d%< d&t5d'd(� t j6� D �� |d)< t j7� } d*t8| j9�t:| j;�t:| j<�f |d+< t j=� } d*t8| j9�t:| j;�t:| j<�f |d,< t>t j?� �|d-< t j@� jA� } | jBd.d � |jC| �|d/< tDd0d1 t%jEd2� x0|jF� D ]$\}}tDd3|d4 |f t%jEd2� �qhW tDd0d1 t%jEd2� t%jGjH� t�r�t-jd5� nt d6��r�t-jd7� tDd0d1 t%jEd2� t%jGjH� d S )8Nr Z lsb_releasezlsb_release -d -sZOSz Darwin %szWindows � � win32_editionz, z%s %s�archri �kernel�python� __version__z not installed�pipz (wheel=%s)r^ z --versionr r �glibcz fs-encodingz%s, %s�langz%Y-%m-%d %H:%M:%Sz boot-timer� �user�~�homer� Zpyexe�hostnameZPIDZcpusz%.1f%%, %.1f%%, %.1f%%c S s g | ]}|t j� d �qS )�d )r� � cpu_count)r� r� r} r} r~ r� 0 s z!print_sysinfo.<locals>.<listcomp>Zloadavgz%s%%, used=%s, total=%sZmemory�swaprD r� r �=�F )r� z%-17s %s�:Ztasklist�pszps aux)I� collections�datetime�getpass�locale�pprintr� � ImportError�wheel� OrderedDictr� r r r �OSXrq rr r r� rt r � win32_verr4 r� �systemr| �list� architecture�machiner r* �python_implementation�python_version�python_compilerr� r� rv �libc_verry �getfilesystemencoding� getlocale� fromtimestamp� boot_time�strftime�nowZgetuserr� r� � expanduserr� r$ �node�getpidr� rs r� �virtual_memoryru �percentr �used�total� swap_memoryr, rD r� r� r% �pformatr� r� �itemsr� �flush)r� r� r� r� r� r� r� �info�outr� r� r� r� Zpinfo�k�vr} r} r~ rM � s� c C s4 t dd� �}y|� | dkS tk r. dS X d S )Nc S s\ i } t d�}xJ|j� dd � D ]6}dd� |jd�D �}|d t|d � }}|| |< q W | S )Nztasklist.exe /NH /FO csvr c S s g | ]}|j d d��qS )�"r( )�replace)r� r� r} r} r~ r� X s z@is_win_secure_system_proc.<locals>.get_procs.<locals>.<listcomp>�,r )r � splitlinesrv ru )rK r� �line�bitsr� r� r} r} r~ � get_procsS s z,is_win_secure_system_proc.<locals>.get_procsz Secure SystemF)r �KeyError)r� r� r} r} r~ rN Q s c C s6 t j� } t| d�r| j� S t| d�r2tj| j� �S dS )Nr� r� r )r� r� r4 r� �random�choicer� )r r} r} r~ �_get_eligible_cpuc s r� c @ sB e Zd ZdZdf i fdf i fgZdf i fdf ddifdf i fd f i fd f i fd f i fd f i fd f i fddCi fg Zdf i fdf ddifdf i fdf i fdf i fdf i fdf i fdf i fdf i fdf i fd f i fd f i fd f i fd f i fd f i fd!f i fd"f i fgZe�rFed#f i fg7 Zed$f i fg7 Zed%f i fg7 Zed&f i fg7 Ze�r\ed'f i fg7 Ze �rred(f i fg7 Ze �r�ed)e j fi fg7 Ze �r�ed*f i fg7 Ze�r�ed+f i fg7 Ze�r�ed,f i fg7 Ze�r�ed-f i fg7 Ze�r�ed.f d/d0ifg7 Zg Ze�reddDi fg7 Znede jfi fg7 Ze �rJed)e j dEfi fg7 Ze �r�e�rned(e jdfi fg7 Zned(e jfi fg7 Ze �r�ed*e� gfi fg7 Zd3ejfi fd4f i fd5f i fd6f i fd7f i fgZe�r�ed3ejfi fg7 Zed3ej fi fg7 Zee e e Z d8d9� Z dFd:d;�Z d<d=� Z e!d>d?� �Z"e!d@dA� �Z#dBS )GrK a A container that lists all Process class method names + some reasonable parameters to be called with. Utility methods (parent(), children(), ...) are excluded. >>> ns = process_namespace(psutil.Process()) >>> for fun, name in ns.iter(ns.getters): ... fun() � cpu_percentZmemory_percentr� r$ r# Tr� Zmemory_info_exZoneshotr� �parentsr� r� r r� Z connections�kindr{ � cpu_timesZ create_timer� r� r� Z memory_infor� �niceZnum_ctx_switches� num_threadsZ open_filesrr r� r� �usernameZuidsZgids�terminalr� r� r� r� r� r� r� r� r� ZgroupedF� � r r� r� r? r� c C s || _ d S )N)�_proc)r� r r} r} r~ r� � s zprocess_namespace.__init__c c s^ t |�}tj|� xF|D ]>\}}}|r.| j� t| j|�}tj|f|�|�}||fV qW dS )z_Given a list of tuples yields a set of (fun, fun_name) tuples in random order. N)r� r� �shufflery r� r r� rP )r� �lsry �fun_namer� r� r� r} r} r~ rz � s zprocess_namespace.iterc C s | j j| j jdd� dS )z&Clear the cache of a Process instance.T)Z _ignore_nspN)r �_initr� )r� r} r} r~ ry � s z process_namespace.clear_cachec C sB x<|D ]4\}}}d| }t ||�sd|jj|f }t|��qW dS )z}Given a TestCase instance and a list of tuples checks that the class defines the required test method names. Ztest_z$%r class should define a '%s' methodN)r4 r� r� �AttributeError)r� Z test_classr r r� Z meth_namer} r} r} r~ �test_class_coverage� s z%process_namespace.test_class_coveragec C s` t dd� | jD ��}t dd� | jD ��}t dd� ttj�D ��}||B |A }|r\td| ��d S )Nc S s g | ] }|d �qS )r r} )r� r� r} r} r~ r� � s z*process_namespace.test.<locals>.<listcomp>c S s g | ] }|d �qS )r r} )r� r� r} r} r~ r� � s c S s g | ]}|d dkr|�qS )r r� r} )r� r� r} r} r~ r� � s z!uncovered Process class names: %r)r� r{ �ignoredr� r� r� r� )r� �thisr �klassZleftoutr} r} r~ �test� s zprocess_namespace.testN)r )r )r r )T)$r� r� r� r� �utilsr �gettersr r2 r3 r6 r� Z RLIMIT_NOFILEr/ r5 r1 r r4 ZsettersZNORMAL_PRIORITY_CLASSr ZIOPRIO_CLASS_NONEZ IOPRIO_NORMALr� r �SIGTERMZkillersZ CTRL_C_EVENTZCTRL_BREAK_EVENTr{ r� rz ry r� r r r} r} r} r~ rK l s� c @ s� e Zd ZdZdf i fdf ddifdf ddifdf i fdf d difdf d difd f d difd f d difdej� fi fdf dd ifdf i fdf i fdf ddifdej� fi fdf i fdf i fdf i fdf i fgZer�edf d difg7 Ze r�edf i fg7 Ze �red f i fg7 Ze �r$ed f i fg7 Ze �r:ed f i fg7 Ze �r`ed f i fg7 Zed d)i fg7 Zd"f i fd#ej� gfi fd$f i fd%f i fgZeZed&d'� �ZejZd(S )*rL z�A container that lists all the module-level, system-related APIs. Utilities such as cpu_percent() are excluded. Usage: >>> ns = system_namespace >>> for fun, name in ns.iter(ns.getters): ... fun() r� r� ZlogicalFTZ cpu_statsr� ZpercpuZdisk_io_countersZperdiskZdisk_partitionsr{ � disk_usageZnet_connectionsr� Z net_if_addrsZ net_if_statsr� Zpernicr! rD r� Zusersr� r� r� r� r� r� Zwin_service_iterZwin_service_get�algrv r& r� Zcpu_times_percentc c sP t | �} tj| � x8| D ]0\}}}tt|�}tj|f|�|�}||fV qW dS )z_Given a list of tuples yields a set of (fun, fun_name) tuples in random order. N)r� r� r r� r� r� rP )r r r� r� r� r} r} r~ rz ) s zsystem_namespace.iterN)r )r� r� r� r� r� r� r� r r0 �HAS_GETLOADAVGr: r9 r7 r r� r� r r{ � staticmethodrz rK r r} r} r} r~ rL � sN c C s t j| �st| ��d| _| S )zA decorator to mark a TestCase class. When running parallel tests, class' unit tests will be run serially (1 process). T)�inspect�isclassr� Z _serialrun)r r} r} r~ � serialrun8 s r c C s dd� }t td| |d�S )zZDecorator which runs a test function and retries N times before actually failing. c S s t d| tjd� d S )Nz %r, retrying)r� )r� ry r� )rA r} r} r~ r> G s z retry_on_failure.<locals>.logfunN)r; r r< r> )r: r� )r< r> r} r} r~ rH B s c s � fdd�}|S )z,Decorator to Ignore AccessDenied exceptions.c s t j� �� �fdd��}|S )Nc s> y � | |�S t jk r8 �d k r*�s*� tjd��Y nX d S )Nzraises AccessDenied)r� r� rE r` )r� r� )r� �only_ifr} r~ r� S s z9skip_on_access_denied.<locals>.decorator.<locals>.wrapper)r� r� )r� r� )r )r� r~ rB R s z(skip_on_access_denied.<locals>.decoratorr} )r rB r} )r r~ rF O s c s � fdd�}|S )z3Decorator to Ignore NotImplementedError exceptions.c s t j� �� �fdd��}|S )Nc sF y � | |�S t k r@ �d k r(�s(� d� j }tj|��Y nX d S )Nz4%r was skipped because it raised NotImplementedError)r) r� rE r` )r� r� r} )r� r r} r~ r� f s z;skip_on_not_implemented.<locals>.decorator.<locals>.wrapper)r� r� )r� r� )r )r� r~ rB e s z*skip_on_not_implemented.<locals>.decoratorr} )r rB r} )r r~ rG b s � 127.0.0.1c C s4 t jtj� �� }|j| df� |j� d S Q R X dS )z6Return an unused TCP port. Subject to race conditions.r r N)rk �closing�socket�bind� getsockname)�hostr� r} r} r~ r[ s c C s� |dkr| t tfkrd}tj| |�}y>tjd krB|jtjtjd� |j|� |tj kr`|j d� |S t k r� |j � � Y nX dS ) zBinds a generic socket.Nr( r �nt�cygwinr r� )r( r )r" r# ) r r r r� r� � setsockopt� SOL_SOCKET� SO_REUSEADDRr r �listenr� r� )�family�type�addrr� r} r} r~ r\ � s c C st t js t�tjj| � s t| ��tjtj|�}y"|j| � |tj krN|j d� W n t k rn |j � � Y nX |S )zBind a UNIX socket.r� ) r� r r� r� r� r� r r� r r r' r� r� )r� r) r� r} r} r~ r] � s c C s� t jtj| t����}|j|� |jd� |j� }tj| t�}y@|j|� |j� }x(|j� \}}||krn||fS |j � qRW W n t k r� |j � � Y nX W dQ R X dS )z^Build a pair of TCP sockets connected to each other. Return a (server, client) tuple. r� N) rk r r r r r' r �connectr� r� r )r( r* Zllr- Zcaddr�ar} r} r~ r^ � s c C s� t js t�d }}y@t| tjd�}|jd� tjtjtj�}|jd� |j| � W n6 t k r� |dk rr|j � |dk r�|j � � Y nX ||fS )z�Build a pair of UNIX sockets connected to each other through the same UNIX file name. Return a (server, client) tuple. N)r) r ) r� r r� r] r r � setblockingr� r+ r� r� )r� �server�clientr} r} r~ r_ � s c c s� g } d }}z�| j ttjtj�� | j ttjtj�� t� rd| j ttjtj�� | j ttjtj�� tr�t r�t � }t � }t |�\}}t |tjd�}x |||fD ]}| j |� q�W | V W dx| D ] }|j � q�W x ||fD ]}|dk r�t|� q�W X dS )z1Open as many socket families / types as possible.N)r) )r� r\ r r r � SOCK_DGRAMr r r �HAS_CONNECTIONS_UNIXrS r_ r] r� rP )ZsocksZfname1Zfname2�s1�s2Zs3r� rG r} r} r~ r` � s* c C s ddl }tr*tr*t r*t|tj�s*t|��|tjkr�dd� | j d�D �}t |�dks\t| ��x,|D ]$}d| koxdkn sbt| ��qbW ts�t | �} |j | � nd|tj kr�t| t�s�t| ��ts�t | �} |j| � n0|tjkr�tjd| �dk s�t| ��n td | ��dS ) z[Check a net address validity. Supported families are IPv4, IPv6 and MAC addresses. r Nc S s g | ] }t |��qS r} )ru )r� r� r} r} r~ r� � s z%check_net_address.<locals>.<listcomp>rk r� � z([a-fA-F0-9]{2}[:|\-]?){6}zunknown family %r)� ipaddress�enumr r# r �IntEnumr� r r rv r, r Z IPv4Addressr r Z IPv6Addressr� ZAF_LINKr5 �matchr� )r* r( r5 Zocts�numr} r} r~ rY � s& $ c C sT dd� }dd� }dd� }dd� }d d � }|| � || � || � || � || � d S ) z*Check validity of a connection namedtuple.c S s� t | �dk}t | �d ks$tt | ���| d | jks<t| j��| d | jksTt| j��| d | jkslt| j��| d | jks�t| j��| d | jks�t| j��| d | jks�t| j��|r�| d | jks�t| j��d S ) Nr� r r r ri r� r� r� )r r� ) r, r� r� r( r) �laddr�raddrr� r� )r� Zhas_pidr} r} r~ � check_ntuple s z-check_connection_ntuple.<locals>.check_ntuplec S s� | j tttfkst| j ��td k r:t| j tj�sNt| ��nt| j t�sNt| ��| j tkr�t j | j | j �}t j |��R y|j | jd df� W n2 t jk r� } z|jtjkr�� W Y d d }~X nX W d Q R X n | j tkr�| jtjks�t| j��d S )Nr )r( r r r� r� r6 r r7 ru r r) rk r r r: �errorr Z EADDRNOTAVAILr� r� � CONN_NONE)r� r� r r} r} r~ � check_family s z-check_connection_ntuple.<locals>.check_familyc S s� t tdt� �}| jtjtj|fks,t| j��td k rLt| jtj �s`t| ��nt| jt �s`t| ��| jtjkr�| j t j ks�t| j ��d S )N�SOCK_SEQPACKET)r� r �objectr) r r0 r� r6 r r7 ru r� r� r> )r� r@ r} r} r~ � check_type. s z+check_connection_ntuple.<locals>.check_typec S s� x�| j | jfD ]�}| jttfkr�t|t�s6tt|���|s<qt|j t �sVtt|j ���d|j kojdkn szt|j ��t |j | j� q| jt krt|t�stt|���qW d S )Nr i�� )r: r; r( r r r rs r� r) �portru rY �ipr� r )r� r* r} r} r~ � check_addrs= s $ z,check_connection_ntuple.<locals>.check_addrsc S s� t | jt�st| j��dd� tt�D �}| j|ks<t| j��| jttfkrl| j t krl| jtj ks�t| j��n| jtj ks�t| j��d S )Nc S s g | ]}|j d �rtt|��qS )ZCONN_)r� r� r� )r� r� r} r} r~ r� M s zAcheck_connection_ntuple.<locals>.check_status.<locals>.<listcomp>) r r� r r� r� r� r( r r r) r r> )r� Zvalidsr} r} r~ � check_statusJ s z-check_connection_ntuple.<locals>.check_statusNr} )r� r< r? rB rE rF r} r} r~ �check_connection_ntuple s rG c C sP g }xF| D ]>}t r>|jtjkr>tr>d|jkr>tdt|� � q |j|� q W |S )ztOur process may start with some open UNIX sockets which are not initialized by us, invalidating unit tests. z/syslogz skipping %s) r r( r r� r r; r r r� )Zcons�newr� r} r} r~ rZ \ s c C sL yddl }t|d�st�W n" tk r< ddl}|j| �S X |j| �S dS )z,Backport of importlib.reload of Python 3.3+.r N�reload)� importlibr4 r� �imprI )�modulerJ rK r} r} r~ ra o s c C sp t jjt jj| ��d }tjd dk r:dd l}|j|| �S dd l}|j j || �}|j j |�}|j j |� |S d S )Nr r� )r� r� �splitextr� ry r� rK Z load_source�importlib.util�util�spec_from_file_location�module_from_spec�loader� exec_module)r� r� rK rJ �spec�modr} r} r~ rb ~ s c C s t j| tdd� dS )zRaise a warning msg.ri )� stacklevelN)�warningsrc � UserWarning)r} r} r} r~ rc � s c C sV t | �}|j}t|�dks&|d tkr*dS t|dd�}t|t�sDdS tdd� |D ��S )z-Check if object is an instance of namedtuple.r r F�_fieldsNc s s | ]}t |t�V qd S )N)r r )r� �nr} r} r~ � <genexpr>� s z is_namedtuple.<locals>.<genexpr>)r) � __bases__r, rs r� r r{ )r� �t�br r} r} r~ re � s c # st t rdnd� d�t| � d�}� �fdd�tj� j� D �}tj|�}tj||� zt j |� |V W dt |� X dS )z�Ctx manager which picks up a random shared CO lib used by this process, copies it in another location and loads it in memory via ctypes. Return the new absolutized path. �pypyr� z.so)r_ c s6 g | ].}t jj|j�d �kr� |jj� kr|j�qS )r )r� r� rM �lower)r� r� )r� �extr} r~ r� � s z'copyload_shared_lib.<locals>.<listcomp>N) r# rS r� r� r� r� r� rQ r[ �ctypes�CDLLrP )r_ �dst�libsr� r} )r� ra r~ rd � s c # s� ddl m} ddl m} d� t| � d�}� fdd�tj� j� D �}trd| rddd� tj� j� D �}tj |�}t j ||� d }zt j |�}|V W d |d k r�t j jj}|jg|_||j�}|dkr�|� t|� X d S ) z�Ctx manager which picks up a random shared DLL lib used by this process, copies it in another location and loads it in memory via ctypes. Return the new absolutized, normcased path. r )�WinError)�wintypesz.dll)r_ c sF g | ]>}|j j� j� �rd tj j|j �j� krd|j j� kr|j �qS )r� Zwow64)r� r` r r� r� )r� r� )ra r} r~ r� � s z'copyload_shared_lib.<locals>.<listcomp>c S s( g | ] }d t jj|j�j� kr|j�qS )r_ )r� r� r� r` )r� r� r} r} r~ r� � s N)rb rf rg rS r� r� r� r# r� r� rQ r[ ZWinDLL�windll�kernel32� FreeLibraryZHMODULE�argtypes�_handlerP ) r_ rf rg rd re r� �cfilerj rK r} )ra r~ rd � s, c C s t dd� d S )NT)r# )r@ r} r} r} r~ �cleanup_test_procs� s rn c C s t j| �S )N)ry �exit)r r� r} r} r~ �<lambda>� s rp l )rl r� )r� r i i P i ( i � )r� r� )N)F)TF)N)r( N)N)N)r �r( r )rq )r( )r( )�r� � __future__r rY rk rb r r� r� r r� rq r� r5 r� r rQ r r rM rw ry rc r� r� r� rE rW r r r r� r r r r r r r r Zpsutil._commonr r r r r Zpsutil._compatr r r r r r r r r r� �catch_warnings� simplefilterr6 Zpsutil._psposixr �__all__�builtin_module_namesr# r� r rg r+ r= �maxsizer. r r; r< r" r! r- r r� r� r( r) �decoder* r� r` ZASCII_FSr� r� r� rW �__file__r& �getr' �HEREr1 r4 r� r/ r0 r r1 r3 r4 ZHAS_NET_IO_COUNTERSr5 r2 r6 r7 r� r� r8 r� r9 r: Z HAS_THREADS�getuidZ SKIP_SYSCONSr� r$ r% r� �devnullr rZ r� r� r, r� rA r� r� r� r� r� rD r� rA rC rB r> r r r? r@ rU rT r: r rW r� rX rV rP rV rl rO rQ rR rS re rJ ZskipIfrI rM rN r� rK rL r rH rF rG r[ r\ r] r^ r_ r` rY rG rZ ra rb rc re rd rn r} r} r} r~ �<module> s� * 0 ) '- V %; " %k C R 3
💾 Save Changes
❌ Cancel