File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/cheroot/__pycache__/connections.cpython-310.pyc
Back
o ;j#; � @ s d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z ddl mZ zddlZW n> eyv z#ddlZddlmZmZ ejjZejjejjejjge_ejj e_ W n eyo d d � Z Y nw d d � Z Y nw d d � Z G d d� d�Z G dd� d�Z dS )z%Utilities to manage open connections.� N)�suppress� )�errors)� IS_WINDOWS)�MakeFile)�WinError�windllc C s dS )ztStub inheritance prevention. Dummy function, since neither fcntl nor ctypes are available. N� ��sockr r �G/opt/saltstack/salt/lib/python3.10/site-packages/cheroot/connections.py�prevent_socket_inheritance s r c C s t | �� dd�s t� �dS )z6Mark the given socket fd as non-inheritable (Windows).r r N)�_SetHandleInformation�filenor r r r r r ' s �c C s0 | � � }t�|tj�}t�|tj|tjB � dS )z4Mark the given socket fd as non-inheritable (POSIX).N)r �fcntl�F_GETFD�F_SETFD� FD_CLOEXEC)r �fdZ old_flagsr r r r - s c @ sP e Zd ZdZdd� Zdd� Zedd� �Zdd d �Zd d � Z dd d�Z dd� Z dS )�_ThreadsafeSelectora� Thread-safe wrapper around a DefaultSelector. There are 2 thread contexts in which it may be accessed: * the selector thread * one of the worker threads in workers/threadpool.py The expected read/write patterns are: * :py:func:`~iter`: selector thread * :py:meth:`register`: selector thread and threadpool, via :py:meth:`~cheroot.workers.threadpool.ThreadPool.put` * :py:meth:`unregister`: selector thread only Notably, this means :py:class:`_ThreadsafeSelector` never needs to worry that connections will be removed behind its back. The lock is held when iterating or modifying the selector but is not required when :py:meth:`select()ing <selectors.BaseSelector.select>` on it. c C s t �� | _t�� | _d S �N)� selectors�DefaultSelector� _selector� threading�Lock�_lock��selfr r r �__init__H s z _ThreadsafeSelector.__init__c C s< | j � t| j�� p i �W d � S 1 sw Y d S r )r �lenr �get_mapr r r r �__len__L s $�z_ThreadsafeSelector.__len__c c s` � | j �" | j�� p i }|�� D ] \}\}}}}||fV qW d � dS 1 s)w Y dS )z2Retrieve connections registered with the selector.N)r r r! �items)r �mapping�_�sock_fd�connr r r � connectionsP s � �"�z _ThreadsafeSelector.connectionsNc C s: | j � | j�|||�W d � S 1 sw Y dS )z'Register ``fileobj`` with the selector.N)r r �register)r �fileobj�events�datar r r r) X s $�z _ThreadsafeSelector.registerc C s6 | j � | j�|�W d � S 1 sw Y dS )z)Unregister ``fileobj`` from the selector.N)r r � unregister)r r* r r r r- ] s $�z _ThreadsafeSelector.unregisterc C s dd� | j j|d�D �S )z�Return socket fd and data pairs from selectors.select call. Returns entries ready to read in the form: (socket_file_descriptor, connection) c s s � | ] \}}|j |jfV qd S r )r r, )�.0�keyr% r r r � <genexpr>h s � � �z-_ThreadsafeSelector.select.<locals>.<genexpr>��timeout)r �select)r r2 r r r r3 b s �z_ThreadsafeSelector.selectc C s6 | j � | j�� W d � dS 1 sw Y dS )zClose the selector.N)r r �closer r r r r4 m s "�z_ThreadsafeSelector.closer ) �__name__� __module__� __qualname__�__doc__r r" �propertyr( r) r- r3 r4 r r r r r 4 s r c @ sp e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z e dd� �Ze dd� �ZdS )�ConnectionManagerz�Class which manages HTTPConnection objects. This is for connections which are being kept-alive for follow-up requests. c C s8 d| _ d| _|| _t� | _| jj|j�� tj |d� dS )z�Initialize ConnectionManager object. Args: server (cheroot.server.HTTPServer): web server object that uses this ConnectionManager instance. F�r, N) �_serving�_stop_requested�serverr r r) �socketr r � EVENT_READ)r r> r r r r y s �zConnectionManager.__init__c C sB t � � |_|j�� r| j�|� dS | jj|j� � t j |d� dS )z�Put idle connection into the ConnectionManager to be managed. :param conn: HTTP connection to be managed :type conn: cheroot.server.HTTPConnection r; N) �time� last_usedZrfileZhas_datar> � process_connr r) r? r r r@ )r r' r r r �put� s �zConnectionManager.putc s> � �fdd�� j jD �}|D ]\}}� j �|� |�� qdS )aI Expire least recently used connections. :param threshold: Connections that have not been used within this \ duration (in seconds), are considered expired and \ are closed and removed. :type threshold: float This should be called periodically. c s, g | ]\}}|� j kr|j�k r||f�qS r )r> rB )r. r& r' �r � thresholdr r � <listcomp>� s �z-ConnectionManager._expire.<locals>.<listcomp>N)r r( r- r4 )r rF Ztimed_out_connectionsr& r' r rE r �_expire� s � �zConnectionManager._expirec C s$ d| _ | jrt�d� | jsdS dS )z^Stop the selector loop in run() synchronously. May take up to half a second. Tg{�G�z�?N)r= r< rA �sleepr r r r �stop� s �zConnectionManager.stopc C s& d| _ z | �|� W d| _ dS d| _ w )a� Run the connections selector indefinitely. Args: expiration_interval (float): Interval, in seconds, at which connections will be checked for expiration. Connections that are ready to process are submitted via self.server.process_conn() Connections submitted for processing must be `put()` back if they should be examined again for another request. Can be shut down by calling `stop()`. TFN)r< �_run)r �expiration_intervalr r r �run� s zConnectionManager.runc C s� t � � }tr t|d�}n|}| jsmz | jj|d�}W n ty' | �� Y qw |D ]'\}}|| ju rE| � | jj �}|durD| j� |� q*| j� |� | j� |� q*t � � }|| |krh| j || jj d� |}| jrdS dS )a Run connection handler loop until stop was requested. :param expiration_interval: Interval, in seconds, at which \ connections will be checked for \ expiration. :type expiration_interval: float Use ``expiration_interval`` as ``select()`` timeout to assure expired connections are closed in time. On Windows cap the timeout to 0.05 seconds as ``select()`` does not return when a socket is ready. g�������?r1 N)rF )rA r �minr= r r3 �OSError�_remove_invalid_socketsr> �_from_server_socketr? rC r- rH r2 ) r rL Zlast_expiration_checkZselect_timeoutZ active_listr& r' Znew_conn�nowr r r rK � s0 � � �zConnectionManager._runc C s� g }| j jD ]!\}}|| ju rqzt�|� W q ty' |�||f� Y qw |D ]"\}}| j �|� tt�� |� � W d � n1 sGw Y q*dS )a Clean up the resources of any broken connections. This method attempts to detect any connections in an invalid state, unregisters them from the selector and closes the file descriptors of the corresponding network sockets where possible. N) r r( r> �os�fstatrO �appendr- r r4 )r Z invalid_connsr& r' r r r rP s � ���z)ConnectionManager._remove_invalid_socketsc C s� �z|� � \}}| jjd r| jjd d7 < t|� t|d�r(|�| jj� t}i }| jjd ur�z | jj� |�\}}W n� t j y^ } z| j� d|�d|��� W Y d }~W d S d }~w t j y� } zT| j� d|�d|��� d}d | jj d t|� d |g} ||d tj�} z | �d �| ��d�� W n ty� } z| jd t jvr�� W Y d } ~ nd } ~ ww W Y d }~W d S d }~ww | jjj}t|d�r�|�| jj� | j�| j||�} t| jjt t f�s�|d u r�t|� � �dkr�d}nd}|d | _ |d | _ || _!| W S t"j�y Y d S t�y\ } zB| jjd �r'| jjd d7 < | jd t j#v �r7W Y d } ~ d S | jd t j$v �rGW Y d } ~ d S | jd t jv �rWW Y d } ~ d S � d } ~ ww )NZEnabledZAcceptsr � settimeoutzClient uF lost — peer dropped the TLS connection suddenly, during handshake: u� attempted to speak plain HTTP into a TCP connection configured for TLS-only traffic — trying to send back a plain HTTP error response: zUThe client sent a plain HTTP request, but this server only speaks HTTPS on this port.z%s 400 Bad Request zContent-Length: %s z Content-Type: text/plain �wb� z ISO-8859-1r � )z0.0.0.0r )z::r z Socket Errors)%�acceptr> Zstatsr �hasattrrV r2 r Z ssl_adapter�wrapr Z FatalSSLAlertZ error_logZ NoSSLError�protocolr �io�DEFAULT_BUFFER_SIZE�write�join�encoderO �argsZsocket_errors_to_ignore�makefileZConnectionClass� isinstanceZ bind_addr�str�bytes� getsocknameZ remote_addrZ remote_port�ssl_envr? Zsocket_error_eintrZsocket_errors_nonblocking) r Z server_socket�s�addrZmfri Ztls_connection_drop_errorZhttp_over_https_err�msg�bufZwfile�exr' r r r rQ s� ������ � ����� ��z%ConnectionManager._from_server_socketc C s2 | j jD ] \}}|| jur|�� q| j �� dS )z Close all monitored connections.N)r r( r> r4 )r r% r' r r r r4 � s �zConnectionManager.closec C s t | j�d S )z�Return the current number of connections. Includes all connections registered with the selector, minus one for the server socket, which is always registered with the selector. r )r r r r r r �_num_connections� s z"ConnectionManager._num_connectionsc C s | j j}|du p | j|k S )z>Flag whether it is allowed to add a new keep-alive connection.N)r> Zkeep_alive_conn_limitro )r Zka_limitr r r � can_add_keepalive_connection� s z.ConnectionManager.can_add_keepalive_connectionN)r5 r6 r7 r8 r rD rH rJ rM rK rP rQ r4 r9 ro rp r r r r r: s s 5a r: )!r8 r^ rS r r? r rA � contextlibr rX r Z_compatr rd r r � ImportErrorZctypes.wintypes�ctypesr r Zkernel32ZSetHandleInformationr ZwintypesZHANDLEZDWORD�argtypesZBOOL�restyper r r: r r r r �<module> s@ � � ��?
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings