U
    .e                     @   sd  d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZddl	m
Z
 ddl	mZ ddl	mZmZ ddlmZ ddlmZmZ d dlmZ dd	l
mZ zdd
lmZ W n$ ek
r   ejdkrЂ dZY n$X ejdkrejZejZejZejZddddgZeedZdZ dZ!e" Z#dZ$dgZ%eedrFdZ$e%dg7 Z%ejdkr`dZ$e%dg7 Z%e!fddZ&dd Z'dd Z(dd Z)dd Z*G d d! d!Z+G d"d# d#Z,erG d$d% d%e,Z-G d&d' d'e,Z.G d(d dZ/d\d)dZ0d*d+ Z1ejdkrd]d.dZ2n
d^d/dZ2G d0d1 d1Z3d2d3 Z4ejdkrTG d4d5 d5Z5ej6ej7ffd6d7Z8d8Z9d9Z:d:Z;d;Z<d<d= Z=d>d? Z>G d@dA dAZ?dBdC Z@dDdE ZAG dFdG dGe/ZBdHdI ZCejdkrdJdK ZDejEejFhZGd_dLdZHn(eedMrdNdO ZIndPdO ZId`dQdZHejdkrDdRdS ZJdTdU ZKe
Le.eJ dVdW ZMdXdY ZNe
Le-eM ndZdS ZJd[dU ZKe
Le.eJ dS )a    N   )	reduction)util)AuthenticationErrorBufferTooShort)	_billiard)setblockingsend_offset	monotonic)ForkingPickler)_winapiwin32ClientListenerPipewaitpypy_version_infoi    g      4@AF_INETAF_UNIXAF_PIPEc                 C   s
   t  |  S Nr
   )timeout r   7/tmp/pip-unpacked-wheel-39f38r4u/billiard/connection.py_init_timeoutE   s    r   c                 C   s
   t  | kS r   r
   )tr   r   r   _check_timeoutI   s    r   c                 C   sX   | dkrdS | dkr&t jdt dS | dkrLt jdt ttf ddS td	d
S )z?
    Return an arbitrary free address for the given family
    r   )	localhostr   r   z	listener-)prefixdirr   z\\.\pipe\pyc-%d-%d- zunrecognized familyN)	tempfilemktempr   Zget_temp_dirosgetpidnext_mmap_counter
ValueErrorfamilyr   r   r   arbitrary_addressQ   s    r+   c                 C   sJ   t jdkr| dkrtd|  t jdkrF| dkrFtt| sFtd|  dS )zD
    Checks if the family is valid for the current environment.
    r   r   zFamily %s is not recognized.r   N)sysplatformr(   hasattrsocketr)   r   r   r   _validate_family`   s
    
r0   c                 C   sJ   t | tkrdS t | tkr*| dr*dS t | tkr:dS td|  dS )z]
    Return the types of the address

    This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE'
    r   z\\r   r   zaddress type of %r unrecognizedN)typetuplestr
startswithr(   )addressr   r   r   address_typem   s    r6   c                   @   s   e Zd Zdd ZdS )_SocketContainerc                 C   s
   || _ d S r   sock)selfr9   r   r   r   __init__   s    z_SocketContainer.__init__N)__name__
__module____qualname__r;   r   r   r   r   r7      s   r7   c                   @   s   e Zd ZdZd/ddZdd Zdd Zd	d
 Zdd Zdd Z	e
dd Ze
dd Ze
dd Zdd Zdd Zd0ddZdd Zd1ddZd2d d!Zd"d# Zd3d%d&Zd'd( Zd)d* Zd+d, Zd-d. ZdS )4_ConnectionBaseNTc                 C   sZ   t |tr|j| _|j }| }|dk r4td|sD|sDtd|| _|| _|| _	d S )Nr   zinvalid handlez6at least one of `readable` and `writable` must be True)

isinstancer7   r9   _socketfileno	__index__r(   _handle	_readable	_writable)r:   handlereadablewritabler   r   r   r;      s    

z_ConnectionBase.__init__c                 C   s   | j d k	r|   d S r   rD   _closer:   r   r   r   __del__   s    
z_ConnectionBase.__del__c                 C   s   | j d krtdd S )Nzhandle is closed)rD   OSErrorrL   r   r   r   _check_closed   s    
z_ConnectionBase._check_closedc                 C   s   | j stdd S )Nzconnection is write-only)rE   rN   rL   r   r   r   _check_readable   s    z_ConnectionBase._check_readablec                 C   s   | j stdd S )Nzconnection is read-only)rF   rN   rL   r   r   r   _check_writable   s    z_ConnectionBase._check_writablec                 C   s"   | j rd| _n|   tdd S )NFzbad message length)rF   rE   closerN   rL   r   r   r   _bad_message_length   s    z#_ConnectionBase._bad_message_lengthc                 C   s
   | j dkS )z True if the connection is closedNrD   rL   r   r   r   closed   s    z_ConnectionBase.closedc                 C   s   | j S )z"True if the connection is readable)rE   rL   r   r   r   rH      s    z_ConnectionBase.readablec                 C   s   | j S )z"True if the connection is writable)rF   rL   r   r   r   rI      s    z_ConnectionBase.writablec                 C   s   |    | jS )z+File descriptor or handle of the connection)rO   rD   rL   r   r   r   rB      s    z_ConnectionBase.filenoc                 C   s$   | j dk	r z|   W 5 d| _ X dS )zClose the connectionNrJ   rL   r   r   r   rR      s    
z_ConnectionBase.closer   c                 C   s   |    |   t|}|jdkr.tt|}t|}|dk rFtd||k rVtd|dkrh|| }n&|dk rztdn|| |krtd| ||||   dS )z,Send the bytes data from a bytes-like objectr   r   zoffset is negativezbuffer length < offsetNzsize is negativezbuffer length < offset + size)rO   rQ   
memoryviewitemsizebyteslenr(   _send_bytes)r:   bufoffsetsizemnr   r   r   
send_bytes   s"    


z_ConnectionBase.send_bytesc                 C   s$   |    |   | t| dS )zSend a (picklable) objectN)rO   rQ   rZ   r   dumpsr:   objr   r   r   send   s    z_ConnectionBase.sendc                 C   sJ   |    |   |dk	r(|dk r(td| |}|dkrB|   | S )z7
        Receive bytes data as a bytes object.
        Nr   znegative maxlength)rO   rP   r(   _recv_bytesrS   getvalue)r:   Z	maxlengthr[   r   r   r   
recv_bytes   s    
z_ConnectionBase.recv_bytesc              
   C   s   |    |   t|}|j}|t| }|dk r>tdn||krNtd|  }| }||| k rvt|	 |
d |||| || |   |W  5 Q R  S Q R X dS )zq
        Receive bytes data into a writeable bytes-like object.
        Return the number of bytes read.
        r   znegative offsetzoffset too largeN)rO   rP   rV   rW   rY   r(   re   tellr   rf   seekreadinto)r:   r[   r\   r^   rW   Zbytesizeresultr]   r   r   r   recv_bytes_into   s&    


 
z_ConnectionBase.recv_bytes_intoc                 C   s"   |    |   |  }t|S )zReceive a (picklable) object)rO   rP   re   r   Zloadbuf)r:   r[   r   r   r   recv  s    z_ConnectionBase.recv        c                 C   s   |    |   | |S )z/Whether there is any input available to be read)rO   rP   _pollr:   r   r   r   r   poll  s    z_ConnectionBase.pollc                 C   s   | S r   r   rL   r   r   r   	__enter__  s    z_ConnectionBase.__enter__c                 C   s   |    d S r   rR   r:   exc_type	exc_valueexc_tbr   r   r   __exit__  s    z_ConnectionBase.__exit__c                 C   s   t |  ||S r   )r	   rB   )r:   r[   r\   r   r   r   r	   "  s    z_ConnectionBase.send_offsetc                 C   s   t |  | d S r   )r   rB   )r:   blockingr   r   r   r   %  s    z_ConnectionBase.setblocking)TT)r   N)N)r   )rn   )r<   r=   r>   rD   r;   rM   rO   rP   rQ   rS   propertyrU   rH   rI   rB   rR   r`   rd   rg   rl   rm   rq   rr   rx   r	   r   r   r   r   r   r?      s2   







r?   c                   @   sD   e Zd ZdZdZejfddZdd Zddd	Z	d
d Z
dd ZdS )PipeConnectionz
        Connection class based on a Windows named pipe.
        Overlapped I/O is used, so the handles must have been created
        with FILE_FLAG_OVERLAPPED.
        Fc                 C   s   || j  d S r   rT   )r:   Z_CloseHandler   r   r   rK   3  s    zPipeConnection._closec              	   C   s   t j| j|dd\}}zHz,|t jkrBt |jgdt}|tksBt	W n   |
   Y nX W 5 |d\}}X |dks|t	|t|kst	d S )NT
overlappedFr   )r   Z	WriteFilerD   GetOverlappedResultERROR_IO_PENDINGWaitForMultipleObjectseventINFINITEWAIT_OBJECT_0AssertionErrorcancelrY   )r:   r[   overrZnwrittenwaitresr   r   r   rZ   6  s    
  zPipeConnection._send_bytesNc           	      C   s2  | j rd| _ t S |d kr dnt|d}ztj| j|dd\}}d zHz,|tjkrpt|jgdt}|tksptW n   |   Y nX W 5 |d\}}|dkrt }||	  |  W S |tj
kr| ||  W S X  W n: tk
r$ } z|jtjkrtn W 5 d }~X Y nX tdd S )NF   Tr|   r   z.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminr   ReadFilerD   r~   write	getbufferZERROR_MORE_DATA_get_more_datar   r   r   r   r   r   r   rN   winerrorERROR_BROKEN_PIPEEOFErrorRuntimeError)	r:   maxsizeZbsizer   r   Znreadfr   er   r   r   re   F  sF      

  
zPipeConnection._recv_bytesc                 C   s.   | j st| jd dkrdS tt| g|S )Nr   T)r   r   PeekNamedPiperD   boolr   rp   r   r   r   ro   h  s
    zPipeConnection._pollc                 C   s   |  }t }|| t| jd }|dks6t|d k	rVt|| |krV| 	  tj
| j|dd\}}|d\}}|dkst||kst||   |S )Nr   r   Tr|   )r   r   r   r   r   r   rD   r   rY   rS   r   r~   )r:   r   r   r[   r   leftr   Zrbytesr   r   r   r   n  s    
zPipeConnection._get_more_data)N)r<   r=   r>   __doc__r   r   CloseHandlerK   rZ   re   ro   r   r   r   r   r   r{   +  s   
"r{   c                   @   s   e Zd ZdZer,ejfddZejZ	ej
ZnejfddZejZ	ejZe	fddZefddZefd	d
ZdddZdd ZdS )
Connectionzo
    Connection class based on an arbitrary file descriptor (Unix only), or
    a socket handle (Windows).
    c                 C   s   || j  d S r   rT   r:   rK   r   r   r   rK     s    zConnection._closec                 C   s   || j  d S r   rT   r   r   r   r   rK     s    c              
   C   s|   t |}z|| j|}W n> tttjfk
rV } zt|dd tjkrF W 5 d }~X Y qX ||8 }|dkrjqx||d  }qd S )Nerrnor   )	rY   rD   rN   IOErrorr/   errorgetattrr   EINTR)r:   r[   r   	remainingr_   excr   r   r   _send  s    zConnection._sendc           	   
   C   s   t  }| j}|}|dkrz|||}W n> tttjfk
rf } zt|dd tj	krV W 5 d }~X Y qX t
|}|dkr||krtntd|| ||8 }q|S )Nr   r   zgot end of file during message)r   r   rD   rN   r   r/   r   r   r   r   rY   r   r   )	r:   r]   readr[   rG   r   chunkr   r_   r   r   r   _recv  s"    

zConnection._recvc                 C   sV   t |}td|}|dkr2| | | | n t||rD| }| ||  d S )N!ii @  )rY   structpackr   r@   tobytes)r:   r[   rV   r_   headerr   r   r   rZ     s    

zConnection._send_bytesNc                 C   s:   |  d}td| \}|d k	r0||kr0d S |  |S )N   r   )r   r   unpackrf   )r:   r   r[   r]   r   r   r   re     s
    
zConnection._recv_bytesc                 C   s   t | g|}t|S r   )r   r   )r:   r   rr   r   r   ro     s    zConnection._poll)N)r<   r=   r>   r   r   r   ZclosesocketrK   rd   _writerm   _readr$   rR   r   r   r   r   rV   rZ   re   ro   r   r   r   r   r   ~  s   
r   c                   @   sR   e Zd ZdZdddZdd Zdd	 Zed
d Zedd Z	dd Z
dd ZdS )r   z
    Returns a listener object.

    This is a wrapper for a bound socket which is 'listening' for
    connections, or for a Windows named pipe.
    Nr   c                 C   sp   |p|rt |pt}|pt|}t| |dkr>t||| _nt|||| _|d k	rft|tsft	d|| _
d S )Nr   authkey should be a byte string)r6   default_familyr+   r0   PipeListener	_listenerSocketListenerr@   rX   	TypeError_authkey)r:   r5   r*   backlogauthkeyr   r   r   r;     s    
zListener.__init__c                 C   s>   | j dkrtd| j  }| jr:t|| j t|| j |S )zz
        Accept a connection on the bound socket or named pipe of `self`.

        Returns a `Connection` object.
        Nzlistener is closed)r   rN   acceptr   deliver_challengeanswer_challenge)r:   cr   r   r   r     s    

zListener.acceptc                 C   s    | j }|dk	rd| _ |  dS )zA
        Close the bound socket or named pipe of `self`.
        N)r   rR   )r:   Zlistenerr   r   r   rR     s    zListener.closec                 C   s   | j jS r   )r   _addressrL   r   r   r   <lambda>      zListener.<lambda>c                 C   s   | j jS r   )r   _last_acceptedrL   r   r   r   r     r   c                 C   s   | S r   r   rL   r   r   r   rr     s    zListener.__enter__c                 C   s   |    d S r   rs   rt   r   r   r   rx     s    zListener.__exit__)NNr   N)r<   r=   r>   r   r;   r   rR   rz   r5   Zlast_acceptedrr   rx   r   r   r   r   r     s   
	c                 C   sh   |p
t | }t| |dkr&t| }nt| }|dk	rHt|tsHtd|dk	rdt|| t|| |S )z=
    Returns a connection to the address of a `Listener`
    r   Nr   )	r6   r0   
PipeClientSocketClientr@   rX   r   r   r   )r5   r*   r   r   r   r   r   r     s    


c                 C   s   t | dr|  S t| S )Ndetach)r.   r   r7   r8   r   r   r   r   !  s    
r   TFc           	      C   s   | rBt  \}}||  ||  tt|}tt|}n@t \}}|r\t|d |rjt|d t|dd}t|dd}||fS )L
        Returns pair of connection objects at either end of a pipe
        r   FrI   rH   )r/   
socketpairr   r   r   r$   pipe)	duplex	rnonblock	wnonblocks1s2c1c2Zfd1fd2r   r   r   r   +  s    

c              
   C   s  |rt d|rt dtd}| rBtj}tjtjB }tt }}ntj}tj}dt }}t||tj	B tj
B tjtjB tjB d||tjtj}t||dtjtjtj	tj}	t|	tjdd tj|dd}
|
d\}}|dkst t|| d	}t|	| d
}||fS )r   z"rnonblock not supported on windowsz"wnonblock not supported on windowsr   r   r   NTr|   r   r   )r   r+   r   PIPE_ACCESS_DUPLEXGENERIC_READGENERIC_WRITEBUFSIZEZPIPE_ACCESS_INBOUNDCreateNamedPipeFILE_FLAG_OVERLAPPEDFILE_FLAG_FIRST_PIPE_INSTANCEPIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE	PIPE_WAITNMPWAIT_WAIT_FOREVERNULL
CreateFileOPEN_EXISTINGSetNamedPipeHandleStateConnectNamedPiper~   r{   )r   r   r   r5   ZopenmodeaccessZobsizeZibsizeh1h2r}   _r   r   r   r   r   r   r   B  sZ    
 
   	        c                   @   s*   e Zd ZdZd
ddZdd Zdd Zd	S )r   zO
    Representation of a socket which is bound to an address and listening
    r   c                 C   s   t  tt || _zRtjdkr2| jt jt jd | jd | j	| | j
| | j | _W n  tk
r   | j   Y nX || _d | _|dkrtj| tj|fdd| _nd | _d S )Nposixr   Tr   r   argsZexitpriority)r/   r   rA   r$   name
setsockopt
SOL_SOCKETSO_REUSEADDRr   bindlistengetsocknamer   rN   rR   Z_familyr   r   Finalizeunlink_unlink)r:   r5   r*   r   r   r   r   r;   u  s0    

 
   
zSocketListener.__init__c              
   C   sn   z| j  \}| _W qX tttjfk
rR } zt|dd tj	krB W 5 d }~X Y q X qXq |
d tt|S )Nr   T)rA   r   r   rN   r   r/   r   r   r   r   r   r   r   )r:   sr   r   r   r   r     s    
zSocketListener.acceptc                 C   s0   z| j  W 5 | j }|d k	r*d | _ |  X d S r   )r   rA   rR   )r:   r   r   r   r   rR     s    zSocketListener.closeN)r   )r<   r=   r>   r   r;   r   rR   r   r   r   r   r   q  s   
r   c                 C   s8   t | }ttt|}|d ||  tt|S )zO
    Return a connection object connected to the socket given by `address`
    T)r6   r/   r   r   connectr   r   )r5   r*   r   r   r   r   r     s
    

r   c                   @   s8   e Zd ZdZdddZdddZdd	 Zed
d ZdS )r   z0
        Representation of a named pipe
        Nc                 C   sL   || _ | jddg| _d | _td| j  tj| tj| j| j fdd| _	d S )NT)firstz listener created with address=%rr   r   )
r   _new_handle_handle_queuer   r   	sub_debugr   r   _finalize_pipe_listenerrR   )r:   r5   r   r   r   r   r;     s     
 zPipeListener.__init__Fc              
   C   sH   t jt jB }|r|t jO }t | j|t jt jB t jB t j	t
t
t jt jS r   )r   r   r   r   r   r   r   r   r   ZPIPE_UNLIMITED_INSTANCESr   r   r   )r:   r   flagsr   r   r   r     s    
 
   zPipeListener._new_handlec              
   C   s   | j |   | j d}ztj|dd}W n0 tk
r^ } z|jtjkrN W 5 d }~X Y n\X z<zt|jgdt W n    |  t|  Y nX W 5 |	d\}}|dkst
X t|S )Nr   Tr|   F)r   appendr   popr   r   rN   r   ZERROR_NO_DATAr~   r   r   r   r   r   r   r{   )r:   rG   r   r   r   r   r   r   r   r     s(      
zPipeListener.acceptc                 C   s$   t d| | D ]}t| qd S )Nz closing listener with address=%r)r   r   r   r   )queuer5   rG   r   r   r   r     s    z$PipeListener._finalize_pipe_listener)N)F)	r<   r=   r>   r   r;   r   r   staticmethodr   r   r   r   r   r     s   

r   c              
   C   s   t  }z6t| d t| tjtjB dtjtjtjtj}W qz t	k
rr } z|j
|ks`t|rb W 5 d}~X Y qX qzq t|tjdd t|S )zU
        Return a connection object connected to the pipe given by `address`
          r   N)r   r   ZWaitNamedPiper   r   r   r   r   r   rN   r   r   r   r   r{   )r5   _ignorer   hr   r   r   r   r     s0     
      r      s   #CHALLENGE#s	   #WELCOME#s	   #FAILURE#c                 C   st   dd l }t|tsttt}| t|  |	||d
 }| d}||kr^| t n| t tdd S )Nr   md5   zdigest received was wrong)hmacr@   rX   r   r$   urandomMESSAGE_LENGTHr`   	CHALLENGEnewdigestrg   WELCOMEFAILUREr   
connectionr   r	  messager  responser   r   r   r     s    


r   c                 C   s   dd l }t|tst| d}|d tt tks@td| |ttd  }|||d }| 	| | d}|t
krtdd S )Nr   r  zmessage = %rr  zdigest sent was rejected)r	  r@   rX   r   rg   rY   r  r  r  r`   r  r   r  r   r   r   r     s    
 

r   c                   @   s$   e Zd Zdd Zdd Zdd ZdS )ConnectionWrapperc                 C   s6   || _ || _|| _dD ]}t||}t| || qd S )N)rB   rR   rq   rg   r`   )_conn_dumps_loadsr   setattr)r:   connra   loadsattrrc   r   r   r   r;   2  s    
zConnectionWrapper.__init__c                 C   s   |  |}| j| d S r   )r  r  r`   )r:   rc   r   r   r   r   rd   :  s    
zConnectionWrapper.sendc                 C   s   | j  }| |S r   )r  rg   r  )r:   r   r   r   r   rm   >  s    
zConnectionWrapper.recvN)r<   r=   r>   r;   rd   rm   r   r   r   r   r  0  s   r  c                 C   s   t | fd d d d}|dS )Nr   utf-8)	xmlrpclibra   encode)rc   or   r   r   
_xml_dumpsC  s    r!  c                 C   s   t | d\\}}|S )Nr  )r  r  decode)r   rc   methodr   r   r   
_xml_loadsH  s    r$  c                   @   s   e Zd Zdd ZdS )XmlListenerc                 C   s"   dd l ma t| }t|ttS Nr   )xmlrpc.clientclientr  r   r   r  r!  r$  rb   r   r   r   r   O  s    
zXmlListener.acceptN)r<   r=   r>   r   r   r   r   r   r%  M  s   r%  c                  O   s   dd l ma tt| |ttS r&  )r'  r(  r  r  r   r!  r$  )r   kwdsr   r   r   	XmlClientV  s    r*  c                 C   s   t | }g }|rt|d|}|tkr*qn\t|  krFtt| k rTn n
|t8 }n2t|  krptt| k r~n n
|t8 }ntd|||  ||d d  }d}q|S )NFzShould not get herer   r   )	listr   r   WAIT_TIMEOUTr   rY   WAIT_ABANDONED_0r   r   )Zhandlesr   Lreadyresr   r   r   _exhaustive_waita  s     
 
r1  c           
         s  |dkrt }n|dk rd}nt|d d }t| } i g }t  t }z| D ]}zt|d}	W n  tk
r   || < Y qNX zt	|	 dd\}}W n2 tk
r } z|j}|tkr W 5 d}~X Y nX |t	jkr|| ||j< qN | d}qNt |}W 5 |D ]}|  q|D ]}z|d\}}W n6 tk
rt } z|j}|tkrd W 5 d}~X Y nX |t	j
kr(|j } | |dkr(t|dr(d|_q(X  fdd	|D   fd
d| D S )
        Wait till an object in object_list is ready/readable.

        Returns list of those objects in object_list which are ready/readable.
        Nr   r  g      ?Tr   rB   c                 3   s   | ]} | V  qd S r   r   ).0r  )waithandle_to_objr   r   	<genexpr>  s     zwait.<locals>.<genexpr>c                    s   g | ]}| kr|qS r   r   )r3  p)ready_objectsr   r   
<listcomp>  s      zwait.<locals>.<listcomp>)r   intr+  setr   r~   rN   r   _ready_errorsr   ZERROR_OPERATION_ABORTEDr   addr.   r   r   AttributeErrorrC   r   r   r   r1  keysupdate)
object_listr   Zov_listZready_handlesr   r   r   r   r   rB   r   )r7  r4  r   r   w  sZ    






rq   c                 C   s   |d k	rt |d }i }t }| D ]2}||tj t|drN||| < q$|||< q$g }||D ],\}}|tj@ rtd| |	||  qf|S )Nr  rB   zinvalid file descriptor %i)
r9  selectrq   registerPOLLINr.   rB   POLLNVALr(   r   )fdsr   Zfd_mapZpollsterfdZlsr   r   r   r   ro     s    


ro   c                 C   s   t  | g g |d S r&  )rA  )rE  r   r   r   r   ro     s    c              
   C   s   |dk	r$|dkrt | dS t | }zt | |W S  tttjfk
rh } z|jtjkrX W 5 d}~X Y nX |dk	r$|t  }q$dS )r2  Nr   )ro   r   rN   r   r/   r   r   r   )r@  r   deadliner   r   r   r   r     s    

c              
   C   sZ   |   }t|tjtj6}ddlm} ||}t|| j	| j
ffW  5 Q R  S Q R X d S )Nr   )resource_sharer)rB   r/   fromfdr   SOCK_STREAMr!   rH  Z	DupSocketrebuild_connectionrH   rI   )r  rG   r   rH  dsr   r   r   reduce_connection  s
    
rM  c                 C   s   |   }tt |||S r   )r   r   )rL  rH   rI   r9   r   r   r   rK    s    rK  c                 C   sB   | j rtjnd| jrtjndB }t|  |}t|| j | jffS r&  )	rH   r   ZFILE_GENERIC_READrI   ZFILE_GENERIC_WRITEr   Z	DupHandlerB   rebuild_pipe_connection)r  r   dhr   r   r   reduce_pipe_connection  s
    rP  c                 C   s   t t| ||S r   )r{   r   )rO  rH   rI   r   r   r   rN    s    rN  c                 C   s    t |  }t|| j| jffS r   )r   ZDupFdrB   rK  rH   rI   )r  dfr   r   r   rM    s    c                 C   s   t t| ||S r   )r   r   )rQ  rH   rI   r   r   r   rK    s    )NN)TFF)TFF)N)N)Or   r   r$   r,   r/   rA  r   r"   	itertoolsr!   r   r   r   r   Z_extr   compatr   r	   timer   r   r   ImportErrorr-   r   r-  r,  r   __all__r.   Zis_pypyr   ZCONNECTION_TIMEOUTcountr'   r   Zfamiliesr   r   r+   r0   r6   r7   r?   r{   r   r   r   r   r   r   r   r   ZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYr   r  r  r  r  r   r   r  r!  r$  r%  r*  r1  r   ZERROR_NETNAME_DELETEDr;  r   ro   rM  rK  rB  rP  rN  r   r   r   r   <module>
   s   





 #SV8

/28		G

