Mh(UdZddlmZ ddlZejs en9#e$r1ddlmZeej dZ de de dZ ee wxYwddl Z dd l mZdd lmZdd lmZddlZdd lmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#dd l$m%Z%m&Z&m'Z'm(Z(m)Z)ddl*m+Z+m,Z,m-Z-ddl.m/Z/ddl0m1Z1m2Z2m3Z3m4Z4m5Z5ddl6m7Z7ddl8m9Z9ddl8m:Z;ddlZ>ddl?m@Z@ddlAmBZBmCZCmDZDmEZEmFZFmGZGddlHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZambZbmcZcmdZdmeZemfZfmgZgmhZhmiZimjZjmkZkmlZlmmZmmnZnmoZompZpmqZqmrZrmsZsmtZtmuZumvZvmwZwmxZxmyZymzZzm{Z{m|Z|m}Z}m~Z~mZmZmZmZmZmZmZmZddlHmZddlHmZddlZddlmZmZddlmZmZmZmZmZeBZded<eeejddsdtd%Zeje e!eFe"&Zeedud*Zeedvd.Zeedsdwd3ZdaeGd4d5ZeGd6d7Zeedxd9ZeGd:d;Zeedyd=Zeedzd>Zeed{d|dBZeed}d~dCZeed}ddEZeed}d~dFZeeddKZeeddLZddMZddPZddRZddUZddWZddXZdddZZddd^Z ddd`ZeeeddhZeeeddkZ dddqZgdrZdS)zCython 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)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_LENFrcC.interror_without_errnor returnct}t|dkr|sdS|dkr]|tkrt||tkrt ||t krt|t|dS)zhinternal utility for checking zmq return condition and raising the appropriate Exception class rr|) _zmq_errnor!r#rwr"rur4rvrx)r}rerrnos W/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/zmq/backend/cython/_zmq.py _check_rcrs<>'.. . f__,,  i  #E** *5// ! 1)sockmutexiddatarvhintc4tt}t|}tt t |}|t krFt|tttt|t|j ttt|j}|dkrtt d|t#||jd}|dkrFt't(kr/tt dt+t't-|j}|dkrtt d|t/|t1|dSdS)a$A 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)rrcr r r_zhintr r[rrr,rUrr0rr(cstderrr^rrr3ror2rSr*)rrmsgmsg_ptrhintr}s rfree_python_msgrsL" )  C")#,,G %88D t||'6&>>222|G$$gdg&6&6vGGG  # # 77 GA2 F F F '49a 0 0 66|||++9< ;U;U$* % % 77 GCR H H Hg T q)|rzmq_msgpointer(zmq_msg_t)bytesct}ttt|}t |}t ||S)zCopy the data from a zmq_msg_t)r r rrUrbr)rdata_c data_len_cs r_copy_zmq_msg_bytesrs=F &,w// 0 0Fg&&J $VZ 8 88rrpointer(p_void)writablerctt}t}|r |tz}t |t ||}|dkrt d|j|d<|j}tt ||S)z Get a C buffer from a memoryviewrzCouldn't create buffer) rrrrrr ValueErrorbuflenr)objrrpybufflagsr} data_sizes r _asbufferrs I  E'E  "3>>B Avv1222 F1I IWU^^$$$ rcteZdZ ddZdZdZddZdd ZddZe dZ e dZ dZ dZ dS)FrameNFc t}d}| tj}d}||}t|j} d|_||_d|_d|_d|_ d|_ d|_ |rtj |_ t|trtd|'t!| } t#| d|_dSt%|t't)t*t|}d} ||r ||krd} nd} n|} | rFt-| |} t#| t/t1| ||d|_dS|r.t3} | |_ tj| |_ t6ddlmat't)t<t?tAt<} t6!||j | _"t6j#s8tI| _%t'tL| j%t6_#nDt't)tNt'tLt6j#| _%t't*t'tLt6j(j)| _*tW| t't*||t't)tXtZt't*| } | dkrt]| t#| d|_dS)NrFTz8Str objects not allowed. Only: bytes, buffer interfaces.)gc)/r zmqCOPY_THRESHOLDr rmore_data _failed_init_buffer_bytes tracker_eventtracker_FINISHED_TRACKER isinstancestr TypeErrorrYrrr rrr[r,rUrMessageTracker_gczmq.utils.garbagerrr+rstorer _push_mutexr/rrr1 _push_socket underlyingrrZrNrr*)selfrtrackcopycopy_thresholdkwargsrrc_copy_threshold zmq_msg_ptrr}c_copyevtrs r__init__zFrame.__init__s!"  ! /N%&  %- *1$,*?*?      !   10DL dC  XVWW W <k**B bMMM %D  FtT'&//76??%K%KLL  < J1A$A$AF  "; ;;B bMMM < ,,fj A A A %D  F  3''C!$D -c22DL ; 3 3 3 3 3 3 $WV__fVF^^6L6L M M))D$"455 O'))DJ"64:66COOgg..VS_0M0MNNDJfc.>.I!J!JKK     %% 7 7       77 JJJ bMMM!rc|jrdSt5tt|j}dddn #1swxYwYt |dSN)rrrSr rrrr}s r __dealloc__zFrame.__dealloc__ws    F  = =%gdl&;&;<>  NT""7|| rcj|j&tt|j|_|jS)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 rrz Frame.bytess- ; -gdl.C.CDDDK{rcZd}t}t|tr3tt |j|}t ||S|dkr8tt |j}|dkrt d|S|dkrPtt |j}|tkrt d| dStddt|tr| d}t|tstd||}tt t#t |j|}|tkrt d| dS) 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_idr|grouputf8rzget string propertieszexpected str, got: )r rrzrVr rrr]rXdecoderyrencoderrr rrW)roptionr} property_crrresults rgetz Frame.gets|&!  fc " " WT\22F;;B bMMMI \ ! !#5gdl6K6K#L#LJQ"   w   5 566Cd{{" ::f%% % v6777 fc " " +]]6**F&%(( ><&<<== = fl74<3H3H*&U&UVV T>> bMMM}}V$$$rc|dkr5|}tt|j|}t|dS|dkr]t |t r|d}tt|j|}t|dStt|j||}t|dS)amSet 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) rar rrrrrr`r_)rrvaluerr}s rsetz Frame.sets \ ! !#(J' (=(=zJJB bMMM F w  %%% - V,,"74<#8#8%@@B bMMM F .. > >" r)NFNN)rr)rrrr~)rr)__name__ __module__ __qualname__rrrrrrpropertyrrrrrrrrsAE_"_"_"_"B   ,     X  X 4%4%4%lrrcpeZdZdZdddZed Zeedd Z d Z ddZ ddZ dS)Contextz Manage the lifecycle of a 0MQ context. Parameters ---------- io_threads : int The number of IO threads. rr io_threadsr~shadowrct|_d|_d|_|r"t t ||_d|_nd|_t |_|jtkrtd}|js*t|jt|}t|d|_ t|_dS)NrFT) r handle_pid_shadowr rrIrxrJr8rclosedr.)rrrr}s rrzContext.__init__"s    (vv..DKDLL DL%--DK ;$  ** | T[.*EEB bMMM HH rc6tt|jS)z,The address of the underlying libzmq contextr rrrs rrzContext.underlying9FDK(((rrcd}|jtkrQ|jsJt|jkr3t 5t |j}dddn #1swxYwYt|_|SNr)rr rr.rrrGrs r_termz Context._term>s ;$  t{ vxx497L7L 2 2$T[11 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2  sAA Ac~|} t|n#t$rYnwxYwd|_dS)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)rrrwrrs rtermz Context.termHsRJJLL  bMMMM$    D   s & 33rc|jrtdt|tst d||}t |j||}t|dS)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 RuntimeErrorrrzrrJrr)rroptval optval_int_cr}s rrz Context.setYsm0 ; =;<< <&#&& ><&<<== = fl ; ;" rc~|jrtdt|j|}t |d|S)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. r F)r)rr rHrr)rrr}s rrz Context.getzsF2 ; =;<< < f - -"%0000 rN)rr)rr~rrrr~rr~) rrr__doc__rrrrrrr rrrrrrrs.))X)   V U"Brrrct|tr|d} |}n #t$rtd|wxYw|S)Nzutf-8z"Expected addr to be str, got addr=)rrrr)addrc_addrs r_c_addrrso$${{7##G GGGETEEFFFG Ms /A ceZdZdZ d)d*d Zed Zed Zd+d,dZd-dZ d-dZ d.dZ d/dZ d.dZ d.dZefd0dZd1dZdZd2d3d%Zd2d3d&Zddd'd4d(ZdS)5Socketa2 A 0MQ socket. These objects will generally be constructed via the socket() method of a Context object. Note: 0MQ Sockets are *not* threadsafe. **DO NOT** share them across threads. Parameters ---------- context : Context The 0MQ Context this Socket belongs to. socket_type : int The socket type, which can be any of the 0MQ socket types: REQ, REP, PUB, SUB, PAIR, DEALER, ROUTER, PULL, PUSH, XPUB, XSUB. See Also -------- .Context.socket : method for creating a socket bound to a Context. Nr|r socket_typer~rrct|_t|_d|_d|_d|_| t j}||_t|_||_|r"d|_tt||_nL|td|dkrtdd|_t|jj||_|jtkrtd|_t|_dS)NrFTzcontext must be specifiedzsocket_type must be specified)r r _draft_pollerrrcontextrrrr rrrmrx_closedr.)rrrrrs rrzSocket.__init__s !    ! /N,   GDLvv..DKK ;<<<Q ?@@@ DL$T\%8+FFDK ;$  **  HH rc6tt|jS)z+The address of the underlying libzmq socketrrs rrzSocket.underlyingrrc t|S)zWhether the socket is closed)_check_closed_deeprs rrz Socket.closeds"$'''rlinger int | Nonecd}d}||}d}|jtkr|jst|jkr|r;t |jt t|tt|j tkr-tt|j t|_ t|j}|dkr&ttkrt|d|_t|_dSdSdSdS)a Close the socket. If linger is specified, LINGER sockopt will be set prior to closing. This can be called to close the socket by hand. If this is not called, the socket will automatically be closed when it is garbage collected. rFNT)rr rr.rrlr9r rrzrrerErr&r)rr"r} setlingerlinger_cs rclosez Socket.closes  HI ;$  t| DI8M8M Xt{J8I8I6RU;;WWW!T))"74+=#>#>???%)"4;''BAvv*,,(22" DLDKKK    8M8MrrcPt|t|trtd t |}|j}n#t $rtj}YnwxYw|tj kr^t|tstd|t|}t|}t|j |||dS|tjkrat|tstd||}t|j |t|t!t"dSt|tstd||}t|j |t|t!tdS)ay 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: r N) _check_closedrrrrs _opt_typerrtrzrrr _setsockoptrint64r rrC) rrrsoptopt_typeoptval_croptval_int64_crs rrz Socket.set s: d fc " " JHII I &''D~HH  $ $ $ |HHH  $ x~ % %fe,, D B B BCCC'//Hf%%B  VXr : : : : :  ' 'fc** B @f @ @AAA#N  VW^-D-DfWoo V V V V Vfc** B @f @ @AAA!L  VW\-B-BF3KK P P P P PsA A%$A%c <tt}ttj}tt}tt d}t | t|}|j}n#t$rtj}YnwxYw|tj krd}t|j |tt|t!||t"kr-|dkr'tt$||dz dkr|dz}t'tt$||} n|tjkr\t+t}t|j |ttt!|t!||} nk|t,krE|jt0kr5t3|jt!|} t5| |} n|tjkrt+t} t|j |ttt!|t!|nR#t8$rD} |t,kr-| jt<jj kr|!tDrtGddt=j$dstKdtMj't<j()d tU|_|jt0krtW|j|j t0tXtZz} t5| t3|jt!|} t5| nYd } ~ nd } ~ wwxYw|} nZt+t}t|j |ttt!|t!||} | S) 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_fddraft'libzmq must be built with draft supportr4) stacklevelN).rrCCrzrBrr)rsr*rrtr _getsockoptrr rr r7rrr,rr6rr rfrfdrxrrErrnoEINVALrr?ryhasr warningswarnerrorDraftFDWarningrgrdr:r;) rrr0r optval_fd_cidentity_str_cr-r.rrr}es rrz Socket.getMs.!))qu~~ dmm  c++ d &''D~HH  $ $ $ |HHH  $ x~ % %B  VT&.-I-I7SU;; W W W,&&FF&.1126:eCCa.tFN/K/KRPPFF  ' 'B  VT&'.2I2I%J%JGTVKK   $FF v  $"4"<"<t17;3G3GHHB bMMM FF  $ $B# Kfgk6J6J)K)KWUW[[    f$$39#333114#!#N77++V*+TUUUM#)":":"<"<KKKK*8)9)9D&)T11'*DKzK?WBbMMM&t'97;;O;OPPBbMMMM"MMMM; @!FFB  VT&',2G2G%H%H'RT++   "F s,,BBB'AI-- N<8D:N77N<r str | bytesct|}t|t|j|}|dkrt }t }|r@|t kr5|ddd}d|d|d}t||tkr2|ddd}d |d }t| t|d S#t$rt|j|}Y4wxYw) a2 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://rr|z 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".TN) rr)rDrrr-r$splitrxr%rrw)rrrr}_errno_ipc_maxpathrs rbindz Socket.bindsB !dT[&11 77&LLF244H (Fl22zz%++B/?????? 3''''6!!zz%++B/IIII3''''  "  )   dk622 sC((D  D rNonect|}t| t|j|}t |dS#t $rY4wxYw)ar 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. TN)rr)rFrrrwrrrr}s rconnectzSocket.connectsl!d   f55"  )    s$A AAct|}t|t|j|}|dkrt dS)a 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)rr)rprrxrNs runbindz Socket.unbindsH!dt{F33 77**  7rct|}t|t|j|}|dkrt dS)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)rr)rMrrxrNs r disconnectzSocket.disconnectsH!d"4;77 77**  7rstr | bytes | Noneeventsct}|t|}t|tt |j||dS)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 rr)rrnr)rrrUrs rmonitorzSocket.monitor2sK*  T]]Fd$T[&&AABBBBBrrc tddtjdstdt |t r|d}|}t|j|}t|dS)z Join a RADIO-DISH group Only for DISH sockets. libzmq and pyzmq must have been built with ZMQ_BUILD_DRAFT_API .. versionadded:: 17 rr4 RADIO-DISHr5r6rN) ryrr=r rrrrQrr)rrc_groupr}s rjoinz Socket.joinNs~ v|,,,ww JHII I eS ! ! )LL((ET['22" rctddtjdstdt |j|}t |dS)z Leave a RADIO-DISH group Only for DISH sockets. libzmq and pyzmq must have been built with ZMQ_BUILD_DRAFT_API .. versionadded:: 17 rYrZr5r6N)ryrr=r rRrr)rrr}s rleavez Socket.leaveasV v|,,,ww JHII Idk511" rTFrr rct|t|trtd|r+t|tst |j||St|tr|r|jstd|}nc|j rEt|}|j }|j }||kr"t |j||tj St |||j }t|j||S)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) rrrrrrrrars rsendz Socket.sendqsT d dC  DBCC C  8 4// 8dk477 7$&& S>>$%<===&5$T**C%(ZF-1-@N.."4;U;;;"44Dd>QRRRt{C77 7rc Jt||rt|j|St|j||}d}t t }t |jtttt|t|||_ |S)a 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 r9r<r rr r)rrrrframerrs rrecvz Socket.recvs@ d  dk511 1 UE::EDB  [$vwt}}*E*Ewr{{   EJLr)rarc|}t||}|dkrtd|dt|}tt t j}t|t|d}|dkr|}n||krtd|d|d t5t|j |||} dddn #1swxYwY t| | S#t$rYUwxYw)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)rrrrr8voidrr rrkrrrw) rrrarc_flagsc_nbytesviewc_data view_bytesr}s r recv_intozSocket.recv_intosuNd! a<<>>>>?? ?&!!))(wvEE Q;;!HH  " "QQQJQQQRR R  M M$T[&(GLL M M M M M M M M M M M M M M M "  )    s$-CCCC.. C;:C;)Nr|rN)rr~rrr)r"r#r)rrE)rrErrL)rrTrUr~)rrE)rTF)rr rr r)rrrrrrrrr'rrrKrOrQrSr5rWr\r^rcrhrprrrrrs, !!!!!F))X)((X(     D?Q?Q?Q?QBrrrrh****X4*,ANCCCCC8& @8@8@8@8@8D,,,,,\./a========rrsc<|jrttdS)zDraise ENOTSUP if socket is closed Does not do a deep check N)rrxr&)rqs rr)r)$s& y!x   !!rc ttj}tt}|jrdSt |jtttt|t|}|dkr0t}|tkr d|_dS|tkrdSnt|dS)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)rr8rzrrrOrr@r rr rr&r4r)rqstyperr}rs rr!r!/s AENNEByt  HhVWU^^ < 'E%rrrpointer(size_t)cpd} t||||} t|dS#t$rY1wxYw)zXgetsockopt, retrying interrupted calls checks rc, raising ZMQError on failure. rTN)rOrrwrrrrr}s rr9r9ZB FFFB 7 7  bMMM E%    H  ( 55cpd} t||||} t|dS#t$rY1wxYw)zXsetsockopt, retrying interrupted calls checks rc, raising ZMQError on failure. rTN)rlrrwrs rr+r+rrctS)z6Return the integer errno of the most recent zmq error.)rrrrrqrqs <<rrrcLt|}|ddS)z9 Return the error string given the error number. rreplace)ror)rstr_es rstrerrorrs% &&E << * **rtuple[int, int, int]cd}d}d}tt|t|t||||fS)z9Return the version of ZeroMQ itself as a 3-tuple of ints.r)rAr )majorminorpatchs rzmq_version_inforsBEEE@@@ 5%  r capabilityboolctdd|d}tt|S)zxCheck for zmq capability by name (e.g. 'ipc', 'curve') .. versionadded:: libzmq-4.1 .. versionadded:: 14.1 rzzmq.hasr)ryrrrP)rccaps rr=r=s; 69%%%##F++D   rtuple[bytes, bytes]cttd}ttd}tddt||}t |||fS)urgenerate a Z85 key pair for use with zmq.CURVE security Requires libzmq (≥ 4.0) to have been built with CURVE support. .. versionadded:: libzmq-4.0 .. versionadded:: 14.0 Returns ------- public: bytes The public key as 40 byte z85-encoded bytestring. private: bytes The private key as 40 byte z85-encoded bytestring. @)rr curve_keypair)rrryrKr) public_key secret_keyr}s rrrs] b""Jb""J6?+++ :z 2 2B bMMM z !!rcDt|tr|d}t|dkst dt t d}|}tddt||}t||ddS)uhCompute the public key corresponding to a secret key for use with zmq.CURVE security Requires libzmq (≥ 4.2) to have been built with CURVE support. Parameters ---------- private The private key as a 40 byte z85-encoded bytestring Returns ------- bytes The public key as a 40 byte z85-encoded bytestring r(z/secret key must be a 40 byte z85 encoded stringrrY curve_publicN) rrrrrrrryrLr)rr c_secret_keyr}s rrrs *c""/&&v.. z??b JKKKb""J",L6>*** *l 3 3B bMMM crc?rtimeoutc t}t|}|dkrgStttt |t tz}|tkrtdt|D]y}||\}}t|trMtt|j ||_ d||_ |||_d||_pt|t r<|}t||_ |||_ |||_d||_t#|dr t!|}t||_ |||_ |||_d||_.#t&$rt)|t+dwxYwt)|t-d|d} t/} t05t3|||} dddn #1swxYwY t5| nr#t6$re|dkr\t/} t!d| | z z}|dkr t9jd |d t<d}t?d||z }YwxYwn#t&$rt)|wxYwg} t|D]^}||j} | dkrI||j tkr||d}n ||j }| || f_t)|| S) aezmq_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: TNiz,Negative elapsed time for interrupted poll: z. Did the clock change?)!r rr rrhr+r MemoryErrorrangerrrsocketr:rUreventsrzhasattrrrxr*rrrr zmq_poll_crrwr>r?RuntimeWarningmaxappend)socketsr pollitemsnsocketsirqrUr ms_passedstartr}ticresultsrs rrrrr<s(*.I'llH1}} W^,,fX~@V@V5V.W.WXXID9::: 8__AJ 6 a  "&vq//"8IaL IaLO"(IaL #$IaL 3   F"&IaL $IaLO"(IaL #$IaL Q ! !  )QXXZZ '+ ! #"( ! &, ! #'( ! $$ L L LY !JKKK L OOO,&',,  I $;;E > > 8W== > > > > > > > > > > > > > > > " &%)   Q;;#++C #DC%K$8 9 9I 1}}! 69666*%& !!Wy%899G! $  Y G 8__ ) )A,& Q;;|"d**AJqMaLO NNAw< ( ( (OOO Nsa!F::)G# K H>2 K >IK IK IK A,K K K  K K(frontendbackendcapturec d}t|tr|j}nt} t5t |j|j|}dddn #1swxYwY t |n#t$rYXwxYw|S)a~ 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. rTN)rrrr rrirrw)rrrr}capture_handles rproxyrs B'6""   L L8?GNNKKB L L L L L L L L L L L L L L L  bMMM %    H  Is#AAA#A33 B?BcontrolcTd}t|tr|j}nt}t|tr|j}nt} t5t |j|j||}dddn #1swxYwY t |n#t$rYYwxYw|S)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. rTN)rrrr rrjrrw)rrrrr}rcontrol_handles rproxy_steerablers.B'6"" '6""     $B                 bMMM %    H  Is$A<<BBB B%$B% in_socket out_socket side_socketrcside_msgid_msgswap_idsctt}tt}tt}|r\t t ||d} | dkr| St t ||d} | dkr| St t |t |} | dkr| Stt ||t} | dkr| Stt ||t} | dkr| St t |t |} | dkr| Stt ||t} | dkr| Stt ||t} | dkr| S t t ||d} | dkr| St|tt |t |} | dkr| Sd} |r | tz} t t |t |} | dkr| S| rRtt ||| } | dkr| Stt ||t} | dkr| SnMtt ||d} | dkr| Stt ||d} | dkr| SnB| Sr) rrrzrr\r rTr^r>rOr<) rrrrrrrflagszrr}rs r _mq_relayrsV__F 3< Ir in_msg_ptr out_msg_ptrc tt}tt|}tt}tt|}|dkr|Stt} tt| }|dkr|Sttd} || d_t | d_dx| d_| d_ || d_t | d_dx| d_| d_ tt| ddd}|dkr|S| dj t zrmtt| |}|dkr|Stt| |t}|dkr|St||||| ||}|dkr|S| dj t zrmtt| |}|dkr|Stt| |t}|dkr|St||||| ||}|dkr|S2)z. inner C function for monitored_queue rr4rTr|)rrcrYr rhrr:rUr:rrrTr^r>r) rrrrrrrr}rritemss r _mq_inlinerPs@Y''CWS\\**B Y  F gfoo & &B Avv y!!H gh'' ( (B Avv N1% & &EE!HO E!HO%&&E!HK%(" E!HO E!HO%&&E!HK%("  a))1b 1 1 66I 8 j ( gh//< threadingrtimerweakrefrr8r 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.cython._externsr-r.r/r0r1r2)cython.cimports.zmq.backend.cython.libzmqr3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorprqrrrrr zmq.constantsrsrt zmq.errorrurvrwrxryr{__annotations__ exceptvalrstructrrrrrrrrrr)r!rfrerbr`r9r+rrr=rrrrrrr__all__rrrrs"  #"""""MMM ?kmmtH~~%a(H  "   "   C +c  '*$ ;:::::TTTTTTTTTTTTTT000000......88888844444444......????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????@NMMMMMLLLLLL 00000000-,...... R     .   ''      ((((V9999      D@@@@@@@@Fv v v v v v v v x!!!!@$0,@         & ++++!!!!""""4Bkkkkk\J ,,,,,bMMMM`@@@@N IIIIIX   s !6A