ó L]c@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((s6lib/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((s6lib/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((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pytinitialize_opt_pointer.s     tSocketcBsÝeZdZdZdZdZdZeZ dZ dddd„Z e d„ƒZ d„Ze d„ƒZdd„Zd„Zd„Zd„Zd „Zd „Zd „Zdeed „Zdeed „Zdd„ZRS(icCs||_|dk rQt|tƒr0|j}ntjd|ƒ|_t|_ n!t |_ t j |j |ƒ|_|jtjkrtƒ‚nt |_dS(Nsvoid *(tcontexttNonet isinstanceRt underlyingRtcastt _zmq_sockettTruet_shadowtFalseRt zmq_sockett_zmq_ctxtNULLRt_closed(tselfRt socket_typetshadow((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyt__init__Cs      cCsttjd|jƒƒS(s+The address of the underlying libzmq sockettsize_t(RRR#R$(R,((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyR"QscCs]|jr tSy|jtjƒWn5tk rX}|jtjkrRt|_tS‚nXtS(sÒthorough check of whether the socket has been closed, even if by another entity (e.g. ctx.destroy). Only used by the `closed` property. returns True if closed, False otherwise ( R+R%tgettzmqtTYPERterrnotENOTSOCKR'(R,te((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyt_check_closed_deepVs  cCs |jƒS(N(R7(R,((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pytclosedjscCsŽd}|j rqt|dƒrq|jdk re|dk rP|jtj|ƒntj|jƒ}nt |_n|dkrŠt |ƒndS(NiR$( R+thasattrR$R tsetR2tLINGERRt zmq_closeR%R(R,tlingertrc((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pytclosens   cCsHt|tƒr!|jdƒ}ntj|j|ƒ}|dkrDtrÁtjƒtj krÁt tkr~|j ddƒ}n|j ddƒd}dj |tƒ}ttjƒd |ƒ‚qDtjƒtjkr7t tkr÷|j ddƒ}n|j ddƒd}d j |ƒ}ttjƒd |ƒ‚qDt|ƒndS( Ntutf8isutf-8treplaces://iiÿÿÿÿsLipc path "{0}" is longer than {1} characters (sizeof(sockaddr_un.sun_path)).tmsgs-No such file or directory for ipc path "{0}".(R!RtencodeRtzmq_bindR$R t zmq_errnot errno_modt ENAMETOOLONGtstrtdecodetsplittformatRtENOENTR(R,taddressR>tpathRB((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pytbindys&     cCsQtddƒt|tƒr.|jdƒ}ntj|j|ƒ}t|ƒdS(NiitunbindR@(ii(RR!RRCRt zmq_unbindR$R(R,RMR>((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyRP’s  cCsDt|tƒr!|jdƒ}ntj|j|ƒ}t|ƒdS(NR@(R!RRCRt zmq_connectR$R(R,RMR>((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pytconnect™scCsQtddƒt|tƒr.|jdƒ}ntj|j|ƒ}t|ƒdS(Niit disconnectR@(ii(RR!RRCRtzmq_disconnectR$R(R,RMR>((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyRTŸs  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 TypeErrortbytesR2t constantsRtlenRR Rtzmq_setsockoptR$RR#(R,RRRtc_datatc_value_pointertc_sizet((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyR:¦s   cCsŸt|ddƒ}|d}|d}ttj|j|||ƒ|d}t|||ƒ}|tjkr›|tjj kr›|j dƒr›|d }n|S(NRiÿiisiÿÿÿÿ( RR Rtzmq_getsockoptR$RR2tIDENTITYRXRtendswith(R,RR[R\tc_sizet_pointertsztv((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyR1»s    0 c Cst|tƒrtdƒ‚nt|tƒr9|j}ntjdƒ}t|tƒslt|ƒjƒ}ntjd|ƒ}t j |t |ƒƒ}t |ƒt j t j|ƒ|t |ƒƒtt j||j|ƒt j|ƒ}t |ƒ|rtjƒSdS(Ns/Message must be in bytes, not an unicode Objects zmq_msg_t*schar[](R!RRVR RWRtnewt memoryviewttobytesRtzmq_msg_init_sizeRYRtmemcpyt zmq_msg_dataR t zmq_msg_sendR$t zmq_msg_closeR2tMessageTracker( R,tmessagetflagstcopyttracktzmq_msgt c_messageR>trc2((s6lib/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*Rp(RRdRt zmq_msg_initR t zmq_msg_recvR$t ExceptionRkRRit zmq_msg_sizeRR t getsockoptR tmoreRW( R,RnRoRpRqt_bufferRR>tframe((s6lib/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. iitmonitoriR@N(ii( RR2t EVENT_ALLR RR*R!RRCRtzmq_socket_monitorR$(R,taddrteventsR>((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyR~ûs     N(t__name__t __module__R RR-R$R+t_refR'R&tcopy_thresholdR/tpropertyR"R7R8R?RORPRSRTR:R1RtR%R}R~(((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyR:s*       R ("t__doc__R4RFt_cffiRRRRRRRRRR R RmR RXR tutilsR R2t zmq.errorRRRtzmq.utils.strtypesRRRRtobjectRt__all__(((s6lib/python2.7/site-packages/zmq/backend/cffi/socket.pyts L  Ý