File: //usr/local/CyberCP/lib64/python3.10/site-packages/uvicorn/__pycache__/workers.cpython-310.pyc
o
�h7 � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
Z
d dl m Z d dl
mZ d dlmZ e�de� G d d
� d
e �ZG d d � d e�ZdS )
� )� annotationsN)�Any)�Arbiter)�Worker)�Config)�Serverz�The `uvicorn.workers` module is deprecated. Please use `uvicorn-worker` package instead.
For more details, see https://github.com/Kludex/uvicorn-worker.c sv e Zd ZU dZddd�Zded< d� fd d � Zd� fd
d� Zddd�Zddd�Z ddd�Z
ddd�Z ddd�Z � Z
S )�
UvicornWorkerzv
A worker class for Gunicorn that interfaces with an ASGI consumer callable,
rather than a WSGI callable.
�auto��loop�httpzdict[str, Any]�
CONFIG_KWARGS�argsr �kwargs�return�Nonec s8 t � j|i |�� t�d�}| jjj|_|�| jjj� d|_ t�d�}| jj
j|_|�| jj
j� d|_ d d | j j | j
| j| j| j jd�}| j jr|| j j�d�| j j�d�| j j�d�| j j�d�| j j�d �| j j�d
�| j j�d �d �}|�|� | j jd
jr�| j jd
j|d
< |�| j� tdi |��| _d S )Nz
uvicorn.errorFzuvicorn.access)�app�
log_config�timeout_keep_alive�timeout_notify�callback_notify�limit_max_requests�forwarded_allow_ips�keyfile�certfile�password� ssl_version� cert_reqs�ca_certs�ciphers)� ssl_keyfile� ssl_certfile�ssl_keyfile_passwordr �
ssl_cert_reqs� ssl_ca_certs� ssl_ciphers�backlog� )�super�__init__�logging� getLogger�log� error_log�handlers�setLevel�level� propagate�
access_log�cfg� keepalive�timeoutr � max_requestsr �is_ssl� ssl_options�get�update�settings�valuer
r �config)�selfr r �logger�
config_kwargs�
ssl_kwargs�� __class__r' �B/usr/local/CyberCP/lib/python3.10/site-packages/uvicorn/workers.pyr) s>
�
�
zUvicornWorker.__init__c s | j �� t� �� d S �N)r= �setup_event_loopr( � init_process�r> rB r' rD rG I s
zUvicornWorker.init_processc C s< | j D ] }t�|tj� qt�tj| j� t�tjd� d S )NF)�SIGNALS�signal�SIG_DFL�SIGUSR1� handle_usr1� siginterrupt)r> �sr' r' rD � init_signalsM s
zUvicornWorker.init_signalsc C s" t �� }|�tj| jtjd� dS )z�Install a SIGQUIT handler on workers.
- https://github.com/encode/uvicorn/issues/1116
- https://github.com/benoitc/gunicorn/issues/2604
N)�asyncio�get_running_loop�add_signal_handlerrJ �SIGQUIT� handle_exit)r> r r' r' rD �_install_sigquit_handlerX s z&UvicornWorker._install_sigquit_handlerc � sN �| j | j_t| jd�}| �� |j| jd�I d H |js%t� t
j � d S d S )N)r= )�sockets) �wsgir= r r rV �serverW �started�sys�exitr �WORKER_BOOT_ERROR)r> �serverr' r' rD �_serveb s �
�zUvicornWorker._servec C s t �| �� �S rE )rQ �runr_ rH r' r' rD r` j s zUvicornWorker.runc � s �| � � d S rE )�notifyrH r' r' rD r m s � z UvicornWorker.callback_notify)r r r r r r )r r )�__name__�
__module__� __qualname__�__doc__r
�__annotations__r) rG rP rV r_ r` r �
__classcell__r' r' rB rD r s
*
r c @ s e Zd Zddd�ZdS )�UvicornH11WorkerrQ �h11r
N)rb rc rd r
r' r' r' rD rh q s rh )�
__future__r rQ r* rJ r[ �warnings�typingr �gunicorn.arbiterr �gunicorn.workers.baser �uvicorn.configr �uvicorn.serverr �warn�DeprecationWarningr rh r' r' r' rD �<module> s" �Z