← Back
Editing: events.cpython-37.opt-2.pyc
B YI~dlf � @ s| d Z ddlZddlZddlZddlZddlZddlZddlmZ G dd� de �Z G dd� d�Z G d d � d e �Z G d d � d �Z G d d� d�ZG dd� d�ZG dd� de�Zdae�� ZG dd� dej�Ze� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z d!d"� Z d#d$� Z d%d&� Z d'd(� Z d)d*� Z!eZ"eZ#eZ$e Z%y dd+l&mZmZmZm Z W n e'k �rf Y nX eZ(eZ)eZ*e Z+dS ),)�AbstractEventLoopPolicy�AbstractEventLoop�AbstractServer�Handle� TimerHandle�SendfileNotAvailableError�get_event_loop_policy�set_event_loop_policy�get_event_loop�set_event_loop�new_event_loop�get_child_watcher�set_child_watcher�_set_running_loop�get_running_loop�_get_running_loop� N� )�format_helpersc @ s e Zd ZdS )r N)�__name__� __module__� __qualname__� r r �3/opt/alt/python37/lib64/python3.7/asyncio/events.pyr s r c @ sB e Zd ZdZddd�Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )r )� _callback�_args� _cancelled�_loop�_source_traceback�_repr� __weakref__�_contextNc C s\ |d krt �� }|| _|| _|| _|| _d| _d | _| j�� rRt � t � d��| _ nd | _ d S )NFr )� contextvarsZ copy_contextr r r r r r � get_debugr � extract_stack�sys� _getframer )�self�callback�args�loop�contextr r r �__init__' s zHandle.__init__c C sl | j jg}| jr|�d� | jd k r:|�t�| j| j�� | jrh| jd }|�d|d � d|d � �� |S )N� cancelled���z created at r �:r ) � __class__r r �appendr r �_format_callback_sourcer r )r& �info�framer r r � _repr_info6 s zHandle._repr_infoc C s( | j d k r| j S | �� }d�d�|��S )Nz<{}>� )r r4 �format�join)r& r2 r r r �__repr__B s zHandle.__repr__c C s0 | j s,d| _ | j�� r t| �| _d | _d | _d S )NT)r r r" �reprr r r )r& r r r �cancelH s z Handle.cancelc C s | j S )N)r )r& r r r r, S s zHandle.cancelledc C s� y| j j| jf| j�� W nd tk r~ } zFt�| j| j�}d|� �}||| d�}| jrb| j|d< | j� |� W d d }~X Y nX d } d S )NzException in callback )�messageZ exception�handleZsource_traceback) r �runr r � Exceptionr r1 r r �call_exception_handler)r& �exc�cb�msgr* r r r �_runV s z Handle._run)N) r r r � __slots__r+ r4 r8 r: r, rC r r r r r s r c s~ e Zd ZddgZd� fdd� Z� fdd�Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z � fdd�Z dd� Z� ZS )r � _scheduled�_whenNc s0 t � �||||� | jr | jd= || _d| _d S )Nr- F)�superr+ r rF rE )r& �whenr' r( r) r* )r/ r r r+ m s zTimerHandle.__init__c s0 t � �� }| jrdnd}|�|d| j� �� |S )N� r zwhen=)rG r4 r �insertrF )r& r2 �pos)r/ r r r4 u s zTimerHandle._repr_infoc C s t | j�S )N)�hashrF )r& r r r �__hash__{ s zTimerHandle.__hash__c C s | j |j k S )N)rF )r& �otherr r r �__lt__~ s zTimerHandle.__lt__c C s | j |j k rdS | �|�S )NT)rF �__eq__)r& rN r r r �__le__� s zTimerHandle.__le__c C s | j |j kS )N)rF )r& rN r r r �__gt__� s zTimerHandle.__gt__c C s | j |j krdS | �|�S )NT)rF rP )r& rN r r r �__ge__� s zTimerHandle.__ge__c C s> t |t�r:| j|jko8| j|jko8| j|jko8| j|jkS tS )N)� isinstancer rF r r r �NotImplemented)r& rN r r r rP � s zTimerHandle.__eq__c C s | � |�}|tkrtS | S )N)rP rU )r& rN Zequalr r r �__ne__� s zTimerHandle.__ne__c s | j s| j�| � t� �� d S )N)r r �_timer_handle_cancelledrG r: )r& )r/ r r r: � s zTimerHandle.cancelc C s | j S )N)rF )r& r r r rH � s zTimerHandle.when)N)r r r rD r+ r4 rM rO rQ rR rS rP rV r: rH � __classcell__r r )r/ r r h s r c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )r c C s t �d S )N)�NotImplementedError)r& r r r �close� s zAbstractServer.closec C s t �d S )N)rY )r& r r r �get_loop� s zAbstractServer.get_loopc C s t �d S )N)rY )r& r r r � is_serving� s zAbstractServer.is_servingc � s t �d S )N)rY )r& r r r � start_serving� s z AbstractServer.start_servingc � s t �d S )N)rY )r& r r r � serve_forever� s z AbstractServer.serve_foreverc � s t �d S )N)rY )r& r r r � wait_closed� s zAbstractServer.wait_closedc � s | S )Nr )r& r r r � __aenter__� s zAbstractServer.__aenter__c � s | � � | �� I d H d S )N)rZ r_ )r& r@ r r r � __aexit__� s zAbstractServer.__aexit__N) r r r rZ r[ r\ r] r^ r_ r` ra r r r r r � s r c @ sH e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d#d#d#d$�d%d&�Zdsd'd(�Zdtd)d#d#d#d)d)d)d)d*�d+d,�Zduejejd)d-d)d)d)d)d.d/� d0d1�Zdvd.d2�d3d4�Zd5d)d)d6�d7d8�Z dwd)d)d)d)d9�d:d;�Z dxd)d-d)d)d.d<�d=d>�Z dyd#d#d#d)d)d)d)d?�d@dA�Z dBdC� Z dDdE� Z!e"j#e"j#e"j#dF�dGdH�Z$e"j#e"j#e"j#dF�dIdJ�Z%dKdL� Z&dMdN� Z'dOdP� Z(dQdR� Z)dSdT� Z*dUdV� Z+dWdX� Z,dYdZ� Z-d[d\� Z.dzd)d2�d]d^�Z/d_d`� Z0dadb� Z1dcdd� Z2dedf� Z3dgdh� Z4didj� Z5dkdl� Z6dmdn� Z7dodp� Z8dqdr� Z9d)S ){r c C s t �d S )N)rY )r& r r r � run_forever� s z AbstractEventLoop.run_foreverc C s t �d S )N)rY )r& Zfuturer r r �run_until_complete� s z$AbstractEventLoop.run_until_completec C s t �d S )N)rY )r& r r r �stop� s zAbstractEventLoop.stopc C s t �d S )N)rY )r& r r r � is_running� s z AbstractEventLoop.is_runningc C s t �d S )N)rY )r& r r r � is_closed� s zAbstractEventLoop.is_closedc C s t �d S )N)rY )r& r r r rZ � s zAbstractEventLoop.closec � s t �d S )N)rY )r& r r r �shutdown_asyncgens� s z$AbstractEventLoop.shutdown_asyncgensc C s t �d S )N)rY )r& r< r r r rW s z)AbstractEventLoop._timer_handle_cancelledc G s | j d|f|�� S )Nr )� call_later)r& r' r( r r r � call_soon s zAbstractEventLoop.call_soonc G s t �d S )N)rY )r& Zdelayr' r( r r r rh s z AbstractEventLoop.call_laterc G s t �d S )N)rY )r& rH r' r( r r r �call_at s zAbstractEventLoop.call_atc C s t �d S )N)rY )r& r r r �time s zAbstractEventLoop.timec C s t �d S )N)rY )r& r r r � create_future s z AbstractEventLoop.create_futurec C s t �d S )N)rY )r& �coror r r � create_task s z AbstractEventLoop.create_taskc G s t �d S )N)rY )r& r' r( r r r �call_soon_threadsafe s z&AbstractEventLoop.call_soon_threadsafec � s t �d S )N)rY )r& �executor�funcr( r r r �run_in_executor s z!AbstractEventLoop.run_in_executorc C s t �d S )N)rY )r& rp r r r �set_default_executor# s z&AbstractEventLoop.set_default_executorr )�family�type�proto�flagsc � s t �d S )N)rY )r& �host�portrt ru rv rw r r r � getaddrinfo( s z AbstractEventLoop.getaddrinfoc � s t �d S )N)rY )r& Zsockaddrrw r r r � getnameinfo, s z AbstractEventLoop.getnameinfoN)�sslrt rv rw �sock� local_addr�server_hostname�ssl_handshake_timeoutc � s t �d S )N)rY ) r& �protocol_factoryrx ry r| rt rv rw r} r~ r r� r r r �create_connection/ s z#AbstractEventLoop.create_connection�d T) rt rw r} �backlogr| � reuse_address� reuse_portr� r] c � s t �d S )N)rY ) r& r� rx ry rt rw r} r� r| r� r� r� r] r r r � create_server7 s 3z AbstractEventLoop.create_server)�fallbackc � s t �d S )N)rY )r& � transport�file�offset�countr� r r r �sendfilel s zAbstractEventLoop.sendfileF)� server_sider r� c � s t �d S )N)rY )r& r� ZprotocolZ sslcontextr� r r� r r r � start_tlst s zAbstractEventLoop.start_tls)r| r} r r� c � s t �d S )N)rY )r& r� �pathr| r} r r� r r r �create_unix_connection s z(AbstractEventLoop.create_unix_connection)r} r� r| r� r] c � s t �d S )N)rY )r& r� r� r} r� r| r� r] r r r �create_unix_server� s z$AbstractEventLoop.create_unix_server)rt rv rw r� r� �allow_broadcastr} c � s t �d S )N)rY ) r& r� r~ Z remote_addrrt rv rw r� r� r� r} r r r �create_datagram_endpoint� s !z*AbstractEventLoop.create_datagram_endpointc � s t �d S )N)rY )r& r� �piper r r �connect_read_pipe� s z#AbstractEventLoop.connect_read_pipec � s t �d S )N)rY )r& r� r� r r r �connect_write_pipe� s z$AbstractEventLoop.connect_write_pipe)�stdin�stdout�stderrc � s t �d S )N)rY )r& r� �cmdr� r� r� �kwargsr r r �subprocess_shell� s z"AbstractEventLoop.subprocess_shellc � s t �d S )N)rY )r& r� r� r� r� r( r� r r r �subprocess_exec� s z!AbstractEventLoop.subprocess_execc G s t �d S )N)rY )r& �fdr' r( r r r � add_reader� s z AbstractEventLoop.add_readerc C s t �d S )N)rY )r& r� r r r � remove_reader� s z AbstractEventLoop.remove_readerc G s t �d S )N)rY )r& r� r' r( r r r � add_writer� s z AbstractEventLoop.add_writerc C s t �d S )N)rY )r& r� r r r � remove_writer s z AbstractEventLoop.remove_writerc � s t �d S )N)rY )r& r} �nbytesr r r � sock_recv s zAbstractEventLoop.sock_recvc � s t �d S )N)rY )r& r} �bufr r r �sock_recv_into s z AbstractEventLoop.sock_recv_intoc � s t �d S )N)rY )r& r} �datar r r � sock_sendall s z AbstractEventLoop.sock_sendallc � s t �d S )N)rY )r& r} Zaddressr r r � sock_connect s z AbstractEventLoop.sock_connectc � s t �d S )N)rY )r& r} r r r � sock_accept s z AbstractEventLoop.sock_acceptc � s t �d S )N)rY )r& r} r� r� r� r� r r r � sock_sendfile s z AbstractEventLoop.sock_sendfilec G s t �d S )N)rY )r& �sigr' r( r r r �add_signal_handler s z$AbstractEventLoop.add_signal_handlerc C s t �d S )N)rY )r& r� r r r �remove_signal_handler s z'AbstractEventLoop.remove_signal_handlerc C s t �d S )N)rY )r& �factoryr r r �set_task_factory# s z"AbstractEventLoop.set_task_factoryc C s t �d S )N)rY )r& r r r �get_task_factory& s z"AbstractEventLoop.get_task_factoryc C s t �d S )N)rY )r& r r r �get_exception_handler+ s z'AbstractEventLoop.get_exception_handlerc C s t �d S )N)rY )r& Zhandlerr r r �set_exception_handler. s z'AbstractEventLoop.set_exception_handlerc C s t �d S )N)rY )r& r* r r r �default_exception_handler1 s z+AbstractEventLoop.default_exception_handlerc C s t �d S )N)rY )r& r* r r r r? 4 s z(AbstractEventLoop.call_exception_handlerc C s t �d S )N)rY )r& r r r r" 9 s zAbstractEventLoop.get_debugc C s t �d S )N)rY )r& Zenabledr r r � set_debug< s zAbstractEventLoop.set_debug)r )NN)NN)r N)N)N)NN)r N):r r r rb rc rd re rf rZ rg rW ri rh rj rk rl rn ro rr rs rz r{ r� �socketZ AF_UNSPECZ AI_PASSIVEr� r� r� r� r� r� r� r� � subprocess�PIPEr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r? r" r� r r r r r � s� / ! r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) r c C s t �d S )N)rY )r& r r r r C s z&AbstractEventLoopPolicy.get_event_loopc C s t �d S )N)rY )r& r) r r r r M s z&AbstractEventLoopPolicy.set_event_loopc C s t �d S )N)rY )r& r r r r Q s z&AbstractEventLoopPolicy.new_event_loopc C s t �d S )N)rY )r& r r r r Y s z)AbstractEventLoopPolicy.get_child_watcherc C s t �d S )N)rY )r& �watcherr r r r ] s z)AbstractEventLoopPolicy.set_child_watcherN)r r r r r r r r r r r r r @ s r c @ sB e Zd ZdZG dd� dej�Zdd� Zdd� Zdd � Z d d � Z dS ) �BaseDefaultEventLoopPolicyNc @ s e Zd ZdZdZdS )z!BaseDefaultEventLoopPolicy._LocalNF)r r r r � _set_calledr r r r �_Localq s r� c C s | � � | _d S )N)r� �_local)r& r r r r+ u s z#BaseDefaultEventLoopPolicy.__init__c C sX | j jd kr2| j js2tt�� tj�r2| �| �� � | j jd krPt dt�� j ��| j jS )Nz,There is no current event loop in thread %r.) r� r r� rT � threadingZcurrent_threadZ _MainThreadr r � RuntimeError�name)r& r r r r x s z)BaseDefaultEventLoopPolicy.get_event_loopc C s d| j _|| j _d S )NT)r� r� r )r& r) r r r r � s z)BaseDefaultEventLoopPolicy.set_event_loopc C s | � � S )N)� _loop_factory)r& r r r r � s z)BaseDefaultEventLoopPolicy.new_event_loop) r r r r� r� �localr� r+ r r r r r r r r� b s r� c @ s e Zd ZdZdS )� _RunningLoop)NNN)r r r �loop_pidr r r r r� � s r� c C s t � } | d krtd��| S )Nzno running event loop)r r� )r) r r r r � s r c C s& t j\} }| d k r"|t�� kr"| S d S )N)� _running_loopr� �os�getpid)Z running_loop�pidr r r r � s r c C s | t �� ft_d S )N)r� r� r� r� )r) r r r r � s r c C s. t � td kr ddlm} | � aW d Q R X d S )Nr )�DefaultEventLoopPolicy)�_lock�_event_loop_policy� r� )r� r r r �_init_event_loop_policy� s r� c C s t d krt� t S )N)r� r� r r r r r � s r c C s | a d S )N)r� )Zpolicyr r r r � s r c C s t � } | d k r| S t� �� S )N)r r r )Z current_loopr r r r � s r c C s t � �| � d S )N)r r )r) r r r r � s r c C s t � �� S )N)r r r r r r r � s r c C s t � �� S )N)r r r r r r r � s r c C s t � �| �S )N)r r )r� r r r r s r )r r r r ),�__all__r! r� r� r� r$ r� r� r r� r r r r r r r� r� ZLockr� r� r� r� r r r r� r r r r r r r Z_py__get_running_loopZ_py__set_running_loopZ_py_get_running_loopZ_py_get_event_loopZ_asyncio� ImportErrorZ_c__get_running_loopZ_c__set_running_loopZ_c_get_running_loopZ_c_get_event_loopr r r r �<module> sV H@* p"9
Save File
Cancel