^h%SrSSKJr SSKr\R(d\"5eSSK r SS K Jr SS KJr SS KJr SSKrSS KJrJrJrJrJrJrJrJrJrJrJrJrJ r J!r!J"r"J#r# SS K$J%r%J&r&J'r'J(r(J)r) SSK*J+r+J,r,J-r- SSK.J/r/ SSK0J1r1J2r2J3r3J4r4J5r5 SSK6J7r7 SSK8J9r9 SSK8J:r; SSKr> SSK?J@r@ SSKAJBrB SSKCJDrDJErEJFrFJGrGJHrHJIrI SSKJJKrKJLrLJMrMJNrNJOrOJPrPJQrQJRrRJSrSJTrTJUrUJVrVJWrWJXrXJYrYJZrZJ[r[J\r\J]r]J^r^J_r_J`r`JaraJbrbJcrcJdrdJereJfrfJgrgJhrhJiriJjrjJkrkJlrlJmrmJnrnJoroJprpJqrqJrrrJsrsJtrtJuruJvrvJwrwJxrxJyryJzrzJ{r{J|r|J}r}J~r~JrJrJrJrJrJrJrJrJrJr SSKJJr SSKJJr SSKrSSKJrJr SSKJrJrJrJrJr \D"5rS\S'\"\BGR45rS\S '\\\GR6"S!5SCSDS"jj555r\GR:"\ \!"\H5\"S#9r\\SES$j55r\\SFS%j55r\\SCSGS&jj55rSq\"S'S(55r\"S)S*55r\\SHS+j55r\"S,S-55r\\SIS.j55r\\SJS/j55r\\SKSLS0jj55r\\SMSNS1jj55r\\SMSOS2jj55r\\SMSNS3jj55r\\SPS4j55r\\SQS5j55rSRS6jrSSS7jrSTS8jrSUS9jrSVS:jrSHS;jrSWSXS<jjrSYSZS=jjrS[S\S>jjr\\\S]S?j555r\\\S^S@j555rS_S`SAjjr/SBQrg!\a- SSKJr \"\5RSr S\ S\ S3r \"\ 5ef=f)azCython backend for pyzmq) annotationsN)Pathz Attempting to import zmq Cython backend, which has not been compiled. This probably means you are importing zmq from its source tree. if this is what you want, make sure to do an in-place build first: pip install -e 'z' If it is not, then 'a!' is probably on your sys.path, when it shouldn't be. Is that your current working directory? If neither of those is true and this file is actually installed, something seems to have gone wrong with the install! Please report at https://github.com/zeromq/pyzmq/issues )Event) monotonic)ref)NULL Py_ssize_taddressbintcastcclasscfuncchardeclareinlinenogilp_charp_voidpointersize_tsizeof) Py_bufferPyBUF_ANY_CONTIGUOUSPyBUF_WRITABLEPyBuffer_ReleasePyObject_GetBuffer)PyBytes_AsStringPyBytes_FromStringAndSize PyBytes_Size)PyErr_CheckSignals)EAGAINEINTR ENAMETOOLONGENOENTENOTSOCK)uint32_t)fprintf)stderr)freemalloc)memcpy)libzmq)get_ipc_path_max_lengetpidmutex_allocate mutex_lockmutex_t mutex_unlock)> ZMQ_ENOTSOCK ZMQ_ETERM ZMQ_EVENT_ALLZMQ_FD ZMQ_IDENTITYZMQ_IO_THREADS ZMQ_LINGER ZMQ_POLLIN ZMQ_POLLOUT ZMQ_RCVMORE ZMQ_ROUTER ZMQ_SNDMOREZMQ_THREAD_SAFEZMQ_TYPE _zmq_versionfd_tint64_tzmq_bind zmq_close zmq_connectzmq_ctx_destroy zmq_ctx_get zmq_ctx_new zmq_ctx_setzmq_curve_keypairzmq_curve_publiczmq_disconnect zmq_free_fnzmq_getsockoptzmq_haszmq_join zmq_leave zmq_msg_close zmq_msg_copy zmq_msg_data zmq_msg_get zmq_msg_gets zmq_msg_group zmq_msg_initzmq_msg_init_datazmq_msg_init_size zmq_msg_recvzmq_msg_routing_id zmq_msg_send zmq_msg_setzmq_msg_set_groupzmq_msg_set_routing_id zmq_msg_size zmq_msg_tzmq_poller_addzmq_poller_destroy zmq_poller_fdzmq_poller_newzmq_pollitem_t zmq_proxyzmq_proxy_steerablezmq_recvzmq_setsockopt zmq_socketzmq_socket_monitor zmq_strerror zmq_unbind) zmq_errno)zmq_poll) SocketOption_OptType)AgainContextTerminatedInterruptedSystemCallZMQError_check_versionintIPC_PATH_MAX_LENboolPYZMQ_DRAFT_APIc[5n[5 US:XaU(dgUS:XaJU[:Xa [U5eU[:Xa [ U5eU[ :Xa [U5e[U5eg)z`internal utility for checking zmq return condition and raising the appropriate Exception class rr) _zmq_errnor!r#rxr"rvr5rwry)rcerror_without_errnoerrnos Q/home/james-whalen/.local/lib/python3.13/site-packages/zmq/backend/cython/_zmq.py _check_rcrsh'. . f_,  i #E* *5/ ! )sockmutexidc[[5n[U5n[[ [ 5U5nU[ :wGa[U[[55 [[U5[UR5[[55 [UR5nUS:wa[[ SU5 [#X4R$S5nUS:a4['5[(:wa"[[ S[+['555 [-UR5nUS:wa[[ SU5 [/U5 [1U5 gg)aA pure-C function for DECREF'ing Python-owned message data. Sends a message on a PUSH socket The hint is a `zhint` struct with two values: sock (void *): pointer to the Garbage Collector's PUSH socket id (size_t): the id to be used to construct a zmq_msg_t that should be sent on a PUSH socket, signaling the Garbage Collector to remove its reference to the object. When the Garbage Collector's PULL socket receives the message, it deletes its reference to the object, allowing Python to free the memory. rz!pyzmq-gc mutex lock failed rc=%d zpyzmq-gc send failed: %s z#pyzmq-gc mutex unlock failed rc=%d N)rrdr r r_zhintr r\rrr,rVrr1rr(cstderrr_rrr4rpr3rTr*)datavhintmsgmsg_ptrhintrs rfree_python_msgrs" ) C")#,G %8D t|'6&>2|G$gdgg&6vG  # 7 GA2 F '99a 0 6||+9< ;U$** % 7 GCR Hg T )rcl[n[[[U55n[ U5n[ X5$)zCopy the data from a zmq_msg_t)r r rrVrcr)zmq_msgdata_c data_len_cs r_copy_zmq_msg_bytesrs/F &,w/ 0Fg&J $V 88rc[[5n[nU(a U[-n[ U[ U5U5nUS:a [ S5eURUS'URn[[ U55 U$)z Get a C buffer from a memoryviewrzCouldn't create buffer) rrrrrr ValueErrorbuflenr)objrwritablepybufflagsr data_sizes r _asbufferrsm I E'E "3>B Av122 F1I IWU^$ rcv\rSrSrSSjrSrSrSSjrSSjrSSjr \ S 5r \ S 5r S r S rS rg)FrameiNc [nSnUc[RnSnUbUn[UR5n SUlXlSUlSUlSUl SUl SUl U(a[RUl [U[5(a [S5eUc[!U 5n [#U 5 SUlg[%U['[)[*5[U555nSn UcU(aXx:aSn OSn OUn U (a3[-X5n [#U 5 [/[1U 5Xg5 SUlgU(a+[35n Xl [R4"U 5Ul [6cSSKJq ['[)[<5[?[A[<555n [6RCXR5U l"[6RF(d3[I5U l%['[LU RJ5[6l#O:['[)[N5['[L[6RF55U l%['[*['[L[6RPRR55U l*[WU ['[*U5U['[)[X5[Z5['[*U 55n U S:wa[]U 5 [#U 5 SUlg)NrFTz8Str objects not allowed. Only: bytes, buffer interfaces.)gc)/r zmqCOPY_THRESHOLDr rmore_data _failed_init_buffer_bytes tracker_eventtracker_FINISHED_TRACKER isinstancestr TypeErrorrZrrr rrr\r,rVrMessageTracker_gczmq.utils.garbagerrr+rstorer _push_mutexr0rrr2 _push_socket underlyingrr[rOrr*)selfrtrackcopycopy_thresholdkwargsrrc_copy_threshold zmq_msg_ptrrc_copyevtrs r__init__Frame.__init__s;!"  ! //N%&  %- *1$,,*?      !  00DL dC VW W <k*B bM %D  tT'&/76?%KL  <J$AF ";;B bM < ,f A %D   'C!$ --c2DL ; 3 $WV_fVF^6L M))D"4"45')DJ"64::6COgg.VS__0MNDJfc.>.>.I.I!JK     % 7     7 J bM!rcUR(ag[ [[UR55nSSS5 [ W5 g!,(df  N=fN)rrrTr rrrrs r __dealloc__Frame.__dealloc__zs8     %gdll&;  NT"7| rczURc#[[UR55UlUR$)zThe message content as a Python bytes object. The first time this property is accessed, a copy of the message contents is made. From then on that same copy of the message is returned. )rrr rrs rbytes Frame.bytess- ;; -gdll.CDDK{{rcSn[n[U[5(a,[[ UR 5U5n[ U5 U$US:Xa1[[ UR 55nUS:Xa [ S5 U$US:XaD[[ UR 55nU[:Xa [ S5 URS5$[SS5 [U[5(aURS5n[U[5(d[SU<35eUn[[ [#[ UR 5U55nU[:Xa [ S5 URS5$) a Get a Frame option or property. See the 0MQ API documentation for zmq_msg_get and zmq_msg_gets for details on specific options. .. versionadded:: libzmq-3.2 .. versionadded:: 13.0 .. versionchanged:: 14.3 add support for zmq_msg_gets (requires libzmq-4.1) All message properties are strings. .. versionchanged:: 17.0 Added support for `routing_id` and `group`. Only available if draft API is enabled with libzmq >= 4.2. r routing_idrgrouputf8rzget string propertieszexpected str, got: )r rr{rWr rrr^rYdecoderzrencoderrr rrX)roptionr property_crrresults rget Frame.gets+&!  fc " "WT\\2F;B bMI \ !#5gdll6K#LJQ"   w  56Cd{" ::f% % v67 fc " "]]6*F&%((1&<= = fl74<<3H*&UV T> bM}}V$$rclUS:Xa-Un[[UR5U5n[U5 gUS:XaQ[ U[ 5(aUR S5n[[UR5U5n[U5 g[[UR5X5n[U5 g)a%Set a Frame option. See the 0MQ API documentation for zmq_msg_set for details on specific options. .. versionadded:: libzmq-3.2 .. versionadded:: 13.0 .. versionchanged:: 17.0 Added support for `routing_id` and `group`. Only available if draft API is enabled with libzmq >= 4.2. rNrr) rbr rrrrrrar`)rrvaluerrs rset Frame.sets \ !#(J' (=zJB bM  w %%% V,"74<<#8%@B bM  . >" r)rrrrrrr)NFNN)returnr)rzpointer(Py_buffer)rC.int)rr)__name__ __module__ __qualname____firstlineno__rrrrrrpropertyrrrr__static_attributes__rrrrs\AE_"B ,    4%lrrcn\rSrSrSrS S Sjjr\S5r\\ S Sj55r Sr SSjr SSjr S rg )Contextizn Manage the lifecycle of a 0MQ context. Parameters ---------- io_threads : int The number of IO threads. c[UlSUlSUlU(a[ [ U5UlSUlOSUl[ 5UlUR[:Xa [5eSnUR(d&[UR[U5n[U5 SUl [5Ulg)NrFT) r handle_pid_shadowr rrJryrKr9rclosedr/)r io_threadsshadowrs rrContext.__init__%s   vv.DKDL DL%-DK ;;$ * ||T[[.*EB bM H rc6[[UR5$)z,The address of the underlying libzmq contextr rrrs rrContext.underlying<FDKK((rcSnUR[:waMUR(d<[5UR:Xa$[  [ UR5nSSS5 [UlU$!,(df  N=fNr)rr r r/r rrHrs r_term Context._termAsR ;;$ t{{vx4997L$T[[1  s A11 A?cjUR5n[U5 SUlg![a Nf=f)z Close or terminate the context. This can be called to close the context by hand. If this is not called, the context will automatically be closed when it is garbage collected. TN)rrrxr rs rterm Context.termKs:JJL  bM  %   s % 22cUR(a [S5e[U[5(d[ SU<35eUn[ UR X5n[U5 g)a Set a context option. See the 0MQ API documentation for zmq_ctx_set for details on specific options. .. versionadded:: libzmq-3.2 .. versionadded:: 13.0 Parameters ---------- option : int The option to set. Available values will depend on your version of libzmq. Examples include:: zmq.IO_THREADS, zmq.MAX_SOCKETS optval : int The value of the option to set. Context has been destroyedexpected int, got: N)r  RuntimeErrorrr{rrKrr)rroptval optval_int_crs rr Context.set\sS0 ;;;< <&#&&1&<= = f ;" rc~UR(a [S5e[URU5n[ USS9 U$)a Get the value of a context option. See the 0MQ API documentation for zmq_ctx_get for details on specific options. .. versionadded:: libzmq-3.2 .. versionadded:: 13.0 Parameters ---------- option : int The option to get. Available values will depend on your version of libzmq. Examples include:: zmq.IO_THREADS, zmq.MAX_SOCKETS Returns ------- optval : int The value of the option as an integer. rF)r)r rrIrr)rrrs rr Context.get}s62 ;;;< < f -"%0 r)r r r rN)rr)r rr rrrrr)rrrr__doc__rrrrrrrrrrrrrrrsL.))    "Brrc[U[5(aURS5nUnU$![a [SU<35ef=f)zmcast an address input to bytes Expects a str, but accepts bytes and raises informative TypeError otherwise. zutf-8z"Expected addr to be str, got addr=)rrrr)addrc_addrs r_c_addrr)sW${{7#G M G?%)"4;;'BAv*,(2" DLDK9N| rc[U5 [U[5(a [S5e[ U5nUR nU[R:XaR[U[5(d[SU<35e[U5n[U5n[URXU5 gU[R:XaU[U[5(d[SU<35eUn[URU[U5[!["55 g[U[5(d[SU<35eUn[URU[U5[![55 g![ a [RnGNAf=f)a Set socket options. See the 0MQ API documentation for details on specific options. Parameters ---------- option : int The option to set. Available values will depend on your version of libzmq. Examples include:: zmq.SUBSCRIBE, UNSUBSCRIBE, IDENTITY, HWM, LINGER, FD optval : int or bytes The value of the option to set. Notes ----- .. warning:: All options other than zmq.SUBSCRIBE, zmq.UNSUBSCRIBE and zmq.LINGER only take effect for subsequent socket bind/connects. z*unicode not allowed, use setsockopt_stringzexpected bytes, got: rN) _check_closedrrrrt _opt_typerrur{rrr _setsockoptrint64r rrD) rrrsoptopt_typeoptval_croptval_int64_crs rr Socket.sets9: d fc " "HI I &'D~~H x~~ %fe,,"7z BCC'/Hf%B  Vr :  'fc**"5fZ @AA#N  VW^-DfWo Vfc**"5fZ @AA!L  VW\-BF3K P9 $ ||H  $s E((FFc [[5n[[R5n[[5n[[ S5n[ U5 [U5nURnU[R:Xa|Sn[URU[[U5[!U55 U[":wa%US:a[[$U5US- S:XaUS-n['[[$U5U5n U $U[R(:XaK[+[5n[URU[[[!U55[!U55 Un U $U[,:XaBUR.[0:wa.[3UR.[!U55n [5U 5 Un U $U[R6:XaL[+[5n[URU[[[!U55[!U55 Un U $[+[5n[URU[[[!U55[!U55 Un U $![a [RnGNf=f![8GaAn U[,:XGa0U R:[<R>R@:XGaURC[D5(a[GSS5 [<RH(d [KS5e[LRN"[<RPRS5SS 9 [U5UlUR.[0:Xae[WUR.UR[0[X[Z-5n [5U 5 [3UR.[!U55n [5U 5 S n A GNeS n A ff=f) a Get the value of a socket option. See the 0MQ API documentation for details on specific options. .. versionchanged:: 27 Added experimental support for ZMQ_FD for draft sockets via `zmq_poller_fd`. Requires libzmq >=4.3.2 built with draft support. Parameters ---------- option : int The option to get. Available values will depend on your version of libzmq. Examples include:: zmq.IDENTITY, HWM, LINGER, FD, EVENTS Returns ------- optval : int or bytes The value of the option as a bytestring or int. rr)rrz)draft socket FD support via zmq_poller_fd1libzmq and pyzmq must be built with draft supportrJ) stacklevelN).rrDCr{rCrr>rtr?rrur _getsockoptrr rr r8rrrArr7r-r rgrfdryrrErrnoEINVALrr@rz DRAFT_APIrwarningswarnerrorDraftFDWarningrhrer;r<) rrrEr optval_fd_cidentity_str_crBrCrrres rr Socket.getUs.!)quu~ dm  c+ d &'D~~H x~~ %B  VT&.-I7SU; W,&F&.126:eCa.tFN/KRPFB A 'B  VT&'.2I%JGTVK $Fv uv $"4"4"<t117;3GHB bM Fl k $B% KKfgk6J)KWUW[J!F B  VT&',2G%H'RT+ "F g $ ||H  $H!  f$399#3#3311"!#N==*OMM#))":":"<K*8)9D&))T1'**DKKzK?WBbM&t'9'97;;OPBbMMC! s1 I 8I4I10I14 O?D5N;:N;;Oc[U5nUn[U5 [URU5nUS:waz[ 5n[ 5nU(a1U[ :Xa'URSS5SnSUSUS3n[US9eU[:Xa$URSS5SnS US 3n[US9e[U5 g ![a [URU5nM1f=f) a Bind the socket to an address. This causes the socket to listen on a network port. Sockets on the other side of this connection will use ``Socket.connect(addr)`` to connect to this socket. Parameters ---------- addr : str The address string. This has the form 'protocol://interface:port', for example 'tcp://127.0.0.1:5555'. Protocols supported include tcp, udp, pgm, epgm, inproc and ipc. If the address is unicode, it is encoded to utf-8 first. rz://rrz ipc path "z" is longer than z~ characters (sizeof(sockaddr_un.sun_path)). zmq.IPC_PATH_MAX_LEN constant can be used to check addr length (if it is defined).)rz(No such file or directory for ipc path "z".N) r)r>rErrr.r$splitryr%rrx) rr' _addr_bytesr(r_errno_ipc_maxpathrs rbind Socket.binds %T] $dT[[&1 7&LF24HFl2zz%+B/ &7zB?? 3''6!zz%+B/@bI3'' "  ) dkk62 s1 B== C! C!c[U5nUn[U5 [URU5n[ U5 g![ a M1f=f)a* Connect to a remote 0MQ socket. Parameters ---------- addr : str The address string. This has the form 'protocol://interface:port', for example 'tcp://127.0.0.1:5555'. Protocols supported are tcp, udp, pgm, inproc and ipc. If the address is unicode, it is encoded to utf-8 first. N)r)r>rGrrrxrr'r]r(rs rconnectSocket.connectsR%T] $d  f5"  )  s!= A  A c[U5nUn[U5 [URU5nUS:wa [ 5eg)ao Unbind from an address (undoes a call to bind). .. versionadded:: libzmq-3.2 .. versionadded:: 13.0 Parameters ---------- addr : str The address string. This has the form 'protocol://interface:port', for example 'tcp://127.0.0.1:5555'. Protocols supported are tcp, udp, pgm, inproc and ipc. If the address is unicode, it is encoded to utf-8 first. rN)r)r>rqrryrds runbind Socket.unbinds>%T] $dt{{F3 7*  rc[U5nUn[U5 [URU5nUS:wa [ 5eg)a Disconnect from a remote 0MQ socket (undoes a call to connect). .. versionadded:: libzmq-3.2 .. versionadded:: 13.0 Parameters ---------- addr : str The address string. This has the form 'protocol://interface:port', for example 'tcp://127.0.0.1:5555'. Protocols supported are tcp, udp, pgm, inproc and ipc. If the address is unicode, it is encoded to utf-8 first. rN)r)r>rNrryrds r disconnectSocket.disconnect)s>%T] $d"4;;7 7*  rc[nUb [U5nUn[U5 [[ UR X255 g)a Start publishing socket events on inproc. See libzmq docs for zmq_monitor for details. While this function is available from libzmq 3.2, pyzmq cannot parse monitor messages from libzmq prior to 4.0. .. versionadded: libzmq-3.2 .. versionadded: 14.0 Parameters ---------- addr : str | None 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. N)r r)r>rror)rr'eventsr(r]s rmonitorSocket.monitor@s9*  !(K(Fd$T[[&ABrc[SS5 [R(d [S5e[ U[ 5(aUR S5nUn[URU5n[U5 g)z Join a RADIO-DISH group Only for DISH sockets. libzmq and pyzmq must have been built with ZMQ_BUILD_DRAFT_API .. versionadded:: 17 rrJ RADIO-DISHrKrN) rzrrRrrrrrRrr)rrc_grouprs rjoin Socket.join]sX v|,}}RS S eS ! !LL(ET[['2" rc[SS5 [R(d [S5e[ UR U5n[ U5 g)z Leave a RADIO-DISH group Only for DISH sockets. libzmq and pyzmq must have been built with ZMQ_BUILD_DRAFT_API .. versionadded:: 17 rrrsrKN)rzrrRrrSrr)rrrs rleave Socket.leaveps8 v|,}}RS Sdkk51" rcD[U5 [U[5(a [S5eU(a+[U[5(d[ UR X5$[U[5(a&U(aUR(d [S5eUnOsUR(aN[U5nURnURnXx:a&[ UR Xb5 [R$[ XURS9n[UR XR5$)a Send a single zmq message frame on this socket. This queues the message to be sent by the IO thread at a later time. With flags=NOBLOCK, this raises :class:`ZMQError` if the queue is full; otherwise, this waits until space is available. See :class:`Poller` for more general non-blocking I/O. Parameters ---------- data : bytes, Frame, memoryview The content of the message. This can be any object that provides the Python buffer API (`memoryview(data)` can be called). flags : int 0, NOBLOCK, SNDMORE, or NOBLOCK|SNDMORE. copy : bool Should the message be sent in a copying or non-copying manner. track : bool Should the message be tracked for notification that ZMQ has finished with it? (ignored if copy=True) Returns ------- None : if `copy` or not track None if message was sent, raises an exception otherwise. MessageTracker : if track and not copy a MessageTracker object, whose `done` property will be False until the send is completed. Raises ------ TypeError If a unicode object is passed ValueError If `track=True`, but an untracked Frame is passed. ZMQError for any of the reasons zmq_msg_send might fail (including if NOBLOCK is set and the outgoing queue is full). z$unicode not allowed, use send_stringzNot a tracked message)rr)r>rrrr _send_copyrrrrrnbytesrr _send_frame) rrrrrrrr|rs rsend Socket.sendsT d dC BC C  4//dkk47 7$&&$%<==&&$T*C%(ZZF-1-@-@N."4;;;"444Dd>Q>QRt{{C7 7rc ([U5 U(a[URU5$[URX5nSn[ [ 5n[ UR[[[[U55[U55 XTl U$)aJ Receive a message. With flags=NOBLOCK, this raises :class:`ZMQError` if no messages have arrived; otherwise, this waits until a message arrives. See :class:`Poller` for more general non-blocking I/O. Parameters ---------- flags : int 0 or NOBLOCK. copy : bool Should the message be received in a copying or non-copying manner? If False a Frame object is returned, if True a string copy of message is returned. track : bool Should the message be tracked for notification that ZMQ has finished with it? (ignored if copy=True) Returns ------- msg : bytes or Frame The received message frame. If `copy` is False, then it will be a Frame, otherwise it will be bytes. Raises ------ ZMQError for any of the reasons zmq_msg_recv might fail (including if NOBLOCK is set and no new messages have arrived). F) r> _recv_copyr _recv_framerr rNr=r rr r)rrrrframerrs rrecv Socket.recvso@ d dkk51 1 U:EDB  [$vwt}*Ewr{ JLr)r|rcUn[U5 UnUS:a[SU<S35e[U5n[[ [ R 55n[U[U5S5nUS:XaUnOXX:a[SU<SUS35e[ [URXuU5n SSS5 [W 5 U $!,(df  N=f![a MSf=f)a Receive up to nbytes bytes from the socket, storing the data into a buffer rather than allocating a new Frame. The next message frame can be discarded by receiving into an empty buffer:: sock.recv_into(bytearray()) .. versionadded:: 26.4 Parameters ---------- buffer : memoryview Any object providing the buffer interface (i.e. `memoryview(buffer)` works), where the memoryview is contiguous and writable. nbytes: int, default=0 The maximum number of bytes to receive. If nbytes is not specified (or 0), receive up to the size available in the given buffer. If the next frame is larger than this, the frame will be truncated and message content discarded. flags: int, default=0 See `socket.recv` Returns ------- bytes_received: int Returns the number of bytes received. This is always the size of the received frame. If the returned `bytes_received` is larger than `nbytes` (or size of `buffer` if `nbytes=0`), the message has been truncated and the rest of the frame discarded. Truncated data cannot be recovered. Raises ------ ZMQError for any of the reasons `zmq_recv` might fail. BufferError for invalid buffers, such as readonly or not contiguous. rznbytes=z must be non-negativeTz too big for memoryview of rN)r>rrrrrMvoidrr rrlrrrx) rrr|rc_flagsc_nbytesviewc_data view_bytesrs r recv_intoSocket.recv_intosNd! a<y(=>? ?&!)(wvE Q;!H  "y(CJr>3s yyx  rc d[[R5n[[5nUR(ag[ UR [[[[U55[U55nUS:a)[5nU[:XaSUlgU[:Xagg[U5 g)zthorough 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 TrF)rrMr{rr/rPrrAr rr rr&r5r)rstyperrrs rr5r5>s AEENEByy  HHhVWU^ * * 3B bM cr?rc [n[U5nUS:Xa/$[[[5[ U[ [5-55nU[:Xa [S5e[U5GH nXupV[U[5(a>[[U5RX$l SX$l XbUlSX$lM][U[ 5(a,Un[X$l XrUl XbUlSX$lM[#US5(aD[!UR%55n[X$l XrUl XbUlSX$lM[)U5 [-SU<35e Sn[/5n [0 [3X#U5n SSS5 [5W 5 /n [U5HWnX$Rn U S:dMX$R[:waXSnOX$RnU RAX]45 MY [)U5 U $![&a [)U5 [+S5ef=f!,(df  N=f![6aZ US:aO[/5n [!SX- -5nUS:a![8R:"SUS 3[<5 Sn[?SX- 5nGM@f=f![&a [)U5 ef=f) a5zmq_poll(sockets, timeout=-1) Poll a set of 0MQ sockets, native file descs. or sockets. Parameters ---------- sockets : list of tuples of (socket, flags) Each element of this list is a two-tuple containing a socket and a flags. The socket may be a 0MQ socket or any object with a ``fileno()`` method. The flags can be zmq.POLLIN (for detecting for incoming messages), zmq.POLLOUT (for detecting that send is OK) or zmq.POLLIN|zmq.POLLOUT for detecting both. timeout : int The number of milliseconds to poll for. Negative means no timeout. rzCould not allocate poll itemsfilenoz'fileno() must return a valid integer fdzFSocket must be a 0MQ socket, an integer fd or have a fileno() method: Niz,Negative elapsed time for interrupted poll: z. Did the clock change?)!r rr rrir+r MemoryErrorrangerr+rsocketrOrnreventsr{hasattrrrr*rrrr zmq_poll_crrxrSrTRuntimeWarningmaxappend)socketstimeout pollitemsnsocketsirrnr ms_passedstartrticresultsrs rrsrsKs(*.I'lH1} W^,fX~@V5V.WXID9:: 8_J  a "&vq/"8"8IL ILO"(aL #$IL 3  F"&IL $aLO"(aL #$IL Q ! ! )QXXZ '+ #"(! &,! #'( $ O&&'U, 5>I$;E W= " & G 8_,&& Q;|""d*JqMLOO NNA< ( O N{ LY !JKK L() Q;#+C #DCK$8 9I 1}! J9+V66*%& !!W%89G! &  Y sOH&>K I K% I&!I IKAJ?:K>J??KKcSn[U[5(a URnO[n[ [ URURU5nSSS5 [ U5 U$!,(df  N=f![a M^f=f)aN Start a zeromq proxy (replacement for device). .. versionadded:: libzmq-3.2 .. versionadded:: 13.0 Parameters ---------- frontend : Socket The Socket instance for the incoming traffic. backend : Socket The Socket instance for the outbound traffic. capture : Socket (optional) The Socket instance for capturing traffic. rN)rr+rr rrjrrx)frontendbackendcapturercapture_handles rproxyrsv B'6""   8??GNNNKB  bM  IU%   s"A+ A<+ A9< B  B cjSn[U[5(a URnO[n[U[5(a URnO[n[ [ URURXV5nSSS5 [ U5 U$!,(df  N=f![a M^f=f)a Start a zeromq proxy with control flow. .. versionadded:: libzmq-4.1 .. versionadded:: 18.0 Parameters ---------- frontend : Socket The Socket instance for the incoming traffic. backend : Socket The Socket instance for the outbound traffic. capture : Socket (optional) The Socket instance for capturing traffic. control : Socket (optional) The Socket instance for control flow. rN)rr+rr rrkrrx)rrrcontrolrrcontrol_handles rproxy_steerablers.B'6"" '6""   $B  bM  IU %   s"B B$ B!$ B21B2c[[5n[[5n[[5nU(Ga[ [ U5US5n U S:aU $[ [ U5US5n U S:aU $[ [ U5[ U55n U S:aU $[[ U5U[5n U S:aU $[[ U5U[5n U S:aU $[ [ U5[ U55n U S:aU $[[ U5U[5n U S:aU $[[ U5U[5n U S:aU $[ [ U5US5n U S:aU $[U[[ U5[ U55n U S:aU $Sn U(a U [-n [ [ U5[ U55n U S:aU $U (a@[[ U5X5n U S:aU $[[ U5U[5n U S:aU $O?[[ U5US5n U S:aU $[[ U5US5n U S:aU $U $GM r) rrr{rr]r rUr_r?rPr=) in_socket out_socket side_socketrside_msgid_msgswap_idsflagszrrrs r _mq_relayr s#V_F 3rr r\rr,rVrcrrrx)rr mon_socket in_prefix out_prefixinsoutsmonsin_msgout_msgmsg_c msg_c_lenrrs rmonitored_queuersUD""C$$D$$D Y Fi GE #I~~+M :0MH)WU^4I 76?I 6B bM < (%gfo1NO*gen5I 77+Y 7B bM   WW-.|GGDT7U 4''2BHB   bM  IU%   s'AF F" F" F0/F0)r|r~rr+rrrrrrrrsrrr)F)rrrr rr)rrrrrr)rpointer(zmq_msg_t)rr)rzpointer(p_void)rr rr)rr)rr+)rr+rr )rF)rrrrrr rr)r)rrrr)rrrrrr)rrrrrrrzpointer(size_t))rrrrrrrrr#)rrrr)rztuple[int, int, int])rrrr})rztuple[bytes, bytes])r)rrr)rr+rr+rr+)NN)rr+rr+rr+rr+)rrrrrrrrdrrdrrdrr rr)rrrrrrrrrrrr rr)sinsout) rr+rr+rr+rrrr)r% __future__rcythoncompiled ImportErrorpathlibr__file__parentszmq_rootrrS threadingrtimerweakrefrrMr r r r r rrrrrrrrrrrcython.cimports.cpython.bufferrrrrrcython.cimports.cpython.bytesrrr cython.cimports.cpython.excr!cython.cimports.libc.errnor"r#r$r%r&cython.cimports.libc.stdintr'cython.cimports.libc.stdior(r)rcython.cimports.libc.stdlibr*r+cython.cimports.libc.stringr,"cython.cimports.zmq.backend.cythonr-+cython.cimports.zmq.backend.cython._externsr.r/r0r1r2r3)cython.cimports.zmq.backend.cython.libzmqr4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorprqrrrrsrr zmq.constantsrtru zmq.errorrvrwrxryrzr|__annotations__r}r~ exceptvalrstructrrrrrrrr)r+r>r5rrr}r{rNr@rrrrrrrrrr__all__rrrrs # ??m .$ ;TT0.84.5????????????????@NL 0-.#.V3344R  .   '   ((V99   D@@@F  } } } F!!@$0,@     & +!"4Bk\J ,, ,, ,bMMMM  M  M  MM MM`@@@@# @ $ @  @ @@N IIII I  IX E?H~%%a(H " #! # C c 's M3N