File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/zmq/backend/cython/__pycache__/_zmq.cpython-310.pyc
Back
o ;j�� � @ s U d Z ddlmZ z ddlZejse� �W n! ey6 ddlmZ ee�j d Z de � de � d�Z ee ��w ddl Z dd l mZ dd lmZ dd lmZ ddlZdd lmZmZmZmZmZmZmZmZm Z m Z m Z m Z m 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/ ddl0m1Z1m2Z2m3Z3m4Z4m5Z5 ddl6m7Z7 ddl8m9Z9 ddl8m:Z; ddl<m=Z=m>Z> ddl?m@Z@ ddlAmBZB ddlCmDZDmEZEmFZFmGZGmHZHmIZI ddlJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZambZbmcZcmdZdmeZemfZfmgZgmhZhmiZimjZjmkZkmlZlmmZmmnZnmoZompZpmqZqmrZrmsZsmtZtmuZumvZvmwZwmxZxmyZymzZzm{Z{m|Z|m}Z}m~Z~mZm�Z�m�Z�m�Z�m�Z�m�Z�m�Z�m�Z�m�Z�m�Z� ddlJm�Z� ddlJm�Z� ddl�Z�ddl�m�Z�m�Z� dd l�m�Z�m�Z�m�Z�m�Z�m�Z� eD� Z�d e�d < e�eBj��Z�d e�d < ee e��d!�d�d�d(d)����Z�ej�e e!eH�e"d*�Z�ee d�d.d/���Z�ee d�d3d4���Z�ee d�d�d9d:���Z�da�eG d;d<� d<��Z�eG d=d>� d>��Z�ee d�d?d@���Z�eG dAdB� dB��Z�e ed�dDdE���Z�e ed�dFdG���Z�ee d�d�dKdL���Z�ee d�d�dMdN���Z�ee d�d�dPdQ���Z�ee d�d�dRdS���Z�ee d�dXdY���Z�ee d�dZd[���Z�d�d\d]�Z�d�d`da�Z�d�dcdd�Z�d�dfdg�Z�d�didj�Z�d�dkdl�Z�d�d�dndo�Z�d�d�dsdt�Z� d�d�dvdw�Z�ee e d�dd�����Z�ee e d�d�d�����Z� � �d�d�d�d��Z�g d��Z�dS )�zCython backend for pyzmq� )� annotationsN)�Path� z� 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_t�address�bint�cast�cclass�cfunc�char�declare�inline�nogil�p_char�p_void�pointer�size_t�sizeof)� Py_buffer�PyBUF_ANY_CONTIGUOUS�PyBUF_WRITABLE�PyBuffer_Release�PyObject_GetBuffer)�PyBytes_AsString�PyBytes_FromStringAndSize� PyBytes_Size)�PyErr_CheckSignals)�EAGAIN�EINTR� ENAMETOOLONG�ENOENT�ENOTSOCK)�uint32_t)�fprintf)�stderr)�free�malloc)�memcpy)�libzmq)�get_ipc_path_max_len�getpid�mutex_allocate� mutex_lock�mutex_t� mutex_unlock)>� ZMQ_ENOTSOCK� ZMQ_ETERM� ZMQ_EVENT_ALL�ZMQ_FD� ZMQ_IDENTITY�ZMQ_IO_THREADS� ZMQ_LINGER� ZMQ_POLLIN� ZMQ_POLLOUT� ZMQ_RCVMORE� ZMQ_ROUTER� ZMQ_SNDMORE�ZMQ_THREAD_SAFE�ZMQ_TYPE� _zmq_version�fd_t�int64_t�zmq_bind� zmq_close� zmq_connect�zmq_ctx_destroy� zmq_ctx_get� zmq_ctx_new� zmq_ctx_set�zmq_curve_keypair�zmq_curve_public�zmq_disconnect� zmq_free_fn�zmq_getsockopt�zmq_has�zmq_join� zmq_leave� zmq_msg_close� zmq_msg_copy� zmq_msg_data� zmq_msg_get� zmq_msg_gets� zmq_msg_group� zmq_msg_init�zmq_msg_init_data�zmq_msg_init_size� zmq_msg_recv�zmq_msg_routing_id� zmq_msg_send� zmq_msg_set�zmq_msg_set_group�zmq_msg_set_routing_id� zmq_msg_size� zmq_msg_t�zmq_poller_add�zmq_poller_destroy� zmq_poller_fd�zmq_poller_new�zmq_pollitem_t� zmq_proxy�zmq_proxy_steerable�zmq_recv�zmq_setsockopt� zmq_socket�zmq_socket_monitor� zmq_strerror� zmq_unbind)� zmq_errno)�zmq_poll)� SocketOption�_OptType)�Again�ContextTerminated�InterruptedSystemCall�ZMQError�_check_version�int�IPC_PATH_MAX_LEN�bool�PYZMQ_DRAFT_API���F�rc�C.int�error_without_errnor �returnc C s` t � }t� |dkr|sdS | dkr.|tkrt|��|tkr"t|��|tkr*t|��t|��dS )zhinternal utility for checking zmq return condition and raising the appropriate Exception class r r~ ) � _zmq_errnor r" rw r! ru r4 rv rx )r r� �errno� r� �K/opt/saltstack/salt/lib/python3.10/site-packages/zmq/backend/cython/_zmq.py� _check_rc� s r� )�sock�mutex�id�datar �vhintc C s� t t�}t|�}ttt�|�}|tkrht|tt �� t t |�t|j �tt �� t |j�}|dkr6ttd|� t||jd�}|dk rOt� tkrOttdtt� �� t|j�}|dkr^ttd|� t|� t|� dS dS )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. r z!pyzmq-gc mutex lock failed rc=%d zpyzmq-gc send failed: %s z#pyzmq-gc mutex unlock failed rc=%d N)r rc r r r �_zhintr r[ r r r+ rU r� r0 r� r' �cstderrr^ r� r� r3 ro r2 rS r) )r� r� �msgZmsg_ptr�hintr r� r� r� �free_python_msg� s, � �r� �zmq_msg�pointer(zmq_msg_t)�bytesc C s$ t }ttt| ��}t| �}t||�S )z Copy the data from a zmq_msg_t)r r r rU rb r )r� �data_c� data_len_cr� r� r� �_copy_zmq_msg_bytes� s r� r� �pointer(p_void)�writabler c C sX t t�}t}|r |tO }t| t|�|�}|dk r td��|j|d< |j}t t|�� |S )z Get a C buffer from a memoryviewr zCouldn't create buffer) r r r r r r � ValueError�buf�lenr )�objr� r� Zpybuf�flagsr � data_sizer� r� r� � _asbuffer s r� c @ sn e Zd Z d dd�Zdd� Zdd� Zd d d �Zd dd�Zd dd�Ze dd� �Z e dd� �Z dd� Z dd � Z dS )!�FrameNFc K s� t }d}|d u r tj}d}|d ur|}t| j�} d| _|| _d| _d | _d | _ d | _ d | _ |r3tj | _ t |t�r<td��|d u rMt| �} t| � d| _d S t|ttt�t|���}d} |d u rk|rh||k rhd} nd} n|} | r�t| |�} t| � tt| �||� d| _d S |r�t� } | | _ t�| �| _ td u r�ddl m a ttt �t t t ���} t�!|| j �| _"tj#s�t$� | _%tt&| j%�t_#n ttt'�tt&tj#��| _%tttt&tj(j)��| _*t+| tt|�|ttt,�t-�tt| ��} | dkr�t.| � t| � d| _d S )Nr FTz8Str objects not allowed. Only: bytes, buffer interfaces.)�gc)/r �zmq�COPY_THRESHOLDr r� �more�_data� _failed_init�_buffer�_bytes� tracker_event�tracker�_FINISHED_TRACKER� isinstance�str� TypeErrorrY r� r� r r r r[ r+ rU r ZMessageTracker�_gcZzmq.utils.garbager� r� r* r �storer� Z _push_mutexr/ r� r r1 Z _push_socket� underlyingr� rZ rN r� r) )�selfr� �track�copy�copy_threshold�kwargsr� r� Zc_copy_thresholdZ zmq_msg_ptrr Zc_copyZevtr� r� r� r� �__init__ sz � zFrame.__init__c C sH | j rd S t� tt| j��}W d � n1 sw Y t|� d S �N)r� r rS r r� r� �r� r r� r� r� � __dealloc__z s � zFrame.__dealloc__c C s | � � S r� )� fast_copy�r� r� r� r� �__copy__� s zFrame.__copy__r� c C sf t � }tt|j�t| j�� | jd ur| j|_| jd ur | j|_| jd ur)| j|_| j|_| j|_|S r� ) r� rT r r� r� r� r� r� r� )r� Znew_msgr� r� r� r� � s zFrame.fast_copy�buffer�pointer(Py_buffer)r� r� c C s` t t| j��|_tt| j��|_| |_d|_d|_d|_ t|j�|_ t |_ t |_ d|_t |_d S )Nr �B� )rU r r� r� rb r� r� �readonly�format�ndim�shaper �strides� suboffsets�itemsizeZinternal)r� r� r� r� r� r� � __getbuffer__� s zFrame.__getbuffer__r c C s t t| j��}|S )z*Return the length of the message in bytes.)rb r r� )r� �szr� r� r� �__len__� s z Frame.__len__c C s0 | j o| � � }|dur |S t| �}t|�| _ |S )z%A memoryview of the message contents.N)r� � memoryviewr )r� r� r� r� r� r� � s z Frame.bufferc C s | j du r tt| j��| _ | j S )z�The 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. N)r� r� r r� r� r� r� r� r� � s z Frame.bytesc C s� d}t }t|t�rtt| j�|�}t|� |S |dkr,tt| j��}|dkr*td� |S |dkrDtt| j��}|t kr?td� |� d�S t dd� t|t �rS|� d�}t|t �s_td|����|}tttt| j�|��}|t krttd� |� d�S ) 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~ �group�utf8�� r� zget string propertieszexpected str, got: )r r� rz rV r r� r� r] rX �decodery r� �encoder� r� r r rW )r� �optionr Z property_cr� r� �resultr� r� r� �get� s4 z Frame.getc C s~ |dkr|}t t| j�|�}t|� dS |dkr0t|t�r"|�d�}tt| j�|�}t|� dS tt| j�||�}t|� dS )am 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. r� Nr� r� ) ra r r� r� r� r� r� r` r_ )r� r� �valuer� r r� r� r� �set� s z Frame.set)NFNN)r� r� )r� r� r� r� )r� r )�__name__� __module__� __qualname__r� r� r� r� r� r� �propertyr� r� r� r� r� r� r� r� r� s �a 6r� c @ sV e Zd ZdZdddd �Zed d � �Zeedd d���Z dd� Z ddd�Z ddd�Z dS )�Contextz� Manage the lifecycle of a 0MQ context. Parameters ---------- io_threads : int The number of IO threads. r� r � io_threadsr� �shadowr c C sz t | _d| _d| _|rtt|�| _d| _nd| _t� | _| jt kr$t� �d}| js4t| jt |�}t |� d| _ t � | _d S )Nr FT) r �handle�_pid�_shadowr r rI rx rJ r8 r� �closedr. )r� r� r� r r� r� r� r� % s zContext.__init__c C � t t| j�S )z,The address of the underlying libzmq context�r r r� r� r� r� r� r� < � zContext.underlyingr� c C sX d}| j tkr'| js't� | jkr't� t| j �}W d � n1 s"w Y t| _ |S �Nr )r� r r� r. r� r rG r� r� r� r� �_termA s �z Context._termc C s2 | � � }zt|� W n ty Y nw d| _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)r� r� rw r� r� r� r� r� �termK s � z Context.termr� c C sD | j rtd��t|t�std|����|}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 destroyed�expected int, got: N)r� � RuntimeErrorr� rz r� rJ r� r� )r� r� �optval� optval_int_cr r� r� r� r� \ s z Context.setc C s* | j rtd��t| j|�}t|dd� |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� )r� r� rH r� r� )r� r� r r� r� r� r� } s z Context.getN)r� r )r� r� r� r �r� r� �r� r� ) r� r� r� �__doc__r� r� r� r r r� r� r� r� r� r� r� r� r� s !r� c C s< t | t�r | �d�} z| }W |S ty td| ����w )zycast 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=)r� r� r� r� )�addr�c_addrr� r� r� �_c_addr� s ��r� c @ s� e Zd ZdZ d9d:d d �Zed d � �Zed d� �Zd;d<dd�Zd=dd�Z d=dd�Z d>dd�Z d?d d �Z d>d d!�Z d>d"d#�Zefd@d&d'�ZdAd)d*�Zd+d,� ZdBdCd2d3�ZdBdCd4d5�Zddd6�dDd7d8�ZdS )E�Socketa2 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� r� r c C s� t | _t | _d| _d| _d | _|d u rtj}|| _t | _|| _|r+d| _t t |�| _n|d u r3t d��|dk r;t d��d| _t | jj|�| _| jt krNt � �d| _t� | _d S )Nr FTzcontext must be specifiedz socket_type must be specified)r r� � _draft_pollerr� r� �contextr� r� r� r r r� rm rx �_closedr. )r� r� r� r� r� r� r� r� r� � s. zSocket.__init__c C r� )z+The address of the underlying libzmq socketr� r� r� r� r� r� � r� zSocket.underlyingc C s t | �S )z Whether the socket is closed)�_check_closed_deepr� r� r� r� r� � s z Socket.closed�linger� int | Nonec C s� d}d}|dur |}d}| j tkrQ| jsSt� | jkrU|r(t| j tt|�tt �� | j tkr7t t| j �� t| _ t | j �}|dk rIt � tkrIt|� d| _t| _ dS dS dS dS )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. r FNT)r� r r� r. r� rl r9 r r rz r� re rE r� r% r� )r� r� r Z setlingerZlinger_cr� r� r� �close� s" �z Socket.closer� c C s t | � t|t�r td��zt|�}W n ty tj}Y nw |j}|tj krFt|t �s4td|����t |�}t |�}t | j |||� dS |tjkrgt|t�sWtd|����|}t | j |t|�tt�� dS t|t�sstd|����|}t | j |t|�tt�� dS )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_closedr� r� r� rs r� rt rz � _opt_typer� r r � _setsockoptr� �int64r r rC ) r� r� r� �sopt�opt_typeZoptval_cr� �optval_int64_cr� r� r� r� r� s0 � z Socket.setc C sf t t�}t tj�}t t�}t td �}t| � zt|�}W n ty) t j}Y nw |j }|t j krbd}t | j |tt|�t|�� |tkrX|dkrXtt|�|d dkrX|d8 }ttt|�|�} | S |t jkr~tt�}t | j |ttt|��t|�� |} | S |tkr�| jtkr�t| jt|��} t| � |} | S |t jk�r tt�}zt | j |ttt|��t|�� W |} | S t �y } zY|tk�r | j t j j k�r | �!t"��r t#dd� t j$s�t%d��t&j't j(�)� dd � t*� | _| jtkr� t+| j| j tt,t-B �} t| � t| jt|��} t| � n� W Y d } ~ |} | S d } ~ ww tt�}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. � r r� � )r� r � z)draft socket FD support via zmq_poller_fd�1libzmq and pyzmq must be built with draft supportr )� stacklevelN).r rC �Crz rB r r� rs r� rt r r� � _getsockoptr� r r r r7 r r r r r6 r� r rf r� �fdrx r� r� ZErrno�EINVALr� r? ry � DRAFT_APIr� �warnings�warn�errorZDraftFDWarningrg rd r: r; ) r� r� r r� Z optval_fd_cZidentity_str_cr r r� r� r �er� r� r� r� U s� � A ��;�6 ��% � ��� � � ��)�z Socket.getr� � str | bytesc C s� t |�}|}t| � t| j|�}|dkrMt� }t� }|r6|tkr6|�dd�d }d|� d|� d�}t|d��|t krM|�dd�d }d |� d �}t|d�� zt |� W d S t yd t| j|�}Y qMw ) 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. r z://r� r~ 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).)r� z(No such file or directory for ipc path "z".TN) r� r� rD r� r� r- r# �splitrx r$ r� rw ) r� r� � _addr_bytesr� r Z_errnoZ_ipc_max�pathr� r� r� r� �bind� s0 � � �z Socket.bindr� �Nonec C sD t |�}|}t| � z t| j|�}t|� W dS ty! Y q w )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)r� r� rF r� r� rw �r� r� r r� r r� r� r� �connect� s ��zSocket.connectc C �2 t |�}|}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. r N)r� r� rp r� rx r r� r� r� �unbind s �z Socket.unbindc C r )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. r N)r� r� rM r� rx r r� r� r� � disconnect) s �zSocket.disconnect�str | bytes | None�eventsc C s6 t }|dur 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 r� r� r� rn r� )r� r� r r� r r� r� r� �monitor@ s zSocket.monitorr� c C sH t dd� tjs td��t|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 �r� r � RADIO-DISHr r� N) ry r� r r� r� r� r� rQ r� r� )r� r� Zc_groupr r� r� r� �join] s z Socket.joinc C s0 t dd� tjs td��t| 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 r" r# r N)ry r� r r� rR r� r� )r� r� r r� r� r� �leavep s z Socket.leaveTFr� r r� c C s� t | � t|t�r td��|rt|t�st| j||�S t|t�r,|r)|js)td��|}n#| j rGt |�}|j }| j }||k rGt| j||� t j S t||| j d�}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)r� r� )r� r� r� r� r� � _send_copyr� r� r� r� r� �nbytesr� r� � _send_frame) r� r� r� r� r� r� r� r' r� r� r� r� �send� s$ * z Socket.sendc C sZ t | � |r t| j|�S t| j||�}d}tt�}t| jttt t |��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_framer r r r< r r r r� )r� r� r� r� �framer� r� r� r� r� �recv� s �z Socket.recv)r' r� c C s� |}t | � |}|dk rtd|�d���t|�}tttj��}t|t|�d�}|dkr.|}n||kr=td|�d|� d��� t � t | j |||�} W d � n1 sSw Y zt | � W | S t yh Y q=w )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. r znbytes=z must be non-negativeTz too big for memoryview of r� N)r� r� r� r r r Zvoidr� r r rk r� r� rw ) r� r� r' r� Zc_flagsZc_nbytes�viewZc_dataZ view_bytesr r� r� r� � recv_into� s, ' � ��zSocket.recv_into)Nr~ r N)r� r� r� r r� )r� r� r� )r� r )r� r r� r )r� r r r� )r� r )r TF)r� r r� r r� )r� r� r� r� r� r� r� r� r� r� r� r r r r r5 r! r$ r% r) r- r/ r� r� r� r� r� � s0 �# " A v - B.r� �sc C s | j rtt��dS )zDraise ENOTSUP if socket is closed Does not do a deep check N)r� rx r% )r0 r� r� r� r� 3 s �r� c C sv t tj�}tt�}| jrdS t| jttt t |��t |��}|dk r5t � }|t kr-d| _dS |t kr3dS dS t|� dS )z�thorough 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 Tr F)r r rz r r� rO r� r@ r r r r� r% r4 r� )r0 �styper� r r� r� r� r� r� > s" ��r� r� r� r� c C sl t j|d�}|} t� tt|j�| |�}W d � n1 s w Y zt|� W |S ty5 Y qw )z=Receive a message in a non-copying manner and return a Frame.)r� TN)r� r� r r\ r r� r� rw )r� r� r� r� Zcmsgr r� r� r� r+ ` s � ��r+ c C s� t t�}t|�}t|�}t|� t� t|| |�}W d � n1 s$w Y zt|� W n ty8 Y q tyC t |� � w t |�}t |� |S )z#Receive a message and return a copyTN) r rc r rY r� r r\ rw � ExceptionrS r� )r� r� r� Z zmq_msg_pr Z msg_bytesr� r� r� r* t s( � �r* r� c C sf |� � } t� tt|j�| |�}W d � n1 sw Y z t|� W |jS ty2 Y qw )z1Send a Frame on this socket in a non-copy manner.TN)r� r r^ r r� r� rw r� )r� r� r� Zmsg_copyr r� r� r� r( � s � ��r( c C s� t t�}t t�}t|t|��}tt|�|�}t|� t� tt t|��|t t|��� t t|�| |�}W d � n1 s>w Y zt|� W n t yR Y q t y_ tt|�� � w tt|��}t|� dS )z5Send a message on this socket by copying its content.TN)r rc r r� r r[ r� r r+ rU rb r^ rw r2 rS )r� r� r� r� Zc_bytesZ c_bytes_lenr r� r� r� r& � s* � � r& r� r� r� �pointer(size_t)c C �6 d} t | |||�}zt|� W dS ty Y qw )zXgetsockopt, retrying interrupted calls checks rc, raising ZMQError on failure. r TN)rO r� rw �r� r� r� r� r r� r� r� r � � ��r c C r4 )zXsetsockopt, retrying interrupted calls checks rc, raising ZMQError on failure. r TN)rl r� rw r5 r� r� r� r � r6 r c C s t � S )z6Return the integer errno of the most recent zmq error.)r� r� r� r� r� rq � s rq r� r� c C s t | �}|�dd�S )z9 Return the error string given the error number. r� �replace)ro r� )r� Zstr_er� r� r� �strerror� s r8 �tuple[int, int, int]c C s. d} d}d}t t| �t|�t|�� | ||fS )z9Return the version of ZeroMQ itself as a 3-tuple of ints.r )rA r )�major�minorZpatchr� r� r� �zmq_version_info� s r< � capabilityc C s t dd� | �d�}tt|��S )zxCheck for zmq capability by name (e.g. 'ipc', 'curve') .. versionadded:: libzmq-4.1 .. versionadded:: 14.1 r� zzmq.hasr� )ry r� r| rP )r= Zccapr� r� r� �has s r> �tuple[bytes, bytes]c C s< t td �} t td �}tdd� t| |�}t|� | |fS )ur generate 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. �@ )r� r � curve_keypair)r r ry rK r� )� public_key� secret_keyr r� r� r� rA s rA c C s` t | t�r | �d�} t| �dkstd��ttd �}| }tdd� t||�}t |� |dd� S )uh Compute 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 stringr@ r" � curve_publicN) r� r� r� r� r� r r ry rL r� )rC rB Z c_secret_keyr r� r� r� rE * s rE �timeoutc C s| t }t| �}|dkr g S ttt�t|tt� ��}|t kr!td��t|�D ]~}| | \}}t |t �rKtt |�j || _ d|| _ ||| _d|| _q%t |t�rg|}t || _ ||| _ ||| _d|| _q%t|d�r�zt|�� �}W n ty� t|� td��w t || _ ||| _ ||| _d|| _q%t|� td|����d}zU t� } t� t|||�} W d � n1 s�w Y zt| � W n/ ty� |dkr�t� } td| | �}|dk r�t � d |� d �t � d}t d|| �}Y q�w W n t�y t|� � w g } t|�D ](}|| j} | dk�r6|| j t k�r*| | d }n|| j }| � || f� �qt|� | S ) ae zmq_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. r z Could not allocate poll items�filenoz'fileno() must return a valid integer fdzFSocket must be a 0MQ socket, an integer fd or have a fileno() method: TNi� z,Negative elapsed time for interrupted poll: z. Did the clock change?)!r r� r r rh r* r � MemoryError�ranger� r� r� �socketr r �reventsrz �hasattrrG r2 r) r� r� r r � zmq_poll_cr� rw r r �RuntimeWarning�max�append)ZsocketsrF Z pollitemsZnsockets�ir0 r rG Z ms_passed�startr Ztic�resultsrK r� r� r� rr K s� � �� � ��� �rr �frontend�backend�capturec C st d}t |t�r |j}nt} t� t| j|j|�}W d � n1 s#w Y zt|� W |S ty9 Y q w )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. r TN)r� r� r� r r ri r� rw )rT rU rV r �capture_handler� r� r� �proxy� s � ��rX �controlc C s� d}t |t�r |j}nt}t |t�r|j}nt} t� t| j|j||�}W d � n1 s/w Y zt|� W |S tyE Y qw )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. r TN)r� r� r� r r rj r� rw )rT rU rV rY r rW Zcontrol_handler� r� r� �proxy_steerable� s( � � ��rZ � in_socket� out_socket� side_socketrc �side_msg�id_msg�swap_idsc C s� t t�}t t�}tt�}|r�tt|�| d�} | dk r | S tt|�| d�} | dk r*| S tt|�t|��} | dk r9| S tt|�|t�} | dk rG| S tt|�|t�} | dk rU| S tt|�t|��} | dk rd| S tt|�|t�} | dk rr| S tt|�|t�} | dk r�| S tt|�| d�} | dk r�| S t | t t|�t|��} | dk r�| S d} |r�| tO } tt|�t|��} | dk r�| S | r�tt|�|| �} | dk r�| S tt|�|t�} | dk r�| S n tt|�|d�} | dk r�| S tt|�|d�} | dk r�| S | S q�r� ) r r rz r r\ r rT r^ r> rO r< ) r[ r\ r] r� r^ r_ r` Zflagszr� r r� r� r� r� � _mq_relay st ��ra � in_msg_ptr� out_msg_ptrc C s� t t�}tt|��}t t�}tt|��}|dk r|S t t�} tt| ��}|dk r*|S t td �} | | d _t| d _d | d _| d _ || d _t| d _d | d _| d _ t t| d �dd�}|dk ri|S | d j t@ r�t t| �|�}|dk r}|S t t| �|t �}|dk r�|S t| |||| ||�}|dk r�|S | d j t@ r�t t| �|�}|dk r�|S t t| �|t �}|dk r�|S t|| ||| ||�}|dk r�|S qY)z. inner C function for monitored_queue r r r� Tr~ )r rc rY r rh rJ r: r r rK rM rT r^ r> ra ) r[ r\ r] rb rc r` r� r r_ r^ �itemsr� r� r� � _mq_inline_ s\ ���re � in� out� mon_socket� in_prefix� out_prefixc C s& | j }|j }|j }tt�}tt�} t} tt�} | jtko |jtk} t|t| ��} t t|�| �} t | � t t t|��| t t|��� t|t| ��} t t| �| �} t | � t�# t t t| ��| t t| ��� t|||t|�t| �| �} W d � n1 s|w Y zt | � W | S ty� Y qSw )a� Start a monitored queue device. A monitored queue is very similar to the zmq.proxy device (monitored queue came first). Differences from zmq.proxy: - monitored_queue supports both in and out being ROUTER sockets (via swapping IDENTITY prefixes). - monitor messages are prefixed, making in and out messages distinguishable. Parameters ---------- in_socket : zmq.Socket One of the sockets to the Queue. Its messages will be prefixed with 'in'. out_socket : zmq.Socket One of the sockets to the Queue. Its messages will be prefixed with 'out'. The only difference between in/out socket is this prefix. mon_socket : zmq.Socket This socket sends out every message received by each of the others with an in/out prefix specifying which one it was. in_prefix : str Prefix added to broadcast messages from in_socket. out_prefix : str Prefix added to broadcast messages from out_socket. TN)r� r rc r r �typer= r� r r[ r� r+ rU rb r re rw )r[ r\ rh ri rj ZinsZoutsZmonsZin_msgZout_msgZmsg_cZ msg_c_lenr` r r� r� r� �monitored_queue� s> " �� � ��rl )r{ r} r� r� r� r> rA rE r< rq rr r8 rX rZ )F)r r� r� r r� r� )r� r r� r r� r� )r� r� r� r� )r� r� r� r r� r )r� r� )r0 r� )r0 r� r� r )r F)r� r r� r� r� r r� r� )r )r� r r� r� )r� r r� r� r� r� )r� r r� r� r� r r� r3 )r� r r� r� r� r r� r r� )r� r� r� r� )r� r9 )r= r� r� r| )r� r? )r~ )rF r� r� )rT r� rU r� rV r� )NN)rT r� rU r� rV r� rY r� )r[ r r\ r r] r r� rc r^ rc r_ rc r` r r� r� )r[ r r\ r r] r rb r� rc r� r` r r� r� )rf rg ) r[ r� r\ r� rh r� ri r� rj r� )�r� � __future__r ZcythonZcompiled� ImportError�pathlibr �__file__�parentsZzmq_rootr� r � threadingr �timer �weakrefr r r r r r r r r r r r r r r r r r Z cython.cimports.cpython.bufferr r r r r Z cython.cimports.cpython.bytesr r r Zcython.cimports.cpython.excr Zcython.cimports.libc.errnor! r" r# r$ r% Zcython.cimports.libc.stdintr& Zcython.cimports.libc.stdior' r( r� Zcython.cimports.libc.stdlibr) r* Zcython.cimports.libc.stringr+ Z"cython.cimports.zmq.backend.cythonr, Z+cython.cimports.zmq.backend.cython._externsr- r. r/ r0 r1 r2 Z)cython.cimports.zmq.backend.cython.libzmqr3 r4 r5 r6 r7 r8 r9 r: r; r< r= r> r? r@ rA rB rC rD rE rF rG rH rI rJ rK rL rM rN rO rP rQ rR rS rT rU rV rW rX rY rZ r[ r\ r] r^ r_ r` ra rb rc rd re rf rg rh ri rj rk rl rm rn ro rp rq r� rr rM r� Z zmq.constantsrs rt Z zmq.errorru rv rw rx ry r{ �__annotations__r| r} Z exceptvalr� �structr� r� r� r� r� r� r� r� r� r� r� r+ r* r( r& r r r8 r< r> rA rE rX rZ ra re rl �__all__r� r� r� r� �<module> s� � ��� H � @ �+ ! n% �1PG � L
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings