Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/__pycache__/transport.cpython-39.pyc
Ðазад
a ]�h� � @ st d dl Z d dlZd dlZd dlZd dlZd dlZG dd� de�ZG dd� de�Z G dd� de�Z G dd � d e�Z dS ) � Nc @ s e Zd Zdd� Zdd� ZdS )�IdCachec C s< t � � }|d }t| �� �D ]\}}||k r | �|� q d S )N�< )�time�tuple�items�pop)�self� current_timeZ collect_time�mid�meta� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/transport.py� invalidate s zIdCache.invalidatec C s& t | �dkr| �� t�| ||� d S )N�d )�lenr �dict� __setitem__)r �key�valuer r r r s zIdCache.__setitem__N)�__name__� __module__� __qualname__r r r r r r r s r c @ s@ e Zd Zdd� Zedd� �Zdd� Zdd� Zd d � Zd d � Z d S )�Peerc C s4 || _ || _d | _|| _|| _|| _d| _d| _d S )Nr )�address�port�socket� remote_id�local_id�cache�version�last_exception_time)r r r r r r r r r �__init__ s z Peer.__init__c C s | j d uS �N)r �r r r r � connected" s zPeer.connectedc C s* | j r d}nd}d| j| j| j| j|f S )Nz not connectedr$ z[%s-%s] %s:%s [%s])r$ r r r r )r r$ r r r �__repr__& s �z Peer.__repr__c C sJ t t�� j�}|| jvr t�� | j|< q*q t�d|dd��}| �|� d S )N�systemZHELLO)�type�id�data) �str�uuid�uuid4�hexr r �pickle�dumps�send)r � message_idr) r r r �hello3 s �z Peer.helloc C s� t |�}t�d|| j| j�| }| jd u r�t�� | j dk r@d S t�tjtj �| _z | j� | j | j f� | � � W n$ ty� t�� | _d | _Y d S 0 z| j�|� W n: ty� z| j�� W n ty� Y n0 d | _Y n0 d S )N�III� )r �struct�packr r r r r �AF_INET� SOCK_STREAM�connectr r r2 � Exceptionr0 �close)r r) �lengthr r r r0 > s* z Peer.sendc C s | j �� d S r" �r r; r# r r r r; U s z Peer.closeN) r r r r! �propertyr$ r% r2 r0 r; r r r r r s r c @ s6 e Zd Zdd� Zdd� Zd dd�Zdd � Zd d � ZdS ) � Transportc C s| g | _ || _|| _d| _t�tjtj�| _| j�tjtj d� | j�tjtj d� | j� | j| jf� | j� d� g | _ d S )Nr i � � )�peersr r r r r7 r8 � setsockopt� SOL_SOCKET� SO_RCVBUF� SO_REUSEADDR�bind�listen�stream_endpoints)r r r r r r r! Z s zTransport.__init__c C s | j �|� d S r" )rB �append)r �peerr r r �add_peerf s zTransport.add_peerNc C s6 |pg }g }| j D ] }|j|vr|�|�|�� q|S r" )rB r rJ r0 )r r) �exclude�retrK r r r r0 i s zTransport.sendc C s� | j g| j }t�|g |�\}}}|D ]"}|| jv r&| j�| j�|�� q&|D ]�}|| j krx| j �� \}}| j�|� qN|�d�}t|�dkr�| j�| j�|�� qNt � d|�\} } } | | j kr�qNd}t|�| k r�||�| t|� �7 }q�|| f S qNq d S )N� r r3 � ) r rI �selectr �index�acceptrJ �recvr r5 �unpackr ) r �fdsZrlistZwlistZxlist�fdZnew_fd�raddrr) r< r r r r r �getq s4 �� �� z Transport.getc C s | j �� d S r" r= r# r r r r; � s zTransport.close)N)r r r r! rL r0 rY r; r r r r r? Y s r? c @ s> e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � ZdS )� MessengerNc C s* || _ |ptdd�| _t� | _t� | _d S )Nz 127.0.0.1i0 )r r? � transport�set�targetsr �id_cache)r r r[ r r r r! � s zMessenger.__init__c C s | S r" r r# r r r �__iter__� s zMessenger.__iter__c C s | � � }|d ur |S q d S r" )�handle)r �msgr r r �__next__� s zMessenger.__next__c C s� | j �� \}}t�|�}|d | jv r*d S |d dkrL| j j||gd� |S t�� | j|d < |d dkr~|d | jv r~d }n |d dkr�|d | jvr�d }| j j||gd� |S )Nr( r' r& )rM r[ �target�api)r[ rY r. �loadsr^ r0 r r] )r r) r �messager r r r` � s( � � � �zMessenger.handlec C sP d|� dd�t�� jf }|| jvr t�� | j|< q6q ||d< | j�t� |��S )Nz%s-%src �-r( ) rY r+ r, r- r^ r r[ r0 r. r/ )r rf r1 r r r �emit� s � zMessenger.emitc C s$ t || j||| j�}| j�|� d S r" )r r r^ r[ rL )r r r r rK r r r rL � s zMessenger.add_peer)N) r r r r! r_ rb r` rh rL r r r r rZ � s rZ ) r. rQ r r5 r r+ r r �objectr r? rZ r r r r �<module> s B<
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка