File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/web_runner.cpython-310.pyc
o
���g
. � @ sX d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZm Z m
Z
m Z m Z d dl
mZ ddlmZ ddlmZ ddlmZ erGd d lmZ nzd d lmZ W n eyZ eZY nw d
ZG d d � d e�Zd dd�Z G dd� de�Z G dd� de �Z G dd� de �Z G dd� de �Z G dd� de �Z!G dd� de�Z"G d d � d e"�Z#G d d � d e"�Z$dS )!� N)�ABC�abstractmethod)�
TYPE_CHECKING�Any�List�Optional�Set)�URL� )�PathLike)� Application)�Server)�
SSLContext) �BaseSite�TCPSite�UnixSite�
NamedPipeSite�SockSite�
BaseRunner� AppRunner� ServerRunner� GracefulExitc @ s e Zd ZdZdS )r r
N)�__name__�
__module__� __qualname__�code� r r �=/usr/local/lib/python3.10/dist-packages/aiohttp/web_runner.pyr # s r �returnc C s t � ��N)r r r r r �_raise_graceful_exit' s r c @ sj e Zd ZdZdddd�ddded ee d
ed df
d d
�Ze e
d e fdd���Z e
ddd��Z
ddd�ZdS )r )�_runner� _ssl_context�_backlog�_server� N@N� ��shutdown_timeout� ssl_context�backlog�runnerr r( r) r* r c C sP |j d u r td��|dkrd}tj|tdd� ||_|| _|| _|| _d | _ d S )Nz(Call runner.setup() before making a siter% z,shutdown_timeout should be set on BaseRunner� )�
stacklevel)
�server� RuntimeError�warnings�warn�DeprecationWarning�_shutdown_timeoutr! r" r# r$ )�selfr+ r( r) r* �msgr r r �__init__. s
zBaseSite.__init__c C s d S r r �r4 r r r �nameA s z
BaseSite.namec � s �| j �| � d S r )r! � _reg_siter7 r r r �startF s �zBaseSite.startc � s2 �| j �| � | jd ur| j�� | j �| � d S r )r! � _check_siter$ �close� _unreg_siter7 r r r �stopJ s
�
z
BaseSite.stop�r N)r r r � __slots__�floatr r �intr6 �propertyr �strr8 r: r> r r r r r + s, �����
� r c s� e Zd ZdZ ddddddd�dddee d ee d
ed ee d ed
ee dee ddf� fdd�Z
e defdd��Z d� fdd� Z
� ZS )r )�_host�_port�_reuse_address� _reuse_portNr% r& )r( r) r* �
reuse_address�
reuse_portr+ r �host�portr( r) r* rI rJ r c sF t � j||||d� || _|d u r| jrdnd}|| _|| _|| _d S )Nr' i� i� )�superr6 rE r" rF rG rH ) r4 r+ rK rL r( r) r* rI rJ �� __class__r r r6 U s �
zTCPSite.__init__c C s4 | j rdnd}| js dn| j}ttj||| jd��S )N�https�httpz0.0.0.0��schemerK rL )r" rE rD r �buildrF )r4 rS rK r r r r8 n s z TCPSite.namec � s^ �t � �� I d H t�� }| jj}|d usJ �|j|| j| j| j | j
| j | j d�I d H | _
d S )N)�sslr* rI rJ )rM r: �asyncio�get_event_loopr! r. �
create_serverrE rF r" r# rG rH r$ �r4 �loopr. rN r r r: t s � �z
TCPSite.start)NNr? )r r r r@ r rD rB rA r �boolr6 rC r8 r: �
__classcell__r r rN r r R s@ �������� �
� �r c
sh e Zd ZdZdddd�ddded ed
ee d ed df � fd
d�Z e
d e fdd��Z d� fdd� Z
� ZS )r ��_pathr% Nr& r' r+ r �pathr( r) r* r c s t � j||||d� || _d S )Nr' )rM r6 r^ )r4 r+ r_ r( r) r* rN r r r6 � s �
zUnixSite.__init__c C s | j rdnd}|� d| j� d�S )NrP rQ �://unix:�:)r" r^ )r4 rS r r r r8 � s z
UnixSite.namec � �R �t � �� I d H t�� }| jj}|d usJ �|j|| j| j| j d�I d H | _
d S )N)rU r* ) rM r: rV rW r! r. �create_unix_serverr^ r" r# r$ rY rN r r r: � s � �zUnixSite.startr? )r r r r@ r rA r r rB r6 rC rD r8 r: r\ r r rN r r � s* �������r c sX e Zd ZdZdd�dddededd f� fd
d �Zedefd d
��Zd� fdd� Z � Z
S )r r] r% �r( r+ r r_ r( r Nc s6 t �� }t|t j�std��t� j||d� || _d S )Nz9Named Pipes only available in proactor loop under windowsrd )rV rW �
isinstance�ProactorEventLoopr/ rM r6 r^ )r4 r+ r_ r( rZ rN r r r6 � s ��
zNamedPipeSite.__init__c C � | j S r r] r7 r r r r8 � � zNamedPipeSite.namec � sP �t � �� I d H t�� }| jj}|d usJ �|�|| j�I d H }|d | _d S �Nr ) rM r: rV rW r! r. �start_serving_piper^ r$ )r4 rZ r. r$ rN r r r: � s �
�zNamedPipeSite.startr? ) r r r r@ rD rA r6 rC r8 r: r\ r r rN r r � s �����
r c
sj e Zd ZdZdddd�dddejd ed
ee d ed df � fd
d�Z e
d e fdd��Z d� fdd� Z
� ZS )r )�_sock�_namer% Nr& r' r+ r �sockr( r) r* r c
s� t � j||||d� || _| jrdnd}ttd�r*|jtjkr*|� d|�� � d�}n|�� d d� \}} t t
j ||| d��}|| _ d S ) Nr' rP rQ �AF_UNIXr` ra r, rR )
rM r6 rk r" �hasattr�socket�familyrn � getsocknamerD r rT rl )
r4 r+ rm r( r) r* rS r8 rK rL rN r r r6 � s �
zSockSite.__init__c C rg r )rl r7 r r r r8 � rh z
SockSite.namec � rb )N)rm rU r* ) rM r: rV rW r! r. rX rk r" r# r$ rY rN r r r: � s � �zSockSite.startr? )r r r r@ rp rA r r rB r6 rC rD r8 r: r\ r r rN r r � s* �������r c @ s� e Zd ZdZddd�dedededd fd
d �Zede e
fd d
��Z ede e fdd��Z
edee fdd��Zd#dd�Zed#dd��Zd#dd�Zede
fdd��Zed#dd��Zd edd fd d �Zd edd fd d �Zd edd fd!d"�Zd S )$r ��_handle_signals�_kwargsr$ �_sitesr3 Fr% )�handle_signalsr( rw r( �kwargsr Nc K s" || _ || _d | _g | _|| _d S r rs )r4 rw r( rx r r r r6 � s
zBaseRunner.__init__c C rg r )r$ r7 r r r r. rh zBaseRunner.serverc C sH g }| j D ] }|j}|d ur!|j}|d ur!|D ] }|�|�� � qq|S r )rv r$ �sockets�appendrr )r4 �ret�siter. ry rm r r r � addresses s
�zBaseRunner.addressesc C s
t | j�S r )�setrv r7 r r r �sites s
zBaseRunner.sitesc � sX �t �� }| jr"z|�tjt� |�tjt� W n ty! Y nw | � � I d H | _
d S r ) rV rW rt �add_signal_handler�signal�SIGINTr �SIGTERM�NotImplementedError� _make_serverr$ �r4 rZ r r r �setup s � �zBaseRunner.setupc � s �dS )z8Call any shutdown hooks to help server close gracefully.Nr r7 r r r �shutdown# s zBaseRunner.shutdownc � s� �t | j�D ] }|�� I d H q| jr1t�d�I d H | j�� | �� I d H | j�| j�I d H | � � I d H d | _| j
r\t� � }z|� t
j� |� t
j� W d S ty[ Y d S w d S ri )�listrv r> r$ rV �sleep� pre_shutdownr� r3 �_cleanup_serverrt �get_running_loop�remove_signal_handlerr� r� r� r� )r4 r| rZ r r r �cleanup' s& �
��zBaseRunner.cleanupc � � �d S r r r7 r r r r� B � �zBaseRunner._make_serverc � r� r r r7 r r r r� F r� zBaseRunner._cleanup_serverr| c C s. || j v rtd|� d| � ���| j �|� d S )N�Site z! is already registered in runner )rv r/ rz �r4 r| r r r r9 J �
zBaseRunner._reg_sitec C s" || j vrtd|� d| � ���d S �Nr� z is not registered in runner )rv r/ r� r r r r; O s
�zBaseRunner._check_sitec C s. || j vrtd|� d| � ���| j �|� d S r� )rv r/ �remover� r r r r= S r� zBaseRunner._unreg_siter? )r r r r@ r[ rA r r6 rC r r
r. r r} r r r r� r r� r� r� r� r9 r; r= r r r r r � s< ����
�
r c s^ e Zd ZdZdZdd�dedededd f� fd
d �Zdd d
�Z defdd�Z
ddd�Z � Z S )r zLow-level web server runner�� _web_serverF�rw �
web_serverrw rx r Nc s t � jdd|i|�� || _d S )Nrw r )rM r6 r� )r4 r� rw rx rN r r r6 ^ s
zServerRunner.__init__c � r� r r r7 r r r r� d � �zServerRunner.shutdownc � s �| j S r r� r7 r r r r� g s �zServerRunner._make_serverc � r� r r r7 r r r r� j r� z ServerRunner._cleanup_serverr? )
r r r �__doc__r@ r
r[ r r6 r� r� r� r\ r r rN r r Y s �����
r c sp e Zd ZdZdZdd�dedededd f� fd
d �Ze defd d
��Z
ddd�Z de fdd�Z
ddd�Z� ZS )r zWeb Application runner��_appFr� �apprw rx r Nc s8 t � jdd|i|�� t|t�std�|���|| _d S )Nrw z?The first argument should be web.Application instance, got {!r}r )rM r6 re r � TypeError�formatr� )r4 r� rw rx rN r r r6 s s
�
zAppRunner.__init__c C rg r r� r7 r r r r� ~ rh z
AppRunner.appc � � �| j �� I d H d S r )r� r� r7 r r r r� � � �zAppRunner.shutdownc � sT �t �� }| j�|� | jj�� | j�� I d H | j�� | jjdd|i| j��S )NrZ r ) rV rW r� � _set_loop�
on_startup�freeze�startup�
_make_handlerru r� r r r r� � s �
zAppRunner._make_serverc � r� r )r� r� r7 r r r r� � r� zAppRunner._cleanup_serverr? )r r r r� r@ r r[ r r6 rC r� r� r
r� r� r\ r r rN r r n s$ �����
r r? )%rV r� rp r0 �abcr r �typingr r r r r �yarlr �typedefsr �web_appr r� r
rU r � ImportError�object�__all__�
SystemExitr r r r r r r r r r r r r r �<module> s8 �
'2& )g