��]�� @s�ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl mZddl mZddl m Z ddl mZddl mZdd l mZdd l mZddl mZddl mZdd lmZddlmZdddddgZejdkr\ed��dd�Zy ejZWnek r�dd�ZYnXGdd�dej�Ze ed�r�dd�Z!nddl"Z"dd�Z!Gd d!�d!ej#�Z$Gd"d#�d#ej%ej&�Z'e ed$�r8ej(Z)nddl"Z"d%d&�Z)Gd'd(�d(ej*�Z+Gd)d�d�Z,Gd*d+�d+e,�Z-Gd,d�de-�Z.Gd-d�de-�Z/Gd.d/�d/ej0�Z1eZ2e1Z3dS)0�N�)�base_events)�base_subprocess)�compat)� constants)� coroutines)�events)�futures)�selector_events)� selectors)� transports)� coroutine)�logger�SelectorEventLoop�AbstractChildWatcher�SafeChildWatcher�FastChildWatcher�DefaultEventLoopPolicy�win32z+Signals are not really supported on WindowscCsdS)N�)�signum�framerr�0/opt/alt/python35/lib64/python3.5/unix_events.py�_sighandler_noop%srcCs|S)Nr)�pathrrr�.src seZdZd�fdd�Zdd�Z�fdd�Zdd �Zd d�Zdd �Zdd�Z dd�Z dddd�Zdddd�Ze ddd��Zdd�Ze dddddddd��Ze ddddd ddd!d"��Z�S)#�_UnixSelectorEventLoopNcst�j|�i|_dS)N)�super�__init__�_signal_handlers)�self�selector)� __class__rrr7sz_UnixSelectorEventLoop.__init__cCs tj�S)N)�socket� socketpair)r rrr�_socketpair;sz"_UnixSelectorEventLoop._socketpaircs8t�j�x$t|j�D]}|j|�qWdS)N)r�close�listr�remove_signal_handler)r �sig)r"rrr&>s z_UnixSelectorEventLoop.closecCs+x$|D]}|sq|j|�qWdS)N)�_handle_signal)r �datarrrr�_process_self_dataCs z)_UnixSelectorEventLoop._process_self_datac+Gs�tj|�stj|�r*td��|j|�|j�ytj|jj ��Wn=t tfk r�}ztt |��WYdd}~XnXtj|||�}||j|tjkns^tdj|tj��dS)Nzsig must be an int, not {!r}rzsig {} out of range(1, {}))� isinstance�intr.r<r1�NSIGr4)r r)rrrr/�s z$_UnixSelectorEventLoop._check_signalcCst|||||�S)N)�_UnixReadPipeTransport)r �pipe�protocol�waiter�extrarrr�_make_read_pipe_transport�sz0_UnixSelectorEventLoop._make_read_pipe_transportcCst|||||�S)N)�_UnixWritePipeTransport)r rLrMrNrOrrr�_make_write_pipe_transport�sz1_UnixSelectorEventLoop._make_write_pipe_transportc ks�tj��} |j�}t||||||||d|d|| �}| j|j�|j|�y |EdHWn+tk r�} z| }WYdd} ~ XnXd}|dk r�|j�|j �EdH|�WdQRX|S)NrNrO) r�get_child_watcherZ create_future�_UnixSubprocessTransport�add_child_handlerZget_pid�_child_watcher_callback� Exceptionr&�_wait)r rMr>�shell�stdin�stdout�stderr�bufsizerO�kwargs�watcherrN�transpr?�errrrr�_make_subprocess_transport�s$ z1_UnixSelectorEventLoop._make_subprocess_transportcCs|j|j|�dS)N)Zcall_soon_threadsafeZ_process_exited)r �pid� returncoder`rrrrV�sz._UnixSelectorEventLoop._child_watcher_callback�ssl�sock�server_hostnameccsB|r!|dkr9td��n|dk r9td��|dk r�|dk r]td��tjtjtjd�}y&|jd�|j||�EdHWq|j��YqXn\|dkr�td��|jtjks�tj |�rtdj |��|jd�|j||||�EdH\}}||fS)Nz/you have to pass server_hostname when using sslz+server_hostname is only meaningful with sslz3path and sock can not be specified at the same timerFzno path and sock were specifiedz2A UNIX Domain Stream Socket was expected, got {!r})r4r#�AF_UNIX�SOCK_STREAM�setblockingZsock_connectr&�familyr�_is_stream_socketr<Z_create_connection_transport)r �protocol_factoryrrerfrg� transportrMrrr�create_unix_connection�s8 z-_UnixSelectorEventLoop.create_unix_connection�backlog�dc !Cst|t�rtd��|dk r�|dk r?td��t|�}tjtjtj�}|dd kr�y,tj t j|�j�r�t j|�WnIt k r�Yn8tk r�}ztjd||�WYdd}~XnXy|j|�Wq�tk ri}zK|j�|jtjkrTdj|�}ttj|�d�n�WYdd}~Xq�|j��Yq�XnO|dkr�td��|jtjks�tj|�r�tdj|��tj||g�} |j|�|jd �|j|||| �| S)Nz*ssl argument must be an SSLContext or Nonez3path and sock can not be specified at the same timer�z2Unable to check or remove stale UNIX socket %r: %rzAddress {!r} is already in usez-path was not specified, and no sock specifiedz2A UNIX Domain Stream Socket was expected, got {!r}F)rrr)rH�boolr.r4�_fspathr#rhri�stat�S_ISSOCK�os�st_mode�remove�FileNotFoundErrorr5r�error�bindr&r:Z EADDRINUSEr<rkrrlZServer�listenrjZ_start_serving) r rmrrfrprerar?�msgZserverrrr�create_unix_server�sP & z)_UnixSelectorEventLoop.create_unix_server)�__name__� __module__�__qualname__rr%r&r,rAr*r(r/rPrRr rbrVrorrr)r"rr1s*- %r�set_blockingcCstj|d�dS)NF)rwr�)�fdrrr�_set_nonblocking9sr�cCs<tj|tj�}|tjB}tj|tj|�dS)N)�fcntlZF_GETFLrw� O_NONBLOCKZF_SETFL)r��flagsrrrr�>s cs�eZdZdZdd�fdd�Zdd�Zdd �Zd d�Zdd �Zdd�Z dd�Z dd�Zdd�Ze jr�dd�Zddd�Zdd�Zdd�Z�S) rK�iNcs*t�j|�||jd<||_||_|j�|_||_d|_t j |j�j}tj |�p�tj|�p�tj|�s�d|_d|_d|_td��t|j�|jj|jj|�|jj|jj|j|j�|dk r&|jjtj|d�dS)NrLFz)Pipe transport is for pipes/sockets only.)rr�_extra�_loop�_piper3�_fileno� _protocol�_closingrw�fstatrxru�S_ISFIFOrv�S_ISCHRr4r�� call_soon�connection_made�_add_reader�_read_readyr �_set_result_unless_cancelled)r �looprLrMrNrO�mode)r"rrrHs, z_UnixReadPipeTransport.__init__cCs|jjg}|jdkr.|jd�n|jrD|jd�|jd|j�t|jdd�}|jdk r�|dk r�tj ||jt j�}|r�|jd�q�|jd�n,|jdk r�|jd�n |jd�dd j|�S) N�closed�closingzfd=%s� _selector�polling�idle�openz<%s>� ) r"r�r��appendr�r��getattrr�r �_test_selector_eventr� EVENT_READ�join)r r9r!r�rrr�__repr__es$ z_UnixReadPipeTransport.__repr__cCs�ytj|j|j�}WnLttfk r6Yn�tk rj}z|j|d�WYdd}~Xn�X|r�|jj |�ng|j j�r�tj d|�d|_|j j|j�|j j|jj�|j j|jd�dS)Nz"Fatal read error on pipe transportz%r was closed by peerT)rw�readr��max_size�BlockingIOError�InterruptedErrorr5�_fatal_errorr�Z data_receivedr�� get_debugrr9r��_remove_readerr�Zeof_received�_call_connection_lost)r r+r?rrrr�{s# z"_UnixReadPipeTransport._read_readycCs|jj|j�dS)N)r�r�r�)r rrr� pause_reading�sz$_UnixReadPipeTransport.pause_readingcCs|jj|j|j�dS)N)r�r�r�r�)r rrr�resume_reading�sz%_UnixReadPipeTransport.resume_readingcCs ||_dS)N)r�)r rMrrr�set_protocol�sz#_UnixReadPipeTransport.set_protocolcCs|jS)N)r�)r rrr�get_protocol�sz#_UnixReadPipeTransport.get_protocolcCs|jS)N)r�)r rrr� is_closing�sz!_UnixReadPipeTransport.is_closingcCs|js|jd�dS)N)r��_close)r rrrr&�s z_UnixReadPipeTransport.closecCs4|jdk r0tjd|t�|jj�dS)Nzunclosed transport %r)r��warnings�warn�ResourceWarningr&)r rrr�__del__�sz_UnixReadPipeTransport.__del__zFatal error on pipe transportc Cs�t|t�rL|jtjkrL|jj�rwtjd||dd�n+|jjd|d|d|d|j i�|j |�dS)Nz%r: %s�exc_infoT�message� exceptionrnrM)rHr5r:ZEIOr�r�r�debug�call_exception_handlerr�r�)r r?r�rrrr��s! z#_UnixReadPipeTransport._fatal_errorcCs6d|_|jj|j�|jj|j|�dS)NT)r�r�r�r�r�r�)r r?rrrr��s z_UnixReadPipeTransport._closecCsDz|jj|�Wd|jj�d|_d|_d|_XdS)N)r��connection_lostr�r&r�)r r?rrrr��s z,_UnixReadPipeTransport._call_connection_losti)r�r�r�r�rr�r�r�r�r�r�r�r&r�PY34r�r�r�r�rr)r"rrKDs rKcs�eZdZdd�fdd�Zdd�Zdd�Zdd �Zd d�Zdd �Zdd�Z dd�Z dd�Zdd�Zdd�Z dd�Zejr�dd�Zdd�Zddd �Zdd!d"�Zd#d$�Z�S)%rQNc sjt�j||�||jd<||_|j�|_||_t�|_d|_ d|_ tj|j�j }tj|�}tj|�}tj|�} |p�|p�| s�d|_d|_d|_td��t|j�|jj|jj|�| s|rAtjjd�rA|jj|jj|j|j�|dk rf|jjtj|d�dS)NrLrFz?Pipe transport is only for pipes, sockets and character devices�aix)rrr�r�r3r�r�� bytearray�_buffer� _conn_lostr�rwr�rxrur�r�rvr4r�r�r�r��sys�platform� startswithr�r�r r�) r r�rLrMrNrOr�Zis_charZis_fifoZ is_socket)r"rrr�s2 z _UnixWritePipeTransport.__init__cCs#|jjg}|jdkr.|jd�n|jrD|jd�|jd|j�t|jdd�}|jdk r�|dk r�tj ||jt j�}|r�|jd�n |jd�|j�}|jd|�n,|jdk r|jd�n |jd�d d j |�S)Nr�r�zfd=%sr�r�r�z bufsize=%sr�z<%s>r�)r"r�r�r�r�r�r�r�r r�r�EVENT_WRITE�get_write_buffer_sizer�)r r9r!r�r]rrrr��s( z _UnixWritePipeTransport.__repr__cCs t|j�S)N)�lenr�)r rrrr�sz-_UnixWritePipeTransport.get_write_buffer_sizecCsI|jj�rtjd|�|jr;|jt��n |j�dS)Nz%r was closed by peer)r�r�rr9r�r��BrokenPipeError)r rrrr� s z#_UnixWritePipeTransport._read_readycCsat|t�rt|�}|s%dS|js7|jri|jtjkrVtjd�|jd7_dS|j sDyt j|j|�}Wnet tfk r�d}YnHtk r�}z(|jd7_|j|d�dSWYdd}~XnX|t|�kr dS|dkr+t|�|d�}|jj|j|j�|j |7_ |j�dS)Nz=pipe closed by peer or os.write(pipe, data) raised exception.rrz#Fatal write error on pipe transport)rHr�� memoryviewr�r�rZ!LOG_THRESHOLD_FOR_CONNLOST_WRITESr�warningr�rw�writer�r�r�rWr�r�r�Z_add_writer�_write_readyZ_maybe_pause_protocol)r r+�nr?rrrr�s2 z_UnixWritePipeTransport.writecCs&ytj|j|j�}Wn{ttfk r6Yn�tk r�}zD|jj�|jd7_|j j |j�|j|d�WYdd}~Xn�X|t|j�kr|jj�|j j |j�|j �|jr|j j|j�|jd�dS|dkr"|jd|�=dS)Nrz#Fatal write error on pipe transportr)rwr�r�r�r�r�rW�clearr�r��_remove_writerr�r�Z_maybe_resume_protocolr�r�r�)r r�r?rrrr�4s& # z$_UnixWritePipeTransport._write_readycCsdS)NTr)r rrr� can_write_eofNsz%_UnixWritePipeTransport.can_write_eofcCsL|jr dSd|_|jsH|jj|j�|jj|jd�dS)NT)r�r�r�r�r�r�r�)r rrr� write_eofQs z!_UnixWritePipeTransport.write_eofcCs ||_dS)N)r�)r rMrrrr�Zsz$_UnixWritePipeTransport.set_protocolcCs|jS)N)r�)r rrrr�]sz$_UnixWritePipeTransport.get_protocolcCs|jS)N)r�)r rrrr�`sz"_UnixWritePipeTransport.is_closingcCs'|jdk r#|jr#|j�dS)N)r�r�r�)r rrrr&csz_UnixWritePipeTransport.closecCs4|jdk r0tjd|t�|jj�dS)Nzunclosed transport %r)r�r�r�r�r&)r rrrr�lsz_UnixWritePipeTransport.__del__cCs|jd�dS)N)r�)r rrr�abortqsz_UnixWritePipeTransport.abortzFatal error on pipe transportc Csyt|tj�r=|jj�rhtjd||dd�n+|jjd|d|d|d|ji�|j |�dS)Nz%r: %sr�Tr�r�rnrM) rHrZ_FATAL_ERROR_IGNOREr�r�rr�r�r�r�)r r?r�rrrr�ts z$_UnixWritePipeTransport._fatal_errorcCs_d|_|jr%|jj|j�|jj�|jj|j�|jj|j|�dS)NT) r�r�r�r�r�r�r�r�r�)r r?rrrr��s z_UnixWritePipeTransport._closecCsDz|jj|�Wd|jj�d|_d|_d|_XdS)N)r�r�r�r&r�)r r?rrrr��s z-_UnixWritePipeTransport._call_connection_lost)r�r�r�rr�r�r�r�r�r�r�r�r�r�r&rr�r�r�r�r�r�rr)r"rrQ�s$% ! rQ�set_inheritablecCsittdd�}tj|tj�}|sJtj|tj||B�ntj|tj||@�dS)NZ FD_CLOEXECr)r�r�ZF_GETFDZF_SETFD)r��inheritableZcloexec_flag�oldrrr�_set_inheritable�s r�c@seZdZdd�ZdS)rTc Ks�d}|tjkr=|jj�\}}t|j�d�tj|d|d|d|d|ddd||�|_|dk r�|j�t |j �dd |�|j_dS) NFrYrZr[r\�universal_newlinesr]�wb� buffering)� subprocess�PIPEr�r%r�r3�Popen�_procr&r��detachrZ) r r>rYrZr[r\r]r^Zstdin_wrrr�_start�s z_UnixSubprocessTransport._startN)r�r�r�r�rrrrrT�srTc@sXeZdZdd�Zdd�Zdd�Zdd�Zd d �Zdd�Zd S)rcGs t��dS)N)�NotImplementedError)r rcr=r>rrrrU�s z&AbstractChildWatcher.add_child_handlercCs t��dS)N)r�)r rcrrr�remove_child_handler�sz)AbstractChildWatcher.remove_child_handlercCs t��dS)N)r�)r r�rrr�attach_loop�sz AbstractChildWatcher.attach_loopcCs t��dS)N)r�)r rrrr&�szAbstractChildWatcher.closecCs t��dS)N)r�)r rrr� __enter__�szAbstractChildWatcher.__enter__cCs t��dS)N)r�)r �a�b�crrr�__exit__�szAbstractChildWatcher.__exit__N) r�r�r�rUr�r�r&r�r�rrrrr�s c@sdeZdZdd�Zdd�Zdd�Zdd�Zd d �Zdd�Zd d�Z dS)�BaseChildWatchercCsd|_i|_dS)N)r�� _callbacks)r rrrrs zBaseChildWatcher.__init__cCs|jd�dS)N)r�)r rrrr& szBaseChildWatcher.closecCs t��dS)N)r�)r �expected_pidrrr�_do_waitpidszBaseChildWatcher._do_waitpidcCs t��dS)N)r�)r rrr�_do_waitpid_allsz BaseChildWatcher._do_waitpid_allcCs�|jdk r4|dkr4|jr4tjdt�|jdk rV|jjtj�||_|dk r�|jtj|j �|j �dS)NzCA loop is being detached from a child watcher with pending handlers)r�r�r�r��RuntimeWarningr(r1�SIGCHLDrA� _sig_chldr�)r r�rrrr�s$ zBaseChildWatcher.attach_loopcCsVy|j�WnAtk rQ}z!|jjddd|i�WYdd}~XnXdS)Nr�z$Unknown exception in SIGCHLD handlerr�)r�rWr�r�)r r?rrrr�&s zBaseChildWatcher._sig_chldcCsAtj|�rtj|�Stj|�r9tj|�S|SdS)N)rw�WIFSIGNALED�WTERMSIG� WIFEXITED�WEXITSTATUS)r �statusrrr�_compute_returncode2s z$BaseChildWatcher._compute_returncodeN) r�r�r�rr&r�r�r�r�r�rrrrr�sr�csjeZdZ�fdd�Zdd�Zdd�Zdd�Zd d �Zdd�Zd d�Z �S)rcs|jj�t�j�dS)N)r�r�rr&)r )r"rrr&Ks zSafeChildWatcher.closecCs|S)Nr)r rrrr�OszSafeChildWatcher.__enter__cCsdS)Nr)r r�r�r�rrrr�RszSafeChildWatcher.__exit__cGs?|jdkrtd��||f|j|<|j|�dS)NzICannot add child handler, the child watcher does not have a loop attached)r�r6r�r�)r rcr=r>rrrrUUs z"SafeChildWatcher.add_child_handlercCs/y|j|=dSWntk r*dSYnXdS)NTF)r�rC)r rcrrrr�`s z%SafeChildWatcher.remove_child_handlercCs+x$t|j�D]}|j|�qWdS)N)r'r�r�)r rcrrrr�gsz SafeChildWatcher._do_waitpid_allcCs�ytj|tj�\}}Wn.tk rO|}d}tjd|�YnBX|dkr`dS|j|�}|jj�r�tj d||�y|j j|�\}}Wn7tk r�|jj�r�tjd|dd�YnX||||�dS)N��z8Unknown child process pid %d, will report returncode 255rz$process %s exited with returncode %sz'Child watcher got an unexpected pid: %rr�T) rw�waitpid�WNOHANG�ChildProcessErrorrr�r�r�r�r�r��poprC)r r�rcr�rdr=r>rrrr�ls* zSafeChildWatcher._do_waitpid) r�r�r�r&r�r�rUr�r�r�rr)r"rr@scspeZdZ�fdd�Z�fdd�Zdd�Zdd�Zd d �Zdd�Zd d�Z �S)rcs2t�j�tj�|_i|_d|_dS)Nr)rr� threading�Lock�_lock�_zombies�_forks)r )r"rrr�s zFastChildWatcher.__init__cs+|jj�|jj�t�j�dS)N)r�r�rrr&)r )r"rrr&�s zFastChildWatcher.closec Cs(|j�|jd7_|SWdQRXdS)Nr)r�r)r rrrr��s zFastChildWatcher.__enter__c Csg|j�G|jd8_|js,|jr0dSt|j�}|jj�WdQRXtjd|�dS)Nrz5Caught subprocesses termination from unknown pids: %s)r�rrr7r�rr�)r r�r�r�Zcollateral_victimsrrrr��s zFastChildWatcher.__exit__cGs�|jdkrtd��|j�Gy|jj|�}Wn)tk rf||f|j|rdrrrrU�s z"FastChildWatcher.add_child_handlercCs/y|j|=dSWntk r*dSYnXdS)NTF)r�rC)r rcrrrr��s z%FastChildWatcher.remove_child_handlercCs9x2ytjdtj�\}}Wntk r:dSYn X|dkrKdS|j|�}|j��y|jj|�\}}WnStk r�|j r�||j |<|jj�r�t jd||�wd}Yn#X|jj�r�t jd||�WdQRX|dkr!t jd||�q||||�qWdS)Nrrz,unknown process %s exited with returncode %sz$process %s exited with returncode %sz8Caught subprocess termination from unknown pid: %d -> %dr-)rwr�r�r�r�r�r�r�rCrrr�r�rr�r�)r rcr�rdr=r>rrrr��s6 z FastChildWatcher._do_waitpid_all) r�r�r�rr&r�r�rUr�r�rr)r"rr�s cs^eZdZeZ�fdd�Zdd�Z�fdd�Zdd�Zd d �Z �S)�_UnixDefaultEventLoopPolicycst�j�d|_dS)N)rr�_watcher)r )r"rrrs z$_UnixDefaultEventLoopPolicy.__init__c Cs^tj�N|jdkrSt�|_ttj�tj�rS|jj|j j �WdQRXdS)N)rr�rrrHr��current_thread�_MainThreadr��_localr�)r rrr� _init_watchers z)_UnixDefaultEventLoopPolicy._init_watchercsKt�j|�|jdk rGttj�tj�rG|jj|�dS)N)r�set_event_looprrHr�rrr�)r r�)r"rrr sz*_UnixDefaultEventLoopPolicy.set_event_loopcCs |jdkr|j�|jS)N)rr)r rrrrSs z-_UnixDefaultEventLoopPolicy.get_child_watchercCs)|jdk r|jj�||_dS)N)rr&)r r_rrr�set_child_watcher%s z-_UnixDefaultEventLoopPolicy.set_child_watcher) r�r�r�rZ _loop_factoryrrrrSr rr)r"rr�s r)4r:rwr1r#rur�r�r�r��rrrrrrr r rrr �logr�__all__r��ImportErrorrZfspathrt�AttributeErrorZBaseSelectorEventLoopr�hasattrr�r�Z ReadTransportrKZ_FlowControlMixinZWriteTransportrQr�r�ZBaseSubprocessTransportrTrr�rrZBaseDefaultEventLoopPolicyrrrrrrr�sf �� F=On2