Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/psutil/tests/__pycache__/__init__.cpython-39.pyc
Ðазад
a d�h�� � @ s d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZ ddlmZ ddlmZ 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'm-Z- ddl'm.Z. ddl'm/Z/ e*�r�ddl0Z0nddl1Z0zddl0m2Z2 W nP e3�y0 e�4� �" e�5d� ddl2Z2W d � n1 �s"0 Y Y n0 ej6dk�rHddl7Z7ndZ7g d�Z8d ej9v Z:d e j;v Z<d e j;v Z=d e j;v Z>d e j;v Z?e<�p�e=�p�e>�p�e?Z@ejAd!kZBd"ZCd#ZDd$ZEd%ZFe@�r�eCd&9 ZCeFd&9 ZFeDd&9 ZDeEd&9 ZEe jGd'k�r�d(e �H� ZIn d)e �H� ZIe-d*�ZJe*�r d+�Kd,d-�ZLnd.ZLe�M� �N� d/v ZOe jP�Qe jP�Re jP�SeT�d0d0��ZUe jP�ReUd1�ZVe jP�Qe jP�SeT��ZWe �o~e! ZXeYe jZd2�Z[eYe d3�Z\eYe d4�Z]eYe jZd5�Z^eYe jZd6�Z_eYe jZd7�Z`eYe d8�ZaeYe jZd9�ZbeYe jZd:�ZceYe jZd;�ZdeYe d<�Zezee�oefe �g� �ZhW n ei�y* d=ZhY n0 eYe d>�ZjeYe d?�ZkeYe jZd@�Zle �sXe �obe �m� dkZndAdB� Zoeo� Zpeqe jrdC�Zse�tesju� dDdE� eve �D �ZwexedFey� �Zze{� Z|e{� Z}G dGdH� dHej~�ZdIdJ� Z�e�d�dKdL��Z�e�dMdN� �Z�dOdP� Z�e�dQdR� �Z�e�dSdT� �Z�ej�eFfdUdV�Z�d�dWdX�Z�dYdZ� Z�d[d\� Z�G d]d^� d^ey�Z�e�e j�deFd_d`�dadb� �Z�e�e)e�fdeFd_d`�d�ddde��Z�e�e�deFd_d`�dfdg� �Z�dhdi� Z�djdk� Z�ej�dldm� �Z�d�dndo�Z�d�dqdr�Z�G dsdt� dte0j��Z�e�e0_�G dudv� dve��Z�e0��e:dw�G dxdy� dye���Z�dzd{� Z�d|d}� Z�G d~d� d�Z�G d�d�� d��Z�d�d�� Z�eCfd�d��Z�d�d�d��Z�d�d�d��Z�d�d�d��Z�eedfd�d��Z�ejfd�d��Z�d�d�d��Z�d�d�� Z�ej�d�d�� �Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�e �r�ej�d�d�d���Z�nej�d�d�d���Z�ejtd�d�� �Z�e �r e�ej�d�d�� � dS )�z Test utilities. � )�print_functionN)�AF_INET)�AF_INET6)� SOCK_STREAM)�AIX)�LINUX)�MACOS)�POSIX)�SUNOS)�WINDOWS)� bytes2human)� print_color)� supports_ipv6)�FileExistsError)�FileNotFoundError)�PY3)�range)�super)�u)�unicode)�which)�mock�ignore�� � )G�APPVEYOR�DEVNULL�GLOBAL_TIMEOUT�TOLERANCE_SYS_MEM� NO_RETRIES�PYPY� PYTHON_EXE�ROOT_DIR� SCRIPTS_DIR� TESTFN_PREFIX�UNICODE_SUFFIX�INVALID_UNICODE_SUFFIX�TRAVIS�CIRRUS� 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_TEMPERATURESZHAS_MEMORY_FULL_INFO�pyrun� terminate� reap_children�spawn_testproc� spawn_zombie�spawn_children_pairZThreadTaskunittest�skip_on_access_denied�skip_on_not_implemented�retry_on_failure�TestMemoryLeak�PsutilTestCase�process_namespace�system_namespace� print_sysinfoZ install_pipZinstall_test_deps�chdir� safe_rmpath� create_exeZ decode_pathZ encode_path� get_testfn� get_winver�get_kernel_version� call_until� wait_for_pid� wait_for_file�check_net_address� 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_namedtupleZ__pypy__r( r r) Z CIBUILDWHEELl � i P i � � r �javaz $psutil-%s-z @psutil-%s-u -ƒőős f���utf8�surrogateescapeu fÀ)�asciizus-asciiz..�scripts� cpu_affinity�cpu_freq� getloadavg�environ�ionice� memory_maps�net_io_counters�cpu_num� io_counters�rlimit�sensors_batteryF� sensors_fans�sensors_temperatures�threadsc C s� dd� } t r.tr$tr td�S td�S td�S n�tr�| tj�pv| tj� tj��pv| tdtj d d� ��pv| t � � � � �}|s�td��|S tj� tj�}tj�|�s�J |��|S d S ) Nc S s: z t j| dgt jt jd� W n ty0 Y d S 0 | S d S )Nz-V)�stdout�stderr)� subprocess� check_call�PIPE� Exception)�exe� ry ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/psutil/tests/__init__.py�attempt� s � z _get_py_exe.<locals>.attemptZpypy3�pypy�pythonz python%s.%s� z"can't find python exe real abspath)� GITHUB_WHEELSr! r r r �sys� executable�os�path�realpath� version_info�psutil�Processrx � ValueError�exists)r{ rx ry ry rz � _get_py_exe� s& ���r� zr+c C s g | ]}|� d �rtt|��qS )ZSTATUS_)� startswith�getattrr� ��.0�xry ry rz � <listcomp>� s �r� �AF_UNIXc sP e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z � Z S )� ThreadTaskz6A thread task which does nothing expect staying alive.c s$ t � �� d| _d| _t�� | _d S )NF���MbP?)r �__init__�_running� _interval� threading�Event�_flag��self�� __class__ry rz r� � s zThreadTask.__init__c C s | j j}d|| jt| �f S )Nz<%s running=%s at %#x>)r� �__name__r� �id)r� �namery ry rz �__repr__� s zThreadTask.__repr__c C s | � � | S �N)�startr� ry ry rz � __enter__ s zThreadTask.__enter__c O s | � � d S r� )�stop)r� �args�kwargsry ry rz �__exit__ s zThreadTask.__exit__c C s( | j rtd��tj�| � | j�� 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� �waitr� ry ry rz r� s zThreadTask.startc C s( d| _ | j�� | j r$t�| j� qd S )NT)r� r� �set�time�sleepr� r� ry ry rz �run s zThreadTask.runc C s | j std��d| _ | �� dS )z8Stop thread execution and and waits until it is stopped.zalready stoppedFN)r� r� �joinr� ry ry rz r� s zThreadTask.stop) r� � __module__� __qualname__�__doc__r� r� r� r� r� r� r� � __classcell__ry ry r� rz r� � s r� c s t �� �� fdd��}|S )Nc s0 z� | i |��W S t y* t� � Y n0 d S r� )rw r< �r� r� ��funry rz �wrapper% s z&_reap_children_on_err.<locals>.wrapper�� functools�wraps�r� r� ry r� rz �_reap_children_on_err$ s r� c K s� |� dt� |� dt� |� dt�� � |� dtj� trJd}|� d|� | du r�t� }zPt|� d| }td |g} t j | fi |��}t � |� t |d d d � W t|� q�t|� 0 n&t j | fi |��}t � |� t|j� |S ) a} Creates a python subprocess which does nothing for 60 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 attemps to make sure the process is in a reasonably initialized state. The process is registered for cleanup on reap_children(). �stdinrr �cwd�env� � creationflagsNz:from time import sleep;open(r'%s', 'w').close();sleep(60);z-cT��delete�empty)� setdefaultr r� �getcwdrg r rK rI r" rt �Popen�_subprocesses_started�addrP rO �pid)�cmd�kwdsZCREATE_NO_WINDOW�testfnZpyline�sprocry ry rz r= / s. � r= c C s� d} t t�� d�}z�t�dtj�|�tf �}trDt |dd�\}} n t |�\}} t � |j �}t t|ddd��}t�|� t � |�}||fW t|� | dur�t| � S nt|� | dur�t| � 0 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��dira; 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� TFr� )rK r� r� �textwrap�dedentr� �basenamer" r r: r� r� r� �intrP � _pids_startedr� rI )�tfiler� �s�subp�childZgrandchild_pidZ grandchildry ry rz r? W s0 � � �r? c s& t js J �t� } t�d| �}d}t| �}z�|�t� t|�\}}|� � \}}z~t � |� � gg g t� t |� d��}t�|� t �|�� t� fdd�d� |� fW |�� W |�� t| � |dur�t|� S |�� 0 W |�� t| � |du�r"t|� n$|�� t| � |du�r t|� 0 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) N� c s � � � S r� )�statusry ��zombiery rz �<lambda>� � z spawn_zombie.<locals>.<lambda>zret == psutil.STATUS_ZOMBIE)r� r rK r� r� rT � settimeoutr r: �accept�select�filenor� �recvr� r� r� rN �closerI )Z unix_file�srcr� �sock�parent�conn�_Zzpidry r� rz r> ~ sD � �� � r> c K s� |� dd� |� dd� t� }z^t|d��}|�| � W d � n1 sJ0 Y tt|jgfi |��}t|j� ||fW S t y� t |� � Y n0 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. rr Nrs �wt) r� rK �open�writer= r" r� rO r� rw rI )r� r� �srcfile�fr� ry ry rz r: � s ( r: c K s� t | ttf�rdnd}tr"|r"dnd}|�d|� |�dtj� |�dtj� |�dd� |�d |� tj| fi |��}t� |� t r�|j t d �\}}n |� � \}}|j dkr�t|��|r�t|� |�d �r�|d d � }|S )zUrun cmd in a subprocess and return its output. raises RuntimeError on error. TFr� r �shellrr rs �universal_newlinesr� ��timeout� N���)� isinstance�strr r r� rt rv r� r� r� r � communicater � returncode� RuntimeErrorrZ �endswith)r� r� r� �flags�prr rs ry ry rz �sh� s& r� c s t rddlm� dd� �dd� � � ��fdd�}� ��fd d ����fd d �}d d� }| }�znt|t�r�|||�W t|tjtjf�r�||� t|t�r�|n|j}t� |�r�J |��S t|tj tjf��r�||�W t|tjtjf�r�||� t|t�r�|n|j}t� |��rJ |��S t|tj��rv|||�W t|tjtjf��rJ||� t|t��rZ|n|j}t� |��rtJ |��S t d| ��W t|tjtjf��r�||� t|t��r�|n|j}t� |��rJ |��nHt|tjtjf��r�||� t|t��r�|n|j}t� |��rJ |��0 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. r )�wait_pidc S sb t | tj�rts| �� n | �|� tr^t | tj�r^zt�| j��|�W S tj y\ Y n0 d S r� ) r� rt r� r r� r r� r� r� � NoSuchProcess��procr� ry ry rz r� � s zterminate.<locals>.waitc S s6 t rtrtj}tr(|tjkr(| �tj� | �|� d S r� )r r �signal�SIGKILLr � send_signal�SIGCONT)r �sigry ry rz �sendsig� s zterminate.<locals>.sendsigc s\ z� | �� W nB t yP } z*tr.|jdkr.n|jtjkr<� W Y d }~n d }~0 0 �| |�S )N� )�OSErrorr �winerror�errnoZESRCH)r r� �err�r r r� ry rz � term_subproc� s z terminate.<locals>.term_subprocc s. z� | �� W n t jy" Y n0 �| |�S r� )r� r r r ry rz � term_psproc s z terminate.<locals>.term_psprocc sD zt �| �}W n& t jy4 tr0�| |� Y S Y n 0 � ||�S d S r� )r� r� r r )r� r� r )r r� ry rz �term_pid s zterminate.<locals>.term_pidc S s4 | j r| j �� | jr | j�� | jr0| j�� d S r� )rr r� rs r� )r ry ry rz � flush_popen s z terminate.<locals>.flush_popenz wrong type %rN) r Zpsutil._psposixr� r� r� rt r� r� r� � pid_existsr� � TypeError)Z proc_or_pidr � wait_timeoutr r r r� r� ry )r r r r� r� rz r; � sP � � ��r; c C s� t �� j| d�}tr&t�� }t|� qtr<t�� }t|� q&|r�|D ]}t|dd� qDt j|td�\}}|D ] }t d| � t|t j d� qldS )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 resursive 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 rZ r r )r r r� r� r� �gone�alivery ry rz r< 3 s r< c C s� t s td��d} t�� d }|D ]"}|�� s4|dkr>| |7 } q qDq | sTtd| ��d}d}| �d�}t|d �}t|�dkr�t|d �}t|�dkr�t|d �}|||fS ) z"Return a tuple such as (2, 6, 36).z not POSIX� r~ �.zcan't parse %rr � r ) r �NotImplementedErrorr� �uname�isdigitr� �splitr� �len)r� r! �c�minor�microZnums�majorry ry rz rM X s& rM c C sd t s td��t�� } t| d�r*| jp&d}n(t�d| d �}|rNt|� d��}nd}| d | d |fS )Nz not WINDOWS�service_pack_majorr z\s\d$r r ) r r r� �getwindowsversion�hasattrr) �re�searchr� �group)Zwv�sp�rry ry rz rL p s rL c @ s< e Zd ZdZeddddfdd�Zdd� Zdd � Zd d � ZdS ) �retryzA retry decorator.Nr� c C s2 |r|rt d��|| _|| _|| _|| _|| _d S )Nz/timeout and retries args are mutually exclusive)r� � exceptionr� �retries�interval�logfun)r� r2 r� r3 r4 r5 ry ry rz r� � s zretry.__init__c c sT | j r*t�� | j }t�� |k rPd V qn&| jrHt| j�D ] }d V q:nd V qHd S r� )r� r� r3 r )r� �stop_atr� ry ry rz �__iter__� s zretry.__iter__c C s | j d urt�| j � d S r� )r4 r� r� r� ry ry rz r� � s z retry.sleepc s" t �� �� �fdd��}�|_|S )Nc s� d }�D ]l}z� | i |��W S �j yr } z8|}�jd urJ��|� ��� W Y d }~qW Y d }~qd }~0 0 qtr�|�n� d S r� )r2 r5 r� r )r� r� �excr� �r� r� ry rz r� � s $z retry.__call__.<locals>.wrapper)r� r� � decorator)r� r� r� ry r9 rz �__call__� s zretry.__call__) r� r� r� r� rw r� r7 r� r; ry ry ry rz r1 � s � r1 r� )r2 r5 r� r4 c C s t �| � trt�d� 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. �{�G�z�?N)r� r� r r� r� )r� ry ry rz rO � s rO Tc C sN t | d��}|�� }W d � n1 s(0 Y |s>|s>J �|rJt| � |S )z8Wait for a file to be written on disk with some content.�rbN)r� �readrI )�fnamer� r� r� �datary ry rz rP � s &rP c C s | � }t |�sJ �|S )zVKeep calling function for timeout secs and exit if eval() expression is True. )�eval)r� �expr�retry ry rz rN � s rN c C sl dd� }zLt �| �}t�|j�r0t�tj| �}nt�t j| �}t rJ|� n||� W n t yf Y n0 dS )z>Convenience function for removing temporary test files or dirsc S s~ t � � t }t � � |k rvz| � W S ty2 Y n8 tyh } z |}tdt|� � W Y d }~n d }~0 0 t �d� q |�d S )Nz ignoring %sr< )r� r r Z WindowsErrorrZ r� r� )r� r6 r� r ry ry rz � retry_fun� s & z safe_rmpath.<locals>.retry_funN) r� �stat�S_ISDIR�st_moder� �partial�shutil�rmtree�remover r )r� rD �str� ry ry rz rI � s rI c C s& zt �| � W n ty Y n0 dS )z-Convenience function for creating a directoryN)r� �mkdirr r� ry ry rz � safe_mkdir s rN c c s8 t �� }z t �| � dV W t �|� n t �|� 0 dS )z@Context manager which temporarily changes the current directory.N)r� r� rH )�dirname�curdirry ry rz rH s rH c C s� t j�| �rJ | ��|r�td�s(td��t|t�r<t�d�}t|t �sNJ |��t t dd�d��}|� |� W d � n1 s~0 Y z"t �d|jd| g� W t|j� q�t|j� 0 n.t�t| � tr�t �| �}t �| |jtjB � dS ) z1Creates an executable file in the given location.Zgcczgcc is not installedz� #include <unistd.h> int main() { pause(); return 1; } z.c��suffixr� Nz-o)r� r� r� r r� r� �boolr� r� r� r� rK r� rt ru r� rI rI �copyfiler" r rE �chmodrG �S_IEXEC)ZoutpathZc_coder� rL ry ry rz rJ s$ �( rJ r c C s. t jt| |d�}tj�|�s tj�|�S q 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. )�prefixrR r� N)�tempfile�mktempr% r� r� r� r� )rR r� r� ry ry rz rK 9 s rK c @ s4 e Zd Zdd� Zeejd�s$ejjZe s0dd� Z dS )�TestCasec C s. | j j}|�d�sd| }d|| j j| jf S )Nzpsutil.z psutil.tests.z%s.%s.%s)r� r� r� r� Z_testMethodName)r� Zfqmodry ry rz �__str__N s �zTestCase.__str__�assertRaisesRegexc C s d S r� ry r� ry ry rz �runTest\ s zTestCase.runTestN) r� r� r� r[ r+ �unittestrZ ZassertRaisesRegexpr\ r r] ry ry ry rz rZ J s rZ c @ sB e Zd ZdZddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dS )rD zUTest class providing auto-cleanup wrappers on top of process test utilities. r Nc C s t ||d�}| �t|� |S )N)rR r� )rK � addCleanuprI )r� rR r� r? ry ry rz rK i s zPsutilTestCase.get_testfnc O s t |i |��}| �t|� |S r� )r= r_ r; )r� r� r� r� ry ry rz r= n s z PsutilTestCase.spawn_testprocc C s* t � \}}| �t|� | �t|� ||fS r� )r? r_ r; )r� Zchild1Zchild2ry ry rz r? s s z"PsutilTestCase.spawn_children_pairc C s* t � \}}| �t|� | �t|� ||fS r� )r> r_ r; )r� r� r� ry ry rz r> y s zPsutilTestCase.spawn_zombiec O s. t |i |��\}}| �t|� | �t|� |S r� )r: r_ rI r; )r� r� r� r� r� ry ry rz r: s zPsutilTestCase.pyrunc C sz | � tjtj|j� t|tjtjf�rN|�� r2J �| � tj|j� |j dd� t� |j�rdJ |j��| � |jt� � � d S )Nr r� ) � assertRaisesr� r r� r� r� r� � is_runningr� r� r Z assertNotIn�pids�r� r ry ry rz �assertProcessGone� s z PsutilTestCase.assertProcessGone)r N) r� r� r� r� rK r= r? r> r: rd ry ry ry rz rD d s rD zunreliable on PYPYc @ s~ e Zd ZdZdZdZdZer dndZdZ e � � Z dd� Z d d � Zd d � Zd d� Zdd� Zdd� Zdd� Zddd�Zdd� ZdS )rC 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) �� r] r r^ Tc C s | j �� }t|d|j�S )NZuss)� _thisproc�memory_full_infor� Zrss)r� �memry ry rz �_get_mem� s zTestMemoryLeak._get_memc C s t r| j�� S | j�� S d S r� )r rf �num_fds� num_handlesr� ry ry rz � _get_num_fds� s zTestMemoryLeak._get_num_fdsc C s | j rt|dtjd� d S )N�yellow)�color�file)�verboser r� rs )r� �msgry ry rz �_log� s zTestMemoryLeak._logc C sx | � � }| �|� | � � }|| }|dk r8| �d| ��|dkrttrHdnd}|dkr\|d7 }d|||f }| �|��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)rl �call�failr )r� r� �before�after�diff�type_rq ry ry rz � _check_fds� s � zTestMemoryLeak._check_fdsc C s^ t jdd� | �� }t|�D ]}| �|�}~~q t jdd� | �� }| �t jg � || }|S )z�Get 2 distinct memory samples, before and after having called fun repeadetly, and return the memory difference. r )Z generation)�gcZcollectri r ru Z assertEqual�garbage)r� r� �timesZmem1r� rC Zmem2ry ry ry rz � _call_ntimes� s zTestMemoryLeak._call_ntimesc C s� g }d}|}t d|d �D ]�} | �||�} d| t| �t| | �|f } |�| � | |kp^| |k} | r|| dkrv| �| � d S | dkr�t� | �| � ||7 }| }q| �d�|���d S )Nr r z,Run #%s: extra-mem=%s, per-call=%s, calls=%sz. )r r r �appendrr �printrv r� ) r� r� r~ � warmup_timesr3 � tolerance�messagesZprev_memZincrease�idxrh rq �successry ry rz � _check_mem� s( � zTestMemoryLeak._check_memc C s |� S r� ry )r� r� ry ry rz ru s zTestMemoryLeak.callNc C s� |dur |n| j }|dur |n| j}|dur0|n| j}|durB|n| j}zD|dksZJ d��|dksjJ d��|dkszJ d��|dks�J d��W n0 ty� } ztt|���W Y d}~n d}~0 0 | �||� | �|� | j |||||d� dS ) zTest a callable.Nr ztimes must be >= 1r zwarmup_times must be >= 0zretries must be >= 0ztolerance must be >= 0)r~ r� r3 r� ) r~ r� r3 r� �AssertionErrorr� r� r r{ r� )r� r� r~ r� r3 r� r ry ry rz �execute s$ �" �zTestMemoryLeak.executec s& � ��fdd�}�j |fi |�� dS )znConvenience method to test a callable while making sure it raises an exception on every call. c s �� � �� d S r� )r` ry �r8 r� r� ry rz ru s z*TestMemoryLeak.execute_w_exc.<locals>.callN)r� )r� r8 r� r� ru ry r� rz � execute_w_exc s z TestMemoryLeak.execute_w_exc)NNNN)r� r� r� r� r~ r� r� r* r3 rp r� r� rf ri rl rr r{ r r� ru r� r� ry ry ry rz rC � s$ � rC c C s� dd l } dd l}dd l}dd l}| �� }|�� |d< tjrLt|� � �|d< nBtj r�d� t t|� � ��|d< t|d�r�|�� |d< n |�� |d< tjr�d� t tt� ��|d< d � t|�� �|�� g �|d < |�� |d < d � |�� |�� |�� g�|d < tj�r|�� d }|�r||d< t� � |d< |j� � � d�|d< |� � |d< t �!� |d< t"d� |�#� D ] \}}t"d|d |f � �q`t"d� d S )Nr ZOS�version� � win32_editionZeditionr Zkernelz, �arch�hostnamer} r �glibcz fs-encodingz%Y-%m-%d %H:%M:%Sr� �userr� zF======================================================================z%-14s %s�:)$� collections�datetime�getpass�platform� OrderedDict�systemr� ZOSXr� �mac_verr r� �map� win32_verr+ r� r� r rM �list� architecture�machine�node�python_implementation�python_version�python_compiler�libc_verr� �getfilesystemencoding�now�strftime�getuserr� �getpidr� �items)r� r� r� r� �infor� �k�vry ry rz rG " sH � � rG c C s4 t �� } t| d�r| �� S t| d�r0| �� d S dS )Nrk rd r )r� r� r+ rk rd )r� ry ry rz �_get_eligible_cpuI s r� c @ sB e Zd ZdZddi fddi fgZddi fddddifd di fd di fd di fd di fd di fddi fddi fg Zddi fddddifddi fddi fddi fddi fddi fddi fddi fd di fd di fd di fd di fd di fd!di fd"di fd#di fgZe�rFed$di fg7 Zed%di fg7 Zed&di fg7 Zed'di fg7 Ze�r\ed(di fg7 Ze �rred)di fg7 Ze �r�ed*e j fi fg7 Ze �r�ed+di fg7 Ze�r�ed,di fg7 Ze�r�ed-di fg7 Ze�r�ed.di fg7 Ze�r�ed/dd0d1ifg7 Zg Ze�red di fg7 Zned e jfi fg7 Ze �rJed*e j d2fi fg7 Ze �r�e�rned)e jd3fi fg7 Zned)e jfi fg7 Ze �r�ed+e� gfi fg7 Zd4ejfi fd5di fd6di fd7di fd8di fgZe�r�ed4ejfi fg7 Zed4ej fi fg7 Zee e e Z d9d:� Z dDd;d<�Z d=d>� Z e!d?d@� �Z"e!dAdB� �Z#dCS )ErE 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_percentry Zmemory_percent�as_dictr r Tra Zmemory_info_exZoneshotr� �parentsr� r� �r Zcmdline� connections�kind�all� cpu_timesZ create_timer� rx rg Z memory_infor� �niceZnum_ctx_switchesZ num_threadsZ open_filesZppidr� rq �usernameZuids�gidsZterminalrj rl rh rm rd rk rg rk ri �groupedF)r� i r r Zsuspend�resumer; �killc C s || _ d S r� )�_procrc ry ry rz r� � s zprocess_namespace.__init__c c s` t |�}t�|� |D ]D\}}}|r,| �� t| j|�}tj|g|�R i |��}||fV qdS �z_Given a list of tuples yields a set of (fun, fun_name) tuples in random order. N)r� �random�shuffle� clear_cacher� r� r� rH )r� �lsr� �fun_namer� r� r� ry ry rz �iter� 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� ry ry rz r� � s z process_namespace.clear_cachec C s> |D ]4\}}}d| }t ||�sd|jj|f }t|��qdS )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)r+ r� r� �AttributeError)�clsZ test_classr� r� r� � meth_namerq ry ry rz �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� ry r� ry ry rz r� � r� z*process_namespace.test.<locals>.<listcomp>c S s g | ] }|d �qS r� ry r� ry ry rz r� � r� c S s g | ]}|d dkr|�qS )r r� ry r� ry ry rz r� � r� z!uncovered Process class names: %r)r� r� �ignoredr� r� r� r� )r� �thisr� �klassZleftoutry ry rz �test� s zprocess_namespace.testN)T)$r� r� r� r� �utilsr� �gettersr r1 r2 r5 r� Z RLIMIT_NOFILEr. r4 r0 r r3 �settersZNORMAL_PRIORITY_CLASSr ZIOPRIO_CLASS_NONEZ IOPRIO_NORMALr� r �SIGTERMZkillersZ CTRL_C_EVENTZCTRL_BREAK_EVENTr� r� r� r� � classmethodr� r� ry ry ry rz rE R s� � � � � rE c @ s� e Zd ZdZddi fddddifddddifddi fd dd difd dd difd dd difd dddifde�� fi fddddifddi fddi fddddifde�� fi fddi fddi fddi fddi fgZer�eddd difg7 Ze r�ed di fg7 Ze �red di fg7 Ze �r$ed di fg7 Ze �r:ed di fg7 Ze �r`ed di fg7 Zed!d"i fg7 Zd#di fd$e�� gfi fd%di fd&di fgZeZed'd(� �ZejZd)S )*rF 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() Z boot_timery � cpu_countZlogicalFTZ cpu_statsr� ZpercpuZdisk_io_countersZperdiskZdisk_partitionsr� � disk_usageZnet_connectionsr� Z net_if_addrsZ net_if_statsrj Zpernicr rb Z swap_memoryZusersZvirtual_memoryre rf rp ro rn Zwin_service_iterZwin_service_get)�algZ process_iterr r� Zcpu_times_percentc c sR t | �} t�| � | D ]6\}}}tt|�}tj|g|�R i |��}||fV qdS r� )r� r� r� r� r� r� rH )r� r� r� r� r� ry ry rz r� s zsystem_namespace.iterN)r� r� r� r� r� r� r� r� r/ �HAS_GETLOADAVGr9 r8 r6 r r� r� r� r� � staticmethodr� rE r� ry ry ry rz rF � sT �� rF c C s t �| �sJ | ��d| _| S )zA decorator to mark a TestCase class. When running parallel tests, class' unit tests will be run serially (1 process). T)�inspect�isclassZ _serialrun)r� ry ry rz � serialrun 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)ro )r� r� rs )r8 ry ry rz r5 + s z retry_on_failure.<locals>.logfunN)r2 r� r3 r5 )r1 r� )r3 r5 ry ry rz rB ' s �rB c s � fdd�}|S )z,Decorator to Ignore AccessDenied exceptions.c s t �� �� �fdd��}|S )Nc sB z� | i |��W S t jy< �d ur.�s.� t�d��Y n0 d S )Nzraises AccessDenied)r� Z AccessDeniedr^ �SkipTestr� �r� �only_ifry rz r� 5 s z9skip_on_access_denied.<locals>.decorator.<locals>.wrapperr� r� �r� r� rz r: 4 s z(skip_on_access_denied.<locals>.decoratorry �r� r: ry r� rz r@ 2 s r@ c s � fdd�}|S )z3Decorator to Ignore NotImplementedError exceptions.c s t �� �� �fdd��}|S )Nc sJ z� | i |��W S t yD �d ur,�s,� d� j }t�|��Y n0 d S )Nz4%r was skipped because it raised NotImplementedError)r r� r^ r� )r� r� rq r� ry rz r� E s �z;skip_on_not_implemented.<locals>.decorator.<locals>.wrapperr� r� r� r� rz r: D s z*skip_on_not_implemented.<locals>.decoratorry r� ry r� rz rA B s rA � 127.0.0.1c C sL t �t�� ��*}|�| df� |�� d W d � S 1 s>0 Y dS )zReturn an unused TCP port.r r N)� contextlib�closing�socket�bind� getsockname)�hostr� ry ry rz rR Y s rR c C s� |du r| t tfv rd}t�| |�}z@tjdvrB|�tjtjd� |�|� |tj kr`|� d� |W S t y� |� � � Y n0 dS )zBinds a generic socket.N�r r )�nt�cygwinr r^ ) r r r� r� r� � setsockopt� SOL_SOCKET� SO_REUSEADDRr� r �listenrw r� )�family�type�addrr� ry ry rz rS ` s rS c C sp t js J �tj�| �r J | ��t�tj|�}z"|�| � |tjkrL|� d� W n t yj |� � � Y n0 |S )zBind a UNIX socket.r^ ) r� r r� r� r� r� r� r� r r� rw r� )r� r� r� ry ry rz rT q s rT r� c C s� t �t�| t����}|�|� |�d� |�� }t�| t�}zL|�|� |�� }|�� \}}||kr|||fW W d � S |� � qPW n t y� |� � � Y n0 W d � n1 s�0 Y dS )z^Build a pair of TCP sockets connected to each other. Return a (server, client) tuple. r^ N) r� r� r� r r� r� r� �connectr� r� r )r� r� Zllr% Zcaddr�ary ry rz rU � s rU c C s� t js J �d }}z@t| tjd�}|�d� t�tjtj�}|�d� |�| � W n4 ty� |durp|� � |dur�|� � � Y n0 ||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 rT r� r � setblockingr� r� rw r� )r� �server�clientry ry rz rV � s rV c c s g } d }}z�| � ttjtj�� | � ttjtj�� t� rd| � ttjtj�� | � ttjtj�� tr�t r�t � }t � }t |�\}}t |tjd�}|||fD ]}| � |� q�| V W | D ] }|� � q�||fD ]}|dur�t|� q�n6| D ] }|� � q�||fD ]}|du�r t|� �q 0 dS )z1Open as many socket families / types as possible.Nr� )r� rS r� r r � SOCK_DGRAMr r r �HAS_CONNECTIONS_UNIXrK rV rT r� rI )�socksZfname1Zfname2�s1�s2Zs3r� r? ry ry rz rW � s4 � rW c C s ddl }tr(tr(ts(t|tj�s(J |��|tjkr�dd� | �d�D �}t |�dksZJ | ��|D ]"}d| krvdks^n J | ��q^ts�t | �} |� | � nb|tj kr�t| t �s�J | ��ts�t | �} |�| � n.|tjkr�t�d| �dus�J | ��n td |��dS ) z[Check a net address validity. Supported families are IPv4, IPv6 and MAC addresses. r Nc S s g | ] }t |��qS ry )r� r� ry ry rz r� � r� z%check_net_address.<locals>.<listcomp>r r � z([a-fA-F0-9]{2}[:|\-]?){6}zunknown family %r)� ipaddress�enumr r! r� �IntEnumr� r r# r$ r � IPv4Addressr r� � IPv6Addressr� ZAF_LINKr, �matchr� )r� r� r� Zocts�numry ry rz rQ � s& rQ c C sN zddl }t|d�st�W n$ ty> ddl}|�| � Y S 0 |�| �S dS )z,Backport of importlib.reload of Python 3.3+.r N�reload)� importlibr+ � ImportError�impr )�moduler r ry ry rz rX � s rX c C s� t j�t j�| ��d }tjd dkr:dd l}|�|| �S tjd d� dkrfddlm } ||| �� � S dd l }|j � || �}|j �|�}|j�|� |S d S )Nr r~ r )�SourceFileLoader)r� r� �splitextr� r� r� r Z load_sourceZimportlib.machineryr � load_module�importlib.util�util�spec_from_file_location�module_from_spec�loader� exec_module)r� r� r r r �spec�modry ry rz rY � s rY c C s t �| t� dS )zRaise a warning msg.N)�warningsrZ � UserWarning)rq ry ry rz rZ s rZ 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 |�tkV qd S r� )r� r� )r� �nry ry rz � <genexpr> r� z is_namedtuple.<locals>.<genexpr>)r� � __bases__r$ �tupler� r� r� )r� �t�br� ry ry rz r\ s r\ c # s| t rdnd� d�t| � d�}� �fdd�t�� �� D �}t�|�}t�||� z t � |� |V W t |� n t |� 0 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. r| r} z.sorQ c s6 g | ].}t j�|j�d �kr� |j�� v r|j�qS )r )r� r� r �lowerr� �rx �extry rz r� % s ��'copyload_shared_lib.<locals>.<listcomp>N) r! rK r� r� ri r� �choicerI rT �ctypes�CDLLrI )rR �dst�libsr� ry r rz r[ s r[ c # s ddl m} ddl m} d� t| � d�}� fdd�t�� �� D �}trb|sbdd� t�� �� D �}t� |�}t � ||� d }zPt � |�}|V W |d ur�t j jj}|jg|_||j�}|dkr�|� t|� nB|d u�rt j jj}|jg|_||j�}|dk�r|� t|� 0 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 )�wintypes)�WinErrorz.dllrQ c sF g | ]>}|j �� �� �rd tj �|j ��� v rd|j �� vr|j �qS )r} Zwow64)r� r r� r� r� r� �r ry rz r� ; s �r c S s( g | ] }d t j�|j��� v r|j�qS )r| )r� r� r� r r� ry ry rz r� @ s �N)r" r& r' rK r� r� ri r! r� r! rI rT ZWinDLLZwindllZkernel32� FreeLibraryZHMODULE�argtypesZ_handlerI ) rR r& r' r$ r% r� �cfiler) rC ry r( rz r[ 0 s6 � c C s t dd� d S )NTr )r< ry ry ry rz �cleanup_test_procs] s r, c C s t �| �S r� )r� �exit)r �framery ry rz r� g r� r� )N)F)TF)N)r N)N)N)r� )r� )r )r )�r� � __future__r �atexitr� r" r r� r| r� r� r� r, r� rI r r� rE rt r� rX r� r� r� r r r r r� r r r r r r Zpsutil._commonr r r Zpsutil._compatr r r r r r r r r^ Z unittest2r r �catch_warnings� simplefilterr� r� �__all__�builtin_module_namesr! rg r( r r) r r* �maxsizer- r r r, r r� r� r% r& �decoder' r� r ZASCII_FSr� r� r� rO �__file__r# r$ ZHEREr� r+ r� r. r/ r� r0 r2 r3 ZHAS_NET_IO_COUNTERSr4 r1 r5 r6 rS rn r7 rw r8 r9 Z HAS_THREADS�getuidZ SKIP_SYSCONSr� r" r� �devnullr �registerr� r� r+ r� �objectr� r� r� r� r� r� r� r= r? r> r: r� r� r; r< rM rL r1 r rO r� rP rN rI rN �contextmanagerrH rJ rK rZ rD ZskipIfrC rG r� rE rF r� rB r@ rA rR rS rT rU rV rW rQ rX rY rZ r\ r[ r, ry ry ry rz �<module> sp . - � 0 ' &- X %: � � � ! + ' B ,
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка