Warning: Cannot modify header information - headers already sent by (output started at /var/www/jonas-eriksen.dk/pic/private/index.php:1) in /var/www/jonas-eriksen.dk/pic/private/index.php on line 215
3 \�� @sddlZddlZddlZddlZddlZddlZddlZddlZddlZddl 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��rRdd�Z!nddl"Z"dd�Z!Gd d!�d!ej#�Z$Gd"d#�d#ej%ej&�Z'e ed$��r�ej(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�DefaultEventLoopPolicyZwin32z+Signals are not really supported on WindowscCsdS)N�)�signum�framerr�+/usr/lib64/python3.6/asyncio/unix_events.py�_sighandler_noop%srcCs|S)Nr)�pathrrr�.srcs�eZdZd!�fdd� Zdd�Z�fdd�Zdd �Zd d�Zdd �Zdd�Z dd�Z d"dd�Zd#dd�Ze d$dd��Zdd�Ze dddd�dd��Ze d%dddd�dd ��Z�ZS)&�_UnixSelectorEventLoopNcst�j|�i|_dS)N)�super�__init__�_signal_handlers)�self�selector)� __class__rrr7sz_UnixSelectorEventLoop.__init__cCstj�S)N)�socketZ socketpair)rrrr�_socketpair;sz"_UnixSelectorEventLoop._socketpaircs^t�j�tj�s2xFt|j�D]}|j|�qWn(|jrZtjd|�d�t |d�|jj �dS)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�sig)r!rrr%>s z_UnixSelectorEventLoop.closecCs"x|D]}|sq|j|�qWdS)N)�_handle_signal)r�datarrrr�_process_self_dataLs z)_UnixSelectorEventLoop._process_self_datac+GsHtj|�stj|�rtd��|j|�|j�ytj|jj ��Wn2t tfk rt}ztt |��WYdd}~XnXtj|||�}||j|<ytj|t�tj|d�Wn�tk �rB}zz|j|=|j�sytjd�Wn4t tfk �r}ztjd|�WYdd}~XnX|jtjk�r0tdj|��n�WYdd}~XnXdS)Nz3coroutines cannot be used with add_signal_handler()Frzset_wakeup_fd(-1) failed: %szsig {} cannot be caught��)rZiscoroutineZiscoroutinefunction� TypeError� _check_signalZ _check_closed�signal� set_wakeup_fdZ_csock�fileno� ValueError�OSError�RuntimeError�strrZHandlerr�siginterruptr�info�errno�EINVAL�format)rr.�callback�args�exc�handleZnexcrrr�add_signal_handlerSs0 z)_UnixSelectorEventLoop.add_signal_handlercCs8|jj|�}|dkrdS|jr*|j|�n |j|�dS)N)r�getZ _cancelledr)Z_add_callback_signalsafe)rr.rDrrrr/�sz%_UnixSelectorEventLoop._handle_signalc&Cs�|j|�y|j|=Wntk r*dSX|tjkr>tj}ntj}ytj||�Wn@tk r�}z$|jtj kr�t dj|��n�WYdd}~XnX|js�ytjd�Wn2t tfk r�}ztjd|�WYdd}~XnXdS)NFzsig {} cannot be caughtrzset_wakeup_fd(-1) failed: %sTr2)r4r�KeyErrorr5�SIGINT�default_int_handler�SIG_DFLr9r>r?r:r@r6r8rr=)rr.ZhandlerrCrrrr)�s( z,_UnixSelectorEventLoop.remove_signal_handlercCsHt|t�stdj|��d|ko,tjknsDtdj|tj��dS)Nzsig must be an int, not {!r}rzsig {} out of range(1, {}))� isinstance�intr3r@r5�NSIGr8)rr.rrrr4�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)rrOrPrQrRrrr�_make_write_pipe_transport�sz1_UnixSelectorEventLoop._make_write_pipe_transportc ks�tj��} |j�}t||||||||f||d�| ��}| j|j�|j|�y|EdHWn&tk r~} z | }WYdd} ~ XnXd}|dk r�|j�|j �EdH|�WdQRX|S)N)rQrR) r�get_child_watcherZ create_future�_UnixSubprocessTransport�add_child_handlerZget_pid�_child_watcher_callback� Exceptionr%Z_wait)rrPrB�shell�stdin�stdout�stderr�bufsizerR�kwargs�watcherrQ�transprC�errrrr�_make_subprocess_transport�s$ z1_UnixSelectorEventLoop._make_subprocess_transportcCs|j|j|�dS)N)Zcall_soon_threadsafeZ_process_exited)r�pid� returncoderbrrrrY�sz._UnixSelectorEventLoop._child_watcher_callback)�ssl�sock�server_hostnameccs�|r|dkr&td��n|dk r&td��|dk r�|dk r>td��tjtjtjd�}y |jd�|j||�EdHWq�|j��Yq�XnB|dkr�td��|jtjks�tj |j �r�tdj|��|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}) r8r"�AF_UNIX�SOCK_STREAM�setblockingZsock_connectr%�familyr�_is_stream_socket�typer@Z_create_connection_transport)r�protocol_factoryrrgrhri� transportrPrrr�create_unix_connection�s8 z-_UnixSelectorEventLoop.create_unix_connection�d)rh�backlogrgc !Cs�t|t�rtd��|dk �r0|dk r,td��t|�}tjtjtj�}|dd kr�y tj t j|�j�rnt j|�WnBt k r�Yn0tk r�}ztjd||�WYdd}~XnXy|j|�Wnjtk �r}z8|j�|jtjk�rdj|�}ttj|�d�n�WYdd}~Xn|j��YnXn>|dk�rBtd��|jtjk�s`tj|j��rntdj|��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)rru)rK�boolr3r8�_fspathr"rjrk�stat�S_ISSOCK�os�st_mode�remove�FileNotFoundErrorr9r�errorZbindr%r>Z EADDRINUSEr@rmrrnroZServerZlistenrlZ_start_serving) rrprrhrtrgrcrC�msgZserverrrr�create_unix_serversP z)_UnixSelectorEventLoop.create_unix_server)N)NN)NN)N)N)�__name__� __module__�__qualname__rr#r%r1rEr/r)r4rSrUr rdrYrrr�� __classcell__rr)r!rr1s*- %r�set_blockingcCstj|d�dS)NF)rzr�)�fdrrr�_set_nonblockingBsr�cCs,tj|tj�}|tjB}tj|tj|�dS)N)�fcntlZF_GETFLrz� O_NONBLOCKZF_SETFL)r��flagsrrrr�Gs cs�eZdZdZd �fdd� Zdd�Zdd �Zd d�Zdd �Zdd�Z dd�Z dd�Zdd�Ze jrhdd�Zd!dd�Zdd�Zdd�Z�ZS)"rN�iNcs�t�j|�||jd<||_||_|j�|_||_d|_t j |j�j}tj |�pbtj|�pbtj|�s~d|_d|_d|_td��t|j�|jj|jj|�|jj|jj|j|j�|dk r�|jjtj|d�dS)NrOFz)Pipe transport is for pipes/sockets only.)rr�_extra�_loop�_piper7�_fileno� _protocol�_closingrz�fstatr{rx�S_ISFIFOry�S_ISCHRr8r�� call_soon�connection_made�_add_reader�_read_readyr �_set_result_unless_cancelled)r�looprOrPrQrR�mode)r!rrrQs, z_UnixReadPipeTransport.__init__cCs�|jjg}|jdkr |jd�n|jr0|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_eventrZ EVENT_READ�join)rr=r r�rrr�__repr__ns$ z_UnixReadPipeTransport.__repr__cCs�ytj|j|j�}WnDttfk r,Yn�tk rX}z|j|d�WYdd}~Xn^X|rl|jj |�nJ|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)rz�readr��max_size�BlockingIOError�InterruptedErrorr9�_fatal_errorr�Z data_receivedr�� get_debugrr=r��_remove_readerr�Zeof_received�_call_connection_lost)rr0rCrrrr��s z"_UnixReadPipeTransport._read_readycCs|jj|j�dS)N)r�r�r�)rrrr� pause_reading�sz$_UnixReadPipeTransport.pause_readingcCs|jj|j|j�dS)N)r�r�r�r�)rrrr�resume_reading�sz%_UnixReadPipeTransport.resume_readingcCs ||_dS)N)r�)rrPrrr�set_protocol�sz#_UnixReadPipeTransport.set_protocolcCs|jS)N)r�)rrrr�get_protocol�sz#_UnixReadPipeTransport.get_protocolcCs|jS)N)r�)rrrr� is_closing�sz!_UnixReadPipeTransport.is_closingcCs|js|jd�dS)N)r��_close)rrrrr%�sz_UnixReadPipeTransport.closecCs,|jdk r(tjd|t|d�|jj�dS)Nzunclosed transport %r)r$)r�r*r+r,r%)rrrr�__del__�s z_UnixReadPipeTransport.__del__�Fatal error on pipe transportcCsZt|t�r4|jtjkr4|jj�rLtjd||dd�n|jj||||j d��|j |�dS)Nz%r: %sT)�exc_info)�message� exceptionrqrP)rKr9r>ZEIOr�r�r�debug�call_exception_handlerr�r�)rrCr�rrrr��s z#_UnixReadPipeTransport._fatal_errorcCs(d|_|jj|j�|jj|j|�dS)NT)r�r�r�r�r�r�)rrCrrrr��sz_UnixReadPipeTransport._closecCs4z|jj|�Wd|jj�d|_d|_d|_XdS)N)r��connection_lostr�r%r�)rrCrrrr��s z,_UnixReadPipeTransport._call_connection_losti)NN)r�)r�r�r�r�rr�r�r�r�r�r�r�r%r�PY34r�r�r�r�r�rr)r!rrNMs rNcs�eZdZd%�fdd� Zdd�Zdd�Zdd �Zd d�Zdd �Zdd�Z dd�Z dd�Zdd�Zdd�Z dd�Zejr|dd�Zdd�Zd&dd �Zd'd!d"�Zd#d$�Z�ZS)(rTNc s�t�j||�||jd<||_|j�|_||_t�|_d|_ d|_ tj|j�j }tj|�}tj|�}tj|�} |px|px| s�d|_d|_d|_td��t|j�|jj|jj|�| s�|r�tjjd�r�|jj|jj|j|j�|dk r�|jjtj|d�dS)NrOrFz?Pipe transport is only for pipes, sockets and character devices�aix)rrr�r�r7r�r�� bytearray�_buffer� _conn_lostr�rzr�r{rxr�r�ryr8r�r�r�r�r&�platform� startswithr�r�r r�) rr�rOrPrQrRr�Zis_charZis_fifoZ is_socket)r!rrr�s2 z _UnixWritePipeTransport.__init__cCs�|jjg}|jdkr |jd�n|jr0|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�rZEVENT_WRITE�get_write_buffer_sizer�)rr=r r�r_rrrr��s( z _UnixWritePipeTransport.__repr__cCs t|j�S)N)�lenr�)rrrrr�sz-_UnixWritePipeTransport.get_write_buffer_sizecCs6|jj�rtjd|�|jr*|jt��n|j�dS)Nz%r was closed by peer)r�r�rr=r�r��BrokenPipeError)rrrrr�s z#_UnixWritePipeTransport._read_readycCst|t�rt|�}|sdS|js&|jrN|jtjkrs& z$_UnixWritePipeTransport._write_readycCsdS)NTr)rrrr� can_write_eofXsz%_UnixWritePipeTransport.can_write_eofcCs8|jr dSd|_|js4|jj|j�|jj|jd�dS)NT)r�r�r�r�r�r�r�)rrrr� write_eof[sz!_UnixWritePipeTransport.write_eofcCs ||_dS)N)r�)rrPrrrr�dsz$_UnixWritePipeTransport.set_protocolcCs|jS)N)r�)rrrrr�gsz$_UnixWritePipeTransport.get_protocolcCs|jS)N)r�)rrrrr�jsz"_UnixWritePipeTransport.is_closingcCs|jdk r|jr|j�dS)N)r�r�r�)rrrrr%msz_UnixWritePipeTransport.closecCs,|jdk r(tjd|t|d�|jj�dS)Nzunclosed transport %r)r$)r�r*r+r,r%)rrrrr�vs z_UnixWritePipeTransport.__del__cCs|jd�dS)N)r�)rrrr�abort|sz_UnixWritePipeTransport.abort�Fatal error on pipe transportcCsPt|tj�r*|jj�rBtjd||dd�n|jj||||jd��|j |�dS)Nz%r: %sT)r�)r�r�rqrP) rKrZ_FATAL_ERROR_IGNOREr�r�rr�r�r�r�)rrCr�rrrr�s z$_UnixWritePipeTransport._fatal_errorcCsFd|_|jr|jj|j�|jj�|jj|j�|jj|j|�dS)NT) r�r�r�r�r�r-r�r�r�)rrCrrrr��s z_UnixWritePipeTransport._closecCs4z|jj|�Wd|jj�d|_d|_d|_XdS)N)r�r�r�r%r�)rrCrrrr��s z-_UnixWritePipeTransport._call_connection_lost)NN)r�)N)r�r�r�rr�r�r�r�r�r�r�r�r�r�r%rr�r�r�r�r�r�r�rr)r!rrT�s$% ! rT�set_inheritablecCsNttdd�}tj|tj�}|s4tj|tj||B�ntj|tj||@�dS)NZ FD_CLOEXECr)r�r�ZF_GETFDZF_SETFD)r�ZinheritableZcloexec_flag�oldrrr�_set_inheritable�s r�c@seZdZdd�ZdS)rWc Ksvd}|tjkr*|jj�\}}t|j�d�tj|f||||d|d�|��|_|dk rr|j�t |j �d|d�|j_dS)NF)r[r\r]r^Zuniversal_newlinesr_�wb)� buffering)� subprocess�PIPEr�r#r�r7�Popen�_procr%r��detachr\) rrBr[r\r]r^r_r`Zstdin_wrrr�_start�s z_UnixSubprocessTransport._startN)r�r�r�r�rrrrrW�srWc@s<eZdZdd�Zdd�Zdd�Zdd�Zd d �Zdd�Zd S)rcGs t��dS)N)�NotImplementedError)rrerArBrrrrX�s z&AbstractChildWatcher.add_child_handlercCs t��dS)N)r�)rrerrr�remove_child_handler�sz)AbstractChildWatcher.remove_child_handlercCs t��dS)N)r�)rr�rrr�attach_loop�sz AbstractChildWatcher.attach_loopcCs t��dS)N)r�)rrrrr%�szAbstractChildWatcher.closecCs t��dS)N)r�)rrrr� __enter__szAbstractChildWatcher.__enter__cCs t��dS)N)r�)r�a�b�crrr�__exit__ szAbstractChildWatcher.__exit__N) r�r�r�rXr�r�r%r�r�rrrrr�s c@sDeZdZdd�Zdd�Zdd�Zdd�Zd d �Zdd�Zd d�Z dS)�BaseChildWatchercCsd|_i|_dS)N)r�� _callbacks)rrrrrszBaseChildWatcher.__init__cCs|jd�dS)N)r�)rrrrr%szBaseChildWatcher.closecCs t��dS)N)r�)r�expected_pidrrr�_do_waitpidszBaseChildWatcher._do_waitpidcCs t��dS)N)r�)rrrr�_do_waitpid_allsz BaseChildWatcher._do_waitpid_allcCsf|jdk r$|dkr$|jr$tjdt�|jdk r<|jjtj�||_|dk rb|jtj|j �|j �dS)NzCA loop is being detached from a child watcher with pending handlers)r�r�r*r+�RuntimeWarningr)r5�SIGCHLDrE� _sig_chldr�)rr�rrrr�s zBaseChildWatcher.attach_loopcCsFy|j�Wn4tk r@}z|jjd|d��WYdd}~XnXdS)Nz$Unknown exception in SIGCHLD handler)r�r�)r�rZr�r�)rrCrrrr�1szBaseChildWatcher._sig_chldcCs2tj|�rtj|�Stj|�r*tj|�S|SdS)N)rz�WIFSIGNALED�WTERMSIG� WIFEXITED�WEXITSTATUS)r�statusrrr�_compute_returncode=s z$BaseChildWatcher._compute_returncodeN) r�r�r�rr%r�r�r�r�r�rrrrr�sr�csLeZdZ�fdd�Zdd�Zdd�Zdd�Zd d �Zdd�Zd d�Z �Z S)rcs|jj�t�j�dS)N)r�r-rr%)r)r!rrr%Vs zSafeChildWatcher.closecCs|S)Nr)rrrrr�ZszSafeChildWatcher.__enter__cCsdS)Nr)rr�r�r�rrrr�]szSafeChildWatcher.__exit__cGs.|jdkrtd��||f|j|<|j|�dS)NzICannot add child handler, the child watcher does not have a loop attached)r�r:r�r�)rrerArBrrrrX`s z"SafeChildWatcher.add_child_handlercCs&y|j|=dStk r dSXdS)NTF)r�rG)rrerrrr�ks z%SafeChildWatcher.remove_child_handlercCs"xt|j�D]}|j|�qWdS)N)r(r�r�)rrerrrr�rsz SafeChildWatcher._do_waitpid_allcCs�ytj|tj�\}}Wn(tk r>|}d}tjd|�Yn0X|dkrLdS|j|�}|jj�rntj d||�y|j j|�\}}Wn.tk r�|jj�r�tjd|dd�YnX|||f|��dS)N��z8Unknown child process pid %d, will report returncode 255rz$process %s exited with returncode %sz'Child watcher got an unexpected pid: %rT)r�) rz�waitpid�WNOHANG�ChildProcessErrorrr�r�r�r�r�r��poprG)rr�rer�rfrArBrrrr�ws* zSafeChildWatcher._do_waitpid)r�r�r�r%r�r�rXr�r�r�r�rr)r!rrKscsPeZdZ�fdd�Z�fdd�Zdd�Zdd�Zd d �Zdd�Zd d�Z �Z S)rcs$t�j�tj�|_i|_d|_dS)Nr)rr� threadingZLock�_lock�_zombies�_forks)r)r!rrr�s zFastChildWatcher.__init__cs"|jj�|jj�t�j�dS)N)r�r-r�rr%)r)r!rrr%�s zFastChildWatcher.closec Cs$|j�|jd7_|SQRXdS)Nr)r�r�)rrrrr��szFastChildWatcher.__enter__c CsV|j�:|jd8_|js$|jr(dSt|j�}|jj�WdQRXtjd|�dS)Nrz5Caught subprocesses termination from unknown pids: %s)r�r�r�r;r-rr�)rr�r�r�Zcollateral_victimsrrrr��s zFastChildWatcher.__exit__cGsl|jdkrtd��|j�:y|jj|�}Wn"tk rL||f|j|<dSXWdQRX|||f|��dS)NzICannot add child handler, the child watcher does not have a loop attached)r�r:r�r�r�rGr�)rrerArBrfrrrrX�s z"FastChildWatcher.add_child_handlercCs&y|j|=dStk r dSXdS)NTF)r�rG)rrerrrr��s z%FastChildWatcher.remove_child_handlercCs�x�ytjdtj�\}}Wntk r,dSX|dkr:dS|j|�}|j�vy|jj|�\}}WnBtk r�|j r�||j |<|jj�r�t jd||�wd}YnX|jj�r�t jd||�WdQRX|dkr�t jd||�q|||f|��qWdS)Nrrz,unknown process %s exited with returncode %sz$process %s exited with returncode %sz8Caught subprocess termination from unknown pid: %d -> %dr2)rzr�r�r�r�r�r�r�rGr�r�r�r�rr�r�)rrer�rfrArBrrrr��s6 z FastChildWatcher._do_waitpid_all)r�r�r�rr%r�r�rXr�r�r�rr)r!rr�s csDeZdZeZ�fdd�Zdd�Z�fdd�Zdd�Zd d �Z �Z S)�_UnixDefaultEventLoopPolicycst�j�d|_dS)N)rr�_watcher)r)r!rrrs z$_UnixDefaultEventLoopPolicy.__init__c CsHtj�8|jdkr:t�|_ttj�tj�r:|jj|j j �WdQRXdS)N)rr�r�rrKr��current_thread�_MainThreadr��_localr�)rrrr� _init_watchers z)_UnixDefaultEventLoopPolicy._init_watchercs6t�j|�|jdk r2ttj�tj�r2|jj|�dS)N)r�set_event_loopr�rKr�r�r�r�)rr�)r!rrrs z*_UnixDefaultEventLoopPolicy.set_event_loopcCs|jdkr|j�|jS)N)r�r)rrrrrV&s z-_UnixDefaultEventLoopPolicy.get_child_watchercCs|jdk r|jj�||_dS)N)r�r%)rrarrr�set_child_watcher0s z-_UnixDefaultEventLoopPolicy.set_child_watcher)r�r�r�rZ _loop_factoryrrrrVrr�rr)r!rr�s r�)4r>rzr5r"rxr�r&r�r*�rrrrrrr r rrr �logr�__all__r��ImportErrorr�fspathrw�AttributeErrorZBaseSelectorEventLoopr�hasattrr�r�Z ReadTransportrNZ_FlowControlMixinZWriteTransportrTr�r�ZBaseSubprocessTransportrWrr�rrZBaseDefaultEventLoopPolicyr�rrrrrr�sl O F=On2