← Back
Editing: unix_events.cpython-310.opt-2.pyc
o 0�i�� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z ddl m Z ddl mZ ddl mZ ddl mZ ddl mZ ddl mZ dd l mZ dd l mZ dd l mZ dd l mZ dd lmZ dZe jdkr~ed��dd� Z dd� Z G dd� dej �Z G dd� dej �Z!G dd� dej"ej#�Z$G dd � d ej%�Z&G d d � d �Z'G d d � d e'�Z(G d!d"� d"e'�Z)G d#d$� d$e)�Z*G d%d&� d&e)�Z+G d'd(� d(e'�Z,G d)d*� d*e'�Z-G d+d,� d,ej.�Z/e Z0e/Z1dS )-� N� )� base_events)�base_subprocess)� constants)� coroutines)�events)� exceptions)�futures)�selector_events)�tasks)� transports)�logger)�SelectorEventLoop�AbstractChildWatcher�SafeChildWatcher�FastChildWatcher�PidfdChildWatcher�MultiLoopChildWatcher�ThreadedChildWatcher�DefaultEventLoopPolicyZwin32z+Signals are not really supported on Windowsc C s d S �N� )�signum�framer r �:/opt/alt/python310/lib64/python3.10/asyncio/unix_events.py�_sighandler_noop* s r c C s$ zt �| �W S ty | Y S w r )�os�waitstatus_to_exitcode� ValueError)�statusr r r r / s �r c s� e Zd Z d(� fdd� Z� fdd�Zdd� Zdd � Zd d � Zd d � Zdd� Z d)dd�Z d)dd�Z d(dd�Z dd� Z d(ddddd�dd�Z d(ddddd d �d d �Zd d!� Zd"d#� Zd$d%� Zd&d'� Z� ZS )*�_UnixSelectorEventLoopNc s t � �|� i | _d S r )�super�__init__�_signal_handlers)�self�selector�� __class__r r r" ? � z _UnixSelectorEventLoop.__init__c s` t � �� t�� st| j�D ]}| �|� qd S | jr.tjd| �d�t | d� | j� � d S d S )NzClosing the loop z@ on interpreter shutdown stage, skipping signal handlers removal��source) r! �close�sys� is_finalizing�listr# �remove_signal_handler�warnings�warn�ResourceWarning�clear�r$ �sigr& r r r+ C s ���z _UnixSelectorEventLoop.closec C s |D ] }|sq| � |� qd S r )�_handle_signal)r$ �datar r r r �_process_self_dataQ s �z)_UnixSelectorEventLoop._process_self_datac G s0 t �|�s t �|�rtd��| �|� | �� z t�| j� � � W n t t fy6 } zt t |���d }~ww t�||| d �}|| j|< zt�|t� t�|d� W d S t y� } z8| j|= | js�zt�d� W n t t fy� } z t�d|� W Y d }~nd }~ww |jtjkr�t d|� d���� d }~ww )Nz3coroutines cannot be used with add_signal_handler()F���� set_wakeup_fd(-1) failed: %s�sig � cannot be caught)r Z iscoroutineZiscoroutinefunction� TypeError� _check_signalZ _check_closed�signal� set_wakeup_fdZ_csock�filenor �OSError� RuntimeError�strr ZHandler# r � siginterruptr �info�errno�EINVAL)r$ r5 �callback�args�exc�handleZnexcr r r �add_signal_handlerX s@ � �� �� ��z)_UnixSelectorEventLoop.add_signal_handlerc C s< | j �|�}|d u r d S |jr| �|� d S | �|� d S r )r# �getZ _cancelledr/ Z_add_callback_signalsafe)r$ r5 rL r r r r6 � s z%_UnixSelectorEventLoop._handle_signalc C s� | � |� z| j|= W n ty Y dS w |tjkr tj}ntj}zt�||� W n tyF } z|jtj krAt d|� d���� d }~ww | jsnzt� d� W dS t tfym } z t �d|� W Y d }~dS d }~ww dS )NFr; r< r9 r: T)r> r# �KeyErrorr? �SIGINT�default_int_handler�SIG_DFLrB rG rH rC r@ r r rF )r$ r5 �handlerrK r r r r/ � s8 � �� ���z,_UnixSelectorEventLoop.remove_signal_handlerc C s8 t |t�s td|����|t�� vrtd|� ���d S )Nzsig must be an int, not zinvalid signal number )� isinstance�intr= r? � valid_signalsr r4 r r r r> � s �z$_UnixSelectorEventLoop._check_signalc C � t | ||||�S r )�_UnixReadPipeTransport�r$ �pipe�protocol�waiter�extrar r r �_make_read_pipe_transport� � z0_UnixSelectorEventLoop._make_read_pipe_transportc C rW r )�_UnixWritePipeTransportrY r r r �_make_write_pipe_transport� r_ z1_UnixSelectorEventLoop._make_write_pipe_transportc � s� �t �� �U} | �� std��| �� } t| |||||||f| |d�| ��} | �| �� | j| � z| I d H W n t t fy? � t yQ | � � | � � I d H � w W d � | S 1 s]w Y | S )NzRasyncio.get_child_watcher() is not activated, subprocess support is not installed.)r\ r] )r �get_child_watcher� is_activerC � create_future�_UnixSubprocessTransport�add_child_handlerZget_pid�_child_watcher_callback� SystemExit�KeyboardInterrupt� BaseExceptionr+ Z_wait) r$ r[ rJ �shell�stdin�stdout�stderr�bufsizer] �kwargs�watcherr\ �transpr r r �_make_subprocess_transport� s: � ��� � �� ��z1_UnixSelectorEventLoop._make_subprocess_transportc C s | � | j|j|� d S r )�call_soon_threadsafe� call_soonZ_process_exited)r$ �pid� returncoderr r r r rg � s z._UnixSelectorEventLoop._child_watcher_callback)�ssl�sock�server_hostname�ssl_handshake_timeoutc � s �|r |d u r t d��n|d urt d��|d ur t d��|d urO|d ur(t d��t�|�}t�tjtjd�}z|�d� | �||�I d H W n( |�� � |d u rWt d��|j tjksc|j tjkrjt d|����|�d� | j |||||d �I d H \}}||fS ) Nz/you have to pass server_hostname when using sslz+server_hostname is only meaningful with ssl�1ssl_handshake_timeout is only meaningful with ssl�3path and sock can not be specified at the same timer Fz no path and sock were specified�.A UNIX Domain Stream Socket was expected, got )r{ ) r r �fspath�socket�AF_UNIX� SOCK_STREAM� setblockingZ sock_connectr+ �family�typeZ _create_connection_transport) r$ �protocol_factory�pathrx ry rz r{ � transportr[ r r r �create_unix_connection� sN ����� � �z-_UnixSelectorEventLoop.create_unix_connection�d T)ry �backlogrx r{ � start_servingc � s� �t |t�r td��|d ur|std��|d ur�|d ur td��t�|�}t�tjtj�}|d dvrezt � t� |�j �rBt� |� W n! t yL Y n tyd } z t�d||� W Y d }~nd }~ww z|�|� W nF ty� } z|�� | jtjkr�d|�d�} ttj| �d �� d } ~ w |�� � |d u r�td ��|jtjks�|jtjkr�td |����|�d � t�| |g||||�} |r�| �� t� d�I d H | S ) Nz*ssl argument must be an SSLContext or Noner| r} r )r � z2Unable to check or remove stale UNIX socket %r: %rzAddress z is already in usez-path was not specified, and no sock specifiedr~ F) rT �boolr= r r r r� r� r� �stat�S_ISSOCK�st_mode�remove�FileNotFoundErrorrB r �errorZbindr+ rG Z EADDRINUSEr� r� r� r ZServerZ_start_servingr �sleep) r$ r� r� ry r� rx r{ r� �errrK �msgZserverr r r �create_unix_server sp � �� � ��� �� � �z)_UnixSelectorEventLoop.create_unix_serverc � s� �zt j W n ty t�d��w z|�� }W n ttjfy- } zt�d��d }~ww zt �|�j }W n t yB t�d��w |rG|n|}|sMdS | � � } | � | d |||||d� | I d H S )Nz os.sendfile() is not availableznot a regular filer ) r �sendfile�AttributeErrorr �SendfileNotAvailableErrorrA �io�UnsupportedOperation�fstat�st_sizerB rd �_sock_sendfile_native_impl) r$ ry �file�offset�countrA r� Zfsize� blocksize�futr r r �_sock_sendfile_nativeU s6 � �� �� � � z,_UnixSelectorEventLoop._sock_sendfile_nativec C s* |� � } |d ur | �|� |�� r| �|||� d S |r2|| }|dkr2| �|||� |�|� d S z t�| |||�} W n� ttfya |d u rO| � ||� | � | | j || ||||||� Y d S t y� } zK|d ur�| j t jkr�t| �tur�tdt j�} | | _| } |dkr�t�d�} | �|||� |�| � n| �|||� |�| � W Y d } ~ d S W Y d } ~ d S d } ~ w ttfy� � ty� } z| �|||� |�| � W Y d } ~ d S d } ~ ww | dkr�| �|||� |�|� d S || 7 }|| 7 }|d u �r| � ||� | � | | j || ||||||� d S )Nr zsocket is not connectedzos.sendfile call failed)rA � remove_writer� cancelled� _sock_sendfile_update_fileposZ set_resultr r� �BlockingIOError�InterruptedError� _sock_add_cancellation_callbackZ add_writerr� rB rG ZENOTCONNr� �ConnectionError� __cause__r r� Z set_exceptionrh ri rj )r$ r� Z registered_fdry rA r� r� r� � total_sent�fdZsentrK �new_excr� r r r r� l st � �� ���� �z1_UnixSelectorEventLoop._sock_sendfile_native_implc C s |dkrt �||t j� d S d S �Nr )r �lseek�SEEK_SET)r$ rA r� r� r r r r� � s �z4_UnixSelectorEventLoop._sock_sendfile_update_fileposc s � �fdd�}|� |� d S )Nc s. | � � r��� }|dkr� �|� d S d S d S )Nr9 )r� rA r� )r� r� �r$ ry r r �cb� s �zB_UnixSelectorEventLoop._sock_add_cancellation_callback.<locals>.cb)Zadd_done_callback)r$ r� ry r� r r� r r� � s z6_UnixSelectorEventLoop._sock_add_cancellation_callbackr �NN)�__name__� __module__� __qualname__r" r+ r8 rM r6 r/ r> r^ ra rs rg r� r� r� r� r� r� � __classcell__r r r& r r 9 sD - � � � � �.� �CFr c s� e Zd ZdZd � fdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z e jfdd�Zd dd�Zdd� Zd d � Z� ZS ) rX i Nc s� t � �|� || jd< || _|| _|�� | _|| _d| _d| _ t � | j�j }t �|�sBt �|�sBt �|�sBd | _d | _d | _td��t �| jd� | j�| jj| � | j�| jj| j| j� |d urm| j�tj|d � d S d S )NrZ Fz)Pipe transport is for pipes/sockets only.)r! r" �_extra�_loop�_piperA �_fileno� _protocol�_closing�_pausedr r� r� r� �S_ISFIFOr� �S_ISCHRr � set_blockingru �connection_made� _add_reader� _read_readyr � _set_result_unless_cancelled)r$ �looprZ r[ r\ r] �moder& r r r" � s8 �� � ��z _UnixReadPipeTransport.__init__c C s� | j jg}| jd u r|�d� n| jr|�d� |�d| j� �� t| jdd �}| jd urH|d urHt� || jt j �}|rB|�d� n|�d� n| jd urS|�d� n|�d� d� d � |��S ) N�closed�closing�fd=� _selector�polling�idle�open�<{}>� )r' r� r� �appendr� r� �getattrr� r �_test_selector_event� selectorsZ EVENT_READ�format�join)r$ rF r% r� r r r �__repr__� s$ � z _UnixReadPipeTransport.__repr__c C s� z t �| j| j�}W n$ ttfy Y d S ty. } z | �|d� W Y d }~d S d }~ww |r9| j� |� d S | j � � rDt � d| � d| _| j �| j� | j �| jj� | j �| jd � d S )Nz"Fatal read error on pipe transport�%r was closed by peerT)r �readr� �max_sizer� r� rB � _fatal_errorr� Z data_receivedr� � get_debugr rF r� �_remove_readerru Z eof_received�_call_connection_lost)r$ r7 rK r r r r� � s �� z"_UnixReadPipeTransport._read_readyc C sB | j s| jrd S d| _| j�| j� | j�� r t�d| � d S d S )NTz%r pauses reading)r� r� r� r� r� r� r �debug�r$ r r r � pause_reading s �z$_UnixReadPipeTransport.pause_readingc C sF | j s| jsd S d| _| j�| j| j� | j�� r!t�d| � d S d S )NFz%r resumes reading) r� r� r� r� r� r� r� r r� r� r r r �resume_reading s �z%_UnixReadPipeTransport.resume_readingc C � || _ d S r �r� �r$ r[ r r r � set_protocol � z#_UnixReadPipeTransport.set_protocolc C � | j S r r� r� r r r � get_protocol � z#_UnixReadPipeTransport.get_protocolc C r� r �r� r� r r r � is_closing r� z!_UnixReadPipeTransport.is_closingc C s | j s | �d � d S d S r )r� �_closer� r r r r+ ! s �z _UnixReadPipeTransport.closec C �0 | j d ur|d| ��t| d� | j �� d S d S �Nzunclosed transport r) �r� r2 r+ �r$ �_warnr r r �__del__% � �z _UnixReadPipeTransport.__del__� Fatal error on pipe transportc C sZ t |t�r|jtjkr| j�� rtjd| |dd� n | j�||| | j d�� | � |� d S �Nz%r: %sT��exc_info)�message� exceptionr� r[ ) rT rB rG ZEIOr� r� r r� �call_exception_handlerr� r� �r$ rK r� r r r r� * s ��z#_UnixReadPipeTransport._fatal_errorc C s( d| _ | j�| j� | j�| j|� d S �NT)r� r� r� r� ru r� �r$ rK r r r r� 8 s z _UnixReadPipeTransport._closec C �N z| j �|� W | j�� d | _d | _ d | _d S | j�� d | _d | _ d | _w r �r� Zconnection_lostr� r+ r� r r r r r� = � �z,_UnixReadPipeTransport._call_connection_lostr� �r� )r� r� r� r� r" r� r� r� r� r� r� r� r+ r0 r1 r� r� r� r� r� r r r& r rX � s rX c s� e Zd Zd%� fdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Zejfdd�Zd d � Zd&d d �Zd'd!d"�Zd#d$� Z� ZS )(r` Nc s t � �||� || jd< || _|�� | _|| _t� | _d| _ d| _ t � | j�j }t�|�}t�|�}t�|�} |sJ|sJ| sJd | _d | _d | _td��t �| jd� | j�| jj| � | sd|rptj�d�sp| j�| jj| j| j� |d ur| j�t j |d � d S d S )NrZ r Fz?Pipe transport is only for pipes, sockets and character devices�aix) r! r" r� r� rA r� r� � bytearray�_buffer� _conn_lostr� r r� r� r� r� r� r� r r� r� ru r� r, �platform� startswithr� r� r r� ) r$ r� rZ r[ r\ r] r� Zis_charZis_fifoZ is_socketr& r r r" J s8 � ��z _UnixWritePipeTransport.__init__c C s� | j jg}| jd u r|�d� n| jr|�d� |�d| j� �� t| jdd �}| jd urT|d urTt� || jt j �}|rB|�d� n|�d� | � � }|�d|� �� n| jd ur_|�d� n|�d� d � d �|��S ) Nr� r� r� r� r� r� zbufsize=r� r� r� )r' r� r� r� r� r� r� r� r r� r� Z EVENT_WRITE�get_write_buffer_sizer� r� )r$ rF r% r� ro r r r r� o s( � z _UnixWritePipeTransport.__repr__c C s t | j�S r )�lenr r� r r r r � r� z-_UnixWritePipeTransport.get_write_buffer_sizec C s8 | j �� r t�d| � | jr| �t� � d S | �� d S )Nr� )r� r� r rF r r� �BrokenPipeErrorr� r r r r� � s z#_UnixWritePipeTransport._read_readyc C s& t |t�r t|�}|s d S | js| jr'| jtjkr t�d� | jd7 _d S | j s�z t � | j |�}W n5 t tfy@ d}Y n) ttfyI � tyh } z| jd7 _| �|d� W Y d }~d S d }~ww |t|�krqd S |dkr}t|�|d � }| j�| j | j� | j |7 _ | �� d S )Nz=pipe closed by peer or os.write(pipe, data) raised exception.r r �#Fatal write error on pipe transport)rT r � memoryviewr r� r Z!LOG_THRESHOLD_FOR_CONNLOST_WRITESr �warningr r �writer� r� r� rh ri rj r� r r� Z _add_writer� _write_readyZ_maybe_pause_protocol)r$ r7 �nrK r r r r � s: �� z _UnixWritePipeTransport.writec C s z t �| j| j�}W n@ ttfy Y d S ttfy � tyJ } z | j� � | j d7 _ | j � | j� | � |d� W Y d }~d S d }~ww |t| j�krs| j� � | j � | j� | �� | jrq| j �| j� | �d � d S |dkr| jd |�= d S d S )Nr r r )r r r� r r� r� rh ri rj r3 r r� �_remove_writerr� r Z_maybe_resume_protocolr� r� r� )r$ r rK r r r r � s0 �� �z$_UnixWritePipeTransport._write_readyc C � dS r r r� r r r � can_write_eof� � z%_UnixWritePipeTransport.can_write_eofc C s< | j rd S d| _ | js | j�| j� | j�| jd � d S d S r )r� r r� r� r� ru r� r� r r r � write_eof� s �z!_UnixWritePipeTransport.write_eofc C r� r r� r� r r r r� � r� z$_UnixWritePipeTransport.set_protocolc C r� r r� r� r r r r� � r� z$_UnixWritePipeTransport.get_protocolc C r� r r� r� r r r r� � r� z"_UnixWritePipeTransport.is_closingc C s$ | j d ur| js| �� d S d S d S r )r� r� r r� r r r r+ � s �z _UnixWritePipeTransport.closec C r� r� r� r� r r r r� � r� z _UnixWritePipeTransport.__del__c C � | � d � d S r )r� r� r r r �abort� � z _UnixWritePipeTransport.abortr� c C sN t |t�r| j�� rtjd| |dd� n | j�||| | jd�� | �|� d S r� ) rT rB r� r� r r� r� r� r� r r r r r� � s ��z$_UnixWritePipeTransport._fatal_errorc C sF d| _ | jr | j�| j� | j�� | j�| j� | j�| j|� d S r ) r� r r� r r� r3 r� ru r� r r r r r� s z _UnixWritePipeTransport._closec C r r r r r r r r� r z-_UnixWritePipeTransport._call_connection_lostr� r r )r� r� r� r" r� r r� r r r r r� r� r� r+ r0 r1 r� r r� r� r� r� r r r& r r` G s$ % # r` c @ s e Zd Zdd� ZdS )re c K s� d }|t jkrtj�d�rt�� \}}z7t j|f||||d|d�|��| _|d ur:|� � t |� � d|d�| j_ d }W |d urI|� � |� � d S d S |d urX|� � |� � w w )Nr F)rk rl rm rn Zuniversal_newlinesro �wb)� buffering) � subprocess�PIPEr, r r r� Z socketpair�Popen�_procr+ r� �detachrl ) r$ rJ rk rl rm rn ro rp Zstdin_wr r r �_start s0 ���� � �z _UnixSubprocessTransport._startN)r� r� r� r% r r r r re s re c @ sF e Zd Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )r c G � t � �r ��NotImplementedError�r$ rv rI rJ r r r rf C s z&AbstractChildWatcher.add_child_handlerc C r& r r' �r$ rv r r r �remove_child_handlerN s z)AbstractChildWatcher.remove_child_handlerc C r& r r' �r$ r� r r r � attach_loopV s z AbstractChildWatcher.attach_loopc C r& r r' r� r r r r+ ` s zAbstractChildWatcher.closec C r& r r' r� r r r rc g s z AbstractChildWatcher.is_activec C r& r r' r� r r r � __enter__p s z AbstractChildWatcher.__enter__c C r& r r' �r$ �a�b�cr r r �__exit__v s z AbstractChildWatcher.__exit__N) r� r� r� rf r+ r- r+ rc r. r3 r r r r r , s r c @ sV e Zd Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dS )r c C � d | _ i | _d S r �r� � _callbacksr� r r r r" � � zPidfdChildWatcher.__init__c C � | S r r r� r r r r. � r zPidfdChildWatcher.__enter__c C � d S r r )r$ �exc_type� exc_value� exc_tracebackr r r r3 � r zPidfdChildWatcher.__exit__c C � | j d uo | j �� S r �r� Z is_runningr� r r r rc � � zPidfdChildWatcher.is_activec C r r �r- r� r r r r+ � r zPidfdChildWatcher.closec C sd | j d ur|d u r| jrt�dt� | j�� D ]\}}}| j �|� t�|� q| j� � || _ d S �NzCA loop is being detached from a child watcher with pending handlers) r� r6 r0 r1 �RuntimeWarning�valuesr� r r+ r3 )r$ r� �pidfd�_r r r r- � s � z PidfdChildWatcher.attach_loopc G s\ | j �|�}|d ur|d ||f| j |< d S t�|�}| j�|| j|� |||f| j |< d S r� )r6 rN r Z pidfd_openr� r� �_do_wait)r$ rv rI rJ ZexistingrD r r r rf � s z#PidfdChildWatcher.add_child_handlerc C s~ | j �|�\}}}| j�|� z t�|d�\}}W n ty* d}t�d|� Y nw t |�}t� |� |||g|�R � d S )Nr � zJchild process pid %d exit status already read: will report returncode 255) r6 �popr� r� r �waitpid�ChildProcessErrorr r r r+ )r$ rv rD rI rJ rE r rw r r r rF � s �� zPidfdChildWatcher._do_waitc C sF z | j �|�\}}}W n ty Y dS w | j�|� t�|� dS )NFT)r6 rH rO r� r� r r+ )r$ rv rD rE r r r r+ � s � z&PidfdChildWatcher.remove_child_handlerN) r� r� r� r" r. r3 rc r+ r- rf rF r+ r r r r r { s r c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )�BaseChildWatcherc C r4 r r5 r� r r r r" � r7 zBaseChildWatcher.__init__c C r r r@ r� r r r r+ � r zBaseChildWatcher.closec C r= r r> r� r r r rc � r? zBaseChildWatcher.is_activec C � t � �r r' )r$ � expected_pidr r r � _do_waitpid� r� z BaseChildWatcher._do_waitpidc C rL r r' r� r r r �_do_waitpid_all� r� z BaseChildWatcher._do_waitpid_allc C sj | j d ur|d u r| jrt�dt� | j d ur | j �tj� || _ |d ur3|�tj| j � | � � d S d S rA ) r� r6 r0 r1 rB r/ r? �SIGCHLDrM � _sig_chldrO r, r r r r- � s � �z BaseChildWatcher.attach_loopc C sZ z| � � W d S ttfy � ty, } z| j�d|d�� W Y d }~d S d }~ww )N�$Unknown exception in SIGCHLD handler)r� r� )rO rh ri rj r� r� r r r r rQ � s ���zBaseChildWatcher._sig_chldN) r� r� r� r" r+ rc rN rO r- rQ r r r r rK � s rK c sN e Zd Z � fdd�Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z � Z S )r c s | j �� t� �� d S r )r6 r3 r! r+ r� r& r r r+ s zSafeChildWatcher.closec C r8 r r r� r r r r. r zSafeChildWatcher.__enter__c C r9 r r r/ r r r r3 r zSafeChildWatcher.__exit__c G s ||f| j |< | �|� d S r )r6 rN r) r r r rf s z"SafeChildWatcher.add_child_handlerc C �$ z| j |= W dS ty Y dS w �NTF�r6 rO r* r r r r+ � �z%SafeChildWatcher.remove_child_handlerc C � t | j�D ]}| �|� qd S r �r. r6 rN r* r r r rO s �z SafeChildWatcher._do_waitpid_allc C s� z t �|t j�\}}W n ty |}d}t�d|� Y nw |dkr%d S t|�}| j�� r5t� d||� z | j � |�\}}W n t yY | j�� rVtjd|dd� Y d S Y d S w |||g|�R � d S )NrG �8Unknown child process pid %d, will report returncode 255r �$process %s exited with returncode %s�'Child watcher got an unexpected pid: %rTr� ) r rI �WNOHANGrJ r r r r� r� r� r6 rH rO )r$ rM rv r rw rI rJ r r r rN % s6 �� � ���z SafeChildWatcher._do_waitpid) r� r� r� r+ r. r3 rf r+ rO rN r� r r r& r r � s r c sR e Zd Z � fdd�Z� fdd�Zdd� Zdd� Zd d � Zd d � Zd d� Z � Z S )r c s$ t � �� t�� | _i | _d| _d S r� )r! r" � threadingZLock�_lock�_zombies�_forksr� r& r r r" R s zFastChildWatcher.__init__c s" | j �� | j�� t� �� d S r )r6 r3 r_ r! r+ r� r& r r r+ X s zFastChildWatcher.closec C s< | j � | jd7 _| W d � S 1 sw Y d S )Nr )r^ r` r� r r r r. ] s $�zFastChildWatcher.__enter__c C sv | j �( | jd8 _| js| js W d � d S t| j�}| j�� W d � n1 s.w Y t�d|� d S )Nr z5Caught subprocesses termination from unknown pids: %s)r^ r` r_ rD r3 r r )r$ r0 r1 r2 Zcollateral_victimsr r r r3 c s � � �zFastChildWatcher.__exit__c G s| | j �( z| j�|�}W n ty# ||f| j|< Y W d � d S w W d � n1 s.w Y |||g|�R � d S r )r^ r_ rH rO r6 )r$ rv rI rJ rw r r r rf q s �� � z"FastChildWatcher.add_child_handlerc C rS rT rU r* r r r r+ rV z%FastChildWatcher.remove_child_handlerc C s z t �dt j�\}}W n ty Y d S w |dkr d S t|�}| j�F z | j�|�\}}W n' tyV | j rR|| j |< | j � � rJt �d||� Y W d � q d }Y n w | j � � rct �d||� W d � n1 smw Y |d u r~t �d||� n |||g|�R � q)NTr9 r z,unknown process %s exited with returncode %srZ z8Caught subprocess termination from unknown pid: %d -> %d)r rI r\ rJ r r^ r6 rH rO r` r_ r� r� r r� r )r$ rv r rw rI rJ r r r rO � sH � �� � �� ���z FastChildWatcher._do_waitpid_all) r� r� r� r" r+ r. r3 rf r+ rO r� r r r& r r H s r c @ sf e Zd Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dS )r c C s i | _ d | _d S r )r6 �_saved_sighandlerr� r r r r" � r7 z MultiLoopChildWatcher.__init__c C s | j d uS r )ra r� r r r rc � r� z MultiLoopChildWatcher.is_activec C sT | j �� | jd u r d S t�tj�}|| jkr t�d� nt�tj| j� d | _d S )Nz+SIGCHLD handler was changed by outside code) r6 r3 ra r? � getsignalrP rQ r r )r$ rS r r r r+ � s zMultiLoopChildWatcher.closec C r8 r r r� r r r r. � r z MultiLoopChildWatcher.__enter__c C r9 r r �r$ r: Zexc_valZexc_tbr r r r3 � r z MultiLoopChildWatcher.__exit__c G s& t �� }|||f| j|< | �|� d S r )r �get_running_loopr6 rN )r$ rv rI rJ r� r r r rf � s z'MultiLoopChildWatcher.add_child_handlerc C rS rT rU r* r r r r+ � rV z*MultiLoopChildWatcher.remove_child_handlerc C sN | j d urd S t�tj| j�| _ | j d u r t�d� tj| _ t�tjd� d S )NzaPrevious SIGCHLD handler was set by non-Python code, restore to default handler on watcher close.F)ra r? rP rQ r r rR rE r, r r r r- � s z!MultiLoopChildWatcher.attach_loopc C rW r rX r* r r r rO � s �z%MultiLoopChildWatcher._do_waitpid_allc C s� z t �|t j�\}}W n ty |}d}t�d|� d}Y n w |dkr'd S t|�}d}z | j�|�\}}}W n t yJ tjd|dd� Y d S w |� � rXt�d||� d S |re|� � ret� d ||� |j |||g|�R � d S ) NrG rY Fr Tr[ r� �%Loop %r that handles pid %r is closedrZ )r rI r\ rJ r r r r6 rH rO � is_closedr� r� rt ) r$ rM rv r rw Z debug_logr� rI rJ r r r rN s: �� �� �z!MultiLoopChildWatcher._do_waitpidc C sD z| � � W d S ttfy � ty! tjddd� Y d S w )NrR Tr� )rO rh ri rj r r )r$ r r r r r rQ % s �z MultiLoopChildWatcher._sig_chldN)r� r� r� r" rc r+ r. r3 rf r+ r- rO rN rQ r r r r r � s %r c @ sl e Zd Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Ze j fd d�Z dd� Z dd� Z dd� Zdd� ZdS )r c C s t �d�| _i | _d S r� )� itertoolsr� � _pid_counter�_threadsr� r r r r" ; r( z ThreadedChildWatcher.__init__c C r r r r� r r r rc ? r z ThreadedChildWatcher.is_activec C s | � � d S r )� _join_threadsr� r r r r+ B s zThreadedChildWatcher.closec C s0 dd� t | j�� �D �}|D ]}|�� qd S )Nc S s g | ] }|� � r|js|�qS r )�is_alive�daemon��.0�threadr r r � <listcomp>G s � �z6ThreadedChildWatcher._join_threads.<locals>.<listcomp>)r. ri rC r� )r$ �threadsro r r r rj E s �z"ThreadedChildWatcher._join_threadsc C r8 r r r� r r r r. L r z ThreadedChildWatcher.__enter__c C r9 r r rc r r r r3 O r z ThreadedChildWatcher.__exit__c C s: dd� t | j�� �D �}|r|| j� d�t| d� d S d S )Nc S s g | ]}|� � r|�qS r )rk rm r r r rp S s �z0ThreadedChildWatcher.__del__.<locals>.<listcomp>z0 has registered but not finished child processesr) )r. ri rC r' r2 )r$ r� rq r r r r� R s ��z ThreadedChildWatcher.__del__c G sF t �� }tj| jdt| j�� �||||fdd�}|| j|< |�� d S )Nzwaitpid-T)�target�namerJ rl ) r rd r] ZThreadrN �nextrh ri �start)r$ rv rI rJ r� ro r r r rf Z s � z&ThreadedChildWatcher.add_child_handlerc C r r r r* r r r r+ c s z)ThreadedChildWatcher.remove_child_handlerc C r9 r r r, r r r r- i r z ThreadedChildWatcher.attach_loopc C s� z t �|d�\}}W n ty |}d}t�d|� Y nw t|�}|�� r-t�d||� |�� r9t�d||� n |j |||g|�R � | j � |� d S )Nr rG rY rZ re ) r rI rJ r r r r� r� rf rt ri rH )r$ r� rM rI rJ rv r rw r r r rN l s& �� �z ThreadedChildWatcher._do_waitpidN)r� r� r� r" rc r+ rj r. r3 r0 r1 r� rf r+ r- rN r r r r r . s r c sF e Zd Z eZ� fdd�Zdd� Z� fdd�Zdd� Zd d � Z � Z S ) �_UnixDefaultEventLoopPolicyc s t � �� d | _d S r )r! r" �_watcherr� r& r r r" � s z$_UnixDefaultEventLoopPolicy.__init__c C s~ t j�2 | jd u r%t� | _t�� t�� u r-| j�| jj � W d � d S W d � d S W d � d S 1 s8w Y d S r ) r r^ rw r r] �current_thread� main_threadr- �_localr� r� r r r � _init_watcher� s ��"�z)_UnixDefaultEventLoopPolicy._init_watcherc s@ t � �|� | jd ur t�� t�� u r | j�|� d S d S d S r )r! �set_event_looprw r] rx ry r- r, r& r r r| � s �z*_UnixDefaultEventLoopPolicy.set_event_loopc C s | j d u r | �� | j S r )rw r{ r� r r r rb � s z-_UnixDefaultEventLoopPolicy.get_child_watcherc C s | j d ur | j �� || _ d S r )rw r+ )r$ rq r r r �set_child_watcher� s z-_UnixDefaultEventLoopPolicy.set_child_watcher) r� r� r� r Z _loop_factoryr" r{ r| rb r} r� r r r& r rv � s rv )2rG r� rg r r� r? r� r� r r, r] r0 � r r r r r r r r r r �logr �__all__r � ImportErrorr r ZBaseSelectorEventLoopr Z ReadTransportrX Z_FlowControlMixinZWriteTransportr` ZBaseSubprocessTransportre r r rK r r r r ZBaseDefaultEventLoopPolicyrv r r r r r r �<module> sd � NON5Ji}Y2
Save File
Cancel