관리-도구
편집 파일: events.cpython-310.opt-2.pyc
o 6��f�j � @ s� d Z ddlZddlZddlZddlZddlZddlZddlmZ G dd� d�Z G dd� de �Z G d d � d �Z G d d � d �Z G d d� d�Z G dd� de �Zdae�� ZG dd� dej�Ze� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd-d"d#�Z d$d%� Z d&d'� Z d(d)� Z d*d+� Z eZ!eZ"eZ#eZ$e Z%zdd,l&mZmZmZmZm Z W n e'y� Y dS w eZ(eZ)eZ*eZ+e Z,dS ).)�AbstractEventLoopPolicy�AbstractEventLoop�AbstractServer�Handle� TimerHandle�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 @ sD e Zd Z dZddd�Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )r )� _callback�_args� _cancelled�_loop�_source_traceback�_repr� __weakref__�_contextNc C s^ |d u rt �� }|| _|| _|| _|| _d| _d | _| j�� r*t � t � d��| _ d S d | _ d S )NFr )� contextvarsZ copy_contextr r r r r r � get_debugr � extract_stack�sys� _getframer )�self�callback�args�loop�context� r% �5/opt/alt/python310/lib64/python3.10/asyncio/events.py�__init__ s � zHandle.__init__c C sl | j jg}| jr |�d� | jd ur |�t�| j| j�� | jr4| jd }|�d|d � d|d � �� |S )N� cancelled���z created at r �:r ) � __class__�__name__r �appendr r �_format_callback_sourcer r )r �info�framer% r% r& � _repr_info. s � zHandle._repr_infoc C s( | j d ur| j S | �� }d�d�|��S )Nz<{}>� )r r1 �format�join)r r/ r% r% r& �__repr__: s zHandle.__repr__c C s4 | j sd| _ | j�� rt| �| _d | _d | _d S d S �NT)r r r �reprr r r �r r% r% r& �cancel@ s �z Handle.cancelc C s | j S �N)r r8 r% r% r& r( K s zHandle.cancelledc C s� z| j j| jg| j�R � W d } d S ttfy � tyP } z*t�| j| j�}d|� �}||| d�}| j r=| j |d< | j � |� W Y d }~d } d S d }~ww )NzException in callback )�messageZ exception�handleZsource_traceback) r �runr r � SystemExit�KeyboardInterrupt� BaseExceptionr r. r r �call_exception_handler)r �exc�cb�msgr$ r% r% r& �_runN s( �� � ��z Handle._runr: ) r, � __module__� __qualname__� __slots__r' r1 r5 r9 r( rE r% r% r% r& r s r c sx e Zd Z ddgZd� fdd� Z� fdd�Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z � fdd�Z dd� Z � ZS )r � _scheduled�_whenNc s0 t � �||||� | jr| jd= || _d| _d S )Nr) F)�superr' r rJ rI )r �whenr! r" r# r$ �r+ r% r& r' g s zTimerHandle.__init__c s0 t � �� }| jr dnd}|�|d| j� �� |S )N� r zwhen=)rK r1 r �insertrJ )r r/ �posrM r% r& r1 o s zTimerHandle._repr_infoc C s t | j�S r: )�hashrJ r8 r% r% r& �__hash__u s zTimerHandle.__hash__c C s t |t�r | j|jk S tS r: �� isinstancer rJ �NotImplemented�r �otherr% r% r& �__lt__x � zTimerHandle.__lt__c C s$ t |t�r| j|jk p| �|�S tS r: �rT r rJ �__eq__rU rV r% r% r& �__le__} � zTimerHandle.__le__c C s t |t�r | j|jkS tS r: rS rV r% r% r& �__gt__� rY zTimerHandle.__gt__c C s$ t |t�r| j|jkp| �|�S tS r: rZ rV r% r% r& �__ge__� r] zTimerHandle.__ge__c C s> t |t�r | j|jko | j|jko | j|jko | j|jkS tS r: )rT r rJ r r r rU rV r% r% r& r[ � s � � �zTimerHandle.__eq__c s | j s | j�| � t� �� d S r: )r r �_timer_handle_cancelledrK r9 r8 rM r% r& r9 � s zTimerHandle.cancelc C s | j S r: )rJ r8 r% r% r& rL � s zTimerHandle.whenr: )r, rF rG rH r' r1 rR rX r\ r^ r_ r[ r9 rL � __classcell__r% r% rM r& r b s r c @ sN e Zd Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )r c C � t �r: ��NotImplementedErrorr8 r% r% r& �close� � zAbstractServer.closec C rb r: rc r8 r% r% r& �get_loop� rf zAbstractServer.get_loopc C rb r: rc r8 r% r% r& � is_serving� rf zAbstractServer.is_servingc � � � t �r: rc r8 r% r% r& � start_serving� s �z AbstractServer.start_servingc � ri r: rc r8 r% r% r& � serve_forever� s �z AbstractServer.serve_foreverc � ri r: rc r8 r% r% r& � wait_closed� � �zAbstractServer.wait_closedc � s �| S r: r% r8 r% r% r& � __aenter__� � �zAbstractServer.__aenter__c � s �| � � | �� I d H d S r: )re rl )r rB r% r% r& � __aexit__� s �zAbstractServer.__aexit__N) r, rF rG re rg rh rj rk rl rn rp r% r% r% r& r � s r c @ s� e Zd Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd�dd�Z dd�dd�Z dd�dd�Zdd � Zd d � Zdd �d d!�Zdd�d"d#�Zd$d%� Zd&d'� Zd(d(d(d(d)�d*d+�Zdzd,d-�Z d{dd(d(d(ddddddd.� d/d0�Z d{ejejdd1ddddd2d3� d4d5�Zd|d2d6�d7d8�Z d9ddd:�d;d<�Z d}ddddd=�d>d?�Z d}dd1ddd2d@�dAdB�Z dddC�dDdE�Z d{d(d(d(dddddF�dGdH�Z!dIdJ� Z"dKdL� Z#e$j%e$j%e$j%dM�dNdO�Z&e$j%e$j%e$j%dM�dPdQ�Z'dRdS� Z(dTdU� Z)dVdW� Z*dXdY� Z+dZd[� Z,d\d]� Z-d^d_� Z.d`da� Z/dbdc� Z0d|dd6�ddde�Z1dfdg� Z2dhdi� Z3djdk� Z4dldm� Z5dndo� Z6dpdq� Z7drds� Z8dtdu� Z9dvdw� Z:dxdy� Z;dS )~r c C rb r: rc r8 r% r% r& � run_forever� rf z AbstractEventLoop.run_foreverc C rb r: rc )r Zfuturer% r% r& �run_until_complete� s z$AbstractEventLoop.run_until_completec C rb r: rc r8 r% r% r& �stop� s zAbstractEventLoop.stopc C rb r: rc r8 r% r% r& � is_running� rf z AbstractEventLoop.is_runningc C rb r: rc r8 r% r% r& � is_closed� rf zAbstractEventLoop.is_closedc C rb r: rc r8 r% r% r& re � s zAbstractEventLoop.closec � ri r: rc r8 r% r% r& �shutdown_asyncgens� rm z$AbstractEventLoop.shutdown_asyncgensc � ri r: rc r8 r% r% r& �shutdown_default_executor� rm z+AbstractEventLoop.shutdown_default_executorc C rb r: rc )r r< r% r% r& r` rf z)AbstractEventLoop._timer_handle_cancelledN)r$ c G s | j d|g|�R d|i�S )Nr r$ )� call_later�r r! r$ r" r% r% r& � call_soon s zAbstractEventLoop.call_soonc G � t �r: rc )r Zdelayr! r$ r" r% r% r& rx � z AbstractEventLoop.call_laterc G r{ r: rc )r rL r! r$ r" r% r% r& �call_at r| zAbstractEventLoop.call_atc C r{ r: rc r8 r% r% r& �time r| zAbstractEventLoop.timec C r{ r: rc r8 r% r% r& � create_future r| z AbstractEventLoop.create_future)�namec C r{ r: rc )r �coror� r% r% r& � create_task r| z AbstractEventLoop.create_taskc G r{ r: rc ry r% r% r& �call_soon_threadsafe r| z&AbstractEventLoop.call_soon_threadsafec G r{ r: rc )r �executor�funcr" r% r% r& �run_in_executor r| z!AbstractEventLoop.run_in_executorc C r{ r: rc )r r� r% r% r& �set_default_executor! r| z&AbstractEventLoop.set_default_executorr )�family�type�proto�flagsc � � �t �r: rc )r �host�portr� r� r� r� r% r% r& � getaddrinfo& � �z AbstractEventLoop.getaddrinfoc � r� r: rc )r Zsockaddrr� r% r% r& � getnameinfo* ro z AbstractEventLoop.getnameinfo) �sslr� r� r� �sock� local_addr�server_hostname�ssl_handshake_timeout�happy_eyeballs_delay� interleavec � r� r: rc )r �protocol_factoryr� r� r� r� r� r� r� r� r� r� r� r� r% r% r& �create_connection- s �z#AbstractEventLoop.create_connection�d T) r� r� r� �backlogr� � reuse_address� reuse_portr� rj c � ri r: rc ) r r� r� r� r� r� r� r� r� r� r� r� rj r% r% r& � create_server6 s �,z AbstractEventLoop.create_server)�fallbackc � ri r: rc )r � transport�file�offset�countr� r% r% r& �sendfilek s �zAbstractEventLoop.sendfileF)� server_sider� r� c � ri r: rc )r r� ZprotocolZ sslcontextr� r� r� r% r% r& � start_tlss s �zAbstractEventLoop.start_tls)r� r� r� r� c � r� r: rc )r r� �pathr� r� r� r� r% r% r& �create_unix_connection~ � �z(AbstractEventLoop.create_unix_connection)r� r� r� r� rj c � ri r: rc )r r� r� r� r� r� r� rj r% r% r& �create_unix_server� s �z$AbstractEventLoop.create_unix_server)r� r� c � ri r: rc )r r� r� r� r� r% r% r& �connect_accepted_socket� s �z)AbstractEventLoop.connect_accepted_socket)r� r� r� r� r� �allow_broadcastr� c � ri r: rc ) r r� r� Z remote_addrr� r� r� r� r� r� r� r% r% r& �create_datagram_endpoint� s � z*AbstractEventLoop.create_datagram_endpointc � ri r: rc �r r� �piper% r% r& �connect_read_pipe� � � z#AbstractEventLoop.connect_read_pipec � ri r: rc r� r% r% r& �connect_write_pipe� r� z$AbstractEventLoop.connect_write_pipe)�stdin�stdout�stderrc � r� r: rc )r r� �cmdr� r� r� �kwargsr% r% r& �subprocess_shell� r� z"AbstractEventLoop.subprocess_shellc � r� r: rc )r r� r� r� r� r" r� r% r% r& �subprocess_exec� r� z!AbstractEventLoop.subprocess_execc G r{ r: rc �r �fdr! r" r% r% r& � add_reader r| z AbstractEventLoop.add_readerc C r{ r: rc �r r� r% r% r& � remove_reader r| z AbstractEventLoop.remove_readerc G r{ r: rc r� r% r% r& � add_writer r| z AbstractEventLoop.add_writerc C r{ r: rc r� r% r% r& � remove_writer r| z AbstractEventLoop.remove_writerc � r� r: rc )r r� �nbytesr% r% r& � sock_recv ro zAbstractEventLoop.sock_recvc � r� r: rc )r r� Zbufr% r% r& �sock_recv_into ro z AbstractEventLoop.sock_recv_intoc � r� r: rc )r r� �datar% r% r& � sock_sendall ro z AbstractEventLoop.sock_sendallc � r� r: rc )r r� Zaddressr% r% r& � sock_connect ro z AbstractEventLoop.sock_connectc � r� r: rc )r r� r% r% r& � sock_accept ro z AbstractEventLoop.sock_acceptc � r� r: rc )r r� r� r� r� r� r% r% r& � sock_sendfile" r� z AbstractEventLoop.sock_sendfilec G r{ r: rc )r �sigr! r" r% r% r& �add_signal_handler( r| z$AbstractEventLoop.add_signal_handlerc C r{ r: rc )r r� r% r% r& �remove_signal_handler+ r| z'AbstractEventLoop.remove_signal_handlerc C r{ r: rc )r �factoryr% r% r& �set_task_factory0 r| z"AbstractEventLoop.set_task_factoryc C r{ r: rc r8 r% r% r& �get_task_factory3 r| z"AbstractEventLoop.get_task_factoryc C r{ r: rc r8 r% r% r& �get_exception_handler8 r| z'AbstractEventLoop.get_exception_handlerc C r{ r: rc )r Zhandlerr% r% r& �set_exception_handler; r| z'AbstractEventLoop.set_exception_handlerc C r{ r: rc �r r$ r% r% r& �default_exception_handler> r| z+AbstractEventLoop.default_exception_handlerc C r{ r: rc r� r% r% r& rA A r| z(AbstractEventLoop.call_exception_handlerc C r{ r: rc r8 r% r% r& r F r| zAbstractEventLoop.get_debugc C r{ r: rc )r Zenabledr% r% r& � set_debugI r| zAbstractEventLoop.set_debug)r �NN)r Nr: )<r, rF rG rq rr rs rt ru re rv rw r` rz rx r} r~ r r� r� r� r� r� r� r� �socketZ AF_UNSPECZ AI_PASSIVEr� r� 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� rA r r� r% r% r% r& r � s� � � � � �5 � � � �� �" �� �% � � � r c @ s6 e Zd Z dd� Zdd� Zdd� Zdd� Zd d � Zd S ) r c C rb r: rc r8 r% r% r& r P s z&AbstractEventLoopPolicy.get_event_loopc C rb r: rc �r r# r% r% r& r Z rf z&AbstractEventLoopPolicy.set_event_loopc C rb r: rc r8 r% r% r& r ^ s z&AbstractEventLoopPolicy.new_event_loopc C rb r: rc r8 r% r% r& r f rf z)AbstractEventLoopPolicy.get_child_watcherc C rb r: rc )r �watcherr% r% r& r j rf z)AbstractEventLoopPolicy.set_child_watcherN)r, rF rG r r r r r r% r% r% r& r M s r c @ sD e Zd Z dZG dd� dej�Zdd� Zdd� Zdd � Z d d � Z dS ) �BaseDefaultEventLoopPolicyNc @ s e Zd ZdZdZdS )z!BaseDefaultEventLoopPolicy._LocalNF)r, rF rG r � _set_calledr% r% r% r& �_Local~ s r� c C s | � � | _d S r: )r� �_localr8 r% r% r& r' � s z#BaseDefaultEventLoopPolicy.__init__c C sZ | j jd u r| j jst�� t�� u r| �| �� � | j jd u r)tdt�� j ��| j jS )Nz,There is no current event loop in thread %r.) r� r r� � threadingZcurrent_threadZ main_threadr r � RuntimeErrorr� r8 r% r% r& r � s � �z)BaseDefaultEventLoopPolicy.get_event_loopc C s d| j _|| j _d S r6 )r� r� r r� r% r% r& r � s z)BaseDefaultEventLoopPolicy.set_event_loopc C s | � � S r: )� _loop_factoryr8 r% r% r& r � � z)BaseDefaultEventLoopPolicy.new_event_loop) r, rF rG r� r� �localr� r' r r r r% r% r% r& r� o s r� c @ s e Zd ZdZdS )� _RunningLoopr� N)r, rF rG �loop_pidr% r% r% r& r� � s r� c C s t � } | d u r td��| S )Nzno running event loop)r r� �r# r% r% r& r � s r c C s, t j\} }| d ur|t�� kr| S d S d S r: )� _running_loopr� �os�getpid)Z running_loop�pidr% r% r& r � s �r c C s | t �� ft_d S r: )r� r� r� r� r� r% r% r& r � s r c C sT t � td u rddlm} | � aW d � d S W d � d S 1 s#w Y d S )Nr ��DefaultEventLoopPolicy)�_lock�_event_loop_policy� r� r� r% r% r& �_init_event_loop_policy� s �"�r� c C s t d u rt� t S r: )r� r� r% r% r% r& r � s r c C s | a d S r: )r� )Zpolicyr% r% r& r � r� r c C s t � S r: )�_py__get_event_loopr% r% r% r& r � s r � c C s t � }|d ur |S t� �� S r: )r r r )� stacklevelZ current_loopr% r% r& �_get_event_loop� s r� c C s t � �| � d S r: )r r r� r% r% r& r s r c C � t � �� S r: )r r r% r% r% r& r � r c C r� r: )r r r% r% r% r& r r� r c C s t � �| �S r: )r r )r� r% r% r& r s r )r r r r r� )r� )-�__all__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 r Z_py__get_running_loopZ_py__set_running_loopZ_py_get_running_loopZ_py_get_event_loopr� Z_asyncio� ImportErrorZ_c__get_running_loopZ_c__set_running_loopZ_c_get_running_loopZ_c_get_event_loopZ_c__get_event_loopr% r% r% r& �<module> sb J@* "9 �