?????????????????????? ??? ????????????????? 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@sdZddlZddlmZmZmZmZmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZddlZddlmZmZmZdd lmZd d „Zd d „Zd d „Zdefd„ƒYZ ddgZ!dS(szmq Socket classiÿÿÿÿNi( tCtffitnew_uint64_pointertnew_int64_pointertnew_int_pointertnew_binary_datatvalue_uint64_pointertvalue_int64_pointertvalue_int_pointertvalue_binary_datatIPC_PATH_MAX_LEN(tFrame(tRCVMORE(t_retry_sys_call(tZMQErrort _check_rct_check_version(tunicodeicCsJddlm}m}||kr)tƒS||kr?t|ƒStƒSdS(Niÿÿÿÿ(tint64_sockoptstbytes_sockopts(tzmq.sugar.constantsRRRRR(toptiontlengthRR((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytnew_pointer_from_opts    cCs_ddlm}m}||kr0t|dƒS||krMtj||ƒSt|dƒSdS(Niÿÿÿÿ(RRi(RRRtintRtbuffer(Rt opt_pointerRRR((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytvalue_from_opt_pointer#s   cCsSddlm}m}||kr,t|ƒS||krEt||ƒSt|ƒSdS(Niÿÿÿÿ(RR(RRRRR R(RtvalueRRR((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytinitialize_opt_pointer.s     tSocketcBsÎeZdZdZdZdZdZeZ dddd„Z e d„ƒZ e d„ƒZ dd„Zd„Zd„Zd„Zd„Zd„Zd „Zd eed „Zd eed „Zd d„ZRS(cCs||_|dk r6tjd|ƒ|_t|_n!t|_tj |j |ƒ|_|jtj krut ƒ‚nt|_ |r™|j|ƒ|_ndS(Nsvoid *(tcontexttNoneRtcastt _zmq_sockettTruet_shadowtFalseRt zmq_sockett_zmq_ctxtNULLRt_closedt _add_sockett_ref(tselfRt socket_typetshadow((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pyt__init__Bs      cCsttjd|jƒƒS(s+The address of the underlying libzmq sockettsize_t(RRR!R"(R,((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pyt underlyingPscCs|jS(N(R)(R,((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytclosedUscCsrd}|j rnt|dƒrn|jdk rCtj|jƒ}nt|_|jrn|jj|j ƒqnn|S(NiR"( R)thasattrR"R Rt zmq_closeR#Rt _rm_socketR+(R,tlingertrc((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytcloseYs  cCsÒt|tƒr!|jdƒ}ntj|j|ƒ}|dkrÎtrÁtjƒtj krÁt tkr~|j ddƒ}n|j ddƒd}dj |tƒ}ttjƒd |ƒ‚qÎt|ƒndS( Ntutf8isutf-8treplaces://iiÿÿÿÿsLipc path "{0}" is longer than {1} characters (sizeof(sockaddr_un.sun_path)).tmsg(t isinstanceRtencodeRtzmq_bindR"R t zmq_errnot errno_modt ENAMETOOLONGtstrtdecodetsplittformatRR(R,taddressR7tpathR;((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytbindcs   cCsQtddƒt|tƒr.|jdƒ}ntj|j|ƒ}t|ƒdS(NiitunbindR9(ii(RR<RR=Rt zmq_unbindR"R(R,RFR7((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pyRIts  cCsDt|tƒr!|jdƒ}ntj|j|ƒ}t|ƒdS(NR9(R<RR=Rt zmq_connectR"R(R,RFR7((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytconnect{scCsQtddƒt|tƒr.|jdƒ}ntj|j|ƒ}t|ƒdS(Niit disconnectR9(ii(RR<RR=Rtzmq_disconnectR"R(R,RFR7((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pyRMs  cCs¹d}t|tƒr$tdƒ‚nt|tƒrg|tjjkrXtd|ƒ‚nt|ƒ}nt |||ƒ}|d}|d}t t j |j |tjd|ƒ|ƒdS(Nsunicode not allowed, use bytessnot a bytes sockopt: %siisvoid*(R R<Rt TypeErrortbytestzmqt constantsRtlenRR Rtzmq_setsockoptR"RR!(R,RRRtc_datatc_value_pointertc_sizet((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytsetˆs   cCsŸt|ddƒ}|d}|d}ttj|j|||ƒ|d}t|||ƒ}|tjkr›|tjj kr›|j dƒr›|d }n|S(NRiÿiitiÿÿÿÿ( RR Rtzmq_getsockoptR"RRQtIDENTITYRRRtendswith(R,RRURVtc_sizet_pointertsztv((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytgets    0 ic Csät|tƒrtdƒ‚nt|tƒr9|j}ntjdƒ}tjd|ƒ}tj|t |ƒƒ}t |ƒtj tj |ƒ|t |ƒƒt tj||j|ƒtj|ƒ}t |ƒ|ràtjƒSdS(Ns/Message must be in bytes, not an unicode Objects zmq_msg_t*schar[](R<RROR RPRtnewRtzmq_msg_init_sizeRSRtmemcpyt zmq_msg_dataR t zmq_msg_sendR"t zmq_msg_closeRQtMessageTracker( R,tmessagetflagstcopyttracktzmq_msgt c_messageR7trc2((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytsend¯s  " c CsÚtjdƒ}tj|ƒyttj||j|ƒWn!tk r\tj|ƒ‚nXtj tj |ƒtj |ƒƒ}|}tj|ƒ}t |ƒt |d|ƒ}|jtƒ|_|rÒ|jS|SdS(Ns zmq_msg_t*Rk(RRaRt zmq_msg_initR t zmq_msg_recvR"t ExceptionRfRRdt zmq_msg_sizeRR t getsockoptR tmoreRP( R,RiRjRkRlt_bufferRR7tframe((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pytrecvÂs    $ iÿÿÿÿcCsztddƒ|dkr%tj}n|dkr=tj}nt|tƒr^|jdƒ}nt j |j ||ƒ}dS(ss.monitor(addr, flags) Start publishing socket events on inproc. See libzmq docs for zmq_monitor for details. Note: requires libzmq >= 3.2 Parameters ---------- addr : str The inproc url used for monitoring. Passing None as the addr will cause an existing socket monitor to be deregistered. events : int [default: zmq.EVENT_ALL] The zmq event bitmask for which events will be sent to the monitor. iitmonitoriR9N(ii( RRQt EVENT_ALLR RR(R<RR=Rtzmq_socket_monitorR"(R,taddrteventsR7((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pyRyÙs     N(t__name__t __module__R RR-R"R)R+R%R$R/tpropertyR1R2R8RHRIRLRMRXR`RoR#RxRy(((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pyR:s&      R ("t__doc__terrnoR@t_cffiRRRRRRRRRR R RhR RRR tutilsR RQt zmq.errorRRRtzmq.utils.strtypesRRRRtobjectRt__all__(((s=/usr/lib64/python2.7/site-packages/zmq/backend/cffi/socket.pyts L  »