Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/psutil/tests/__pycache__/test_connections.cpython-39.pyc
Ðазад
a d�hb � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddl Z ddl m Z dd l m Z dd l mZ dd l mZ dd l mZ dd l mZ ddl mZ ddl mZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z ddlm Z ddlm Z ddlm!Z! ddlm"Z" dd lm#Z# dd lm$Z$ dd lm%Z% dd lm&Z& dd lm'Z' dd!lm(Z( dd"lm)Z) dd#lm*Z* dd$lm+Z+ dd%lm,Z, e �-� Z.e/ed&e0� �Z1e%G d'd(� d(e"��Z2G d)d*� d*e2�Z3e%G d+d,� d,e2��Z4e%G d-d.� d.e2��Z5G d/d0� d0e2�Z6e*�7e'd1�G d2d3� d3e2��Z8G d4d5� d5e"�Z9e:d6k�r�dd7l;m<Z< e<e=� dS )8z;Tests for net_connections() and Process.connections() APIs.� N)�closing)�AF_INET)�AF_INET6)� SOCK_DGRAM)� SOCK_STREAM)�FREEBSD)�LINUX)�MACOS)�NETBSD)�OPENBSD)�POSIX)�SUNOS)�WINDOWS)� supports_ipv6)�PY3)�AF_UNIX)� bind_socket)�bind_unix_socket)�check_net_address)�CIRRUS)�create_sockets)�enum)� get_free_port)�HAS_CONNECTIONS_UNIX)�PsutilTestCase)� reap_children)�retry_on_failure)� serialrun)�skip_on_access_denied)� SKIP_SYSCONS)�tcp_socketpair)�TRAVIS)�unittest)�unix_socketpair)� wait_for_file�SOCK_SEQPACKETc @ s. e Zd Zdd� Zdd� Zd dd�Zdd � Zd S ) � _ConnTestCasec C s$ t s ts tjdd�}|r J |��d S �N�all��kind)r r �thisproc� connections��self�cons� r0 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/psutil/tests/test_connections.py�setUp< s z_ConnTestCase.setUpc C s$ t s ts tjdd�}|r J |��d S r' )r r r+ r, r- r0 r0 r1 �tearDownB s z_ConnTestCase.tearDownr( c sd zt j|d�}W n t jy0 tr*Y dS � Y n0 � fdd�|D �}|�� |�� | �||� dS )z�Given a process PID and its list of connections compare those against system-wide connections retrieved via psutil.net_connections. r) Nc s" g | ]}|j � kr|d d� �qS )N�����pid��.0�cr5 r0 r1 � <listcomp>X � z=_ConnTestCase.compare_procsys_connections.<locals>.<listcomp>)�psutil�net_connectionsZ AccessDeniedr �sort� assertEqual)r. r6 Z proc_consr* Zsys_consr0 r5 r1 �compare_procsys_connectionsI s z)_ConnTestCase.compare_procsys_connectionsc sh � fdd�}� fdd�}� fdd�}� fdd�}� fd d �}||� ||� ||� ||� ||� d S ) z*Check validity of a connection namedtuple.c s� t | �dk}� �t | �d� � �| d | j� � �| d | j� � �| d | j� � �| d | j� � �| d | j� � �| d | j� |r�� �| d | j � d S ) N� )� rA r � � � � � rB ) �len�assertInr? �fd�family�type�laddr�raddr�statusr6 )�connZhas_pid�r. r0 r1 � check_ntuple_ s z;_ConnTestCase.check_connection_ntuple.<locals>.check_ntuplec s� � � | jtttf� td ur4t| jtj�sHJ | ��nt| jt�sHJ | ��| jtkr�t � | j| j �}t � |��^ z|� | jd df� W n4 t jy� } z|jtjkr�� W Y d }~n d }~0 0 W d � q�1 s�0 Y n| jtkr�� �| jtj� d S )Nr )rI rK r r r r � isinstance�IntEnum�int�socketrL � contextlibr �bindrM �error�errnoZ EADDRNOTAVAILr? rO r< � CONN_NONE)rP �s�errrQ r0 r1 � check_familyk s 8 z;_ConnTestCase.check_connection_ntuple.<locals>.check_familyc sf � � | jtttf� td ur4t| jtj�sHJ | ��nt| jt�sHJ | ��| jtkrb� � | j t j � d S )N) rI rL r r r% r rS rT rU r? rO r< r[ )rP rQ r0 r1 � check_type� s z9_ConnTestCase.check_connection_ntuple.<locals>.check_typec s� | j | jfD ]z}| jttfv rp� �|t� |s0q � �|jt� d|j krTdks`n J |j��t |j | j� q | jt kr � �|t � q d S )Nr i�� ) rM rN rK r r �assertIsInstance�tuple�portrU r �ipr �str)rP �addrrQ r0 r1 � check_addrs� s " z:_ConnTestCase.check_connection_ntuple.<locals>.check_addrsc sl � � | jt� dd� tt�D �}� �| j|� | jttfv rX| j t krX� � | jtj � n� � | jtj � d S )Nc S s g | ]}|� d �rtt|��qS )�CONN_)� startswith�getattrr< �r8 �xr0 r0 r1 r: � s �zO_ConnTestCase.check_connection_ntuple.<locals>.check_status.<locals>.<listcomp>)r` rO rd �dirr< rI rK r r rL r ZassertNotEqualr[ r? )rP ZvalidsrQ r0 r1 � check_status� s z;_ConnTestCase.check_connection_ntuple.<locals>.check_statusNr0 )r. rP rR r^ r_ rf rm r0 rQ r1 �check_connection_ntuple] s z%_ConnTestCase.check_connection_ntupleN)r( )�__name__� __module__� __qualname__r2 r3 r@ rn r0 r0 r0 r1 r& 9 s r& c @ s0 e Zd Ze�ed�dd� �Zdd� Zdd� ZdS ) �TestBasicOperations� requires rootc C sF t � �, tjdd�D ]}| �|� qW d � n1 s80 Y d S r' )r r< r= rn �r. rP r0 r0 r1 � test_system� s z TestBasicOperations.test_systemc C sJ t � �0 t�� jdd�D ]}| �|� qW d � n1 s<0 Y d S r' )r r< �Processr, rn rt r0 r0 r1 � test_process� s z TestBasicOperations.test_processc C s( | j ttjdd� | j ttjdd� d S )Nz???r) )Z assertRaises� ValueErrorr+ r, r< r= rQ r0 r0 r1 �test_invalid_kind� s z%TestBasicOperations.test_invalid_kindN) ro rp rq r" �skipIfr ru rw ry r0 r0 r0 r1 rr � s rr c @ s� e Zd ZdZdd� Zdd� Zdd� Ze�e � d�d d � �Z d d � Z e�e � d�d d� �Z e�e d�dd� �Ze�e d�dd� �ZdS )�TestUnconnectedSocketsz;Tests sockets which are open but not connected to anything.c C sv t jdd�}tdd� |D ��}ts&tr2||�� S | �t|�d� |d jdkrj| �||�� j|�� � |d S d S )Nr( r) c S s g | ]}|j |f�qS r0 )rJ r7 r0 r0 r1 r: � r; z=TestUnconnectedSockets.get_conn_from_sock.<locals>.<listcomp>rC r r4 ) r+ r, �dictr r �filenor? rH rJ )r. �sockr/ Zsmapr0 r0 r1 �get_conn_from_sock� s z)TestUnconnectedSockets.get_conn_from_sockc C s� | � |�}| �|� |jdkr0| �|j|�� � | �|j|j� | �|j|�tj tj �� |� � }|s|t r|t |t�r||�� }|jtkr�|dd� }|jtkr�tr�n| �|j|� |jtkr�tr�tjdd�}| jt�� |dd� |S )z�Given a socket, makes sure it matches the one obtained via psutil. It assumes this process created one connection only (the one supposed to be checked). r4 NrD r( r) )r rn rJ r? r} rK rL � getsockoptrV � SOL_SOCKET�SO_TYPE� getsocknamer rS �bytes�decoder r r rM r r+ r, r@ �os�getpid)r. r~ rP rM r/ r0 r0 r1 � check_socket� s( � z#TestUnconnectedSockets.check_socketc C sd dt � f}tttt|d���4}| �|�}|jr2J �| �|jt j � W d � n1 sV0 Y d S �N� 127.0.0.1�re ) r r r r r r� rN r? rO r< � CONN_LISTEN�r. re r~ rP r0 r0 r1 � test_tcp_v4� s z"TestUnconnectedSockets.test_tcp_v4zIPv6 not supportedc C sd dt � f}tttt|d���4}| �|�}|jr2J �| �|jt j � W d � n1 sV0 Y d S �N�::1r� ) r r r r r r� rN r? rO r< r� r� r0 r0 r1 � test_tcp_v6� s z"TestUnconnectedSockets.test_tcp_v6c C sd dt � f}tttt|d���4}| �|�}|jr2J �| �|jt j � W d � n1 sV0 Y d S r� ) r r r r r r� rN r? rO r< r[ r� r0 r0 r1 � test_udp_v4� s z"TestUnconnectedSockets.test_udp_v4c C sd dt � f}tttt|d���4}| �|�}|jr2J �| �|jt j � W d � n1 sV0 Y d S r� ) r r r r r r� rN r? rO r< r[ r� r0 r0 r1 � test_udp_v6 s z"TestUnconnectedSockets.test_udp_v6� POSIX onlyc C s` | � � }tt|td���4}| �|�}|jr.J �| �|jtj � W d � n1 sR0 Y d S �N)rL � � get_testfnr r r r� rN r? rO r< r[ �r. �testfnr~ rP r0 r0 r1 � test_unix_tcp s z$TestUnconnectedSockets.test_unix_tcpc C s` | � � }tt|td���4}| �|�}|jr.J �| �|jtj � W d � n1 sR0 Y d S r� r� r� r0 r0 r1 � test_unix_udp s z$TestUnconnectedSockets.test_unix_udpN)ro rp rq �__doc__r r� r� r" rz r r� r� r� r r� r� r0 r0 r0 r1 r{ � s # r{ c @ s: e Zd ZdZe�ed�dd� �Ze�e d�dd� �Z dS ) �TestConnectedSocketzJTest socket pairs which are are actually connected to each other. zunreliable on SUONSc C s� dt � f}tjdd�rJ �tt|d�\}}zXtjdd�}| �t|�d� | �|d jtj � | �|d jtj � W |� � |� � n|� � |� � 0 d S )Nr� �tcp4r) r� rD r rC ) r r+ r, r r r? rH rO r< ZCONN_ESTABLISHED�close)r. re �server�clientr/ r0 r0 r1 �test_tcp% s �z TestConnectedSocket.test_tcpr� c s� | � � }t|�\�� �z\tjdd�}|d jr<|d jr<J �|d jrT|d jrTJ �ts\tr�dd� |D �}tr�� �fdd�|D �}| j t |�d|d � t s�ts�t r�| � |d jd � | � |d jd � | � ||d jp�|d j� n|t �r$|d j|d j|d j|d jfD ]}| � |d � �qn<| � |d j�p<|d j|� | � |d j�pZ|d j|� W ��� � �� n��� � �� 0 d S ) N�unixr) r rC c S s g | ]}|j d kr|�qS )z /var/run/log)rN r7 r0 r0 r1 r: D r; z1TestConnectedSocket.test_unix.<locals>.<listcomp>c s& g | ] }|j ��� � �� fv r|�qS r0 )rJ r} r7 �r� r� r0 r1 r: F s �rD ��msg� )r� r# r+ r, rM rN r r r r? rH r r r r� )r. r� r/ re r0 r� r1 � test_unix9 s4 � �z TestConnectedSocket.test_unixN) ro rp rq r� r" rz r r� r r� r0 r0 r0 r1 r� s r� c @ s. e Zd Zdd� Zeed�dd� �Zdd� ZdS ) � TestFiltersc s� � fdd�}t � �� |dtttgtttg� |dttgttg� |dtgttg� |dttgtg� |dtgtg� |dtgtg� |d ttgtg� |d tgtg� |d tgtg� tr�|d tgtttg� W d � n1 s�0 Y d S ) Nc sd t j| d�D ] }� �|j|� � �|j|� q ts`tj| d�D ] }� �|j|� � �|j|� q>d S )Nr) )r+ r, rI rK rL r r< r= )r* �families�typesrP rQ r0 r1 �checka s z'TestFilters.test_filters.<locals>.checkr( �inet�inet4�tcpr� �tcp6�udp�udp4�udp6r� )r r r r r r r% r )r. r� r0 rQ r1 � test_filters` sV ����������zTestFilters.test_filters)Zonly_ifc s� t � � fdd�}t�d�}t�d�}tj�� jt�� d��}|jt t �d|d�}|jt t �d|d�}|jt t �d|d�}|jt t �d|d�}� � |�} t t|d d ��} � � |�} t t|d d ��} t� r�� � |�} t t|d d ��}� � |�}t t|d d ��}nd } d }d }d }t�� D ]�}|�� }� �t|�d � |D ]�}|j| jk�rb|||t t| d tjd � n�|j| jk�r�|||t t| d tjd� nZ|jt| dd �k�r�|||t t|d tjd� n,|jt|dd �k�r6|||t t|d tjd� �q6�qd S )Nc s� d}� � |� � �|j|� � �|j|� � �|j|� � �|j|� � �|j|� |D ].} | j| d�} | |v rz| s�J �qX| rXJ | ��qXtr�� � | j |g� d S )N) r( r� r� �inet6r� r� r� r� r� r� r) ) rn r? rK rL rM rN rO r, r r@ r6 ) �procrP rK rL rM rN rO �kindsZ all_kindsr* r/ rQ r0 r1 � check_conn� s z+TestFilters.test_combos.<locals>.check_conna import socket, time s = socket.socket({family}, socket.SOCK_STREAM) s.bind(('{addr}', 0)) s.listen(5) with open('{testfn}', 'w') as f: f.write(str(s.getsockname()[:2])) time.sleep(60) a import socket, time s = socket.socket({family}, socket.SOCK_DGRAM) s.bind(('{addr}', 0)) with open('{testfn}', 'w') as f: f.write(str(s.getsockname()[:2])) time.sleep(60) )rl r� )rK re r� r� T)�deleterC r0 )r( r� r� r� r� )r( r� r� r� r� r6 )r( r� r� r� r� )r( r� r� r� r� ) r �textwrap�dedentr� �path�basenamer� �getcwd�formatrU r r �pyrun�evalr$ r r+ �childrenr, r? rH r6 r r< r� r r[ ri )r. r� Z tcp_templateZ udp_templateZtestfileZ tcp4_templateZ udp4_templateZ tcp6_templateZ udp6_templateZ tcp4_procZ tcp4_addrZ udp4_procZ udp4_addrZ tcp6_procZ tcp6_addrZ udp6_procZ udp6_addr�pr/ rP r0 rQ r1 � test_combos� sl � � � � ����zTestFilters.test_combosc C s� t � ��� tjdd�}| �t|�t� r*dnd� |D ]$}| �|jtt f� | �|j t � q4tjdd�}| �t|�d� | �|d jt� | �|d j t � t� r�tjdd�}| �t|�d� | �|d jt � | �|d j t � tjdd�}| �t|�t� �rdnd� |D ]&}| �|jtt f� | �|j t � �q tjd d�}| �t|�d� | �|d jt� | �|d j t � t� �r�tjd d�}| �t|�d� | �|d jt � | �|d j t � tjd d�}| �t|�t� �r�d nd� |D ]*}| �|jtt f� | �|j t t f� �q�t� �rdtjd d�}| �t|�d� |D ]&}| �|jt � | �|j t t f� �q<t �r�t�s�t�s�tjdd�}| �t|�d� |D ]&}| �|jt� | �|j t t f� �q�W d � n1 �s�0 Y d S )Nr� r) rD rC r� r r� r� r� r� r� rF r� r� rE )r r+ r, r? rH r rI rK r r rL r r r r r r )r. r/ rP r0 r0 r1 � test_count� s\ zTestFilters.test_countN)ro rp rq r� r r r� r� r0 r0 r0 r1 r� ^ s + `r� rs c @ s6 e Zd ZdZdd� Ze�eo ed�e � dd� ��Z dS )�TestSystemWideConnectionsz Tests for net_connections().c s� � fdd�}t � �r ddlm} |�� D ]L\}}|dkr>ts>q(|\}}t�|�}� �t|�tt |��� ||||� q(W d � n1 s�0 Y d S )Nc sF | D ]<}� j |j||d� |jtkr6� j |j||d� � �|� qd S )Nr� )rI rK r rL rn )r/ r� �types_rP rQ r0 r1 r� , s z0TestSystemWideConnections.test_it.<locals>.checkr )� conn_tmapr� ) r �psutil._commonr� �itemsr r< r= r? rH �set)r. r� r� r* �groupsr� r� r/ r0 rQ r1 �test_it+ s z!TestSystemWideConnections.test_itz unreliable on MACOS + TRAVISc s� t � �}t|�}W d � n1 s$0 Y g �d}g }t|�D ]:}| �� }|�|� t�d| �}| �|�}��|j� qB|D ] }t |� q��fdd�t j dd�D �} �D ]B� | � t� fdd�| D ��|� t � � �} | � t| �d��|� q�d S )N� a import time, os from psutil.tests import create_sockets with create_sockets(): with open(r'%s', 'w') as f: f.write("hello") time.sleep(60) c s g | ]}|j � v r|�qS r0 r5 rj )�pidsr0 r1 r: _ s �zFTestSystemWideConnections.test_multi_sockets_procs.<locals>.<listcomp>r( r) c s g | ]}|j � kr|�qS r0 r5 rj r5 r0 r1 r: b r; )r rH �ranger� �appendr� r� r� r6 r$ r< r= r? rv r, ) r. �socks�expected�times�fnames�i�fname�srcZsprocZsysconsr� r0 )r6 r� r1 �test_multi_sockets_procs? s, & � � z2TestSystemWideConnections.test_multi_sockets_procsN) ro rp rq r� r� r" rz r r! r r� r0 r0 r0 r1 r� ' s r� c @ s e Zd Zdd� ZdS )�TestMiscc C s� g }g }t t�D ]\}|�d�rtt|�}t|�}|�� s@J |��| �t|� | �||� |�|� |�|� qtr~tj tj t r�tj d S )Nrg ) rl r< rh ri rd �isupperZ assertNotInr� r Z CONN_IDLEZ CONN_BOUNDr ZCONN_DELETE_TCB)r. Zints�strs�name�numZstr_r0 r0 r1 �test_connection_constantsj s z"TestMisc.test_connection_constantsN)ro rp rq r� r0 r0 r0 r1 r� h s r� �__main__)� run_from_name)>r� rW rZ r� rV r� r r r r r r< r r r r r r r r r� r Zpsutil._compatr Z psutil.testsr r r r r r r r r r r r r r r r r! r" r# r$ rv r+ ri �objectr% r& rr r{ r� r� rz r� r� ro Zpsutil.tests.runnerr� �__file__r0 r0 r0 r1 �<module> st nb@ J @
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка