Xh72dZddlZddlZddlZddlmZmZddlm Z m Z m Z ddl m Z ddl mZddlmZdd lmZd xZZd Zd Zd ZdZdZdZdZdZe j<dZedk(Z ejBZ"ddZ#ddZ$ddZ%GddZ&ddgZ'y)zzmq Socket classN) SocketOption_OptType)ZMQError _check_rc_check_version)ffi)lib)Frame)_retry_sys_callc.tjd|S)Nzsize_t*)r newlengths K/var/www/html/myenv/lib/python3.12/site-packages/zmq/backend/cffi/socket.pyrsF)CchtjdttjdfSNz uint64_t*uint64_tr rnspsizeofrrnew_uint64_pointerrs$ 77; SZZ %;!< <>!lx8;;7N "" X^^ #v&&  rc t|}|j}|tj k(rt j||ddSt |dS#t$rtj}YUwxYw)Nr)rr9 ValueErrorrr"r>r buffer)r? opt_pointerrr@s rvalue_from_opt_pointerrFGsk$f%##8>>!zz+v.q11;q>""  <<  s AA/.A/ct|dtj}|tjk(str|tj k(r t |S|tjk(r t||St|Sr8) r:rr"r;r<r=r0r>r4r2)r?valuerr@s rinitialize_opt_pointerrIXs\v{HLL9H8>>!lx8;;7N"5)) X^^ # // ''rceZdZdZdZdZdZdZdZdZ dZ dZ ddZ e dZdZe dZddZd Zd Zd Zd Zd ZdZdZdZddZddZddddededefdZddZy)SocketNFrc^|tj}||_||_dx|_|_|r#t jd||_d|_ n,d|_ tj|j||_|jt jk(r td|_y)Nvoid *TF)zmqCOPY_THRESHOLDcopy_thresholdcontext _draft_poller_draft_poller_ptrr cast _zmq_socket_shadowC zmq_socket_zmq_ctxNULLr_closed)selfrQ socket_typeshadowrPs r__init__zSocket.__init__ms  ! //N, 6::T3 "xx&9D DL DL ||G,<,BB"T%;+%HHSZZ0[[!1!12DL 6 bM rct|tr|jd}n|}t|tr|j d}t j |j|}|dkrtrft jtjk(rA|jddd}d|dtd}tt j| t jtjk(r:|jddd}d |d }tt j| t|yy) Nutf8rz://rz ipc path "z" is longer than z+ characters (sizeof(sockaddr_un.sun_path)).)msgz(No such file or directory for ipc path "z".) isinstancestrencoder>decoderWzmq_bindrUIPC_PATH_MAX_LEN zmq_errno errno_mod ENAMETOOLONGsplitrENOENTr)r\address address_brvpathr{s rbindz Socket.binds gs #v.II gu %&&v.G ZZ(() 4 6AKKMY5K5K$K}}UA.r2 &78H7IJAAq{{}#66)"2"22}}UA.r2@bIq{{}#66"  rct|tr|jd}tj|j |}t |yNry)r|r}r~rW zmq_unbindrUrr\rrvs runbindz Socket.unbinds7 gs #nnV,G \\$**G 4" rct|tr|jd}tj|j |}t |yr)r|r}r~rW zmq_connectrUrrs rconnectzSocket.connects7 gs #nnV,G ]]4++W 5" rct|tr|jd}tj|j |}t |yr)r|r}r~rWzmq_disconnectrUrrs r disconnectzSocket.disconnects9 gs #nnV,G   d.. 8" rc d}t|tr td t|}|j}t|tr,|t jk7rtd|t|}t|||\}}ttj|j|tj d||y#t $rt j}YwxYw)Nzunicode not allowed, use bytesznot a bytes sockopt: void*)r|r} TypeErrorrr9rCrr"r>lenrIr rWzmq_setsockoptrUr rT)r\r?rHrr@c_value_pointerc_sizets rrrz Socket.sets eS !<= = (!&)F''H eU #8>>)"7x @AAZF#9&%#P        HHWo .    $ ||H  $s B>>CCcN t|}|j}|t j k(r\|jPt|\}}tj|jtjd|t |dSt|d\}} ttj|j||||d}tK|||} |t jjLk7r)|tjNk(r| jQd r| dd } | S#t$rtj}YwxYw#t $r}|tj k(r|j"t j$j&k(r|j)tj*r~t-ddt j.s t1dt3j4t j6j9d tj:d |_tj>x|j<d<|_|jtj@k(rdx|_|_tjB|j|jtj@t jDt jFz}tI|tj|jtjd |}tI|t |dcYd}~Sd}~wwxYw)Nrrr)z)draft socket FD support via zmq_poller_fdz'libzmq must be built with draft supportr) stacklevelzvoid*[1]rMrz))rr9rCrr"rNFDrRrArW zmq_poller_fdr rTr zmq_getsockoptrUrrgErrnoEINVALre THREAD_SAFEr DRAFT_API RuntimeErrorwarningswarnerrorDraftFDWarningrrSzmq_poller_newrZzmq_poller_addPOLLINPOLLOUTrrF ROUTING_IDr>endswith) r\r?r@r_c_sizet_pointerrjrvszvs rrez Socket.getsz (!&)F''H SVV  2 2 >!5f!= OQ OOD../0R Sq)* *+?s+S()        TQ  "6?B ? c&&11 1HNN* 5!#2AE $ ||H  $.! ,//)GGsyy///HH\556y*UV}}&'PQQ cii668QG*-)<&ABAQAQASS&&q)D,>%%1BFFD*T-?%%&&$$HHJJ,  " __&&?(K" ?1-..C! s6 D'D:D76D7: L$GLL$LL$ctjd}t|tst |j }tjd|}t j|t|}t|t jt j||t|tt j||j|t j|}t|y)zSend a copy of a bufferable zmq_msg_t*zchar[]N)r rr|r> memoryviewtobytesrWzmq_msg_init_sizerrmemcpy zmq_msg_datar zmq_msg_sendrU zmq_msg_close)r\bufflagszmq_msg c_messagervrc2s r _send_copyzSocket._send_copy:s'','#u%S/))+CGGHc*  #c( 3"  ()SX>1A1A5Ioog&#rc|j}|j}ttj||j ||j }|j|S)z1Send a Frame on this socket in a non-copy manner.) fast_copyrr rWrrUtrackerrw)r\framer frame_copyrrs r _send_framezSocket._send_frameIsO__& $$1A1A5I$$rct|tr td|r"t|ts|j ||Sd}t|tr|r|j s t d|}nl|jrFt|}|j|jkr"|j ||tjSt|||j}d}|j||}|r|j|S)Nz.Message must be in bytes, not a unicode objectFzNot a tracked message)trackrPT)r|r}rr rrrCrPrnbytesrN_FINISHED_TRACKERrrw) r\datarcopyr close_framerrrs rsendz Socket.sendTs dC LM M  4/??4/ /K$&$%<==&&$T*CzzD$7$77U3"444d%@S@ST" &&ue4G Nrc|r+tjd}tj|n"t j |}|j } ttj||j||sStjtj|tj|}|dd}tj|}t||S#t$r|rtj|wxYw)Nr)r)r rrW zmq_msg_initrNr rr zmq_msg_recvrU ExceptionrrDr zmq_msg_sizer) r\rrrrr_buffer_bytesrvs rrecvz Socket.recvos ggl+G NN7 #IIE*EmmG  ANNGT5E5Eu M L**Q^^G4annW6MN __W %"   (  s &C"D)rrrrreturnct|}|js td|jr td|dkrt d|d|j }|dk(r|}n||kDrt d|d|dt j|}ttj|j|||}t||S)Nz%Can only recv_into contiguous buffersz Cannot recv_into readonly bufferrznbytes=z must be non-negativez too big for memoryview of B) r contiguous BufferErrorreadonlyrCrr from_bufferr rWzmq_recvrUr)r\rDrrview view_bytesc_bufrvs r recv_intozSocket.recv_intos&!EF F ==@A A A:y(=>? ?[[ Q;F j y(CJ.>vuU"  rc|dkrtj}|tj}t |t r|j d}tj|j||y)as.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. rNry) rN EVENT_ALLr rZr|r}r~rWzmq_socket_monitorrU)r\addreventss rmonitorzSocket.monitorsR" A:]]F <88D dC ;;v&D T--tVrs  099"CC=;3J=;3N 3::j !1} )1))+ !#"(N=N=b ' (r