uawdijnntqw1x1x1
IP : 3.137.159.13
Hostname : ns1.eurodns.top
Kernel : Linux ns1.eurodns.top 4.18.0-553.5.1.lve.1.el7h.x86_64 #1 SMP Fri Jun 14 14:24:52 UTC 2024 x86_64
Disable Function : mail,sendmail,exec,passthru,shell_exec,system,popen,curl_multi_exec,show_source,eval,open_base
OS : Linux
PATH:
/
home
/
..
/
var
/
..
/
.
/
lib64
/
python2.7
/
multiprocessing
/
connection.pyc
/
/
� �mec@s�dddgZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z mZddlm Z mZmZmZddlmZmZdZd Zd Zej�ZdZdgZeed�rdZedg7Znejd kr4dZedg7Zned�Zd�Zd�Zd�Z de!fd��YZ"ddd�Z$ejd kr�e%d�Z&nddlm'Z'e%d�Z&de!fd��YZ(d�Z)ejd kr de!fd��YZ*d�Z+ndZ,dZ-d Z.d!Z/d"�Z0d#�Z1d$�Z2d%e!fd&��YZ3d'�Z4d(�Z5d)e"fd*��YZ6d+�Z7dS(,tClienttListenertPipei����N(tcurrent_processtAuthenticationError(tget_temp_dirtFinalizet sub_debugtdebug(t duplicatetclosei g4@tsha256tAF_INETtAF_UNIXtwin32tAF_PIPEcCstj�|S(N(ttime(ttimeout((s2/usr/lib64/python2.7/multiprocessing/connection.pyt _init_timeoutMscCstj�|kS(N(R(tt((s2/usr/lib64/python2.7/multiprocessing/connection.pyt_check_timeoutPscCsw|dkrdS|dkr5tjdddt��S|dkrgtjdd tj�tj�f�Std ��dS( s? Return an arbitrary free address for the given family Rt localhostiR tprefixs listener-tdirRs\\.\pipe\pyc-%d-%d-sunrecognized familyN(Ri(ttempfiletmktempRtostgetpidt _mmap_countertnextt ValueError(tfamily((s2/usr/lib64/python2.7/multiprocessing/connection.pytarbitrary_addressWscCset|�tkrdSt|�tkr;|jd�r;dSt|�tkrQdStd|��dS(s] Return the types of the address This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE' Rs\\RR saddress type of %r unrecognizedN(ttypettupletstrt startswithR(taddress((s2/usr/lib64/python2.7/multiprocessing/connection.pytaddress_typefs!cBsSeZdZddddd�Zd�Zd�Zed��Zed��Z RS(s� Returns a listener object. This is a wrapper for a bound socket which is 'listening' for connections, or for a Windows named pipe. icCs�|p|rt|�pt}|p-t|�}|dkrQt||�|_nt|||�|_|dk r�t|t�r�t d�n||_ dS(NRsauthkey should be a byte string(R&tdefault_familyR tPipeListenert _listenertSocketListenertNonet isinstancetbytest TypeErrort_authkey(tselfR%Rtbacklogtauthkey((s2/usr/lib64/python2.7/multiprocessing/connection.pyt__init__�scCs?|jj�}|jr;t||j�t||j�n|S(sz Accept a connection on the bound socket or named pipe of `self`. Returns a `Connection` object. (R)tacceptR/tdeliver_challengetanswer_challenge(R0tc((s2/usr/lib64/python2.7/multiprocessing/connection.pyR4�s cCs |jj�S(sA Close the bound socket or named pipe of `self`. (R)R (R0((s2/usr/lib64/python2.7/multiprocessing/connection.pyR �scCs |jjS(N(R)t_address(R0((s2/usr/lib64/python2.7/multiprocessing/connection.pyt<lambda>�scCs |jjS(N(R)t_last_accepted(R0((s2/usr/lib64/python2.7/multiprocessing/connection.pyR9�sN( t__name__t __module__t__doc__R+R3R4R tpropertyR%t last_accepted(((s2/usr/lib64/python2.7/multiprocessing/connection.pyRys cCs�|pt|�}|dkr-t|�}nt|�}|dk rat|t�ratd�n|dk r�t||�t||�n|S(s= Returns a connection to the address of a `Listener` Rsauthkey should be a byte stringN( R&t PipeClienttSocketClientR+R,R-R.R6R5(R%RR2R7((s2/usr/lib64/python2.7/multiprocessing/connection.pyR�s cCs�|r�tj�\}}|jt�|jt�tjtj|j���}tjtj|j���}|j �|j �n<tj �\}}tj|dt�}tj|dt�}||fS(sL Returns pair of connection objects at either end of a pipe twritabletreadable(tsockett socketpairtsetblockingtTruet_multiprocessingt ConnectionRtduptfilenoR tpipetFalse(tduplexts1ts2tc1tc2tfd1tfd2((s2/usr/lib64/python2.7/multiprocessing/connection.pyR�s (Rc CsUtd�}|r;tj}tjtjB}tt}}ntj}tj}dt}}tj||tjtj Btj Bd||tjtj�}tj ||dtjtjdtj�}tj|tj dd�ytj|tj�Wn/tk r }|jdtjkr!�q!nXtj|d|�} tj|d|�} | | fS(sL Returns pair of connection objects at either end of a pipe RiiRBRCN(R RtPIPE_ACCESS_DUPLEXtGENERIC_READt GENERIC_WRITEtBUFSIZEtPIPE_ACCESS_INBOUNDtCreateNamedPipetPIPE_TYPE_MESSAGEtPIPE_READMODE_MESSAGEt PIPE_WAITtNMPWAIT_WAIT_FOREVERtNULLt CreateFilet OPEN_EXISTINGtSetNamedPipeHandleStateR+tConnectNamedPipetWindowsErrortargstERROR_PIPE_CONNECTEDRHtPipeConnection(RNR%topenmodetaccesstobsizetibsizeth1th2teRQRR((s2/usr/lib64/python2.7/multiprocessing/connection.pyR�s2 $ R*cBs,eZdZdd�Zd�Zd�ZRS(sO Representation of a socket which is bound to an address and listening icCs�tjtt|��|_yb|jjtjtjd�|jjt�|jj|�|jj |�|jj �|_Wn$tjk r�|jj ��nX||_d|_|dkr�t|tjd|fdd�|_n d|_dS(NiR Retexitpriorityi(RDtgetattrt_sockett setsockoptt SOL_SOCKETtSO_REUSEADDRRFRGtbindtlistentgetsocknameR8terrorR t_familyR+R:RRtunlinkt_unlink(R0R%RR1((s2/usr/lib64/python2.7/multiprocessing/connection.pyR3�s $cCs�x\tr^y|jj�\}|_Wn2tjk rY}|jdtjkr[�q[qXPqW|j t�t |j��}tj |�}|j�|S(Ni(RGRqR4R:RDRxReterrnotEINTRRFR RKRHRIR (R0tsRntfdtconn((s2/usr/lib64/python2.7/multiprocessing/connection.pyR4s cCs-|jj�|jdk r)|j�ndS(N(RqR R{R+(R0((s2/usr/lib64/python2.7/multiprocessing/connection.pyR #s (R;R<R=R3R4R (((s2/usr/lib64/python2.7/multiprocessing/connection.pyR*�s cCs�t|�}tjtt|��}|jt�t�}xsy|j|�WnXtjk r�}|jdt j ks�t|�r�td|��nt jd�q=XPq=�t|j��}tj|�}|j�|S(sO Return a connection object connected to the socket given by `address` isfailed to connect to address %sg{�G�z�?(R&RDRpRFRGRtconnectRxReR|tECONNREFUSEDRRRtsleepR RKRHRIR (R%RR~RRnRR�((s2/usr/lib64/python2.7/multiprocessing/connection.pyRA)s$ " R(cBs2eZdZdd�Zd�Zed��ZRS(s0 Representation of a named pipe c Cs�||_tj|tjtjtjBtjBtjtttj tj �}|g|_d|_ td|j�t|tjd|j|jfdd�|_dS(Ns listener created with address=%rReRoi(R8RRZRUR[R\R]tPIPE_UNLIMITED_INSTANCESRXR^R_t _handle_queueR+R:RRR(t_finalize_pipe_listenerR (R0R%R1thandle((s2/usr/lib64/python2.7/multiprocessing/connection.pyR3Ns c Cs�tj|jtjtjtjBtjBtjtttj tj �}|jj|�|jj d�}ytj|tj �Wn8tk r�}|jdtjtjfkr��q�nXtj|�S(Ni(RRZR8RUR[R\R]R�RXR^R_R�tappendtpopRcRdReRft ERROR_NO_DATARHRg(R0t newhandleR�Rn((s2/usr/lib64/python2.7/multiprocessing/connection.pyR4as cCs,td|�x|D]}t|�qWdS(Ns closing listener with address=%r(RR (tqueueR%R�((s2/usr/lib64/python2.7/multiprocessing/connection.pyR�us N(R;R<R=R+R3R4tstaticmethodR�(((s2/usr/lib64/python2.7/multiprocessing/connection.pyR(Js cCs�t�}x�yHtj|d�tj|tjtjBdtjtjdtj�}WnDtk r�}|j dtj tjfks�t|�r��q�qXPq�tj |tjdd�tj|�S(sU Return a connection object connected to the pipe given by `address` i�iN(RRt WaitNamedPipeR`RVRWR_RaRdRetERROR_SEM_TIMEOUTtERROR_PIPE_BUSYRRbR\R+RHRg(R%RthRn((s2/usr/lib64/python2.7/multiprocessing/connection.pyR@{s " is#CHALLENGE#s #WELCOME#s #FAILURE#cCsddl}t|t�S(Ni����(thashlibRptHMAC_DIGEST_NAME(R�((s2/usr/lib64/python2.7/multiprocessing/connection.pytget_digestmod_for_hmac�scCs�ddl}t|t�s!t�tjt�}|jt|�|j ||t ��j�}|jd�}||kr�|jt �n|jt�td��dS(Ni����isdigest received was wrong(thmacR,R-tAssertionErrorRturandomtMESSAGE_LENGTHt send_bytest CHALLENGEtnewR�tdigestt recv_bytestWELCOMEtFAILURER(t connectionR2R�tmessageR�tresponse((s2/usr/lib64/python2.7/multiprocessing/connection.pyR5�s cCs�ddl}t|t�s!t�|jd�}|tt� tksVtd|��|tt�}|j||t��j �}|j |�|jd�}|tkr�td��ndS(Ni����ismessage = %rsdigest sent was rejected( R�R,R-R�R�tlenR�R�R�R�R�R�R(R�R2R�R�R�R�((s2/usr/lib64/python2.7/multiprocessing/connection.pyR6�s& tConnectionWrappercBs#eZd�Zd�Zd�ZRS(cCsO||_||_||_x-dD]%}t||�}t|||�q"WdS(NRKR tpollR�R�(sfilenoscloseR�s recv_bytess send_bytes(t_connt_dumpst_loadsRptsetattr(R0R�tdumpstloadstattrtobj((s2/usr/lib64/python2.7/multiprocessing/connection.pyR3�s cCs#|j|�}|jj|�dS(N(R�R�R�(R0R�R~((s2/usr/lib64/python2.7/multiprocessing/connection.pytsend�scCs|jj�}|j|�S(N(R�R�R�(R0R~((s2/usr/lib64/python2.7/multiprocessing/connection.pytrecv�s(R;R<R3R�R�(((s2/usr/lib64/python2.7/multiprocessing/connection.pyR��s cCs%tj|fdddd�jd�S(Nitutf8(t xmlrpclibR�R+tencode(R�((s2/usr/lib64/python2.7/multiprocessing/connection.pyt _xml_dumps�scCs%tj|jd��\\}}|S(NR�(R�R�tdecode(R~R�tmethod((s2/usr/lib64/python2.7/multiprocessing/connection.pyt _xml_loads�s!tXmlListenercBseZd�ZRS(cCs+ddlatj|�}t|tt�S(Ni����(R�RR4R�R�R�(R0R�((s2/usr/lib64/python2.7/multiprocessing/connection.pyR4�s(R;R<R4(((s2/usr/lib64/python2.7/multiprocessing/connection.pyR��scOs%ddlatt||�tt�S(Ni����(R�R�RR�R�(Retkwds((s2/usr/lib64/python2.7/multiprocessing/connection.pyt XmlClient�s(8t__all__RtsysRDR|RRt itertoolsRHtmultiprocessingRRtmultiprocessing.utilRRRRtmultiprocessing.forkingR R RXtCONNECTION_TIMEOUTR�tcountRR'tfamiliesthasattrtplatformRRR R&tobjectRR+RRGRRR*RAR(R@R�R�R�R�R�R5R6R�R�R�R�R�(((s2/usr/lib64/python2.7/multiprocessing/connection.pyt<module>#sd" ,*. 1
/home/../var/.././lib64/python2.7/multiprocessing/connection.pyc