File: //usr/local/CyberCP/lib64/python3.10/site-packages/uvicorn/lifespan/__pycache__/on.cpython-310.pyc
o
�h@ � @ s� d dl mZ d dlZd dlZd dlmZ d dlmZmZ d dlm Z d dl
m Z m Z m
Z
mZmZmZmZ eee
f Zeeeee f ZdZG dd � d �ZdS )
� )� annotationsN)�Queue)�Any�Union)�Config)�
LifespanScope� LifespanShutdownCompleteEvent�LifespanShutdownEvent�LifespanShutdownFailedEvent� LifespanStartupCompleteEvent�LifespanStartupEvent�LifespanStartupFailedEventz2Got invalid state transition on lifespan protocol.c @ sH e Zd Zddd�Zddd�Zdd d
�Zdd d �Zddd�Zddd�ZdS )�
LifespanOn�configr �return�Nonec C s` |j s|�� || _t�d�| _t�� | _t�� | _ t�
� | _ d| _ d| _
d| _d| _i | _d S )Nz
uvicorn.errorF)�loaded�loadr �logging� getLogger�logger�asyncio�Event�
startup_event�shutdown_eventr �
receive_queue�
error_occured�startup_failed�shutdown_failed� should_exit�state)�selfr � r" �F/usr/local/CyberCP/lib/python3.10/site-packages/uvicorn/lifespan/on.py�__init__ s
zLifespanOn.__init__c � s� �| j �d� t�� }|�| �� �}ddi}| j�|�I d H | j� � I d H | j
s3| j r>| j j
dkr>| j �d� d| _d S | j �d� d S )Nz Waiting for application startup.�typezlifespan.startup�onz$Application startup failed. Exiting.Tz Application startup complete.)r �infor �get_event_loop� create_task�mainr �putr �waitr r r �lifespan�errorr )r! �loop�main_lifespan_taskr r" r" r# �startup/ s �
zLifespanOn.startupc � s� �| j rd S | j�d� ddi}| j�|�I d H | j�� I d H | js-| j r8| jj dkr8| j�
d� d| _ d S | j�d� d S )Nz!Waiting for application shutdown.r% zlifespan.shutdownr& z%Application shutdown failed. Exiting.Tz Application shutdown complete.) r r r' r r+ r r, r r r- r. r )r! r r" r" r# �shutdown@ s �
zLifespanOn.shutdownc
� s �z�z | j j}d| j jdd�| jd�}||| j| j�I d H W nI tyh } z=d | _d| _| j s3| j
rEW Y d }~W | j � � | j
� � d S | j jdkrTd}| j�|� n
d}| jj||d � W Y d }~nd }~ww W | j � � | j
� � d S W | j � � | j
� � d S | j � � | j
� � w )
Nr- z2.0)�version� spec_version)r% �asgir T�autoz-ASGI 'lifespan' protocol appears unsupported.z!Exception in 'lifespan' protocol
)�exc_info)r �
loaded_app� asgi_versionr �receive�send�
BaseExceptionr5 r r r r �setr r- r r' r. )r! �app�scope�exc�msgr" r" r# r* N s< � �
����
�
�
� zLifespanOn.main�message�LifespanSendMessagec � sV �|d dv s J �|d dkr(| j �� rJ t��| j�� r!J t��| j �� d S |d dkrY| j �� r7J t��| j�� r@J t��| j �� d| _|�d�rW| j�|d � d S d S |d dkrx| j �� shJ t��| j�� rqJ t��| j�� d S |d dkr�| j �� s�J t��| j�� r�J t��| j�� d| _ |�d�r�| j�|d � d S d S d S ) Nr% )�lifespan.startup.complete�lifespan.startup.failed�lifespan.shutdown.complete�lifespan.shutdown.failedrD rE TrB rF rG )
r �is_set�STATE_TRANSITION_ERRORr r= r �getr r. r )r! rB r" r" r# r; f s6 �
�
�zLifespanOn.send�LifespanReceiveMessagec � s �| j �� I d H S )N)r rJ )r! r" r" r# r: � s �zLifespanOn.receiveN)r r r r )r r )rB rC r r )r rK ) �__name__�
__module__� __qualname__r$ r1 r2 r* r; r: r" r" r" r# r s
"r )�
__future__r r r r �typingr r �uvicornr �uvicorn._typesr r r r
r r r
rK rC rI r r" r" r" r# �<module> s" $
��