f,&dZddlZddlZddlmZmZddlmZm Z m Z ddl m Z ddl m ZddlmZdd lmZd xZZd Zd Zd ZdZdZdZdZdZe j:ddk(Zej>Z 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 R/var/www/cvtools/html/venv/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_pointerrFEsk$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_pointerrIVs\v{HLL9H8>>!lx8;;7N"5)) X^^ # // ''rceZdZdZdZdZdZdZdZdZ ddZ e dZ dZ e dZddZd Zd Zd Zd Zd ZdZdZdZddZddZddZy)SocketNFrcB|tj}||_||_|r#t j d||_d|_n,d|_tj|j||_|j tjk(r td|_ y)Nzvoid *TF)zmqCOPY_THRESHOLDcopy_thresholdcontextr cast _zmq_socket_shadowC zmq_socket_zmq_ctxNULLr_closed)selfrP socket_typeshadowrOs r__init__zSocket.__init__is  ! //N, "xx&9D DL DL ||G,<,decoderTzmq_bindrRIPC_PATH_MAX_LEN zmq_errno errno_mod ENAMETOOLONGsplitrENOENTr)rYaddress address_brrpathrws rbindz Socket.binds gs #v.II gu %&&v.G ZZ(() 4 6AKKMY5K5K$K}}UA.r2 &78H7IJAAq{{}#66)"2"22}}UA.r2@bIq{{}#66"  rctddt|tr|jd}t j |j |}t|y)Nunbindru)rrxryrzrT zmq_unbindrRrrYrrrs rrz Socket.unbindsAvx( gs #nnV,G \\$**G 4" rct|tr|jd}tj|j |}t |y)Nru)rxryrzrT zmq_connectrRrrs rconnectzSocket.connects7 gs #nnV,G ]]4++W 5" rctddt|tr|jd}t j |j |}t|y)Nr disconnectru)rrxryrzrTzmq_disconnectrRrrs rrzSocket.disconnectsCv|, 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: zvoid*)rxry TypeErrorrr9rCrr"r>lenrIr rTzmq_setsockoptrRr rQ)rYr?rHrr@c_value_pointerc_sizets rrnz Socket.sets eS !<= = (!&)F''H eU #8>>)"7x @AAZF#9&%#P        HHWo .    $ ||H  $s B>>CCc t|}|j}t |d\}}t tj|j||||d}t|||}|tjjk7r)|tjk(r|jdr|dd}|S#t$rtj}YwxYw)Nrrrv)rr9rCrr"rAr rTzmq_getsockoptrRrFrM ROUTING_IDr>endswith)rYr?r@rc_sizet_pointerszvs rrbz Socket.gets (!&)F''H+?s+S(  d.. Q  "6?B ? c&&11 1HNN* 5!#2A- $ ||H  $s B**CCctjd}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 rrxr> memoryviewtobytesrTzmq_msg_init_sizerrmemcpy zmq_msg_datar zmq_msg_sendrR zmq_msg_close)rYbufflagszmq_msg c_messagerrrc2s r _send_copyzSocket._send_copys'','#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 rTrrRtrackerrs)rYframer frame_copyrrs r _send_framezSocket._send_framesO__& $$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)trackrOT)rxryrr rrrCrOrnbytesrM_FINISHED_TRACKERrrs) rYdatarcopyr close_framerrrs rsendz Socket.send!s 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 rrT zmq_msg_initrMr rr zmq_msg_recvrR ExceptionrrDr zmq_msg_sizer) rYrrrrr_buffer_bytesrrs rrecvz Socket.recv<s ggl+G NN7 #IIE*EmmG  ANNGT5E5Eu M L**Q^^G4annW6MN __W %"   (  s &C"Dctdd|dkrtj}|tj}t |t r|jd}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. rmonitorrNru) rrM EVENT_ALLr rWrxryrzrTzmq_socket_monitorrR)rYaddreventss rrzSocket.monitorTs\$ vy) A:]]F <88D dC ;;v&D T--tVrs  099"CC=;3J=;3Nszz*%* )1))+ !#"(M=M=` ' (r