관리-도구
편집 파일: base_events.cpython-38.opt-2.pyc
U i�f� � @ s� d dl Z d dlZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl Z d dl Z d dlZd dlZd dlZz d dlZW n ek r� dZY nX ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd lmZ dd lm Z dd lm Z dd lm Z ddl m Z dZ!dZ"dZ#e$ed�Z%dZ&e'� Z(dd� Z)dd� Z*dd� Z+d*dd�Z,d+d d �Z-d d � Z.e$ed ��r�d!d"� Z/nd#d"� Z/G d$d%� d%ej0�Z1G d&d'� d'ej2�Z3G d(d)� d)ej4�Z5dS ),� N� )� constants)� coroutines)�events)� exceptions)�futures)� protocols)�sslproto)� staggered)�tasks)� transports)�trsock)�logger)� BaseEventLoop�d g �?�AF_INET6i�Q c C s0 | j }tt|dd �tj�r$t|j�S t| �S d S )N�__self__)Z _callback� isinstance�getattrr �Task�reprr �str)�handle�cb� r �8/opt/alt/python38/lib64/python3.8/asyncio/base_events.py�_format_handleJ s r c C s( | t jkrdS | t jkr dS t| �S d S )Nz<pipe>z<stdout>)� subprocess�PIPE�STDOUTr )�fdr r r � _format_pipeS s r! c C sL t td�std��n4z| �tjtjd� W n tk rF td��Y nX d S )N� SO_REUSEPORTz)reuse_port not supported by socket moduler zTreuse_port not supported by socket module, SO_REUSEPORT defined but not implemented.)�hasattr�socket� ValueError� setsockopt� SOL_SOCKETr" �OSError��sockr r r �_set_reuseport\ s r+ c C s� t td�sd S |dtjtjhks(| d kr,d S |tjkr>tj}n|tjkrPtj}nd S |d krbd}nXt|t�rz|dkrzd}n@t|t�r�|dkr�d}n(z t |�}W n t t fk r� Y d S X |tj kr�tj g}tr�|�tj� n|g}t| t�r�| �d�} d| k�rd S |D ]t}zVt�|| � t�rJ|tjk�rJ|||d| |||ffW S |||d| |ffW S W n tk �rz Y nX �q d S )N� inet_ptonr � � Zidna�%)r# r$ � IPPROTO_TCPZ IPPROTO_UDP� SOCK_STREAM� SOCK_DGRAMr �bytesr �int� TypeErrorr% � AF_UNSPEC�AF_INET� _HAS_IPv6�appendr �decoder, r( ) �host�port�family�type�protoZflowinfoZscopeidZafs�afr r r � _ipaddr_infog sN � rA c C s� t �� }| D ]*}|d }||kr(g ||< || �|� q t|�� �}g }|dkr||�|d d |d � � |d d |d �= |�dd� tj�tj |� �D �� |S )Nr r c s s | ]}|d k r|V qd S �Nr )�.0�ar r r � <genexpr>� s �z(_interleave_addrinfos.<locals>.<genexpr>) � collections� OrderedDictr9 �list�values�extend� itertools�chain� from_iterable� zip_longest)Z addrinfosZfirst_address_family_countZaddrinfos_by_family�addrr= Zaddrinfos_listsZ reorderedr r r �_interleave_addrinfos� s" ��rP c C s4 | � � s"| �� }t|ttf�r"d S t�| ��� d S rB )� cancelled� exceptionr � SystemExit�KeyboardInterruptr Z _get_loop�stop)�fut�excr r r �_run_until_complete_cb� s rX � TCP_NODELAYc C s@ | j tjtjhkr<| jtjkr<| jtjkr<| �tjtj d� d S �Nr ) r= r$ r7 r r> r1 r? r0 r& rY r) r r r � _set_nodelay� s � �r[ c C s d S rB r r) r r r r[ � s c @ sT e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dS )�_SendfileFallbackProtocolc C sh t |tj�std��|| _|�� | _|�� | _|j | _ |� � |� | � | j r^| jj �� | _nd | _d S )Nz.transport should be _FlowControlMixin instance)r r Z_FlowControlMixinr5 � _transportZ get_protocol�_protoZ is_reading�_should_resume_readingZ_protocol_paused�_should_resume_writing� pause_reading� set_protocol�_loop� create_future�_write_ready_fut)�self�transpr r r �__init__� s z"_SendfileFallbackProtocol.__init__c � s2 | j �� rtd��| j}|d kr$d S |I d H d S )NzConnection closed by peer)r] � is_closing�ConnectionErrorre )rf rV r r r �drain� s z _SendfileFallbackProtocol.drainc C s t d��d S )Nz?Invalid state: connection should have been established already.�� RuntimeError)rf � transportr r r �connection_made� s z)_SendfileFallbackProtocol.connection_madec C s@ | j d k r0|d kr$| j �td�� n | j �|� | j�|� d S )Nz Connection is closed by peer)re Z set_exceptionrj r^ �connection_lost)rf rW r r r rp � s � z)_SendfileFallbackProtocol.connection_lostc C s | j d k rd S | jj�� | _ d S rB )re r] rc rd �rf r r r � pause_writing� s z'_SendfileFallbackProtocol.pause_writingc C s$ | j d krd S | j �d� d | _ d S )NF)re � set_resultrq r r r �resume_writing� s z(_SendfileFallbackProtocol.resume_writingc C s t d��d S �Nz'Invalid state: reading should be pausedrl )rf �datar r r � data_received� s z'_SendfileFallbackProtocol.data_receivedc C s t d��d S ru rl rq r r r � eof_received s z&_SendfileFallbackProtocol.eof_receivedc � sF | j �| j� | jr | j �� | jd k r2| j�� | jrB| j�� d S rB ) r] rb r^ r_ �resume_readingre �cancelr` rt rq r r r �restore s z!_SendfileFallbackProtocol.restoreN) �__name__� __module__� __qualname__rh rk ro rp rr rt rw rx r{ r r r r r\ � s r\ c @ sx e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z e dd� �Z dd� Z dd� Zdd� Zdd� ZdS ) �Serverc C s@ || _ || _d| _g | _|| _|| _|| _|| _d| _d | _ d S )Nr F) rc �_sockets� _active_count�_waiters�_protocol_factory�_backlog� _ssl_context�_ssl_handshake_timeout�_serving�_serving_forever_fut)rf �loop�sockets�protocol_factoryZ ssl_context�backlog�ssl_handshake_timeoutr r r rh s zServer.__init__c C s d| j j� d| j�d�S )N�<z sockets=�>)� __class__r| r� rq r r r �__repr__ s zServer.__repr__c C s | j d7 _ d S rZ )r� rq r r r �_attach# s zServer._attachc C s. | j d8 _ | j dkr*| jd kr*| �� d S )Nr r )r� r� �_wakeuprq r r r �_detach' s zServer._detachc C s, | j }d | _ |D ]}|�� s|�|� qd S rB )r� �doners )rf �waiters�waiterr r r r� - s zServer._wakeupc C sJ | j r d S d| _ | jD ].}|�| j� | j�| j|| j| | j| j� qd S �NT) r� r� Zlistenr� rc �_start_servingr� r� r� )rf r* r r r r� 4 s �zServer._start_servingc C s | j S rB )rc rq r r r �get_loop> s zServer.get_loopc C s | j S rB )r� rq r r r � is_servingA s zServer.is_servingc C s" | j d krdS tdd� | j D ��S )Nr c s s | ]}t �|�V qd S rB )r ZTransportSocket)rC �sr r r rE H s z!Server.sockets.<locals>.<genexpr>)r� �tuplerq r r r r� D s zServer.socketsc C sn | j }|d krd S d | _ |D ]}| j�|� q d| _| jd k rX| j�� sX| j�� d | _| jdkrj| �� d S )NFr ) r� rc Z _stop_servingr� r� r� rz r� r� )rf r� r* r r r �closeJ s � z Server.closec � s" | � � tjd| jd�I d H d S )Nr �r� )r� r �sleeprc rq r r r � start_serving] s zServer.start_servingc � s� | j d k rtd| �d���| jd kr4td| �d���| �� | j�� | _ zLz| j I d H W n6 tjk r� z| �� | � � I d H W 5 � X Y nX W 5 d | _ X d S )Nzserver z, is already being awaited on serve_forever()z is closed) r� rm r� r� rc rd r ZCancelledErrorr� � wait_closedrq r r r � serve_foreverc s � zServer.serve_foreverc � s< | j d ks| jd krd S | j�� }| j�|� |I d H d S rB )r� r� rc rd r9 )rf r� r r r r� x s zServer.wait_closedN)r| r} r~ rh r� r� r� r� r� r� r� �propertyr� r� r� r� r� r r r r r s r c @ sP e Zd Zdd� Zdd� Zdd� Zdd�d d �Zd d � Zd d� Zd�ddd�dd�Z d�ddddddd�dd�Z d�dd�Z d�dd�Z d�dd �Z d�d d �Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Zd5d6� Zej fd7d8�Z d9d:� Z d;d<� Z dd=�d>d?�Z dd=�d@dA�Z!dd=�dBdC�Z"dDdE� Z#dFdG� Z$dHdI� Z%dd=�dJdK�Z&dLdM� Z'dNdO� Z(dPdQ� Z)dRdRdRdRdS�dTdU�Z*d�dVdW�Z+d�ddX�dYdZ�Z,d[d\� Z-d]d^� Z.d_d`� Z/d�dadb�Z0d�ddRdRdRdddddddc� ddde�Z1d�dfdg�Z2d�ddX�dhdi�Z3djdk� Z4dldm� Z5ddddn�dodp�Z6d�dRdRdRe7ddddq�drds�Z8dRe9j:dRdRdS�dtdu�Z;dvdw� Z<d�e9j=e9j>ddxddddddy� dzd{�Z?ddd|�d}d~�Z@dd�� ZAd�d�� ZBd�d�� ZCeDjEeDjEeDjEdddRdddd�� d�d��ZFeDjEeDjEeDjEdddRdddd�� d�d��ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�d�� ZNd�d�� ZOd�d�� ZPd�d�� ZQd�d�� ZRdS )�r c C s� d| _ d| _d| _t�� | _g | _d | _d| _d | _ t � d�j | _ d | _| �t�� � d| _d | _d | _d| _d | _t�� | _d| _d S )Nr F� monotonicg�������?)�_timer_cancelled_count�_closed� _stoppingrF �deque�_ready� _scheduled�_default_executorZ _internal_fds� _thread_id�time�get_clock_infoZ resolution�_clock_resolution�_exception_handler� set_debugr Z_is_debug_mode�slow_callback_duration�_current_handle� _task_factory�"_coroutine_origin_tracking_enabled�&_coroutine_origin_tracking_saved_depth�weakrefZWeakSet� _asyncgens�_asyncgens_shutdown_calledrq r r r rh � s$ zBaseEventLoop.__init__c C s. d| j j� d| �� � d| �� � d| �� � d� S )Nr� z running=z closed=z debug=r� )r� r| � is_running� is_closed� get_debugrq r r r r� � s ,�zBaseEventLoop.__repr__c C s t j| d�S )Nr� )r ZFuturerq r r r rd � s zBaseEventLoop.create_futureN)�namec C sN | � � | jd kr2tj|| |d�}|jrJ|jd= n| �| |�}t�||� |S )N)r� r� ���)� _check_closedr� r r �_source_tracebackZ_set_task_name)rf �coror� Ztaskr r r � create_task� s zBaseEventLoop.create_taskc C s" |d k rt |�std��|| _d S )Nz'task factory must be a callable or None)�callabler5 r� )rf �factoryr r r �set_task_factory� s z BaseEventLoop.set_task_factoryc C s | j S rB )r� rq r r r �get_task_factory� s z BaseEventLoop.get_task_factory)�extra�serverc C s t �d S rB ��NotImplementedError)rf r* �protocolr� r� r� r r r �_make_socket_transport� s z$BaseEventLoop._make_socket_transportFT)� server_side�server_hostnamer� r� r� �call_connection_madec C s t �d S rB r� ) rf Zrawsockr� � sslcontextr� r� r� r� r� r� r� r r r �_make_ssl_transport� s z!BaseEventLoop._make_ssl_transportc C s t �d S rB r� )rf r* r� �addressr� r� r r r �_make_datagram_transport� s z&BaseEventLoop._make_datagram_transportc C s t �d S rB r� �rf �piper� r� r� r r r �_make_read_pipe_transport� s z'BaseEventLoop._make_read_pipe_transportc C s t �d S rB r� r� r r r �_make_write_pipe_transport� s z(BaseEventLoop._make_write_pipe_transportc � s t �d S rB r� ) rf r� �args�shell�stdin�stdout�stderr�bufsizer� �kwargsr r r �_make_subprocess_transport� s z(BaseEventLoop._make_subprocess_transportc C s t �d S rB r� rq r r r �_write_to_self� s z BaseEventLoop._write_to_selfc C s t �d S rB r� )rf � event_listr r r �_process_events� s z BaseEventLoop._process_eventsc C s | j rtd��d S )NzEvent loop is closed)r� rm rq r r r r� � s zBaseEventLoop._check_closedc C s* | j �|� | �� s&| �| j|�� � d S rB )r� �discardr� �call_soon_threadsafer� �aclose�rf �agenr r r �_asyncgen_finalizer_hook� s z&BaseEventLoop._asyncgen_finalizer_hookc C s. | j r tjd|�d�t| d� | j�|� d S )Nzasynchronous generator z3 was scheduled after loop.shutdown_asyncgens() call��source)r� �warnings�warn�ResourceWarningr� �addr� r r r �_asyncgen_firstiter_hook s �z&BaseEventLoop._asyncgen_firstiter_hookc � s� d| _ t| j�sd S t| j�}| j�� tjdd� |D �d| d��I d H }t||�D ]*\}}t|t �rT| � d|��||d�� qTd S )NTc S s g | ] }|� � �qS r )r� )rC Zagr r r � <listcomp> s z4BaseEventLoop.shutdown_asyncgens.<locals>.<listcomp>)Zreturn_exceptionsr� z;an error occurred during closing of asynchronous generator )�messagerR Zasyncgen) r� �lenr� rH �clearr �gather�zipr � Exception�call_exception_handler)rf Z closing_agensZresults�resultr� r r r �shutdown_asyncgens s" � �z BaseEventLoop.shutdown_asyncgensc C s( | � � rtd��t�� d k r$td��d S )Nz"This event loop is already runningz7Cannot run the event loop while another loop is running)r� rm r Z_get_running_looprq r r r �_check_running& s �z BaseEventLoop._check_runningc C s� | � � | �� | �| j� t�� | _t�� }tj | j | j d� z t �| � | �� | j rLq^qLW 5 d| _ d | _t �d � | �d� tj |� X d S )N)� firstiter� finalizerF)r� r� � _set_coroutine_origin_tracking�_debug� threading� get_identr� �sys�get_asyncgen_hooks�set_asyncgen_hooksr� r� r� r Z_set_running_loop� _run_once)rf Zold_agen_hooksr r r � run_forever- s$ � zBaseEventLoop.run_foreverc C s� | � � | �� t�|� }tj|| d�}|r4d|_|�t� z<z | � � W n* |rp|� � rp|� � sp|� � � Y nX W 5 |� t� X |� � s�td��|�� S )Nr� Fz+Event loop stopped before Future completed.)r� r� r Zisfuturer Z ensure_futureZ_log_destroy_pendingZadd_done_callbackrX Zremove_done_callbackr r� rQ rR rm r� )rf ZfutureZnew_taskr r r �run_until_completeD s" z BaseEventLoop.run_until_completec C s d| _ d S r� )r� rq r r r rU j s zBaseEventLoop.stopc C sj | � � rtd��| jrd S | jr,t�d| � d| _| j�� | j�� | j }|d k rfd | _ |j dd� d S )Nz!Cannot close a running event loopzClose %rTF)�wait) r� rm r� r� r �debugr� r� r� r� Zshutdown�rf �executorr r r r� r s zBaseEventLoop.closec C s | j S rB )r� rq r r r r� � s zBaseEventLoop.is_closedc C s0 | � � s,|d| ��t| d� | �� s,| �� d S )Nzunclosed event loop r� )r� r� r� r� )rf Z_warnr r r �__del__� s zBaseEventLoop.__del__c C s | j d k S rB )r� rq r r r r� � s zBaseEventLoop.is_runningc C s t �� S rB )r� r� rq r r r r� � s zBaseEventLoop.time)�contextc G s2 | j | �� | |f|�d|i�}|jr.|jd= |S )Nr r� )�call_atr� r� )rf Zdelay�callbackr r� �timerr r r � call_later� s �zBaseEventLoop.call_laterc G sZ | � � | jr"| �� | �|d� t�|||| |�}|jrB|jd= t�| j |� d|_ |S )Nr r� T) r� r� � _check_thread�_check_callbackr Z TimerHandler� �heapq�heappushr� )rf �whenr r r� r r r r r � s zBaseEventLoop.call_atc G sB | � � | jr"| �� | �|d� | �|||�}|jr>|jd= |S )N� call_soonr� )r� r� r r � _call_soonr� �rf r r r� r r r r r � s zBaseEventLoop.call_soonc C sD t �|�st �|�r$td|� d���t|�s@td|� d|����d S )Nz coroutines cannot be used with z()z"a callable object was expected by z(), got )r Z iscoroutineZiscoroutinefunctionr5 r� )rf r �methodr r r r � s � ��z BaseEventLoop._check_callbackc C s. t �||| |�}|jr |jd= | j�|� |S )Nr� )r ZHandler� r� r9 )rf r r� r r r r r r � s zBaseEventLoop._call_soonc C s, | j d krd S t�� }|| j kr(td��d S )NzMNon-thread-safe operation invoked on an event loop other than the current one)r� r r rm )rf Z thread_idr r r r � s �zBaseEventLoop._check_threadc G sB | � � | jr| �|d� | �|||�}|jr6|jd= | �� |S )Nr� r� )r� r� r r r� r� r r r r r� � s z"BaseEventLoop.call_soon_threadsafec G sZ | � � | jr| �|d� |d kr@| j}|d kr@tj�� }|| _tj|j|f|�� | d�S )N�run_in_executorr� ) r� r� r r� � concurrentr �ThreadPoolExecutorZ wrap_futureZsubmit)rf r �funcr� r r r r s �z BaseEventLoop.run_in_executorc C s& t |tjj�s t�dtd� || _d S )Nz{Using the default executor that is not an instance of ThreadPoolExecutor is deprecated and will be prohibited in Python 3.9� )r r r r r� r� �DeprecationWarningr� r r r r �set_default_executor s �z"BaseEventLoop.set_default_executorc C s� |� d|��g}|r$|� d|��� |r8|� d|��� |rL|� d|��� |r`|� d|��� d�|�}t�d|� | �� }t�||||||�} | �� | } d|� d | d d �d | ��}| | jkr�t�|� n t�|� | S ) N�:zfamily=ztype=zproto=zflags=�, zGet address info %szGetting address info z took g @�@z.3fzms: ) r9 �joinr r r� r$ � getaddrinfor� �info) rf r; r< r= r> r? �flags�msg�t0�addrinfo�dtr r r �_getaddrinfo_debug s& z BaseEventLoop._getaddrinfo_debugr �r= r> r? r' c � s2 | j r| j}ntj}| �d |||||||�I d H S rB )r� r, r$ r% r )rf r; r< r= r> r? r' Z getaddr_funcr r r r% 2 s �zBaseEventLoop.getaddrinfoc � s | � d tj||�I d H S rB )r r$ � getnameinfo)rf Zsockaddrr' r r r r. < s �zBaseEventLoop.getnameinfo)�fallbackc � s� | j r|�� dkrtd��| �||||� z| �||||�I d H W S tjk rl } z |s\� W 5 d }~X Y nX | �||||�I d H S )Nr z the socket must be non-blocking)r� Z gettimeoutr% �_check_sendfile_params�_sock_sendfile_nativer �SendfileNotAvailableError�_sock_sendfile_fallback)rf r* �file�offset�countr/ rW r r r � sock_sendfile@ s � �zBaseEventLoop.sock_sendfilec � s t �d|�d���d S )Nz-syscall sendfile is not available for socket z and file {file!r} combination�r r2 �rf r* r4 r5 r6 r r r r1 N s �z#BaseEventLoop._sock_sendfile_nativec � s� |r|� |� |r t|tj�ntj}t|�}d}zt|rNt|| |�}|dkrNq�t|�d |� }| �d |j|�I d H } | szq�| � ||d | � �I d H || 7 }q2|W �S |dkr�t|d�r�|� || � X d S )Nr �seek) r: �minr Z!SENDFILE_FALLBACK_READBUFFER_SIZE� bytearrayr# � memoryviewr �readintoZ sock_sendall) rf r* r4 r5 r6 � blocksize�buf� total_sent�view�readr r r r3 U s, �� z%BaseEventLoop._sock_sendfile_fallbackc C s� dt |dd�krtd��|jtjks,td��|d k rbt|t�sLtd�|���|dkrbtd�|���t|t�sztd�|���|dk r�td�|���d S )N�b�modez$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r z0offset must be a non-negative integer (got {!r})) r r% r> r$ r1 r r4 r5 �formatr9 r r r r0 o s2 �� ����z$BaseEventLoop._check_sendfile_paramsc � s@ g }|� |� |\}}}}} d } z�tj|||d�} | �d� |d k r�|D ]r\}}}}} z| �| � W q�W qH tk r� } z0d| �d| j�� � �} t| j| �} |� | � W 5 d } ~ X Y qHX qH|�� �| � | | �I d H | W S tk �r } z"|� | � | d k �r | � � � W 5 d } ~ X Y n | d k �r4| � � � Y nX d S )N�r= r> r? Fz*error while attempting to bind on address �: ) r9 r$ � setblocking�bindr( �strerror�lower�errno�pop� sock_connectr� )rf r Z addr_infoZlocal_addr_infosZ my_exceptionsr= Ztype_r? �_r� r* ZladdrrW r( r r r � _connect_sock� s: � zBaseEventLoop._connect_sock) �sslr= r? r' r* � local_addrr� r� �happy_eyeballs_delay� interleavec � sl | d k r|st d��| d kr0|r0|s,t d��|} | d k rD|sDt d��| d k rX| d krXd} |d k sj|d k �r�|d k rzt d���j||f|tj||�d�I d H }|s�td��| d k r܈j| |tj||�d�I d H ��s�td��nd �| r�t|| �}g � | d k�rH|D ]D}z ��� |��I d H }W �qvW n tk �r@ Y �q Y nX �q n.tj� ��fdd �|D �| �d �I d H \}}}|d k�r d d � � D �� t � �dk�r�� d �nJt � d ��t �fdd �� D ���r҈ d �td� d� dd � � D �����n.|d k�rt d��|jtjk�r t d|�����j|||| | d�I d H \}}�j�rd|�d�}t�d|||||� ||fS )Nz+server_hostname is only meaningful with sslz:You must set server_hostname when using ssl without a host�1ssl_handshake_timeout is only meaningful with sslr �8host/port and sock can not be specified at the same time�r= r> r? r' r� �!getaddrinfo() returned empty listc 3 s | ]}t ��j� |��V qd S rB )� functools�partialrQ )rC r* )r � laddr_infosrf r r rE � s � �z2BaseEventLoop.create_connection.<locals>.<genexpr>r� c S s g | ]}|D ]}|�q qS r r )rC �subrW r r r r� � s z3BaseEventLoop.create_connection.<locals>.<listcomp>r c 3 s | ]}t |�� kV qd S rB �r �rC rW )�modelr r rE s zMultiple exceptions: {}r# c s s | ]}t |�V qd S rB r^ r_ r r r rE s z5host and port was not specified and no sock specified�"A Stream Socket was expected, got )r� r$ z %r connected to %s:%r: (%r, %r))r% �_ensure_resolvedr$ r1 r( rP rQ r Zstaggered_racer� r �allrF r$ r> � _create_connection_transportr� �get_extra_infor r )rf r� r; r< rR r= r? r' r* rS r� r� rT rU �infosr* rP rn r� r )r r\ r` rf r �create_connection� s� �� � � � � � � �� � �z BaseEventLoop.create_connectionc � s� |� d� |� }| �� }|rHt|t�r*d n|} | j||| ||||d�} n| �|||�} z|I d H W n | �� � Y nX | |fS )NF�r� r� r� )rI rd r �boolr� r� r� ) rf r* r� rR r� r� r� r� r� r� rn r r r rd % s* �z*BaseEventLoop._create_connection_transportc � s� |� � rtd��t|dtjj�}|tjjkr:td|����|tjjkr�z| �||||�I d H W S tj k r� } z |sx� W 5 d }~X Y nX |s�td|����| � ||||�I d H S )NzTransport is closingZ_sendfile_compatiblez(sendfile is not supported for transport zHfallback is disabled and native sendfile is not supported for transport ) ri rm r r Z _SendfileModeZ UNSUPPORTEDZ TRY_NATIVE�_sendfile_nativer r2 �_sendfile_fallback)rf rn r4 r5 r6 r/ rE rW r r r �sendfile? s4 � � � � �zBaseEventLoop.sendfilec � s t �d��d S )Nz!sendfile syscall is not supportedr8 )rf rg r4 r5 r6 r r r rj n s �z BaseEventLoop._sendfile_nativec � s� |r|� |� |r t|d�nd}t|�}d}t|�}z�|rXt|| |�}|dkrX|W �bS t|�d |� } | �d |j| �I d H } | s�|W �0S |� � I d H |� | d | � � || 7 }q6W 5 |dkr�t|d�r�|� || � |�� I d H X d S )Ni @ r r: ) r: r; r< r\ r# r{ r= r r> rk �write) rf rg r4 r5 r6 r? r@ rA r? rB rC r r r rk r s* z BaseEventLoop._sendfile_fallbackrh c � s� t d krtd��t|t j�s*td|����t|dd�sFtd|�d���| �� }tj| ||||||dd�}|� � |� |� | � |j |�} | � |j �} z|I d H W n. tk r� |�� | �� | �� � Y nX |jS )Nz"Python ssl module is not availablez@sslcontext is expected to be an instance of ssl.SSLContext, got Z_start_tls_compatibleFz transport z is not supported by start_tls())r� r� )rR rm r Z SSLContextr5 r rd r Z SSLProtocolra rb r ro ry � BaseExceptionr� rz Z_app_transport) rf rn r� r� r� r� r� r� Z ssl_protocolZ conmade_cbZ resume_cbr r r � start_tls� sB � � � zBaseEventLoop.start_tls)r= r? r' � reuse_address� reuse_port�allow_broadcastr* c � s� | d k r�| j tjkr"td| ����� s>�s>|s>|s>|s>|s>| r~t� �|||||| d�} d�dd� | �� D ��} td| � d���| �d� d } �n� s��s�|d kr�td ��||fd ff}�n�ttd ��r�|tj k�r�� �fD ] }|d k r�t |t �s�t d ��qڈ �rx� d dk�rxz"t �t� � �j��r.t�� � W nF tk �rF Y n2 tk �rv } zt�d� |� W 5 d }~X Y nX ||f� �fff}n�i }d � fd�ffD ]�\}}|d k �r�| j||tj||| d�I d H }|�s�td��|D ]:\}}}}}||f}||k�rd d g||< ||| |< �q�q�� �fdd�|�� D �}|�sHtd��g }|tk �rv|�rftd��ntjdtdd� |D ]�\\}}\}}d } d } zxtj|tj|d�} |�r�t| � | �r�| � tj tj d� | �d� � �r�| � |� ��r| �s| � | |�I d H |} W n^ tk �rJ } z | d k �r0| �!� |�"| � W 5 d } ~ X Y n& | d k �rb| �!� � Y nX �q|�qz|d �|� } | �#� } | �$| | | | �} | j%�r̈ �r�t�&d� �| | � nt�'d �| | � z| I d H W n | �!� � Y nX | | fS ) Nz A UDP Socket was expected, got )rS � remote_addrr= r? r' rp rq rr r# c s s$ | ] \}}|r|� d |� �V qdS )�=Nr )rC �k�vr r r rE � s z9BaseEventLoop.create_datagram_endpoint.<locals>.<genexpr>zKsocket modifier keyword arguments can not be used when sock is specified. (�)Fr zunexpected address family)NN�AF_UNIXzstring is expected)r � z2Unable to check or remove stale UNIX socket %r: %rr rX rY c s8 g | ]0\}}� r |d dks�r,|d dks||f�qS )r Nr r )rC �keyZ addr_pair�rS rs r r r� � s �z:BaseEventLoop.create_datagram_endpoint.<locals>.<listcomp>z can not get address informationz~Passing `reuse_address=True` is no longer supported, as the usage of SO_REUSEPORT in UDP poses a significant security concern.zdThe *reuse_address* parameter has been deprecated as of 3.5.10 and is scheduled for removal in 3.11.r )� stacklevelrG z@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))(r> r$ r2 r% �dictr$ �itemsrI r# rx r r r5 �stat�S_ISSOCK�os�st_mode�remove�FileNotFoundErrorr( r �errorrb �_unsetr� r� r r+ r& r' Z SO_BROADCASTrJ rO r� r9 rd r� r� r& r ) rf r� rS rs r= r? r' rp rq rr r* ZoptsZproblemsZr_addrZaddr_pairs_inforO �errZ addr_infos�idxrf ZfamrP Zpror� rz r Z local_addressZremote_addressrW r� r� rn r r{ r �create_datagram_endpoint� s$ ������ � � �� � � �� � � � � �z&BaseEventLoop.create_datagram_endpointc � s\ |d d� \}}t |||||f|dd � �� } | d k r<| gS |j||||||d�I d H S d S )Nr r- )rA r% ) rf r� r= r> r? r' r� r; r< r& r r r rb L s �z BaseEventLoop._ensure_resolvedc � s8 | j ||f|tj|| d�I d H }|s4td|�d���|S )N)r= r> r' r� z getaddrinfo(z) returned empty list)rb r$ r1 r( )rf r; r< r= r' rf r r r �_create_server_getaddrinfoX s � z(BaseEventLoop._create_server_getaddrinfor ) r= r' r* r� rR rp rq r� r� c � s� t |t�rtd��| d k r*|d kr*td��|d k s<�d k �r"|d k rLtd��| d krhtjdkoftjdk} g } |dkr|d g}n$t |t�s�t |t j j �s�|g}n|}� ���fdd�|D �}t j |d �i�I d H }ttj�|��}d }�z |D �]}|\}}}}}zt�|||�}W n8 tjk �rH �j�r@tjd |||d d � Y q�Y nX | �|� | �rl|�tjtjd � | �rzt |� t �r�|tj k�r�t td��r�|�tj tj!d � z|�"|� W q� t#k �r� } z t#|j$d||j%�&� f �d �W 5 d }~X Y q�X q�d }W 5 |�s | D ]}|�� �qX n4|d k�r4td��|j'tj(k�rPtd|����|g} | D ]}|�)d � �qZt*�| |||| �}| �r�|�+� t j,d�d�I d H �j�r�t�-d|� |S )Nz*ssl argument must be an SSLContext or NonerV rW �posix�cygwinr. c s g | ]}�j |�� �d ��qS ))r= r' )r� )rC r; �r= r' r< rf r r r� � s � �z/BaseEventLoop.create_server.<locals>.<listcomp>r� Fz:create_server() failed to create socket.socket(%r, %r, %r)T��exc_info� IPPROTO_IPV6z0error while attempting to bind on address %r: %sz)Neither host/port nor sock were specifiedra r r� z %r is serving).r ri r5 r% r� r� r �platformr rF �abc�Iterabler r� �setrK rL rM r� r$ r� r� r �warningr9 r& r' Z SO_REUSEADDRr+ r8 r r# r� Z IPV6_V6ONLYrJ r( rM rK rL r> r1 rI r r� r� r& )rf r� r; r< r= r' r* r� rR rp rq r� r� r� ZhostsZfsrf Z completed�resr@ Zsocktyper? Z canonnameZsar� r� r r� r � create_server` s� �� �� � ���� �� � zBaseEventLoop.create_server)rR r� c � sv |j tjkrtd|����|d k r.|s.td��| j|||dd|d�I d H \}}| jrn|�d�}t�d|||� ||fS )Nra rV r. T)r� r� r$ z%r handled: (%r, %r)) r> r$ r1 r% rd r� re r r )rf r� r* rR r� rn r� r r r �connect_accepted_socket� s$ � � z%BaseEventLoop.connect_accepted_socketc � sd |� }| � � }| �|||�}z|I d H W n |�� � Y nX | jr\t�d|�� ||� ||fS )Nz Read pipe %r connected: (%r, %r))rd r� r� r� r r �fileno�rf r� r� r� r� rn r r r �connect_read_pipe� s �z BaseEventLoop.connect_read_pipec � sd |� }| � � }| �|||�}z|I d H W n |�� � Y nX | jr\t�d|�� ||� ||fS )Nz!Write pipe %r connected: (%r, %r))rd r� r� r� r r r� r� r r r �connect_write_pipe s �z BaseEventLoop.connect_write_pipec C s� |g}|d k r"|� dt|�� �� |d k rJ|tjkrJ|� dt|�� �� n8|d k rf|� dt|�� �� |d k r�|� dt|�� �� t�d�|�� d S )Nzstdin=zstdout=stderr=zstdout=zstderr=� )r9 r! r r r r r$ )rf r( r� r� r� r& r r r �_log_subprocess s z BaseEventLoop._log_subprocess) r� r� r� �universal_newlinesr� r� �encoding�errors�textc � s� t |ttf�std��|r"td��|s.td��|dkr>td��| rJtd��| d k rZtd��| d k rjtd��|� } d }| jr�d | }| �||||� | j| |d ||||f| �I d H }| jr�|d k r�t�d ||� || fS ) Nzcmd must be a string� universal_newlines must be Falsezshell must be Truer �bufsize must be 0�text must be False�encoding must be None�errors must be Nonezrun shell command %rT�%s: %r) r r3 r r% r� r� r� r r& )rf r� �cmdr� r� r� r� r� r� r� r� r� r� r� � debug_logrn r r r �subprocess_shell sB �� z BaseEventLoop.subprocess_shellc � s� |r t d��|rt d��|dkr(t d��| r4t d��| d k rDt d��| d k rTt d��|f| }|� }d }| jr�d|��}| �||||� | j||d ||||f| �I d H }| jr�|d k r�t�d ||� ||fS ) Nr� zshell must be Falser r� r� r� r� zexecute program Fr� )r% r� r� r� r r& )rf r� Zprogramr� r� r� r� r� r� r� r� r� r� r� Z popen_argsr� r� rn r r r �subprocess_execC s@ �� z BaseEventLoop.subprocess_execc C s | j S rB )r� rq r r r �get_exception_handlere s z#BaseEventLoop.get_exception_handlerc C s( |d k r t |�s td|����|| _d S )Nz+A callable object or None is expected, got )r� r5 r� )rf Zhandlerr r r �set_exception_handlerj s z#BaseEventLoop.set_exception_handlerc C s |� d�}|sd}|� d�}|d k r6t|�||jf}nd}d|kr`| jd k r`| jjr`| jj|d< |g}t|�D ]�}|dkr|qn|| }|dkr�d�t�|��}d }||� � 7 }n2|dkr�d�t�|��}d }||� � 7 }nt |�}|� |� d |� �� qnt j d �|�|d � d S )Nr� z!Unhandled exception in event looprR FZsource_tracebackZhandle_traceback> rR r� r. z+Object created at (most recent call last): z+Handle created at (most recent call last): rH � r� )�getr> � __traceback__r� r� �sortedr$ � traceback� format_list�rstripr r9 r r� ) rf r r� rR r� Z log_linesrz �value�tbr r r �default_exception_handler{ s< ��� z'BaseEventLoop.default_exception_handlerc C s� | j d krVz| �|� W q� ttfk r2 � Y q� tk rR tjddd� Y q�X n�z| � | |� W n� ttfk r� � Y nt tk r� } zVz| �d||d�� W n: ttfk r� � Y n" tk r� tjddd� Y nX W 5 d }~X Y nX d S )Nz&Exception in default exception handlerTr� z$Unhandled error in exception handler)r� rR r zeException in default exception handler while handling an unexpected error in custom exception handler)r� r� rS rT rn r r� )rf r rW r r r r� � s4 �� �z$BaseEventLoop.call_exception_handlerc C s |j r d S | j�|� d S rB )� _cancelledr� r9 �rf r r r r � _add_callback� s zBaseEventLoop._add_callbackc C s | � |� | �� d S rB )r� r� r� r r r �_add_callback_signalsafe� s z&BaseEventLoop._add_callback_signalsafec C s |j r| jd7 _d S rZ )r� r� r� r r r �_timer_handle_cancelled� s z%BaseEventLoop._timer_handle_cancelledc C s� t | j�}|tkr`| j| tkr`g }| jD ] }|jr<d|_q*|�|� q*t�|� || _d| _n4| jr�| jd jr�| jd8 _t� | j�}d|_q`d }| j s�| j r�d}n*| jr�| jd j }t td|| �� �t�}| j�|�}| �|� | �� | j }| j�r:| jd }|j |k�r�q:t� | j�}d|_| j �|� q�t | j �}t|�D ]|} | j �� }|j�rf�qL| j�r�zD|| _| �� } |�� | �� | } | | jk�r�t� dt |�| � W 5 d | _X n|�� �qLd }d S )NFr r z Executing %s took %.3f seconds) r� r� � _MIN_SCHEDULED_TIMER_HANDLESr� �%_MIN_CANCELLED_TIMER_HANDLES_FRACTIONr� r9 r �heapify�heappopr� r� Z_whenr; �maxr� �MAXIMUM_SELECT_TIMEOUTZ _selectorZselectr� r� �range�popleftr� r� Z_runr� r r� r ) rf Z sched_countZ new_scheduledr Ztimeoutr r� Zend_timeZntodo�ir) r+ r r r r � sj �� � zBaseEventLoop._run_oncec C sH t |�t | j�krd S |r2t�� | _t�tj� n t�| j� || _d S rB )ri r� r �#get_coroutine_origin_tracking_depthr� �#set_coroutine_origin_tracking_depthr ZDEBUG_STACK_DEPTH�rf Zenabledr r r r� F s ���z,BaseEventLoop._set_coroutine_origin_trackingc C s | j S rB )r� rq r r r r� U s zBaseEventLoop.get_debugc C s || _ | �� r | �| j|� d S rB )r� r� r� r� r� r r r r� X s zBaseEventLoop.set_debug)N)N)NNN)NN)NN)N)r )r N)N)NN)FN)r N)NN)NN)Sr| r} r~ rh r� rd r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r rU r� r� r� r� r r� r� r r r r r r r� r r! r, r% r. r7 r1 r3 r0 rQ rg rd rl rj rk ro r� r� r$ r1 rb r� r6 Z AI_PASSIVEr� r� r� r� r� r r r� r� r� r� r� r� r� r� r� r r� r� r� r r r r r � sF � � � � � � � & � � % � � � � /� / � � � �� w� � % � "29Nr )r r )r )6rF Zcollections.abcZconcurrent.futuresr rZ r rK r� r$ r r r r� r� r r� r� rR � ImportErrorr. r r r r r r r r r r r �logr �__all__r� r� r# r8 r� �objectr� r r! r+ rA rP rX r[ ZProtocolr\ ZAbstractServerr ZAbstractEventLoopr r r r r �<module> sb ; Do