ytf,&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 a/var/www/html/software/conda/envs/higlass/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)rr7 ValueErrorrr"r<r buffer)r= opt_pointerrr>s rvalue_from_opt_pointerrDEsk$f%##8>>!zz+v.q11;q>""  <<  s AA/.A/ct|dtj}|tjk(str|tj k(r t |S|tjk(r t||St|Sr6) r8rr"r9r:r;r.r<r2r0)r=valuerr>s rinitialize_opt_pointerrGVs\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)selfrN socket_typeshadowrMs r__init__zSocket.__init__is  ! //N, "xx&9D DL DL ||G,<,c_value_pointerc_sizets rrlz Socket.sets eS !<= = (!&)F''H eU #8>>) 9F BCCZF#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)Nrrrt)rr7rArr"r?r rRzmq_getsockoptrPrDrK ROUTING_IDr<endswith)rWr=r>rc_sizet_pointerszvs rr`z 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 rrvr< memoryviewtobytesrRzmq_msg_init_sizerrmemcpy zmq_msg_datar zmq_msg_sendrP zmq_msg_close)rWbufflagszmq_msg c_messagerprc2s 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 rRrrPtrackerrq)rWframer 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)trackrMT)rvrwrr rrrArMrnbytesrK_FINISHED_TRACKERrrq) rWdatarcopyr 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 rrR zmq_msg_initrKr rr zmq_msg_recvrP ExceptionrrBr zmq_msg_sizer) rWrrrrr_buffer_bytesrps 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. rmonitorrNrs) rrK EVENT_ALLr rUrvrwrxrRzmq_socket_monitorrP)rWaddreventss rrzSocket.monitorTs\$ vy) A:]]F <88D dC ;;v&D T--tVrs  099"CC=;3J=;3Pszz*%* )1))+ !#"(M=M=` ' (r