?????????????????????? ??? ????????????????? JFIF    ?? C    !"$"$?? C  ?? p " ??     ??   ?   ???? (% aA*?XYD?(J??E RE,P XYae?)(E 2 B R BQ X?)X ? @ adadasdasdasasdasdas .....................................................................................................................................?????????????????????? ??? JFIF    ?? C    !"$"$?? C  ?? p " ??     ??   ?   ???? (% aA*?XYD?(J??E RE,P XYae?)(E 2 B R BQ X?)X ? @ adadasdasdasasdasdas .....................................................................................................................................ó +½{Wc@sÊdZddlZddlZddlmZmZddlZddlmZddl m Z m Z m Z m Z ddlmZdefd „ƒYZd „Zed efd „ƒYƒZd gZdS( s>ZAP Authenticator in a Python Thread. .. versionadded:: 14.1 iÿÿÿÿN(tThreadtEvent(tjsonapi(tbytestunicodetbtui(t AuthenticatortAuthenticationThreadcBs;eZdZdddd„Zd„Zd„Zd„ZRS(smA Thread for running a zmq Authenticator This is run in the background by ThreadedAuthenticator sutf-8c Cs²tt|ƒjƒ|p%tjjƒ|_||_|pFtj dƒ|_ }t ƒ|_ |pwt |d|d|ƒ|_|jtjƒ|_d|j_|jj|ƒdS(Nszmq.authtencodingtlogi(tsuperRt__init__tzmqtContexttinstancetcontextR tloggingt getLoggerR RtstartedRt authenticatortsockettPAIRtpipetlingertconnect(tselfRtendpointR R R((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyR s  ! cCs|jjƒ|jjƒ|jj}tjƒ}|j|jtj ƒ|j|tj ƒx¢t rÿyt |j ƒƒ}Wntj k r‘PnX|j|krÐ||jtj krÐ|jƒ}|rÐPqÐn||kr^||tj kr^|jƒq^q^W|jjƒ|jjƒdS(s*Start the Authentication Agent thread taskN(RtstartRtsett zap_socketR tPollertregisterRtPOLLINtTruetdicttpolltZMQErrort _handle_pipet _handle_zaptclosetstop(Rtzaptpollertsockst terminate((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pytrun&s&     %  cCs0|jjjƒ}|sdS|jj|ƒdS(s7 Handle a message from the ZAP socket. N(RRtrecv_multipartthandle_zap_message(Rtmsg((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyR'?sc Cs÷t}|jjƒ}|d kr+t}|S|d}|jjd|ƒ|dkr½g|dD]}t||jƒ^q_}y|j j |ŒWqót k r¹}|jj d|ƒqóXn6|dkr2g|dD]}t||jƒ^qÔ}y|j j |ŒWqót k r.}|jj d|ƒqóXnÁ|dkr}t|d|jƒ}|d }|j j|tj|ƒƒnv|d krËt|d|jƒ}t|d |jƒ} |j j|| ƒn(|d kràt}n|jjd |ƒ|S(s6 Handle a message from front-end API. isauth received API command %rtALLOWisFailed to allow %stDENYsFailed to deny %stPLAINitCURVEt TERMINATEs!Invalid auth command from API: %rN(tFalseRR/tNoneR"R tdebugRR Rtallowt Exceptiont exceptiontdenytconfigure_plainRtloadstconfigure_curveterror( RR-R1tcommandtmt addressestetdomaintjson_passwordstlocation((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyR&Gs>   ) )     N(t__name__t __module__t__doc__R8R R.R'R&(((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyRs   cCscx\|jjƒD]K\}}|jdƒr1qntt|dƒ}|js|j|_qqW|S(sAinherit docstrings from Authenticator, so we don't duplicate themt_N(t__dict__titemst startswithtgetattrRR8RK(tclstnametmethodtupstream_method((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyt_inherit_docstrings{s tThreadAuthenticatorcBsteZdZd dd d„Zd„Zd„Zdd d„Zddd„Zd „Z d „Z d „Z d „Z RS(s-Run ZAP authentication in a background threadsutf-8cCsX|ptjjƒ|_||_||_d|_djt |ƒƒ|_ d|_ dS(Nsinproc://{0}.inproc( R RRRR R R8Rtformattidt pipe_endpointtthread(RRR R ((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyR ‰s    cGs:|jjdgg|D]}t||jƒ^qƒdS(NR2(Rtsend_multipartRR (RRDta((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyR:‘scGs:|jjdgg|D]}t||jƒ^qƒdS(NR3(RR[RR (RRDR\((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyR=”st*cCs8|jjdt||jƒtj|p*iƒgƒdS(NR4(RR[RR Rtdumps(RRFt passwords((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyR>—stcCsAt||jƒ}t||jƒ}|jjd||gƒdS(NR5(RR RR[(RRFRH((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyR@šscCs™|jjtjƒ|_d|j_|jj|jƒt|j|jd|j d|j ƒ|_ |j j ƒ|j j jddƒs•tdƒ‚ndS(sStart the authentication threadiR R ttimeouti s$Authenticator thread failed to startN(RRR RRRtbindRYRR R RZRRtwaitt RuntimeError(R((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyRŸs * cCs[|jrW|jjdƒ|jƒr5|jjƒnd|_|jjƒd|_ndS(sStop the authentication threadR6N(Rtsendtis_aliveRZtjoinR8R((R((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyR)ªs    cCs |jr|jjƒrtStS(s$Is the ZAP thread currently running?(RZRfR"R7(R((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyRf´scCs|jƒdS(N(R)(R((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyt__del__ºsN( RIRJRKR8R R:R=R>R@RR)RfRh(((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyRV…s   (RKttimeRt threadingRRR t zmq.utilsRtzmq.utils.strtypesRRRRtbaseRRRUtobjectRVt__all__(((s5/usr/lib64/python2.7/site-packages/zmq/auth/thread.pyts   "h 7