File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/__pycache__/portend.cpython-310.pyc
Back
o ;jX � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl Z ddl m Z dd� ZG dd� de�ZG d d � d e�ZG d d � d e�Zed �fdd�Zed �fdd�Zdd� ZG dd� de�Zddd�Zedkote� dS dS )z: A simple library for managing the availability of ports. � N)�abc)�timingc C s | dkrdS | dv r dS | S )z� Return the host on which a client can connect to the given listener. >>> client_host('192.168.0.1') '192.168.0.1' >>> client_host('0.0.0.0') '127.0.0.1' >>> client_host('::') '::1' z0.0.0.0z 127.0.0.1)z::z::0z ::0.0.0.0z::1� )Z server_hostr r �;/opt/saltstack/salt/lib/python3.10/site-packages/portend.py� client_host s r c @ s( e Zd Zd dd�Zd dd�Zdd� ZdS ) �Checker� �?c C s || _ d S �N��timeout)�selfr r r r �__init__) � zChecker.__init__Nc C sb |du rt |tj�r|dd� \}}t�� dkr t|�}t�||tjtj �}t t � | j |�� dS )a� Assert that the given addr is free in that all attempts to connect fail within the timeout or raise a PortNotFree exception. >>> free_port = find_available_local_port() >>> Checker().assert_free('localhost', free_port) >>> Checker().assert_free('127.0.0.1', free_port) >>> Checker().assert_free('::1', free_port) Also accepts an addr tuple >>> addr = '::1', free_port, 0, 0 >>> Checker().assert_free(addr) Host might refer to a server bind address like '::', which should use localhost to perform the check. >>> Checker().assert_free('::', free_port) N� �Windows)� isinstancer �Sequence�platform�systemr �socket� getaddrinfo� AF_UNSPEC� SOCK_STREAM�list� itertools�starmap�_connect)r �host�port�infor r r � assert_free, s zChecker.assert_freec C s� t � |||�}|�| j� t�|��! z|�|� W n t jy+ Y W d � d S w W d � n1 s6w Y |d d� \}}d} t| jdi t � ����)Nr z Port {port} is in use on {host}.r ) r � settimeoutr � contextlib�closing�connect�error� PortNotFree�format�locals) r �af�socktype�proto� canonname�sa�sr r Ztmplr r r r I s �� �zChecker._connect)r r )�__name__� __module__� __qualname__r r r r r r r r ( s r c @ � e Zd ZdS )�TimeoutN�r/ r0 r1 r r r r r3 Z � r3 c @ r2 )r& Nr4 r r r r r& ^ r5 r& ZInfc C sn | st d��t�|�} z tdd��| |� W dS ty5 |�� r.tdjdi t � ����t � d� Y nw q )u� Wait for the specified port to become free (dropping or rejecting requests). Return when the port is free or raise a Timeout if timeout has elapsed. Timeout may be specified in seconds or as a timedelta. If timeout is None or ∞, the routine will run indefinitely. >>> free('localhost', find_available_local_port()) >>> free(None, None) Traceback (most recent call last): ... ValueError: Host values of '' or None are not allowed. �*Host values of '' or None are not allowed.T皙�����?r Nz Port {port} not free on {host}.r ) � ValueErrorr �Timerr r r& �expiredr3 r' r( �time�sleep�r r r Ztimerr r r �freeb s ��r> c C sn | st d��t�|�} z tdd��| |� |�� r%tdjdi t� ����t � d� W n t y5 Y dS w q ) uE Wait for the specified port to become occupied (accepting requests). Return when the port is occupied or raise a Timeout if timeout has elapsed. Timeout may be specified in seconds or as a timedelta. If timeout is None or ∞, the routine will run indefinitely. >>> occupied('localhost', find_available_local_port(), .1) Traceback (most recent call last): ... Timeout: Port ... not bound on localhost. >>> occupied(None, None) Traceback (most recent call last): ... ValueError: Host values of '' or None are not allowed. r6 Tg �?r z Port {port} not bound on {host}.r7 Nr ) r8 r r9 r r r: r3 r' r( r; r< r& r= r r r �occupied� s ��r? c C s` t �ddt jt j�} tt| ��\}}}}}t � ||�}|�|� |�� dd� \}}|�� |S )zb Find a free port on localhost. >>> 0 < find_available_local_port() < 65536 True Nr r ) r r r r �next�iter�bind� getsockname�close)�infos�familyr+ �_�addr�sockr r r r �find_available_local_port� s rJ c @ s4 e Zd ZdZedd� �Zedd� �Zedd� �ZdS ) �HostPorta A simple representation of a host/port pair as a string >>> hp = HostPort('localhost:32768') >>> hp.host 'localhost' >>> hp.port 32768 >>> len(hp) 15 >>> hp = HostPort('[::1]:32768') >>> hp.host '::1' >>> hp.port 32768 c C � t j�d| � ��jS �Nz//)�urllib�parse�urlparse�hostname�r r r r r � � z HostPort.hostc C rL rM )rN rO rP r rR r r r r � rS z HostPort.portc C sF |d d� \}}t |�}d|v rd|� d�n|}| d�|t|�g��S )Nr �:�[�])r �join�str)�clsrH Z listen_hostr Z plain_hostr r r r � from_addr� s zHostPort.from_addrN) r/ r0 r1 �__doc__�propertyr r � classmethodrZ r r r r rK � s rK c C s� t �� }dd� }|jddtd� |jdd|d� |jdd d td � |�| �} z| j| jj| jj | j d � W d S t yM } z t |t jd � td ��d }~ww )Nc S s t � | S r )�globals)�keyr r r � global_lookup� r z _main.<locals>.global_lookup�targetz host:port)�metavar�type�func�statez-tz --timeout)�defaultrc r )�file� )�argparse�ArgumentParser� add_argumentrK �float� parse_argsrd ra r r r r3 �print�sys�stderr� SystemExit)�args�parserr` r r r r �_main� s ��rt �__main__r ) r[ r; r ri ro r r" r � collectionsr � urllib.parserN Ztemporar r �objectr �IOErrorr3 r& rl r> r? rJ rX rK rt r/ r r r r �<module> s* 2!$ (
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings