File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/web_runner.cpython-310.pyc
Back
o ;j�1 � @ sd d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZm Z d dl m Z ddlm Z ddl mZ ddlmZ dd lmZ dd lmZ erMd d lmZ nzd d lmZ W n ey` eZY nw d ZG d d� de�Zd"dd�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#G d d!� d!e"�Z$dS )#� N)�ABC�abstractmethod)� TYPE_CHECKING�Any)�URL� )�AbstractAccessLogger)�PathLike)� Application)� AccessLogger)�Server)� SSLContext) �BaseSite�TCPSite�UnixSite� NamedPipeSite�SockSite� BaseRunner� AppRunner� ServerRunner� GracefulExitc @ s e Zd ZdZdS )r r N)�__name__� __module__� __qualname__�code� r r �F/opt/saltstack/salt/lib/python3.10/site-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 edB d ed df d d �Zee d e fdd���Z e ddd��Z ddd�Z dS )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__0 s zBaseSite.__init__c C s d S r r �r3 r r r �nameC s z BaseSite.namec � s �| j �| � d S r )r � _reg_siter6 r r r �startH s �zBaseSite.startc � s2 �| j �| � | jd ur| j�� | j �| � d S r )r � _check_siter# �close� _unreg_siter6 r r r �stopL s � z BaseSite.stop�r N)r r r � __slots__�floatr �intr5 �propertyr �strr7 r9 r= r r r r r - s, ����� � r c s� e Zd ZdZ ddddddd�dddedB d edB d ed edB d ed edB dedB ddf� fdd�Z e defdd��Z e defdd��Z d� fdd� Z � ZS )r )�_host�_port� _bound_port�_reuse_address� _reuse_portNr$ r% )r' r( r) � reuse_address� reuse_portr* r �host�portr' r( r) rI rJ r c sL t � j||||d� || _|d u r| jrdnd}|| _d | _|| _|| _d S )Nr& i� i� )�superr5 rD r! rE rF rG rH ) r3 r* rK rL r' r( r) rI rJ �� __class__r r r5 W s � zTCPSite.__init__c C s | j dur| j S | jS )a� The port the server is listening on. If the server hasn't been started yet, this returns the requested port (which might be 0 for a dynamic port). After the server starts, it returns the actual bound port. This is especially useful when port=0 was requested, as it allows retrieving the dynamically assigned port after the site has started. N)rF rE r6 r r r rL q s z TCPSite.portc C s4 | j rdnd}| js dn| j}ttj||| jd��S )N�https�httpz0.0.0.0��schemerK rL )r! rD rC r �buildrL )r3 rS rK r r r r7 s z TCPSite.namec � s� �t � �� I d H t�� }| jj}|d usJ �|j|| j| j| j | j | j | j d�I d H | _ | j jr>| j jd �� d | _d S | j| _d S )N)�sslr) rI rJ r r )rM r9 �asyncio�get_event_loopr r- � create_serverrD rE r! r" rG rH r# �sockets� getsocknamerF �r3 �loopr- rN r r r9 � s" � � z TCPSite.start)NNr> )r r r r? rC rA r@ r �boolr5 rB rL r7 r9 � __classcell__r r rN r r T sD �������� � � � r c sh e Zd ZdZdddd�ddded ed edB d ed df � fd d�Ze d e fdd��Z d� fdd� Z � Z S )r ��_pathr$ Nr% r& r* r �pathr' r( r) r c s t � j||||d� || _d S )Nr& )rM r5 r` )r3 r* ra r' r( r) rN r r r5 � s � zUnixSite.__init__c C s | j rdnd}|� d| j� d�S )NrP rQ �://unix:�:)r! r` )r3 rS r r r r7 � 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 r9 rV rW r r- Zcreate_unix_serverr` r! r" r# r[ rN r r r9 � s � �zUnixSite.startr> )r r r r? r r@ r rA r5 rB rC r7 r9 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 ra r' r Nc s6 t �� }t|t j�std��t� j||d� || _d S )Nz9Named Pipes only available in proactor loop under windowsre )rV rW � isinstanceZProactorEventLoopr. rM r5 r` )r3 r* ra r' r\ rN r r r5 � s �� zNamedPipeSite.__init__c C � | j S r r_ r6 r r r r7 � � zNamedPipeSite.namec � sP �t � �� I d H t�� }| jj}|d usJ �|�|| j�I d H }|d | _d S �Nr ) rM r9 rV rW r r- Zstart_serving_piper` r# )r3 r\ r- r# rN r r r9 � s � �zNamedPipeSite.startr> ) r r r r? rC r@ r5 rB r7 r9 r^ r r rN r r � s ����� r c sj e Zd ZdZdddd�dddejd ed edB d ed df � fd d�Ze d e fdd��Z d� fdd� Z � Z S )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_UNIXrb rc r+ rR ) rM r5 rj r! �hasattr�socket�familyrm rZ rC r rT rk ) r3 r* rl r' r( r) rS r7 rK rL rN r r r5 � s � zSockSite.__init__c C rg r )rk r6 r r r r7 � rh z SockSite.namec � rd )N)rl rU r) ) rM r9 rV rW r r- rX rj r! r" r# r[ rN r r r9 � s � �zSockSite.startr> )r r r r? ro r@ r rA r5 rB rC r7 r9 r^ r r rN r r � s* �������r c @ s� e Zd ZdZddd�dedededd fd d �Zede d B fd d ��Z ede e fdd��Z ede e 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# �_sitesr2 Fr$ )�handle_signalsr' ru r' �kwargsr Nc K s" || _ || _d | _g | _|| _d S r rq )r3 ru r' rv r r r r5 s zBaseRunner.__init__c C rg r )r# r6 r r r r- rh zBaseRunner.serverc C sH g }| j D ] }|j}|d ur!|j}|d ur!|D ] }|�|�� � qq|S r )rt r# rY �appendrZ )r3 �ret�siter- rY rl r r r � addresses s �zBaseRunner.addressesc C s t | j�S r )�setrt r6 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 rr Zadd_signal_handler�signal�SIGINTr �SIGTERM�NotImplementedError� _make_serverr# �r3 r\ r r r �setup+ s � �zBaseRunner.setupc � s �dS )z8Call any shutdown hooks to help server close gracefully.Nr r6 r r r �shutdown8 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 )�listrt r= r# rV �sleepZ pre_shutdownr� r2 �_cleanup_serverrr Zget_running_loopZremove_signal_handlerr} r~ r r� )r3 ry r\ r r r �cleanup< s& � ��zBaseRunner.cleanupc � � �d S r r r6 r r r r� W � �zBaseRunner._make_serverc � r� r r r6 r r r r� [ r� zBaseRunner._cleanup_serverry c C s. || j v rtd|� d| � ���| j �|� d S )N�Site z! is already registered in runner )rt r. rw �r3 ry r r r r8 _ � zBaseRunner._reg_sitec C s" || j vrtd|� d| � ���d S �Nr� z is not registered in runner )rt r. r� r r r r: d s �zBaseRunner._check_sitec C s. || j vrtd|� d| � ���| j �|� d S r� )rt r. �remover� r r r r< h r� zBaseRunner._unreg_siter> )r r r r? r] r@ r r5 rB r r- r� rz r{ r r| r� r r� r� r� r� r8 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)ru � web_serverru rv r Nc s t � jdd|i|�� || _d S )Nru r )rM r5 r� )r3 r� ru rv rN r r r5 s s zServerRunner.__init__c � r� r r r6 r r r r� y � �zServerRunner.shutdownc � s �| j S r r� r6 r r r r� | s �zServerRunner._make_serverc � r� r r r6 r r r r� r� z ServerRunner._cleanup_serverr> ) r r r �__doc__r? r r] r r5 r� r� r� r^ r r rN r r n s ����� r c sz e Zd ZdZdZded�dededee de d d f � fd d �Z e d efd d��Z ddd�Zd efdd�Zddd�Z� ZS )r zWeb Application runner��_appF)ru �access_log_class�appru r� rv r Nc sB t � jdd|i|�� t|t�std|����|| jd< || _d S )Nru z;The first argument should be web.Application instance, got r� r )rM r5 rf r � TypeErrorrs r� )r3 r� ru r� rv rN r r r5 � s � zAppRunner.__init__c C rg r r� r6 r r r r� � rh z AppRunner.appc � � �| j �� I d H d S r )r� r� r6 r r r r� � � �zAppRunner.shutdownc � sT �t �� }| j�|� | jj�� | j�� I d H | j�� | jjdd|i| j��S )Nr\ r ) rV rW r� Z _set_loopZ on_startupZfreezeZstartupZ _make_handlerrs r� r r r r� � s � zAppRunner._make_serverc � r� r )r� r� r6 r r r r� � r� zAppRunner._cleanup_serverr> )r r r r� r? r r r] �typer r r5 rB r� r� r r� r� r^ r r rN r r � s* ������ r r> )%rV r} ro r/ �abcr r �typingr r Zyarlr r Ztypedefsr Zweb_appr Zweb_logr r� r rU r � ImportError�object�__all__� SystemExitr r r r r r r r r r r r r r �<module> s< � 'E& )g
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings