Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/gunicorn/workers/__pycache__/ggevent.cpython-39.pyc
Ðазад
a j�h� � @ sT d dl Z d dlZd dlZd dlmZ d dlmZ d dlZz d dlZW n ey^ e d��Y n(0 d dl m Z e ej �e d�k r�e d��d dl mZ d dlmZ d d lmZmZmZmZ d dlZd d lmZ d d lmZ d ej ej f Zejfd d�Z dd� Z G dd� de�Z G dd� de �Z G dd� dej!�Z"G dd� dej#�Z$G dd� de �Z%dS )� N)�datetime)�partialz+gevent worker requires gevent 1.4 or higher)� parse_versionz1.4)�Pool)� StreamServer)�hub�monkey�socket�pywsgi)� base_environ)� AsyncWorkerzgevent/%s gunicorn/%sc C sZ z|| |||�W S t yR } z*|jd tjkr<t�| � n� W Y d }~q d }~0 0 q d S )Nr )�OSError�args�errno�EAGAINr Z wait_write)ZfdoutZfdin�offset�nbytesZ _os_sendfile�e� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/gunicorn/workers/ggevent.py�_gevent_sendfile! s r c C s t tdt� d S )N�sendfile)�setattr�osr r r r r �patch_sendfile+ s r c sx e Zd ZdZdZdd� Z� fdd�Zdd� Zdd � Z� fd d �Z � fd d �Z � fdd�Z � fdd�Z � fdd�Z � ZS )� GeventWorkerNc C sH t �� t� g }| jD ]$}|�tj|jtj|j� � d�� q|| _d S )N)�fileno) r Z patch_allr �sockets�appendr ZFAMILY� SOCK_STREAM�sockr )�selfr �sr r r �patch4 s � zGeventWorker.patchc s4 t � �� | jt�� kr0| j�d| � t�d� d S )Nz!Parent changed, shutting down: %sr ) �super�notifyZppidr �getppid�log�info�sys�exit�r! �� __class__r r r% A s zGeventWorker.notifyc C s t �| jjd�S )NF)�gevent�Timeout�cfg� keepaliver+ r r r � timeout_ctxG s zGeventWorker.timeout_ctxc C s� g }i }| j jr&tf ddi| j j��}| jD ]�}|�d� t| j�}| jd ur�t | j �}|� dt d�� | j|f| j || j | j|d�|��}n"t| j|�}t|f||d�|��}|�� |�|� q,| jr�| �� t�d� q�z�|D ](}t|d�r�|�� t|d �r�|�� q�t�� }t�� | | j j k�rzd } |D ]"}|j � � |j j k�r4| d7 } �q4| �sdW d S | �� t�d� �q| j � d | j! � |D ]}|j"dd � �q�W n Y n0 d S ) N� server_sideT� )zwsgi.multithread�SERVER_SOFTWARE)Z application�spawnr' Z handler_class�environ)�handler6 g �?�close�killr z Worker graceful timeout (pid:%s))�timeout)#r0 Zis_ssl�dictZ ssl_optionsr � setblockingr Zworker_connections� server_classr �update�VERSIONZwsgir' � wsgi_handlerr r8 r �startr �aliver% r. �sleep�hasattrr9 r: �timeZgraceful_timeout�poolZ free_count�size�warning�pid�stop) r! ZserversZssl_argsr" rG r7 �serverZhfun�tsZ acceptingr r r �runJ sb �� �� zGeventWorker.runc s |� d� t� �|||� d S )Nr4 )r= r$ r8 )r! Zlistener�client�addrr, r r r8 � s zGeventWorker.handlec s@ zt � �||||� W n$ tjy* Y n ty: Y n0 d S �N)r$ �handle_requestr. Z GreenletExit� SystemExit)r! Z listener_name�reqr rP r, r r rR � s zGeventWorker.handle_requestc s t �t� j||� d S rQ )r. r6 r$ � handle_quit�r! �sig�framer, r r rU � s zGeventWorker.handle_quitc s t �t� j||� d S rQ )r. r6 r$ � handle_usr1rV r, r r rY � s zGeventWorker.handle_usr1c s | � � t�� t� �� d S rQ )r# r Zreinitr$ � init_processr+ r, r r rZ � s zGeventWorker.init_process)�__name__� __module__� __qualname__r> rA r# r% r2 rN r8 rR rU rY rZ � __classcell__r r r, r r / s = r c @ s e Zd ZdZdZdZdd� ZdS )�GeventResponseNc C s || _ || _|| _d S rQ )�status�headers�sent)r! r` ra Zclengthr r r �__init__� s zGeventResponse.__init__)r[ r\ r] r` ra rb rc r r r r r_ � s r_ c s$ e Zd Zdd� Z� fdd�Z� ZS )� PyWSGIHandlerc C sp t �| j�}t �| j�}|| }t| di �}t| j|| j�}t| d�rR| j � � }ng }| j j � ||| j|� d S )N�response_headersra )r � fromtimestampZ time_startZ time_finish�getattrr_ r` Zresponse_lengthrE ra �itemsrL r' �accessr7 )r! rB �finishZ response_timeZ resp_headers�respZ req_headersr r r � log_request� s zPyWSGIHandler.log_requestc s" t � �� }| j|d< | j|d< |S )Nz gunicorn.sockZRAW_URI)r$ � get_environr �path)r! �envr, r r rm � s zPyWSGIHandler.get_environ)r[ r\ r] rl rm r^ r r r, r rd � s rd c @ s e Zd ZdS )� PyWSGIServerN)r[ r\ r] r r r r rp � s rp c @ s e Zd ZdZeZeZdS )�GeventPyWSGIWorkerz&The Gevent StreamServer based workers.N)r[ r\ r] �__doc__rp r> rd rA r r r r rq � s rq )&r r r) r � functoolsr rF r. � ImportError� RuntimeError� pkg_resourcesr � __version__Z gevent.poolr Z gevent.serverr r r r r ZgunicornZgunicorn.http.wsgir Zgunicorn.workers.base_asyncr r@ r r r r �objectr_ Z WSGIHandlerrd Z WSGIServerrp rq r r r r �<module> s4 v
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка