Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/netlink/diag/__pycache__/ss2.cpython-39.pyc
Ðазад
a ]�h�I � @ sJ d dl Z d dlZd dlZd dlZd dlZd dlmZmZ z d dlZW n eyZ dZY n0 d dl m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZ zd dlm Z m Z W n" ey� d dl m Z m Z Y n0 dZ G dd� de �Z G dd � d e �Z!G d d � d e!�Z"G d d � d e!�Z#dd� Z$ddd�Z%e&dk�rFe%� dS )� N)�AF_INET�AF_UNIX)�SS_ALL�SS_CLOSE� SS_CLOSE_WAIT� SS_CLOSING�SS_CONN�SS_ESTABLISHED� SS_FIN_WAIT1� SS_FIN_WAIT2� SS_LAST_ACK� SS_LISTEN� SS_SYN_RECV� SS_SYN_SENT� SS_TIME_WAIT�UDIAG_SHOW_NAME�UDIAG_SHOW_PEER�UDIAG_SHOW_VFS� DiagSocket)�Callable�MappingFc @ sx e Zd Ze�d�ZdZg d�Zdd� Zdddddg fdd�Z d d � Z d d � Z d d� Z dd� Z dd� Zdd� Zdd� ZdS )� UserCtxtMapzsocket:\[(?P<ino>\d+)\]z/proc/%d/fd/%d)�inode�usr�pid�fdc C sB | j |j|jf }d }t�|�}| j�|��d�}|s>td��|S )N�inoz"Unexpected kernel sk inode outline) �_proc_sk_fd_castr r �os�readlink� _sk_inode_re�search�group� RuntimeError)�selfZsconnZsk_pathr Z sk_inode_raw� r% ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/netlink/diag/ss2.py� _parse_inodeE s zUserCtxtMap._parse_inodeNc C s� |� d�}| jd |kr2|| j�� vr�i | j|< n�| jd |krb|| j| �� vr�i | j| |< nr| jd |kr�|| j| | �� vr�| j| | �||� n6| jd |kr�| j| | | d �|� d S td��| j||||||d� d S )Nr � � � �fdsz Unexpected step in recursion�� _sk_inode�_sk_fd�_usr�_pid�_ctxt� _recurs_path)�pop�_BUILD_RECURS_PATH�_data�keys� __setitem__�appendr# �_UserCtxtMap__recurs_enter)r$ r- r. r/ r0 r1 r2 �stepr% r% r& Z__recurs_enterQ s, �zUserCtxtMap.__recurs_enterc C sD |j s d S t| �|��}|j}t| j�}| j||||j ||d� d S )Nr, )r �intr' r �listr4 r9 )r$ r �flow�ctxt�sk_inodeZsk_fdZ recurs_pathr% r% r& � _enter_itemz s �zUserCtxtMap._enter_itemc C sl t jdd�D ]Z}z:t �|j�}|�� }|�� |�� g d�}| �|||� W q tt t j fyd Y q 0 q d S )N�all)�kind)�cmdZfull_cmdr+ ) �psutilZnet_connections�Processr �username�exeZcmdliner@ �FileNotFoundError�AttributeErrorZ NoSuchProcess)r$ r= �procr r> r% r% r& �_build� s �zUserCtxtMap._buildc C s i | _ | �� d S �N)r5 rK �r$ r% r% r& �__init__� s zUserCtxtMap.__init__c C s | j | S rL )r5 �r$ �keyr% r% r& � __getitem__� s zUserCtxtMap.__getitem__c C s t | j�� �S rL )�lenr5 r6 rM r% r% r& �__len__� s zUserCtxtMap.__len__c C s t d��d S �NzNot implemented�r# rO r% r% r& � __delitem__� s zUserCtxtMap.__delitem__c C s t d��d S rT rU rM r% r% r& �__iter__� s zUserCtxtMap.__iter__)�__name__� __module__� __qualname__�re�compiler r r4 r' r9 r@ rK rN rQ rS rV rW r% r% r% r& r > s$ � )r c @ s, e Zd ZG dd� d�Zd dd�Zdd� ZdS ) �Protocolc @ s e Zd Zedd� �ZdS )zProtocol.Resolverc C s6 z t �| �}t|d �}|W S ty0 Y d S 0 d S )Nr )�socket� gethostbyaddr�str� Exception)�ip�data�hostr% r% r& �getHost� s zProtocol.Resolver.getHostN)rX rY rZ � staticmethodre r% r% r% r& �Resolver� s rg �jsonc C s( || _ d| }t| |d �| _dd� }d S )Nz_fmt_%sc S s t d��d S )Nznot implementedrU )r$ � nl_diag_sk�args�usr_ctxtr% r% r& �__call__� s z#Protocol.__init__.<locals>.__call__)�_states�getattr�_fmt)r$ � sk_states�fmtZfmterrl r% r% r& rN � s zProtocol.__init__c C s t j|dd�S )N� ��indent)rh �dumps)r$ � refined_statsr% r% r& � _fmt_json� s zProtocol._fmt_jsonN)rh )rX rY rZ rg rN rw r% r% r% r& r] � s r] c s2 e Zd Zedf� fdd� Zdd� Zdd� Z� ZS )�UNIXrh c s t t| �j||d� d S )N�rq )�superrx rN )r$ rp ro �� __class__r% r& rN � s z UNIX.__init__c C s* |j | jtttB tB d�}| �||�}|S )N)�states�family�show)�get_sock_statsrm r r r r �_refine_diag_raw�r$ ri rj rk Zsstatsrv r% r% r& rl � s � z UNIX.__call__c C s� ddg ii}dd� }d}d}d}dd|fd d d �}|D ]p} i } | d | d < | d D ]@} | | } | | } || | }|| | }|r�|| �} | | |< qR|d d � | � q6|r�|d d D ]0}z|d }|| |d< W q� ty� Y q�0 q�|S )Nrx �flowsc S s i }| d |d< | d |d< |S )NZ udiag_vfs_inor Z udiag_vfs_dev�devr% )Zraw_val�outr% r% r& �vfs_cb� s z%UNIX._refine_diag_raw.<locals>.vfs_cbr r( )� path_nameNZvfs)Z peer_inodeN)�shutdownN)ZUNIX_DIAG_NAMEZ UNIX_DIAG_VFSZUNIX_DIAG_PEERZUNIX_DIAG_SHUTDOWNZ udiag_inor �attrsrk )r8 �KeyError)r$ � raw_statsrk �refinedr� �k_idxZval_idx�cb_idxZidiag_attr_refine_map�raw_flow�vessel�attrZattr_kZattr_val�k�cbr= r? r% r% r& r� � s< � zUNIX._refine_diag_raw)rX rY rZ r rN rl r� � __classcell__r% r% r{ r& rx � s rx c s` e Zd ZdZdZdZdZedf� fdd� Zdd � Z d d � Z d d � Z G dd� d�Z dd� Z � ZS )�TCPr( r) r* rr rh c sR t t| �j||d� | j| j| j| jg}d| _|D ]}| jd|d > O _q2d S )Nry r r( )rz r� rN �INET_DIAG_MEMINFO�INET_DIAG_INFO�INET_DIAG_VEGASINFO�INET_DIAG_CONG�ext_f)r$ rp ro ZIDIAG_EXT_FLAGS�fr{ r% r& rN s �z TCP.__init__c C s( |j | jt| jd�}| �||j|�}|S )N)r} r~ � extensions)r� rm r r� r� �resolver� r% r% r& rl s �z TCP.__call__c C s ddg ii}ddddddd d �}|D ]R}i }|� � D ]\}} || ||< q4|d D ]} | �|| �}qR|d d �|� q$|r�|d d D ]0} z| d } || | d < W q� ty� Y q�0 q�|�r |d d D ]<} tj�| d �} | r�| | d< tj�| d �}|r�|| d< q�|S )Nr� r� Z idiag_srcZ idiag_dstZ idiag_sportZ idiag_dportZ idiag_inodeZidiag_ifZ idiag_retrans)�src�dstZsrc_portZdst_portr Z iface_idx�retransr� r rk r� �src_hostr� �dst_host)�items�_refine_extensionr8 r� r] rg re )r$ r� Z do_resolverk r� Zidiag_refine_mapr� r� �k1�k2Z ext_bundler= r? r� r� r% r% r& r� ( s@ � zTCP._refine_diag_rawc C s� |\}}dddddd�i}|dkrVd}i ||< || � � D ]\}}|| || |< q:n0|dkrh||d < n |d kr~| �||�}n|d kr�|S ) NZmeminfoZ idiag_rmemZ idiag_wmemZ idiag_fmemZ idiag_tmem)�r�wr� �tr� r� Z cong_algor� ZINET_DIAG_SHUTDOWN)r� �_refine_tcp_info) r$ r� Zraw_extr� �contentZext_refine_mapZmem_kr� r� r% r% r& r� T s& �� zTCP._refine_extensionc @ sT e Zd Zedd� �Zedd� �Zedd� �Zedd� �Zed d � �Zed d � �Z d S )zTCP.InfoCbCorec K s d }|dkr|d }|S )Ni��- � @�@r% )rP �value�ctxr� r% r% r& �rto_n_cbt s zTCP.InfoCbCore.rto_n_cbc K s |d S )Nr� r% �rP r� r� r% r% r& �generic_1k_n_cb| s z TCP.InfoCbCore.generic_1k_n_cbc K s |dk r |S d S )Ni�� r% r� r% r% r& �snd_thresh_p_cb� s z TCP.InfoCbCore.snd_thresh_p_cbc K sN |d }z&|d dkr,|d dkr,|d W S W n t y@ Y n0 |d d S )N�raw� tcpv_enabledr �tcpv_rtti����tcpi_rttr� )r� )rP r� r� � tcp_info_rawr% r% r& �rtt_p_cb� s � � zTCP.InfoCbCore.rtt_p_cbc K s8 t dtdtdtdtdtdtdtdtd t d t d i }|| S ) NZ establishedzsyn-sentzsyn-recvz fin-wait-1z fin-wait-2z time-waitZ unconnectedz close-waitzlast-ackZ listening�closing) r r r r r r r r r r r )rP r� r� Z state_str_mapr% r% r& � state_c_cb� s �zTCP.InfoCbCore.state_c_cbc K sZ |d }d}d}d}g }|d }||@ r2|� d� ||@ rD|� d� ||@ rV|� d� |S ) Nr� r( r) � � tcpi_options�tsZsackZecn)r8 ) rP r� r� r� ZTCPI_OPT_TIMESTAMPSZ TCPI_OPT_SACKZ TCPI_OPT_ECNr� �optsr% r% r& � opts_c_cb� s zTCP.InfoCbCore.opts_c_cbN) rX rY rZ rf r� r� r� r� r� r� r% r% r% r& � InfoCbCorer s r� c ? C sT t j}d|jfddd|jfd|jfdddd d |jfd |jfd |jfd |jfdd|jfdddddddddddddd d d d d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d0d0d0d1d2d3d4d5d6d7d8d9d:d;�>}d<}d=}d>}i ||< t|t ��sP|� � D ]n\}} ||vr�q�|| | } || | } | } | �r"| d?k�r"q�n | �rBd@|i} | || fi | ��} | || | < q�|S )AN�state)ZpmtuN)r� NZatoZrto)Z snd_wscaleN)Z rcv_wscaleN)Zsnd_mssN)Zsnd_cwndNZ snd_ssthreshZrttZrttvarZrcv_rtt)Z rcv_spaceNr� )Zlast_data_sentN)Z rcv_ssthreshN)Zsegs_inN)Zsegs_outN)Z data_segs_inN)Z data_segs_outN)ZlostN)Z notsent_bytesN)Zrcv_mssN)Z pacing_rateN)Z retransmitsN)Zmin_rttN)Z rwnd_limitedN)Zmax_pacing_rateN)ZprobesN)Z reorderingN)Zlast_data_recvN)�bytes_receivedN)ZfacketsN)Z last_ack_recvN)Z last_ack_sentN)ZunackedN)ZsackedN)Z bytes_ackedN)Zdelivery_rate_app_limitedN)Z delivery_rateN)Zsndbuf_limitedN)Zca_stateN)Z busy_timeN)Z total_retransN)ZadvmssN)NN)N�skip)� bbr_bw_loN)� bbr_bw_hiN)� bbr_min_rttN)�bbr_pacing_gainN)� bbr_cwnd_gainN)� dctcp_enabledN)�dctcp_ce_stateN)� dctcp_alphaN)� dctcp_ab_ecnN)� dctcp_ab_totN)>Z tcpi_stateZ tcpi_pmtuZ tcpi_retransZtcpi_atoZtcpi_rtoZtcpi_snd_wscaleZtcpi_rcv_wscaleZ tcpi_snd_mssZ tcpi_snd_cwndZtcpi_snd_ssthreshr� Z tcpi_rttvarZ tcpi_rcv_rttZtcpi_rcv_spacer� Ztcpi_last_data_sent�tcpi_rcv_ssthreshr� Z tcpi_segs_inZ tcpi_segs_outZtcpi_data_segs_inZtcpi_data_segs_outZ tcpi_lostZtcpi_notsent_bytesZ tcpi_rcv_mssZtcpi_pacing_rateZtcpi_retransmitsZ tcpi_min_rttZtcpi_rwnd_limitedZtcpi_max_pacing_rateZ tcpi_probesZtcpi_reorderingZtcpi_last_data_recvZtcpi_bytes_receivedZ tcpi_facketsZtcpi_last_ack_recvZtcpi_last_ack_sentZ tcpi_unackedZ tcpi_sackedZtcpi_bytes_ackedZ tcpi_delivery_rate_app_limitedZtcpi_delivery_rateZtcpi_sndbuf_limitedZ tcpi_ca_stateZtcpi_busy_timeZtcpi_total_retransZ tcpi_advmssZ tcpi_backoffr� Z tcpv_rttcntr� Z tcpv_minrttr� r� r� r� r� r� r� r� r� r� r r( Ztcp_infor� r� ) r� r� r� r� r� r� r� r� � isinstancer` r� )r$ r� r� �tiZinfo_refine_tablr� r� Zinfo_kr� �vZ refined_kr� Z refined_vr� r% r% r& r� � s� �I zTCP._refine_tcp_info)rX rY rZ r� r� r� r� r rN rl r� r� r� r� r� r% r% r{ r& r� s , Nr� c C s� t jdd�} | jddddd� | jdd d dd� | jd d d dd� | jddddd� | jddddd� | jddddd� | �� }|S )Nz� ss2 - socket statistics depictor meant as a complete and convenient surrogate for iproute2/misc/ss2)� descriptionz-xz--unixz Display Unix domain sockets.� store_true)�help�actionz-tz--tcpzDisplay TCP sockets.z-lz--listenzDisplay listening sockets.z-az--allzDisplay all sockets.z-pz --processzshow socket holding contextz-rz --resolvez resolve host names in addition)�argparse�ArgumentParser� add_argument� parse_args)�parserrj r% r% r& � prepare_args% sF �������r� c C s� t d u rtd��| st� } t}| jr,dt> }| jr6t}g }| jrP|� t |d�� | j rf|� t |d�� |srtd��d }| j r�t� }t� }t� �8}|�� |D ]}||| |�}|� |� q�W d � n1 s�0 Y tr�|S ttj|dd�� d S )Nz(ss2 requires python-psutil >= 5.0 to runr( )rp z¬ implemented - ss2 in fledging moderr rs )rD r# r� r �listenr rA r Ztcpr8 r� �unixrx �processr r< r �bind� RUN_AS_MODULE�printrh ru )rj rm Z protocolsZ_user_ctxt_map�resultZds�pZsub_statisticsr% r% r& �runP s8 *r� �__main__)N)'r� rh r r[ r^ r r rD � ImportErrorZpyroute2.netlink.diagr r r r r r r r r r r r r r r r r �collections.abcr r � collectionsr� r r] rx r� r� r� rX r% r% r% r& �<module> s2 L u@ + )
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка