Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/gunicorn/workers/__pycache__/gthread.cpython-39.pyc
Ðазад
a j�hn. � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z d dl m Z d dl m Z d dlmZ ddlmZ dd lmZ dd lmZ dd lmZ G d d � d e�ZG dd� dej�ZdS )� N)�deque)�datetime)�partial)�RLock� )�base� )�http)�util)�wsgic @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �TConnc C s4 || _ || _|| _|| _d | _d | _| j�d� d S )NF)�cfg�sock�client�server�timeout�parser� setblocking)�selfr r r r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/gunicorn/workers/gthread.py�__init__# s zTConn.__init__c C sR | j �d� | jd u rN| jjr<tj| j fddi| jj��| _ t� | j| j �| _d S )NT� server_side) r r r r Zis_ssl�ssl� wrap_socketZ ssl_optionsr Z RequestParser�r r r r �init/ s �z TConn.initc C s t � � | jj | _d S �N)�timer � keepaliver r r r r � set_timeout: s zTConn.set_timeoutc C s t �| j� d S r )r �closer r r r r r! > s z TConn.closeN)�__name__� __module__� __qualname__r r r r! r r r r r ! s r c s� e Zd Z� fdd�Zedd� �Z� fdd�Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd � Zd d � Z� ZS ) � ThreadWorkerc sZ t � j|i |�� | jj| _| jj| jj | _d | _d | _d | _t � | _ t � | _ d| _ d S )Nr ) �superr r �worker_connections�threads�max_keepalived�tpool�poller�_lockr �futures�_keep�nr_conns)r �args�kwargs�� __class__r r r D s zThreadWorker.__init__c C s( |j |j }|dkr$|jr$|�d� d S )Nr z]No keepalived connections can be handled. Check the number of worker connections and threads.)r' r( r �warning)�clsr �logr) r r r � check_configP s zThreadWorker.check_configc s* | � � | _t�� | _t� | _t� �� d S r ) �get_thread_poolr* � selectors�DefaultSelectorr+ r r, r& � init_processr r2 r r r; X s zThreadWorker.init_processc C s t j| jjd�S )z@Override this method to customize how the thread pool is created)� max_workers)r- ZThreadPoolExecutorr r( r r r r r8 ^ s z ThreadWorker.get_thread_poolc C s6 d| _ | j�| � | j�d� t�d� t�d� d S )NFg�������?r ) �aliver Z worker_intr* �shutdownr �sleep�sys�exit)r �sig�framer r r � handle_quitb s zThreadWorker.handle_quitc C s" ||_ | j�|� |�| j� d S r )�connr- �appendZadd_done_callback�finish_request)r �fsrE r r r � _wrap_futurej s zThreadWorker._wrap_futurec C s( |� � | j�| j|�}| �||� d S r )r r* Zsubmit�handlerI )r rE rH r r r � enqueue_reqo s zThreadWorker.enqueue_reqc C sz z8|� � \}}t| j|||�}| jd7 _| �|� W n< tyt } z$|jtjtjtj fvr`� W Y d }~n d }~0 0 d S )Nr ) �acceptr r r/ rK �EnvironmentError�errno�EAGAIN� ECONNABORTED� EWOULDBLOCK)r r Zlistenerr r rE �er r r rL u s �zThreadWorker.acceptc C sr | j �N | j�|� z| j�|� W n tyD Y W d � d S 0 W d � n1 sZ0 Y | �|� d S r )r, r+ � unregisterr. �remove� ValueErrorrK )r rE r r r r �reuse_connection� s 2z ThreadWorker.reuse_connectionc C sJ t � � }| j�D z| j�� }W n$ tyB Y W d � �qFY n0 W d � n1 sX0 Y |j| }|dkr�| j� | j�|� W d � n1 s�0 Y �qFq| jd8 _| j�j z| j� |j � W nF t �y } z|j t j kr� W Y d }~n d }~0 t�y Y n0 W d � n1 �s20 Y |�� qd S )Nr r )r r, r. �popleft� IndexErrorr � appendleftr/ r+ rS r rM rN �EBADF�KeyErrorr! )r �nowrE �deltarR r r r �murder_keepalived� s* 6 * &z ThreadWorker.murder_keepalivedc C s$ | j t�� kr | j�d| � dS dS )Nz!Parent changed, shutting down: %sFT)Zppid�os�getppidr6 �infor r r r �is_parent_alive� s z ThreadWorker.is_parent_alivec C s | j D ]4}|�d� |�� }t| j|�}| j�|tj|� q| j r�| � � | j | j k r�| j� d�}|D ]\}}|j}||j� qftj| jdtjd�}ntj| jdtjd�}|jD ]} | j�| � q�| �� s�q�| �� q<| j�d� | j�� | j D ] } | �� q�tj| j| jjd� d S )NFg �?r )r Z return_when)r ) Zsocketsr � getsocknamer rL r+ �registerr9 � EVENT_READr= �notifyr/ r' �select�data�fileobjr- �waitZFIRST_COMPLETED�donerT rb r^ r* r> r! r Zgraceful_timeout) r r r Zacceptor�events�key�_�callback�resultZfut�sr r r �run� s8 � � zThreadWorker.runc C s� |� � r$| jd8 _|j�� d S z�|�� \}}|r�|j�d� |�� | j�8 | j � |� | j � |jt jt| j|�� W d � q�1 s�0 Y n| jd8 _|�� W n$ | jd8 _|j�� Y n0 d S )Nr F)Z cancelledr/ rE r! rp r r r r, r. rF r+ rd r9 re r rV )r rH r rE r r r rG � s& �$ zThreadWorker.finish_requestc C s� d}d }z8t |j�}|s"d|fW S | �||�}|r<||fW S W �n~ tjjyx } z | j�d|� W Y d }~�nPd }~0 ty� } z | j�d|� W Y d }~�n d }~0 t j �y } zT|j d t j kr�| j�d� |j �� n | j�d� | �||j |j|� W Y d }~n�d }~0 t�y� } zV|jtjtjfv�rJ| j�d� n(|jtjk�rf| j�d� n | j�d � W Y d }~nBd }~0 t�y� } z | �||j |j|� W Y d }~n d }~0 0 d|fS ) NFz*Ignored premature client disconnection. %szClosing connection. %sr zssl connection closedz Error processing SSL request.z Socket error processing request.zIgnoring connection resetzIgnoring connection epipe)�nextr �handle_requestr �errorsZ NoMoreDatar6 �debug� StopIterationr �SSLErrorr0 � SSL_ERROR_EOFr r! � handle_errorr rM rN �EPIPE� ECONNRESET� exception� Exception)r rE r �reqrR r r r rJ s8 $$ ( *zThreadWorker.handlec C s� i }d }�zT�z�| j �| |� t�� }t�||j|j|j| j �\}}d|d< | j d7 _ | j r�| j | j kr�| j � d� |�� d| _ | j js�|�� nt| j�| jkr�|�� | �||j�}zlt||d �r�|�|� n|D ]}|�|� q�|�� t�� | }| j �||||� W t|d��rB|�� nt|d��r@|�� 0 |�� �r�| j �d� W W z| j � | |||� W n t �y� | j � d � Y n0 dS W n� t �y� t j!t"�#� � Y nh t �y" |�r |j$�r | j � d � z |j�%t&j'� |j�� W n t �y Y n0 t(� �� Y n0 W z| j � | |||� W n t �y\ | j � d � Y n0 n:z| j � | |||� W n t �y� | j � d � Y n0 0 dS ) NTzwsgi.multithreadr z,Autorestarting worker after current request.Fzwsgi.file_wrapperr! zClosing connection.z Exception in post_request hookzError handling request))r Z pre_requestr r\ r �creater r r �nrr= Z max_requestsr6 ra Z force_closer �lenr. r) Zstart_response� isinstance� write_file�writer! �access�hasattrZ should_closerv Z post_requestr~ r} rM r �reraiser@ �exc_infoZ headers_sentr> �socket� SHUT_RDWRrw ) r r rE �environ�respZ request_startZrespiter�itemZ request_timer r r rt , sx � � � �zThreadWorker.handle_request)r" r# r$ r � classmethodr7 r; r8 rD rI rK rL rV r^ rb rr rG rJ rt � __classcell__r r r2 r r% B s 0 &r% )�concurrent.futuresr- rN r_ r9 r� r r@ r � collectionsr r � functoolsr � threadingr � r r r r �objectr ZWorkerr% r r r r �<module> s" !
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка