OwlCyberSecurity - MANAGER
Edit File: 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�dlZd�dlZd�dl Z d�dlZd�dlZd�dlZzd�dlZW�n�ek r����dZY�nX�ddlmZ�ddlmZ�ddlmZ�ddlmZ�ddlmZ�ddlmZ�dd lmZ�dd lmZ�ddlmZ�ddlmZ�dd lmZ�ddlm Z �dZ!dZ"dZ#e$ed�Z%dZ&e'��Z(dd��Z)dd��Z*dd��Z+d*dd�Z,d+dd�Z-dd��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�jkrdS�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(zt |�}W�n�t tfk r����Y�d�S�X�|tjkr�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_TCPZIPPROTO_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�||<�||��|��qt|����}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 ��Zdd��Zd d��Z dd��Z dd��ZdS�)�_SendfileFallbackProtocolc�����������������C���sh���t�|tj�std��||�_|���|�_|���|�_|j |�_ |����|�|���|�j r^|�jj ���|�_nd�|�_d�S�)Nz.transport should be _FlowControlMixin instance)r���r���Z_FlowControlMixinr5���� _transportZget_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�)NzConnection 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 ��Zdd��Zd d��Z dd��Z edd���Zdd��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_factoryZssl_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�|��qd|�_|�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���� � zServer.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 �Zdd��Zd d��Zd�ddd�dd�Z d�ddddddd�dd�Z d�dd�Zd�dd�Zd�dd�Z d�dd�Zdd ��Zd!d"��Zd#d$��Zd%d&��Zd'd(��Zd)d*��Zd+d,��Zd-d.��Zd/d0��Zd1d2��Zd3d4��Zd5d6��Zejfd7d8�Zd9d:��Zd;d<��Zdd=�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���� zBaseEventLoop.set_task_factoryc�����������������C���s���|�j�S�rB���)r����rq���r���r���r����get_task_factory���s����zBaseEventLoop.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����zBaseEventLoop._write_to_selfc�����������������C���s���t��d�S�rB���r����)rf���� event_listr���r���r����_process_events���s����zBaseEventLoop._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�rtjd|�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�����zBaseEventLoop._check_runningc�������������� ���C���s����|������|�����|��|�j��t���|�_t���}tj |�j |�jd��z t �|���|�����|�jrLq^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���ZTimerHandler�����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�)Nzcoroutines cannot be used with z()z"a callable object was expected by z(), got )r���ZiscoroutineZiscoroutinefunctionr5���r����)rf���r���methodr���r���r���r�����s���� � ��zBaseEventLoop._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����ThreadPoolExecutorZwrap_futureZsubmit)rf���r���funcr����r���r���r���r����s���� ��zBaseEventLoop.run_in_executorc�����������������C���s&���t�|tjj�st�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'��Zgetaddr_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���zthe 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|��|��|rt|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���readintoZsock_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 dd����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�]}|�qqS�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���������������� ��� ��� � ������ �����zBaseEventLoop.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 _SendfileModeZUNSUPPORTEDZ 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�����zBaseEventLoop._sendfile_nativec�������������� �������s����|r|��|��|rt|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 ���ZSSLProtocolra���rb���r��ro���ry���� BaseExceptionr����rz���Z_app_transport)rf���rn���r����r����r����r����r����r����Zssl_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 ��||fdff}�n�ttd��r�|tj k�r����fD�]}|d�k r�t |t�s�td ��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�| �tjtjd��| �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�)NzA 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>zcan 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'���ZSO_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������zBaseEventLoop._ensure_resolvedc���������������������s8���|�j�||f|tj||�d�I�d�H�}|s4td|�d���|S�)N)r=���r>���r'��r����zgetaddrinfo(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��}tj |d �i�I�d�H�}ttj�|��}d }�z|D��]}|\}}}}}zt�|||�}W�n8�tjk �rH����j�r@tjd|||dd ��Y�q�Y�nX�| �|��| �rl|�tjtjd��| �rzt|��t�r�|tjk�r�ttd��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�|�+���tj,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'���ZSO_REUSEADDRr+���r8���r���r#���r���ZIPV6_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�������zBaseEventLoop.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����zBaseEventLoop._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������������ zBaseEventLoop.subprocess_shellc������� �������������s����|rt�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@���� ������� zBaseEventLoop.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 rt�|�std|����||�_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|�����qntj 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�|�jr�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���zExecuting %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���Zsched_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��nt�|�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