관리-도구
편집 파일: base_events.cpython-37.opt-2.pyc
B YI~d� � @ 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 dlZy d dlZW n ek r� dZY nX ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd lmZ dd lm Z d Z d Z dZ e ed�Z!dZ"e#� Z$dd� Z%dd� Z&dd� Z'd%dd�Z(dd� Z)e ed��rjd d � Z*nd d � Z*G d d � d ej+�Z,G d!d"� d"ej-�Z.G d#d$� d$ej/�Z0dS )&� N� )� constants)� coroutines)�events)�futures)� protocols)�sslproto)�tasks)� transports)�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/python37/lib64/python3.7/asyncio/base_events.py�_format_handleE 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_pipeN s r c C sL t td�std��n4y| �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_reuseportW s r' c C sz t td�sd S |dtjtjhks(| d kr,d S |tjkr>tj}n|tjkrPtj}nd S |d krbd}nVt|t�rz|dkrzd}n>t|t�r�|dkr�d}n&y t |�}W n t t fk r� d S X |tj kr�tj g}tr�|�tj� n|g}t| t�r�| �d�} d| k�rd S xp|D ]h}yJt�|| � t�rD|tjk�rD|||d| |||ffS |||d| |ffS W n tk �rn Y nX �q W 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_infob sL r= c C s: | � � s(| �� }t|t�r(t|t�s(d S t�| ��� d S )N)� cancelled� exceptionr � BaseException� Exceptionr Z _get_loop�stop)�fut�excr r r �_run_until_complete_cb� s rE � TCP_NODELAYc C s@ | j tjtjhkr<| jtjkr<| jtjkr<| �tjtj d� d S )Nr ) r9 r! r3 r r: r- r; r, r# rF )r& r r r � _set_nodelay� s rG c C s d S )Nr )r& r r r rG � 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_FlowControlMixinr1 � _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)rI � is_closing�ConnectionErrorrQ )rR rC r r r �drain� s z _SendfileFallbackProtocol.drainc C s t d��d S )Nz?Invalid state: connection should have been established already.)� RuntimeError)rR � 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)rQ Z set_exceptionrV rJ �connection_lost)rR rD r r r r[ � s z)_SendfileFallbackProtocol.connection_lostc C s | j d k rd S | jj�� | _ d S )N)rQ rI rO rP )rR r r r � pause_writing� s z'_SendfileFallbackProtocol.pause_writingc C s$ | j d krd S | j �d� d | _ d S )NF)rQ � set_result)rR r r r �resume_writing� s z(_SendfileFallbackProtocol.resume_writingc C s t d��d S )Nz'Invalid state: reading should be paused)rX )rR �datar r r � data_received� s z'_SendfileFallbackProtocol.data_receivedc C s t d��d S )Nz'Invalid state: reading should be paused)rX )rR r r r � eof_received� s z&_SendfileFallbackProtocol.eof_receivedc � sF | j �| j� | jr | j �� | jd k r2| j�� | jrB| j�� d S )N) rI rN rJ rK �resume_readingrQ �cancelrL r^ )rR r r r �restore� s z!_SendfileFallbackProtocol.restoreN) �__name__� __module__� __qualname__rT rW rZ r[ r\ r^ r` ra rd r r r r rH � s rH 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) rO �_sockets� _active_count�_waiters�_protocol_factory�_backlog� _ssl_context�_ssl_handshake_timeout�_serving�_serving_forever_fut)rR �loop�sockets�protocol_factoryZ ssl_context�backlog�ssl_handshake_timeoutr r r rT � s zServer.__init__c C s d| j j� d| j�d�S )N�<z sockets=�>)� __class__re rs )rR r r r �__repr__ s zServer.__repr__c C s | j d7 _ d S )Nr )rj )rR r r r �_attach s zServer._attachc C s. | j d8 _ | j dkr*| jd kr*| �� d S )Nr r )rj ri �_wakeup)rR r r r �_detach s zServer._detachc C s0 | j }d | _ x |D ]}|�� s|�|� qW d S )N)rk �doner] )rR �waiters�waiterr r r r| s zServer._wakeupc C sN | j r d S d| _ x8| jD ].}|�| j� | j�| j|| j| | j| j� qW d S )NT) rp ri Zlistenrm rO �_start_servingrl rn ro )rR r& r r r r� s zServer._start_servingc C s | j S )N)rO )rR r r r �get_loop# s zServer.get_loopc C s | j S )N)rp )rR r r r � is_serving& s zServer.is_servingc C s | j d krg S t| j �S )N)ri �list)rR r r r rs ) s zServer.socketsc C sr | j }|d krd S d | _ x|D ]}| j�|� q W d| _| jd k r\| j�� s\| j�� d | _| jdkrn| �� d S )NFr ) ri rO Z _stop_servingrp rq r~ rc rj r| )rR rs r& r r r �close/ s z Server.closec � s" | � � tjd| jd�I d H d S )Nr )rr )r� r �sleeprO )rR r r r � start_servingB s zServer.start_servingc � s� | j d k rtd| �d���| jd kr4td| �d���| �� | j�� | _ zLy| j I d H W n6 tjk r� z| �� | � � I d H W d � X Y nX W d d | _ X d S )Nzserver z, is already being awaited on serve_forever()z is closed) rq rX ri r� rO rP r ZCancelledErrorr� � wait_closed)rR r r r � serve_foreverH s zServer.serve_foreverc � s< | j d ks| jd krd S | j�� }| j�|� |I d H d S )N)ri rk rO rP r5 )rR r� r r r r� ] s zServer.wait_closedN)re rf rg rT rz r{ r} r| r� r� r� �propertyrs r� r� r� r� r r r r rh � s rh c @ s* e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd�d d d�dd�Z d�dd d d d dd�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.d/� Zd0d1� Zd2d3� Zd4d5� Zd6d7� Zd8d9� Z d:d;� Z d d<�d=d>�Z d d<�d?d@�Z d d<�dAdB�Z dCdD� Z!dEdF� Z"dGdH� Z#d d<�dIdJ�Z$dKdL� Z%dMdN� Z&dOdP� Z'dQdQdQdQdR�dSdT�Z(d�dUdV�Z)d�ddW�dXdY�Z*dZd[� Z+d\d]� Z,d^d_� Z-d�d dQdQdQd d d d d`�dadb�Z.d�dcdd�Z/d�ddW�dedf�Z0dgdh� Z1didj� Z2dd d dk�dldm�Z3d�dQdQdQe4d d d dn�dodp�Z5dQe6j7dQdQdR�dqdr�Z8dsdt� Z9d�e6j:e6j;d dud d d d ddv� dwdx�Z<d d dy�dzd{�Z=d|d}� Z>d~d� Z?d�d�� Z@eAjBeAjBeAjBdddQd��d�d��ZCeAjBeAjBeAjBdddQd��d�d��ZDd�d�� ZEd�d�� ZFd�d�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKd�d�� ZLd�d�� ZMd�d�� ZNd�d�� ZOd S )�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� _stopping� collections�deque�_ready� _scheduled�_default_executorZ _internal_fds� _thread_id�timeZget_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_called)rR r r r rT g s$ zBaseEventLoop.__init__c C s. d| j j� d| �� � d| �� � d| �� � d� S )Nrw z running=z closed=z debug=rx )ry re � is_running� is_closed� get_debug)rR r r r rz � s zBaseEventLoop.__repr__c C s t j| d�S )N)rr )r ZFuture)rR r r r rP � s zBaseEventLoop.create_futurec C s@ | � � | jd kr0tj|| d�}|jr<|jd= n | �| |�}|S )N)rr ���)� _check_closedr� r r �_source_traceback)rR �coroZtaskr 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)�callabler1 r� )rR �factoryr r r �set_task_factory� s z BaseEventLoop.set_task_factoryc C s | j S )N)r� )rR r r r �get_task_factory� s z BaseEventLoop.get_task_factoryN)�extra�serverc C s t �d S )N)�NotImplementedError)rR r& �protocolr� r� r� r r r �_make_socket_transport� s z$BaseEventLoop._make_socket_transportFT)� server_side�server_hostnamer� r� rv �call_connection_madec C s t �d S )N)r� ) rR Zrawsockr� � sslcontextr� r� r� r� r� rv r� r r r �_make_ssl_transport� s z!BaseEventLoop._make_ssl_transportc C s t �d S )N)r� )rR r& r� �addressr� r� r r r �_make_datagram_transport� s z&BaseEventLoop._make_datagram_transportc C s t �d S )N)r� )rR �piper� r� r� r r r �_make_read_pipe_transport� s z'BaseEventLoop._make_read_pipe_transportc C s t �d S )N)r� )rR r� r� r� r� r r r �_make_write_pipe_transport� s z(BaseEventLoop._make_write_pipe_transportc � s t �d S )N)r� ) rR r� �args�shell�stdin�stdout�stderr�bufsizer� �kwargsr r r �_make_subprocess_transport� s z(BaseEventLoop._make_subprocess_transportc C s t �d S )N)r� )rR r r r �_write_to_self� s z BaseEventLoop._write_to_selfc C s t �d S )N)r� )rR � event_listr r r �_process_events� s z BaseEventLoop._process_eventsc C s | j rtd��d S )NzEvent loop is closed)r� rX )rR r r r r� � s zBaseEventLoop._check_closedc C s* | j �|� | �� s&| �| j|�� � d S )N)r� �discardr� �call_soon_threadsafer� �aclose)rR �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� �add)rR r� 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 }x8t||�D ]*\}}t|t �rV| � d|��||d�� qVW d S )NTc S s g | ] }|� � �qS r )r� )�.0Zagr r r � <listcomp>� s z4BaseEventLoop.shutdown_asyncgens.<locals>.<listcomp>)Zreturn_exceptionsrr z;an error occurred during closing of asynchronous generator )�messager? Zasyncgen) r� �lenr� r� �clearr �gather�zipr rA �call_exception_handler)rR Z closing_agens�results�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� rX r Z_get_running_loop)rR r r r �_check_runnung s z BaseEventLoop._check_runnungc C s� | � � | �� | �| j� t�� | _t�� }tj | j | j d� z$t � | � x| �� | jrNP qNW W d 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 Z_set_running_loop� _run_oncer� )rR Zold_agen_hooksr r r � run_forever s$ zBaseEventLoop.run_foreverc C s� | � � | �� t�|� }tj|| d�}|r4d|_|�t� z<y | � � W n* |rp|� � rp|� � sp|� � � Y nX W d |� t� X |� � s�td��|�� S )N)rr Fz+Event loop stopped before Future completed.)r� r� r Zisfuturer Z ensure_futureZ_log_destroy_pendingZadd_done_callbackrE r� r~ r> r? Zremove_done_callbackrX r� )rR ZfutureZnew_taskr r r �run_until_complete' s" z BaseEventLoop.run_until_completec C s d| _ d S )NT)r� )rR r r r rB M 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� rX r� r� r �debugr� r� r� r� Zshutdown)rR �executorr r r r� U s zBaseEventLoop.closec C s | j S )N)r� )rR r r r r� k s zBaseEventLoop.is_closedc C s2 | � � s.tjd| ��t| d� | �� s.| �� d S )Nzunclosed event loop )r� )r� r� r� r� r� r� )rR r r r �__del__o s zBaseEventLoop.__del__c C s | j d k S )N)r� )rR r r r r� v s zBaseEventLoop.is_runningc C s t �� S )N)r� r� )rR r r r r� z s zBaseEventLoop.time)�contextc G s2 | j | �� | |f|�d|i�}|jr.|jd= |S )Nr� r� )�call_atr� r� )rR 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� )rR �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� )rR 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 iscoroutineZiscoroutinefunctionr1 r� )rR r� �methodr r r r� � s z BaseEventLoop._check_callbackc C s. t �||| |�}|jr |jd= | j�|� |S )Nr� )r ZHandler� r� r5 )rR 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� rX )rR 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� )rR 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_executor)rr ) r� r� r� r� � concurrentr ZThreadPoolExecutorZ wrap_futureZsubmit)rR r� �funcr� r r r r� � s z BaseEventLoop.run_in_executorc C s || _ d S )N)r� )rR 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=z, zGet address info %szGetting address info z took g @�@z.3fzms: ) r5 �joinr r� r� r! � getaddrinfor� �info) rR r7 r8 r9 r: r; �flags�msg�t0Zaddrinfo�dtr r r �_getaddrinfo_debug� s& z BaseEventLoop._getaddrinfo_debugr )r9 r: r; r c � s2 | j r| j}ntj}| �d |||||||�I d H S )N)r� r r! r r� )rR r7 r8 r9 r: r; r Z getaddr_funcr r r r s zBaseEventLoop.getaddrinfoc � s | � d tj||�I d H S )N)r� r! � getnameinfo)rR Zsockaddrr r r r r s zBaseEventLoop.getnameinfo)�fallbackc � s� | j r|�� dkrtd��| �||||� y| �||||�I d H S tjk rj } z |sZ� W d 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)rR r& �file�offset�countr rD 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 r )rR r& r r r r r r r , s z#BaseEventLoop._sock_sendfile_nativec � s� |r|� |� |r t|tj�ntj}t|�}d}ztxn|rPt|| |�}|dkrPP t|�d |� }| �d |j|�I d H } | s|P | �||d | � �I d H || 7 }q4W |S |dkr�t |d�r�|� || � X d S )Nr �seek) r �minr Z!SENDFILE_FALLBACK_READBUFFER_SIZE� bytearray� memoryviewr� �readintoZ sock_sendallr ) rR r& r r r � blocksize�buf� total_sent�view�readr r r r 3 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! r- r r0 r1 �format)rR r& r r r r r r r M s& z$BaseEventLoop._check_sendfile_params)�sslr9 r; r r& � local_addrr� rv c � s | d k r|st d��| d kr0|r0|s,t d��|} | d k rD|sDt d��|d k sV|d k �r�|d k rft d��| j||f|tj||| d�I d H } | s�td��| d k r�| j| |tj||| d�I d H } | s�td��g }�x�| D �]J\}}}}}y�tj|||d�}|�d� | d k �r�x�| D ]r\}}}}}y|�|� P W nP tk �r| } z0d |�d |j�� � �}t|j |�}|� |� W d d }~X Y nX �qW |� � d }w�| j �r�t �d ||� | �||�I d H W n^ tk �r� } z |d k �r�|� � |� |� W d d }~X Y q� |d k �r|� � � Y q�X P q�W t|�d k�r:|d �nJt|d �� t� fdd�|D ���rf|d �td�d�dd� |D �����n.|d k�r�t d��|jtjk�r�t d|����| j|||| | d�I d H \}}| j �r�|�d�}t �d|||||� ||fS )Nz+server_hostname is only meaningful with sslz:You must set server_hostname when using ssl without a hostz1ssl_handshake_timeout is only meaningful with sslz8host/port and sock can not be specified at the same time)r9 r: r; r rr z!getaddrinfo() returned empty list)r9 r: r; Fz*error while attempting to bind on address z: zconnect %r to %rr r c 3 s | ]}t |�� kV qd S )N)r )r� rD )�modelr r � <genexpr>� s z2BaseEventLoop.create_connection.<locals>.<genexpr>zMultiple exceptions: {}z, c s s | ]}t |�V qd S )N)r )r� rD r r r r" � s z5host and port was not specified and no sock specifiedz"A Stream Socket was expected, got )rv r! z %r connected to %s:%r: (%r, %r))r" �_ensure_resolvedr! r- r% � setblocking�bind�strerror�lower�errnor5 r� r� r r� � sock_connectr� r �allr r r: � _create_connection_transport�get_extra_info)rR rt r7 r8 r r9 r; r r& r r� rv �infosZ laddr_infos� exceptionsr: Zcnamer� �_ZladdrrD r rY r� r )r! r �create_connectionb s� " z BaseEventLoop.create_connectionc � s� |� d� |� }| �� }|rHt|t�r*d n|} | j||| ||||d�} n| �|||�} y|I d H W n | �� � Y nX | |fS )NF)r� r� rv )r$ rP r �boolr� r� r� ) rR r& rt r r� r� rv r� r� r� rY r r r r+ � s z*BaseEventLoop._create_connection_transportc � s� |� � rtd��t|dtjj�}|tjjkr:td|����|tjjkr�y| �||||�I d H S tj k r� } z |sv� W d 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 ) rU rX r r Z _SendfileModeZ UNSUPPORTEDZ TRY_NATIVE�_sendfile_nativer r �_sendfile_fallback)rR rY r r r r r rD r r r �sendfile s& zBaseEventLoop.sendfilec � s t �d��d S )Nz!sendfile syscall is not supported)r r )rR rS r r r r r r r2 / s z BaseEventLoop._sendfile_nativec � s� |r|� |� |r t|d�nd}t|�}d}t|�}z~xx|rVt|| |�}|dkrV|S t|�d |� } | �d |j| �I d H } | s�|S |�� I d H |�| d | � � || 7 }q8W W d |dkr�t |d�r�|� || � |� � I d H X d S )Ni @ r r ) r r r rH r r� r rW �writer rd ) rR rS r r r r r r r; r r r r r r3 3 s, z BaseEventLoop._sendfile_fallback)r� r� rv c � s� t d krtd��t|t j�s*td|����t|dd�sFtd|�d���| �� }tj| ||||||dd�}|� � |� |� | � |j |�} | � |j �} y|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())rv r� )r rX r Z SSLContextr1 r rP r Z SSLProtocolrM rN r� rZ rb rA r� rc Z_app_transport) rR rY r� r� r� r� rv r� Z ssl_protocolZ conmade_cbZ resume_cbr r r � start_tlsL s4 zBaseEventLoop.start_tls)r9 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�rx*� �fD ] }|d k r�t |t �s�t d ��q�W ||f� �fff}n�t �� }x�d � fd�ffD ]�\}}|d k �r,| j||tj||| d�I d H }|�sjtd��xB|D ]:\}}}}}||f}||k�r�d d g||< ||| |< �qpW �q,W � �fdd�|�� D �}|�s�td��g }|tk �r|�r�td��ntjdtdd� �x|D ]�\\}}\}}d } d } yxtj|tj|d�} |�rJt| � | �rb| �tjtjd� | �d� � �r|| �|� ��r�| �s�| �| |�I d H |} W n^ tk �r� } z | d k �r�| �� |� |� W d d }~X Y n" | d k �r�| �� � Y nX P �qW |d �|� } | � � } | � | | | | �} | j �r`� �rPt �!d� �| | � nt �"d�| | � y| I d H W n | �� � Y nX | | fS )Nz A UDP Socket was expected, got )r � remote_addrr9 r; r r7 r8 r9 z, c s s$ | ] \}}|r|� d |� �V qdS )�=Nr )r� �k�vr r r r" � 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 expectedr )r9 r: r; r rr z!getaddrinfo() returned empty listc s8 g | ]0\}}� r |d dks�r,|d dks||f�qS )r Nr r )r� �keyZ addr_pair)r r: 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.zcThe *reuse_address* parameter has been deprecated as of 3.7.6 and is scheduled for removal in 3.11.� )� stacklevel)r9 r: r; z@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))#r: r! r. r" �dictr �itemsr$ r r? r r r1 r� � OrderedDictr# r% �_unsetr� r� �DeprecationWarningr' r# r$ Z SO_BROADCASTr% r) r� r5 rP r� r� r r r� ) rR rt r r: r9 r; r r7 r8 r9 r& ZoptsZproblemsZr_addrZaddr_pairs_infoZaddrZ addr_infos�idxr- Zfamr/ Zpror� r@ r. Z local_addressZremote_addressrD r� r� rY r )r r: r �create_datagram_endpointz s� z&BaseEventLoop.create_datagram_endpointc � s\ |d d� \}}t |||||f|dd � �� } | d k r<| gS |j||||||d�I d H S d S )NrA )r9 r: r; r )r= r ) rR r� r9 r: r; r rr r7 r8 r r r r r# s z BaseEventLoop._ensure_resolvedc � s8 | j ||f|tj|| d�I d H }|s4td|�d���|S )N)r9 r: r rr z getaddrinfo(z) returned empty list)r# r! r- r% )rR r7 r8 r9 r r- r r r �_create_server_getaddrinfo s z(BaseEventLoop._create_server_getaddrinfor ) r9 r r& ru r r7 r8 rv 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"�x|D �] }|\}}}}}yt�|||�}W n6 tjk �rJ �j�rDtjd |||d d � w�Y nX | �|� | �rn|�tjtjd � | �r|t|� t �r�|tj k�r�t td��r�|�tj tj d � y|�!|� W q� t"k �r� } z t"|j#d||j$�%� f �d �W d d }~X Y q�X q�W d }W d |�s&x| D ]}|�&� �qW X n4|d k�r<td��|j'tj(k�rXtd|����|g} x| D ]}|�)d � �qdW t*�| |||| �}| �r�|�+� t j,d�d�I d H �j�r�t�-d|� |S )Nz*ssl argument must be an SSLContext or Nonez1ssl_handshake_timeout is only meaningful with sslz8host/port and sock can not be specified at the same time�posix�cygwinr* c s g | ]}�j |�� �d ��qS ))r9 r )rJ )r� r7 )r9 r r8 rR r r r� F s z/BaseEventLoop.create_server.<locals>.<listcomp>rr 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 specifiedz"A Stream Socket was expected, got r )rr z %r is serving).r r1 r1 r" �os�namer� �platformr r� �abc�Iterabler r� �set� itertools�chain� from_iterabler! �errorr� r �warningr5 r# r$ Z SO_REUSEADDRr' r4 r r rN Z IPV6_V6ONLYr% r% r( r& r' r� r: r- r$ rh r� r� r )rR rt r7 r8 r9 r r& ru r r7 r8 rv r� rs ZhostsZfsr- Z completedZresr< Zsocktyper; Z canonnameZsa�errr� r )r9 r r8 rR r � create_server s� * zBaseEventLoop.create_server)r rv c � sv |j tjkrtd|����|d k r.|s.td��| j|||dd|d�I d H \}}| jrn|�d�}t�d|||� ||fS )Nz"A Stream Socket was expected, got z1ssl_handshake_timeout is only meaningful with sslr* T)r� rv r! z%r handled: (%r, %r)) r: r! r- r" r+ r� r, r r� )rR rt r& r rv rY r� r r r �connect_accepted_socket� s z%BaseEventLoop.connect_accepted_socketc � sd |� }| � � }| �|||�}y|I d H W n |�� � Y nX | jr\t�d|�� ||� ||fS )Nz Read pipe %r connected: (%r, %r))rP r� r� r� r r� �fileno)rR rt r� r� r� rY r r r �connect_read_pipe� s z BaseEventLoop.connect_read_pipec � sd |� }| � � }| �|||�}y|I d H W n |�� � Y nX | jr\t�d|�� ||� ||fS )Nz!Write pipe %r connected: (%r, %r))rP r� r� r� r r� r] )rR rt r� r� r� rY 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=� )r5 r r r r r� r )rR r r� r� r� r r r r �_log_subprocess� s z BaseEventLoop._log_subprocess)r� r� r� �universal_newlinesr� r� c � s� t |ttf�std��|r"td��|s.td��|dkr>td��|� } d } | jrfd| } | �| |||� | j| |d||||f| �I d H } | jr�| d k r�t�d| | � | | fS ) Nzcmd must be a stringz universal_newlines must be Falsezshell must be Truer zbufsize must be 0zrun shell command %rTz%s: %r) r r/ r r" r� ra r� r r ) rR rt �cmdr� r� r� rb r� r� r� r� � debug_logrY r r r �subprocess_shell� s$ z BaseEventLoop.subprocess_shellc � s� |r t d��|rt d��|dkr(t d��|f| } x.| D ]&} t| ttf�s8tdt| �j� ���q8W |� } d }| jr�d|��}| �||||� | j | | d||||f| �I d H }| jr�|d k r�t � d||� || fS ) Nz universal_newlines must be Falsezshell must be Falser zbufsize must be 0z6program arguments must be a bytes or text string, not zexecute program Fz%s: %r) r" r r r/ r1 r: re r� ra r� r r )rR rt Zprogramr� r� r� rb r� r� r� r� Z popen_args�argr� rd rY r r r �subprocess_exec� s, z BaseEventLoop.subprocess_execc C s | j S )N)r� )rR r r r �get_exception_handler 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� r1 r� )rR Zhandlerr r r �set_exception_handler 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}x�t|�D ]�}|dkr~qp|| }|dkr�d�t�|��}d }||� � 7 }n2|dkr�d�t�|��}d }||� � 7 }nt |�}|� |� d |� �� qpW t j d �|�|d � d S )Nr� z!Unhandled exception in event loopr? FZsource_tracebackZhandle_traceback> r� r? r* z+Object created at (most recent call last): z+Handle created at (most recent call last): z: � )rM )�getr: � __traceback__r� r� �sortedr � traceback� format_list�rstripr r5 r rX ) rR r� r� r? rM Z log_linesr@ �value�tbr r r �default_exception_handler# s6 z'BaseEventLoop.default_exception_handlerc C s� | j d kr>y| �|� W q� tk r: tjddd� Y q�X nny| � | |� W n\ tk r� } z>y| �d||d�� W n" tk r� tjddd� Y nX W d d }~X Y nX d S )Nz&Exception in default exception handlerT)rM z$Unhandled error in exception handler)r� r? r� zeException in default exception handler while handling an unexpected error in custom exception handler)r� rs rA r rX )rR r� rD r r r r� U s" z$BaseEventLoop.call_exception_handlerc C s |j r d S | j�|� d S )N)� _cancelledr� r5 )rR r r r r � _add_callback� s zBaseEventLoop._add_callbackc C s | � |� | �� d S )N)ru r� )rR r r r r �_add_callback_signalsafe� s z&BaseEventLoop._add_callback_signalsafec C s |j r| jd7 _d S )Nr )r� r� )rR r r r r �_timer_handle_cancelled� s z%BaseEventLoop._timer_handle_cancelledc C s� t | j�}|tkrd| j| tkrdg }x&| jD ] }|jr>d|_q,|�|� q,W t�|� || _d| _n8x6| jr�| jd jr�| jd8 _t� | j�}d|_qfW d }| j s�| j r�d}n*| jr�| jd j }t td|| �� �t�}| j�r�|dk�r�| �� }| j�|�}| �� | }|dk�r tj} ntj} t |�} |d k�rNt�| d|d | � nD| �rpt�| d|d |d | � n"|dk�r�t�| d|d |d � n | j�|�}| �|� | �� | j } xD| j�r�| jd }|j | k�r�P t� | j�}d|_| j �|� �q�W t | j �} x�t| �D ]|} | j � � }|j�r,�q| j�r�zD|| _ | �� }|� � | �� | }|| j k�rvt� d t!|�|� W d d | _ X n|� � �qW d }d S ) NFr r g �?z poll took %.3f ms: %s eventsg @�@z$poll %.3f ms took %.3f ms: %s eventsz"poll %.3f ms took %.3f ms: timeoutz Executing %s took %.3f seconds)"r� r� � _MIN_SCHEDULED_TIMER_HANDLESr� �%_MIN_CANCELLED_TIMER_HANDLES_FRACTIONrt r5 r� �heapify�heappopr� r� Z_whenr �maxr� �MAXIMUM_SELECT_TIMEOUTr� Z _selectorZselect�logging�INFO�DEBUGr �logr� r� �range�popleftr� Z_runr� rY r )rR Z sched_countZ new_scheduledr Ztimeoutr� r r� r �levelZneventZend_timeZntodo�ir r r r� � s� zBaseEventLoop._run_oncec C sH t |�t | j�krd S |r2t�� | _t�tj� n t�| j� || _d S )N)r1 r� r� �#get_coroutine_origin_tracking_depthr� �#set_coroutine_origin_tracking_depthr ZDEBUG_STACK_DEPTH)rR �enabledr r r r� � s z,BaseEventLoop._set_coroutine_origin_trackingc C s | j S )N)r� )rR r r r r� s zBaseEventLoop.get_debugc C s || _ | �� r | �| j|� d S )N)r� r� r� r� )rR r� r r r r� s zBaseEventLoop.set_debug)N)N)NNN)NN)NN)N)r )r N)NN)FN)r N)NN)NN)Pre rf rg rT rz rP r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rB r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r r r0 r+ r4 r2 r3 r6 rF rI r! r- r# rJ r2 Z AI_PASSIVEr[ r\ r^ r_ ra r r re rg rh ri rs r� ru rv rw r� r� r� r� r r r r r e s� & ., l23cr )r r )1r� Zcollections.abc�concurrent.futuresr� r� rU r~ rO r! r r� r� rn r� r� r� r � ImportErrorr* r r r r r r r r r� r �__all__rx ry r r4 r} �objectrF r r r' r= rE rG ZProtocolrH ZAbstractServerrh ZAbstractEventLoopr r r r r �<module> sX ; Do