Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/cheroot/workers/__pycache__/threadpool.cpython-39.pyc
Ðазад
a p�ha< � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z dZ G dd� d�Z e � Z e � ZG dd� dej�ZG d d � d �ZdS ) z8A thread-based worker pool. .. spelling:: joinable � N)� pass_none)� WorkerThread� ThreadPoolc @ s e Zd ZdZdd� Zdd� ZdS )� TrueyZerozDObject which equals and does math like the integer 0 but evals True.c C s |S �N� ��self�otherr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/cheroot/workers/threadpool.py�__add__ s zTrueyZero.__add__c C s |S r r r r r r �__radd__ s zTrueyZero.__radd__N)�__name__� __module__� __qualname__�__doc__r r r r r r r s r c @ s4 e Zd ZdZdZdZdZdd� Zdd� Zdd � Z dS ) r aF Thread which continuously polls a Queue for Connection objects. Due to the timing issues of polling a Queue, a WorkerThread does not check its own 'ready' flag after it has started. To stop the thread, it is necessary to stick a _SHUTDOWNREQUEST object onto the Queue (one for each running WorkerThread). NFc sv d� _ |� _d� _d� _d� _d� _d� _� fdd�� fdd�� fdd�� fdd�d d� d d� d �� _tj � � � dS ) z�Initialize WorkerThread instance. Args: server (cheroot.server.HTTPServer): web server object receiving this request Fr Nc s � j � jd u rtp� jj S r )� requests_seen� start_time� trueyzero�conn��s�r r r �<lambda>I s ��z'WorkerThread.__init__.<locals>.<lambda>c s � j � jd u rtp� jjj S r )� bytes_readr r r �rfiler r r r r N s ��c s � j � jd u rtp� jjj S r )� bytes_writtenr r r �wfiler r r r r S s ��c s" � j � jd u rtp t�� � j S r )� work_timer r �timer r r r r X s � �c S s | d | �| d | �pd S )N� Bytes Read� Work Time���ư>r r r r r r ] s �c S s | d | �| d | �pd S )N� Bytes Writtenr! r" r r r r r r ` s �)ZRequestsr r# r! zRead ThroughputzWrite Throughput) �ready�serverr r r r r �stats� threading�Thread�__init__)r r% r r r r) 9 s � zWorkerThread.__init__c C s� | j | jj d | j< d| _z�z | �� W n� ttfyz } z6|jpD|}| jjd|��t j d� || j_ W Y d}~nRd}~0 t y� } z2| jjd|�d�t j dd� || j_ � W Y d}~n d}~0 0 W d | _nd | _0 dS ) a0 Set up incoming HTTP connection processing loop. This is the thread's entry-point. It performs lop-layer exception handling and interrupt processing. :exc:`KeyboardInterrupt` and :exc:`SystemExit` bubbling up from the inner-layer code constitute a global server interrupt request. When they happen, the worker thread exits. :raises BaseException: when an unexpected non-interrupt exception leaks from the inner layers # noqa: DAR401 KeyboardInterrupt SystemExit zWorker ThreadsTz%Setting the server interrupt flag to ��levelNzAA fatal exception happened. Setting the server interrupt flag to z� and giving up. Please, report this on the Cheroot tracker at <https://github.com/cherrypy/cheroot/issues/new/choose>, providing a full reproducer with as much context and details as possible.�r+ � tracebackF)r& r% �namer$ �&_process_connections_until_interrupted�KeyboardInterrupt� SystemExit� __cause__� error_log�logging�DEBUGZ interrupt� BaseException�CRITICAL)r Z interrupt_excZinterrupt_causeZunderlying_excr r r �runf s, � �� zWorkerThread.runc C sV | j j�� }|tu rdS || _| j jd }|r8t�� | _d}�z�z|�� }W �n t �y* } z�d}| j j d|j �d|j �d|�d�t jd� W Y d}~W |r�| j �|� n|�� |�r | j|j7 _| j|jj7 _| j|jj7 _| jt�� | j 7 _d| _d| _q W Y d}~�n4d}~0 ttf�y� } zHd}| j j d |j �d|j �d|�d�t jd� tt|��|�W Y d}~n�d}~0 t�yT } z�| j j d |��t j d d � W Y d}~W |�r�| j �|� n|�� |�r8| j|j7 _| j|jj7 _| j|jj7 _| jt�� | j 7 _d| _d| _q W Y d}~n d}~0 0 W |�rl| j �|� n|�� |�r�| j|j7 _| j|jj7 _| j|jj7 _| jt�� | j 7 _d| _d| _q |�r�| j �|� n|�� |�rH| j|j7 _| j|jj7 _| j|jj7 _| jt�� | j 7 _d| _d| _0 q dS ) a Process incoming HTTP connections in an infinite loop. Retrieves incoming connections from thread pool, processing them one by one. :raises SystemExit: on the internal requests to stop the server instance NZEnabledFz8Got a connection error while handling a connection from �:z (�)r* z?Got a server shutdown request while handling a connection from z8Unhandled error while processing an incoming connection Tr, ) r% �requests�get�_SHUTDOWNREQUESTr r& r r � communicate�ConnectionErrorr3 Z remote_addrZ remote_portr4 �INFOZput_conn�closer r r r r r r0 r1 r5 �strr6 �ERROR)r r Zis_stats_enabledZkeep_conn_openZconnection_error�shutdown_requestZunhandled_errorr r r r/ � s� ���� &��������� � �z3WorkerThread._process_connections_until_interrupted) r r r r r r% r$ r) r8 r/ r r r r r % s -,r c @ s� e Zd ZdZd dd�Zdd� Zedd � �Zd d � Zd d � Z dd� Z dd� Z dd� Z d dd�Z eedd� ��Zdd� Zedd � �Zd S ) r z�A Request Queue for an HTTPServer which pools threads. ThreadPool objects must provide min, get(), put(obj), start() and stop(timeout) attributes. � ���c C s� |dk rt d|�d���|td�kr&n4t|t�r8|dkrJtd|�d���n|dk rZtd�}||k rxt d|�d |�d ���|| _|| _|| _g | _t j |d �| _ || _ | j j | _ t�� | _d S ) an Initialize HTTP requests queue instance. Args: server (cheroot.server.HTTPServer): web server object receiving this request min (int): minimum number of worker threads max (int): maximum number of worker threads (-1/inf for no max) accepted_queue_size (int): maximum number of active requests in queue accepted_queue_timeout (int): timeout for putting request into queue :raises ValueError: if the min/max values are invalid :raises TypeError: if the max is not an integer or inf � zmin=z must be > 0�infr zIExpected an integer or the infinity value for the `max` argument but got �.zmax=z must be > min=z (or infinity for no max))�maxsizeN)� ValueError�float� isinstance�int� TypeErrorr% �min�max�_threads�queue�Queue�_queue�_queue_put_timeoutr< � collections�deque�_pending_shutdowns)r r% rP rQ Zaccepted_queue_sizeZaccepted_queue_timeoutr r r r) � s0 ��� zThreadPool.__init__c C s | j rtd��| �| j� dS )zaStart the pool of threads. :raises RuntimeError: if the pool is already started z%Threadpools can only be started once.N)rR � RuntimeError�growrP r r r r �start s zThreadPool.startc C s( t dd� | jD ��}t|t | j� d�S )z3Number of worker threads which are idle. Read-only.c S s g | ]}|j d u r|�qS r �r ��.0�tr r r � <listcomp># � z#ThreadPool.idle.<locals>.<listcomp>r )�lenrR rQ rY )r Zidlesr r r �idle s zThreadPool.idlec C s | j j|d| jd� dS )z�Put request into queue. Args: obj (:py:class:`~cheroot.server.HTTPConnection`): HTTP connection waiting to be processed T)�block�timeoutN)rU �putrV )r �objr r r rg & s zThreadPool.putc C sH dd� | j D �D ]2}| j �|� z| j�� W q ty@ Y q0 qd S )Nc S s g | ]}|� � s|�qS r )�is_aliver^ r r r ra 1 rb z2ThreadPool._clear_dead_threads.<locals>.<listcomp>)rR �removerY �popleft� IndexError)r r` r r r �_clear_dead_threads/ s z ThreadPool._clear_dead_threadsc sb t � j t� j� d�}t||�}� fdd�t|�D �}|D ]}|js:t�d� q>q:� j�|� dS )z.Spawn new worker threads (not above self.max).r c s g | ] }� � � �qS r )� _spawn_worker)r_ �ir r r ra = rb z#ThreadPool.grow.<locals>.<listcomp>g�������?N) rQ rc rR rP �ranger$ r �sleep�extend)r �amountZbudgetZn_new�workers�workerr r r r[ 8 s zThreadPool.growc C s& t | j�}dj|jd�|_|�� |S )NzCP Server {worker_name!s})Z worker_name)r r% �formatr. r\ )r ru r r r rn C s ��zThreadPool._spawn_workerc C sl |t | j�8 }| �� |dkr"dS tt | j�| j d�}t||�}t|�D ] }| j�d� | j� t � qJdS )z-Kill off worker threads (not below self.min).r N) rc rY rm rQ rR rP rp �appendrU rg r= )r rs Zn_extraZ n_to_remove�_r r r �shrinkL s zThreadPool.shrink� c C s� |dur"|dk r"d}t jddd� |dur6t�� | }| jD ]}| j�t� q<ttf}| � � D ]R}|op|t�� }z*|� |� |� � r�| � |j � |� � W q^ |y� Y q^0 q^dS )z|Terminate all worker threads. Args: timeout (int): time to wait for threads to stop gracefully Nr zZIn the future, negative timeouts to Server.stop() will be equivalent to a timeout of zero.� )� stacklevel)�warnings�warningr rR rU rg r= rZ r0 �_clear_threads�joinri � _force_closer )r rf �endtimeru Zignored_errorsZremaining_timer r r �stopb s, � � zThreadPool.stopc C sX | j jr d S z4z| j�tj� W n ty< | j�� Y n0 W n tyR Y n0 d S r )r �closed�socket�shutdown�SHUT_RDrO �OSErrorr] r r r r� � s zThreadPool._force_closec C s, | j dd� g }| j dd�< dd� |D �S )z3Clear self._threads and yield all joinable threads.Nc s s | ]}|t �� ur|V qd S r )r' �current_thread)r_ �threadr r r � <genexpr>� s �z,ThreadPool._clear_threads.<locals>.<genexpr>)rR )r �threadsr r r r � s �zThreadPool._clear_threadsc C s | j �� S )zReturn the queue size.)rU �qsizer r r r r� � s zThreadPool.qsizeN)rE rF rF rE )rz )r r r r r) r\ �propertyrd rg rm r[ rn ry r� � staticmethodr r� r r� r r r r r � s& � . + r )r rW r4 r' r r� r} rS Zjaraco.functoolsr �__all__r r �objectr= r( r r r r r r �<module> s >
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка