a
    )Bip|                     @   s  g d 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	Z	ddl
mZ ddl
mZmZ ddlmZ ejZz$ddlZddlmZmZmZmZ W n" ey   ejdkr dZY n0 d	Zd
ZdZe ZdZdgZe edrd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&erfG dd de&Z'G dd de&Z(G dd  d e)Z*dQd!d"Z+ejdkrdRd$d%Z,n
dSd&d%Z,G d'd( d(e)Z-d)d* Z.ejdkrG d+d, d,e)Z/d-d. Z0d/Z1d0Z2d1Z3d2Z4d3d4 Z5d5d6 Z6G d7d8 d8e)Z7d9d: Z8d;d< Z9G d=d> d>e*Z:d?d@ Z;ejdkrrdAdB Z<ej=ej>hZ?dTdCdDZ@n,ddlAZAe eAdEreAjBZCneAjDZCdUdFdDZ@ejdkrdGdH ZEdIdJ ZFeGe(eE dKdL ZHdMdN ZIeGe'eH ndOdH ZEdPdJ ZFeGe(eE dS )V)ClientListenerPipewait    N   )util)AuthenticationErrorBufferTooShort)	reduction)WAIT_OBJECT_0WAIT_ABANDONED_0WAIT_TIMEOUTINFINITEwin32i    g      4@sha256AF_INETAF_UNIXAF_PIPEc                 C   s   t  |  S Ntime	monotonic)timeout r   2/usr/lib64/python3.9/multiprocessing/connection.py_init_timeout?   s    r   c                 C   s   t  | kS r   r   )tr   r   r   _check_timeoutB   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   get_temp_dirosgetpidnext_mmap_counter
ValueErrorfamilyr   r   r   arbitrary_addressI   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_familyW   s
    
r1   c                 C   sT   t | tkrdS t | tu r*| dr*dS t | tu s@t| rDd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   is_abstract_socket_namespacer)   )addressr   r   r   address_typec   s    r8   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d,ddZdd Zd-ddZd.d d!Zd"d# Zd/d%d&Zd'd( Zd)d* ZdS )0_ConnectionBaseNTc                 C   s>   |  }|dk rtd|s(|s(td|| _|| _|| _d S )Nr   zinvalid handlez6at least one of `readable` and `writable` must be True)	__index__r)   _handle	_readable	_writable)selfhandlereadablewritabler   r   r   __init__y   s    z_ConnectionBase.__init__c                 C   s   | j d ur|   d S r   r;   _closer>   r   r   r   __del__   s    
z_ConnectionBase.__del__c                 C   s   | j d u rtdd S )Nzhandle is closed)r;   OSErrorrE   r   r   r   _check_closed   s    
z_ConnectionBase._check_closedc                 C   s   | j stdd S )Nzconnection is write-only)r<   rG   rE   r   r   r   _check_readable   s    z_ConnectionBase._check_readablec                 C   s   | j stdd S )Nzconnection is read-only)r=   rG   rE   r   r   r   _check_writable   s    z_ConnectionBase._check_writablec                 C   s"   | j rd| _n|   tdd S )NFzbad message length)r=   r<   closerG   rE   r   r   r   _bad_message_length   s    z#_ConnectionBase._bad_message_lengthc                 C   s
   | j du S )z True if the connection is closedNr;   rE   r   r   r   closed   s    z_ConnectionBase.closedc                 C   s   | j S )z"True if the connection is readable)r<   rE   r   r   r   r@      s    z_ConnectionBase.readablec                 C   s   | j S )z"True if the connection is writable)r=   rE   r   r   r   rA      s    z_ConnectionBase.writablec                 C   s   |    | jS )z+File descriptor or handle of the connection)rH   r;   rE   r   r   r   fileno   s    z_ConnectionBase.filenoc                 C   s*   | j dur&z|   W d| _ nd| _ 0 dS )zClose the connectionNrC   rE   r   r   r   rK      s    

z_ConnectionBase.closer   c                 C   s   |    |   t|}|jdkr.tt|}t|}|dk rFtd||k rVtd|du 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)rH   rJ   
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)rH   rJ   rT   _ForkingPicklerdumpsr>   objr   r   r   send   s    z_ConnectionBase.sendc                 C   sJ   |    |   |dur(|dk r(td| |}|du rB|   | S )z7
        Receive bytes data as a bytes object.
        Nr   znegative maxlength)rH   rI   r)   _recv_bytesrL   getvalue)r>   	maxlengthrU   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  d   S 1 s0    Y  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)rH   rI   rP   rQ   rS   r)   r`   tellr	   ra   seekreadinto)r>   rU   rV   rX   rQ   bytesizeresultrW   r   r   r   recv_bytes_into   s$    



z_ConnectionBase.recv_bytes_intoc                 C   s&   |    |   |  }t| S )zReceive a (picklable) object)rH   rI   r`   r[   loads	getbuffer)r>   rU   r   r   r   recv   s    z_ConnectionBase.recv        c                 C   s   |    |   | |S )z/Whether there is any input available to be read)rH   rI   _pollr>   r   r   r   r   poll  s    z_ConnectionBase.pollc                 C   s   | S r   r   rE   r   r   r   	__enter__  s    z_ConnectionBase.__enter__c                 C   s   |    d S r   rK   r>   exc_type	exc_valueexc_tbr   r   r   __exit__
  s    z_ConnectionBase.__exit__)TT)r   N)N)r   )rm   )__name__
__module____qualname__r;   rB   rF   rH   rI   rJ   rL   propertyrN   r@   rA   rO   rK   rZ   r_   rc   ri   rl   rp   rq   rw   r   r   r   r   r9   v   s.   







r9   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   rM   )r>   Z_CloseHandler   r   r   rD     s    zPipeConnection._closec              	   C   s   t j| j|dd\}}zVz,|t jkrBt |jgdt}|tksBJ W n   |   Y n0 W |	d\}}n|	d\}}0 |dksJ |t
|ksJ d S )NT
overlappedFr   )_winapiZ	WriteFiler;   ERROR_IO_PENDINGWaitForMultipleObjectseventr   r   cancelGetOverlappedResultrS   )r>   rU   overrwaitresZnwrittenr   r   r   rT     s    


 zPipeConnection._send_bytesNc           	   
   C   s  | j rd| _ t S |d u r dnt|d}ztj| j|dd\}}zz,|tjkrpt|j	gdt
}|tkspJ W n   |   Y n0 W |d\}}|dkrt }||  |W S |tjkr| ||W S nh|d\}}|dkrt }||  |     Y W S |tjkr>| ||     Y W S 0 W n< ty~ } z"|jtjkrhtn W Y d }~n
d }~0 0 tdd S )NF   Tr}   r   z.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminr   ReadFiler;   r   r   r   r   r   r   r   writerk   ZERROR_MORE_DATA_get_more_datarG   winerrorERROR_BROKEN_PIPEEOFErrorRuntimeError)	r>   maxsizeZbsizer   r   r   Znreadfer   r   r   r`   *  sH    






 zPipeConnection._recv_bytesc                 C   s.   | j st| jd dkrdS tt| g|S )Nr   T)r   r   PeekNamedPiper;   boolr   ro   r   r   r   rn   J  s
    zPipeConnection._pollc                 C   s   |  }t }|| t| jd }|dks6J |d urVt|| |krV|   tj	| j|dd\}}|
d\}}|dksJ ||ksJ ||   |S )Nr   r   Tr}   )rk   r   r   r   r   r   r;   rS   rL   r   r   )r>   r   r   rU   r   leftr   Zrbytesr   r   r   r   P  s    
zPipeConnection._get_more_data)N)rx   ry   rz   __doc__r   r   CloseHandlerD   rT   r`   rn   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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   rM   r>   rD   r   r   r   rD   g  s    zConnection._closec                 C   s   || j  d S r   rM   r   r   r   r   rD   l  s    c                 C   s8   t |}|| j|}||8 }|dkr&q4||d  }qd S Nr   )rS   r;   )r>   rU   r   	remainingrY   r   r   r   _sendq  s    zConnection._sendc                 C   sb   t  }| j}|}|dkr^|||}t|}|dkrJ||krBtntd|| ||8 }q|S )Nr   zgot end of file during message)r   r   r;   rS   r   rG   r   )r>   rW   readrU   r?   r   chunkrY   r   r   r   _recvz  s    


zConnection._recvc                 C   s   t |}|dkrHtdd}td|}| | | | | | n8td|}|dkrr| | | | n| ||  d S )Ni!i!Qi @  )rS   structpackr   )r>   rU   rY   
pre_headerheaderr   r   r   rT     s    


zConnection._send_bytesNc                 C   s^   |  d}td| \}|dkr@|  d}td| \}|d urT||krTd S |  |S )N   r   r      r   )r   r   unpackra   )r>   r   rU   rW   r   r   r   r`     s    

zConnection._recv_bytesc                 C   s   t | g|}t|S r   )r   r   )r>   r   rr   r   r   rn     s    zConnection._poll)N)rx   ry   rz   r   r   _multiprocessingZclosesocketrD   r_   _writerl   _readr%   rK   r   r   r   r   rT   r`   rn   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 urft|tsft	d|| _
d S )Nr   authkey should be a byte string)r8   default_familyr,   r1   PipeListener	_listenerSocketListener
isinstancerR   	TypeError_authkey)r>   r7   r+   backlogauthkeyr   r   r   rB     s    zListener.__init__c                 C   s>   | j du 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   rG   acceptr   deliver_challengeanswer_challenge)r>   cr   r   r   r     s    

zListener.acceptc                 C   s    | j }|durd| _ |  dS )zA
        Close the bound socket or named pipe of `self`.
        N)r   rK   )r>   listenerr   r   r   rK     s    zListener.closec                 C   s   | j jS r   )r   _addressrE   r   r   r   r7     s    zListener.addressc                 C   s   | j jS r   )r   _last_acceptedrE   r   r   r   last_accepted  s    zListener.last_acceptedc                 C   s   | S r   r   rE   r   r   r   rq     s    zListener.__enter__c                 C   s   |    d S r   rr   rs   r   r   r   rw     s    zListener.__exit__)NNr   N)rx   ry   rz   r   rB   r   rK   r{   r7   r   rq   rw   r   r   r   r   r     s   
	

r   c                 C   sh   |p
t | }t| |dkr&t| }nt| }|durHt|tsHtd|durdt|| t|| |S )z=
    Returns a connection to the address of a `Listener`
    r   Nr   )	r8   r1   
PipeClientSocketClientr   rR   r   r   r   )r7   r+   r   r   r   r   r   r     s    


r   Tc                 C   sj   | r>t  \}}|d |d t| }t| }n$t \}}t|dd}t|dd}||fS )L
        Returns pair of connection objects at either end of a pipe
        TFrA   r@   )r0   
socketpairsetblockingr   detachr%   pipe)duplexs1s2c1c2fd1fd2r   r   r   r     s    

r   c              
   C   s   t d}| r*t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sJ t|| d}t|| d}||fS )	r   r   r   r   NTr}   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   r7   ZopenmodeaccessZobsizeZibsizeZh1Zh2r~   _r   r   r   r   r   r   r     s>    



	
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y   | j   Y n0 || _d | _|dkrt|stj| tj|fdd| _nd | _d S )Nposixr   Tr   r   argsexitpriority)r0   getattr_socketr%   name
setsockopt
SOL_SOCKETSO_REUSEADDRr   bindlistengetsocknamer   rG   rK   _familyr   r   r6   Finalizeunlink_unlink)r>   r7   r+   r   r   r   r   rB   K  s(    



zSocketListener.__init__c                 C   s&   | j  \}| _|d t| S )NT)r   r   r   r   r   r   r>   sr   r   r   r   d  s    
zSocketListener.acceptc                 C   sJ   z(| j   W | j}|d urFd | _|  n| j}|d urDd | _|  0 d S r   )r   rK   r   )r>   r   r   r   r   rK   i  s    zSocketListener.closeN)r   )rx   ry   rz   r   rB   r   rK   r   r   r   r   r   G  s   
r   c                 C   s\   t | }ttt|0}|d ||  t| W  d   S 1 sN0    Y  dS )zO
    Return a connection object connected to the socket given by `address`
    TN)r8   r0   r   r   connectr   r   )r7   r+   r   r   r   r   r   s  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_listenerrK   )r>   r7   r   r   r   r   rB     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 n2 ty` } z|jtjkrL W Y d }~n~d }~0 0 zVzt	|j
gdt}W n    |  t|  Y n0 W |d\}}|dksJ n|d\}}|dksJ 0 t|S )Nr   Tr}   F)r   appendr   popr   r   rG   r   ZERROR_NO_DATAr   r   r   r   r   r   r|   )r>   r?   r   r   resr   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   )queuer7   r?   r   r   r   r     s    z$PipeListener._finalize_pipe_listener)N)F)	rx   ry   rz   r   rB   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 q t	y| } z(|j
tjtjfvsft|rh W Y d}~qd}~0 0 qq 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   rG   r   ZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYr   r   r   r|   )r7   r   hr   r   r   r   r     s*    

r      s   #CHALLENGE#s	   #WELCOME#s	   #FAILURE#c                 C   s   dd l }t|ts$tdt|tt}| 	t
|  |||t }| d}||krl| 	t n| 	t tdd S )Nr    Authkey must be bytes, not {0!s}   zdigest received was wrong)hmacr   rR   r)   formatr2   r%   urandomMESSAGE_LENGTHrZ   	CHALLENGEnewHMAC_DIGEST_NAMEdigestrc   WELCOMEFAILUREr   
connectionr   r
  messager  responser   r   r   r     s    



r   c                 C   s   dd l }t|ts$tdt|| d}|d tt tksNJ d| |ttd  }|	||t
 }| | | d}|tkrtdd S )Nr   r  r	  zmessage = %rzdigest sent was rejected)r
  r   rR   r)   r  r2   rc   rS   r  r  r  r  rZ   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)rO   rK   rp   rc   rZ   )_conn_dumps_loadsr   setattr)r>   connr\   rj   attrr^   r   r   r   rB     s    
zConnectionWrapper.__init__c                 C   s   |  |}| j| d S r   )r  r  rZ   )r>   r^   r   r   r   r   r_   	  s    
zConnectionWrapper.sendc                 C   s   | j  }| |S r   )r  rc   r  r   r   r   r   rl     s    
zConnectionWrapper.recvN)rx   ry   rz   rB   r_   rl   r   r   r   r   r    s   r  c                 C   s   t | fd d d ddS )Nr   utf-8)	xmlrpclibr\   encode)r^   r   r   r   
_xml_dumps  s    r"  c                 C   s   t | d\\}}|S )Nr  )r   rj   decode)r   r^   methodr   r   r   
_xml_loads  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 r   )xmlrpc.clientclientr   r   r   r  r"  r%  r]   r   r   r   r     s    
zXmlListener.acceptN)rx   ry   rz   r   r   r   r   r   r&    s   r&  c                  O   s"   dd l ma tt| i |ttS r   )r'  r(  r   r  r   r"  r%  )r   kwdsr   r   r   	XmlClient  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   r   r   rS   r   r   r   )Zhandlesr   Lreadyr  r   r   r   _exhaustive_wait)  s     
 
r.  c           
         s
  |du rt }n|dk rd}nt|d d }t| } i g }t  t }z| D ](}zt|d}W n ty   || < Y qP0 zt| dd\}}W n: t	y } z"d|j
 }}|tvr W Y d}~n
d}~0 0 |tjkr|| ||j< qP|rlt dd dkrlz|d	\}	}W n, t	yR } z|j
}W Y d}~n
d}~0 0 |slt|d
rld|_ | d}qPt |}W |D ]}|  q|D ]}z|d\}	}W n8 t	y } z|j
}|tvrނ W Y d}~n
d}~0 0 |tjkr|j } | |dkrt|d
rd|_qn|D ]}|  q:|D ]}z|d\}	}W n8 t	y } z|j
}|tvr W Y d}~n
d}~0 0 |tjkrN|j } | |dkrNt|d
rNd|_qN0  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      ?rO   T   )   r0  Fr   c                 3   s   | ]} | V  qd S r   r   ).0r  )waithandle_to_objr   r   	<genexpr>      zwait.<locals>.<genexpr>c                    s   g | ]}| v r|qS r   r   )r2  o)ready_objectsr   r   
<listcomp>  r5  wait.<locals>.<listcomp>)r   intr+  setr   AttributeErrorr:   r   r   rG   r   _ready_errorsr   r   r   r-   getwindowsversionr   r/   r   addr.  keysr   ZERROR_OPERATION_ABORTEDupdate)
object_listr   Zov_listZready_handlesr6  rO   r   r   r   r   r   )r7  r3  r   r   ?  s    











r   PollSelectorc                 C   s   t  }| D ]}||tj q|dur4t | }||}|r^dd |D W  d   S |dur4|t  }|dk r4|W  d   S q4W d   n1 s0    Y  dS )r/  Nc                 S   s   g | ]\}}|j qS r   )fileobj)r2  keyeventsr   r   r   r8    r5  r9  r   )_WaitSelectorregister	selectors
EVENT_READr   r   select)rB  r   selectorr^   deadliner-  r   r   r   r     s    
c                 C   sf   |   }t|tjtj8}ddlm} ||}t|| j	| j
ffW  d    S 1 sX0    Y  d S )Nr   )resource_sharer)rO   r0   fromfdr   SOCK_STREAMr!   rN  Z	DupSocketrebuild_connectionr@   rA   )r  r?   r   rN  dsr   r   r   reduce_connection  s
    
rS  c                 C   s   |   }t|  ||S r   r   r   )rR  r@   rA   sockr   r   r   rQ    s    rQ  c                 C   sB   | j rtjnd| jrtjndB }t|  |}t|| j | jffS r   )	r@   r   ZFILE_GENERIC_READrA   ZFILE_GENERIC_WRITEr
   Z	DupHandlerO   rebuild_pipe_connection)r  r   dhr   r   r   reduce_pipe_connection  s
    rX  c                 C   s   |   }t|||S r   )r   r|   )rW  r@   rA   r?   r   r   r   rV    s    rV  c                 C   s    t |  }t|| j| jffS r   )r
   DupFdrO   rQ  r@   rA   )r  dfr   r   r   rS    s    c                 C   s   |   }t|||S r   rT  )rZ  r@   rA   fdr   r   r   rQ    s    )NN)T)T)N)N)J__all__r   r%   r-   r0   r   r   r"   	itertoolsr   r!   r   r   r	   contextr
   ForkingPicklerr[   r   r   r   r   r   ImportErrorr.   r   CONNECTION_TIMEOUTr  countr(   r   familiesr/   r   r   r,   r1   r8   r9   r|   r   objectr   r   r   r   r   r   r   r  r  r  r  r   r   r  r"  r%  r&  r*  r.  r   ZERROR_NETNAME_DELETEDr=  r   rI  rC  rG  SelectSelectorrS  rQ  rH  rX  rV  r   r   r   r   <module>
   s   




 PT=

,,8	P
