File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/zmq/backend/cffi/__pycache__/socket.cpython-310.pyc
Back
o ;j�7 � @ s d Z ddlZddlZddlZddlmZmZ ddlm Z m Z m Z ddl m Z ddl mZ ddlmZ dd lmZ d d � ZZd d � Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Z dd� Z e � d �Z e d kZ e�!� Z"d'd d �Z#d'd d!�Z$d'd"d#�Z%G d$d%� d%�Z&d%d&gZ'dS )(zzmq Socket class� N)� SocketOption�_OptType)�ZMQError� _check_rc�_check_version� )�ffi)�lib)�Frame)�_retry_sys_callc C s t �d| �S )Nzsize_t*)r �new��length� r �K/opt/saltstack/salt/lib/python3.10/site-packages/zmq/backend/cffi/socket.py�<lambda> s r c C � t �d�tt �d��fS �Nz uint64_t*Zuint64_t�r r �nsp�sizeofr r r r �new_uint64_pointer � r c C r �Nzint64_t*Zint64_tr r r r r �new_int64_pointer r r c C r �Nzint*�intr r r r r �new_int_pointer r r c C s& t �d| d�d��tt �d�| �fS )N�char[�d�]�charr r r r r �new_binary_data! s &r" c C � t �d| �t �d�fS r �r r r ��valr r r �value_uint64_pointer% � r' c C r# r r$ r% r r r �value_int64_pointer) r( r) c C r# r r$ r% r r r �value_int_pointer- r( r* c C s( t �d|d d�d�| �t �d�| fS )Nr r r r r! r$ )r& r r r r �value_binary_data1 s (r+ ZZMQ_FD_T� c C sD t | dtj�}|tjkstr|tjkrt� S |tjkr t|�S t � S �N� _opt_type) �getattrr r �int64� ZMQ_FD_64BIT�fdr �bytesr" r )�optionr �opt_typer r r �new_pointer_from_opt; s r6 c C sV zt | �} W n ty tj}Y nw | j}|tjkr%t�||�d d � S t|d �S )Nr )r � ValueErrorr r r. r3 r �buffer)r4 Z opt_pointerr r5 r r r �value_from_opt_pointerG s � r9 c C sJ t | dtj�}|tjkstr|tjkrt|�S |tjkr!t||�S t |�S r- ) r/ r r r0 r1 r2 r) r3 r+ r* )r4 �valuer r5 r r r �initialize_opt_pointerX s r; c @ s� e Zd ZdZdZdZdZdZdZdZ dZ dZ d,dd�Z e dd� �Zdd � Ze d d � �Zd-d d �Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd.d d �Zd/d!d"�Zddd#�d$e d%e d&e fd'd(�Z d0d*d+�Z dS )1�SocketNFr c C sr |d u rt j}|| _|| _d | _| _|r t�d|�| _d| _ n d| _ t � |j |�| _| jtj kr4t� �d| _d S )N�void *TF)�zmqZCOPY_THRESHOLD�copy_threshold�context� _draft_poller�_draft_poller_ptrr �cast� _zmq_socket�_shadow�CZ zmq_socketZ_zmq_ctx�NULLr �_closed)�selfr@ � socket_typeZshadowr? r r r �__init__m s zSocket.__init__c C s t t�d| j��S )z+The address of the underlying libzmq socketZsize_t)r r rC rD �rI r r r � underlying~ s zSocket.underlyingc C st | j rdS z | �tj� W dS ty9 } z |jtjkr&d| _ W Y d}~dS |jtjkr-n� W Y d}~dS d}~ww )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 TNF)rH �getr> ZTYPEr �errno�ENOTSOCKZETERM)rI �er r r �_check_closed_deep� s � ���zSocket._check_closed_deepc C s | � � S �N)rR rL r r r �closed� s z Socket.closedc C s� d}| j s4t| d�r4| jd urt�| j�}d | _| _| jd ur1|d ur+| �tj |� t� | j�}d| _ |dk r>t |� d S d S )Nr rD T) rH �hasattrrB rF Zzmq_poller_destroyrA rD �setr> ZLINGERZ zmq_closer )rI Zlinger�rcr r r �close� s �z Socket.closec C s� t |t�r |�d�}n|}t |t�r|�d�}t�| j|�}|dk rgtrDt� � t j krD|� dd�d }d|� dt� d�}t t� � |d ��t� � t jkra|� dd�d }d |� d �}t t� � |d ��t|� d S d S ) N�utf8r z://r ���z ipc path "z" is longer than z+ characters (sizeof(sockaddr_un.sun_path)).)�msgz(No such file or directory for ipc path "z".)� isinstance�str�encoder3 �decoderF Zzmq_bindrD �IPC_PATH_MAX_LENZ zmq_errno� errno_modZ ENAMETOOLONG�splitr �ENOENTr )rI �addressZ address_brW �pathr[ r r r �bind� s$ � �z Socket.bindc C �. t |t�r |�d�}t�| j|�}t|� d S �NrY )r\ r] r^ rF Z zmq_unbindrD r �rI rd rW r r r �unbind� � z Socket.unbindc C rg rh )r\ r] r^ rF Z zmq_connectrD r ri r r r �connect� rk zSocket.connectc C rg rh )r\ r] r^ rF Zzmq_disconnectrD r ri r r r � disconnect� rk zSocket.disconnectc C s� d }t |t�r td��zt|�}W n ty tj}Y nw |j}t |t�r6|tjkr2td|� ���t |�}t |||�\}}t t j | j|t�d|�|� d S )Nz unicode not allowed, use bytesznot a bytes sockopt: �void*)r\ r] � TypeErrorr r7 r r r. r3 �lenr; r rF Zzmq_setsockoptrD r rC )rI r4 r: r r5 �c_value_pointerZc_sizetr r r rV � s* � �z Socket.setc C s� zt |�}W n ty tj}Y nw |j}|tjkr7| jd ur7t|�\}}t � | jt � d|�� t|d �S t|dd�\}}z t t j| j|||� W n� ty� } zt|t jkr�|jtjjkr�| �t j�r�tdd� tjsqtd��tjtj� � dd � t � d �| _ t � � | j d< | _| jt j kr�d | _ | _� t �!| j| jt j tj"tj#B �}t$|� t � | jt � d |��}t$|� t|d �W Y d }~S � d }~ww |d }t%|||�} |tj j&kr�|tj'kr�| �(d �r�| d d � } | S )Nrn r � r )� � � z)draft socket FD support via zmq_poller_fdz'libzmq must be built with draft supportru )� stacklevelzvoid*[1]r= � rZ ))r r7 r r r. r> ZFDrA r6 rF Z zmq_poller_fdr rC r Zzmq_getsockoptrD r rO ZErrno�EINVALrN Z THREAD_SAFEr Z DRAFT_API� RuntimeError�warnings�warn�errorZDraftFDWarningr rB Zzmq_poller_newrG Zzmq_poller_add�POLLIN�POLLOUTr r9 Z ROUTING_IDr3 �endswith) rI r4 r5 rq �_Zc_sizet_pointerrQ rW Zsz�vr r r rN � sp � � � ����# � z Socket.getc C s� t �d�}t|t�st|��� }t �d|�}t�|t|��}t |� t� t� |�|t|�� t tj || j|� t�|�}t |� dS )zSend a copy of a bufferable� zmq_msg_t*zchar[]N)r r r\ r3 � memoryview�tobytesrF Zzmq_msg_init_sizerp r Zmemcpy� zmq_msg_datar � zmq_msg_sendrD � zmq_msg_close)rI �buf�flags�zmq_msgZ c_messagerW Zrc2r r r � _send_copy: s zSocket._send_copyc C s2 |� � }|j}ttj|| j|� |j}|�� |S )z1Send a Frame on this socket in a non-copy manner.)Z fast_copyr� r rF r� rD �trackerrX )rI �framer� Z frame_copyr� r� r r r � _send_frameI s zSocket._send_framec C s� t |t�r td��|rt |t�s| �||�S d}t |t�r)|r&|js&td��|}n | jr?t|�}|j | jk r?| �||� t j S t||| jd�}d}| � ||�}|rU|� � |S )Nz.Message must be in bytes, not a unicode objectFzNot a tracked message)�trackr? T)r\ r] ro r r� r� r7 r? r� �nbytesr> Z_FINISHED_TRACKERr� rX ) rI �datar� �copyr� Z close_framer� r� r� r r r �sendT s( z Socket.sendTc C s� |r t �d�}t�|� n tj|d�}|j}z ttj|| j |� W n t y0 |r/t� |� � w |s5|S t � t� |�t�|��}|d d � }t� |�}t|� |S )Nr� )r� )r r rF Z zmq_msg_initr> r r� r Z zmq_msg_recvrD � Exceptionr� r8 r� Z zmq_msg_sizer ) rI r� r� r� r� r� �_bufferZ_bytesrW r r r �recvo s& � z Socket.recv)r� r� r� r� �returnc C s� t |�}|js td��|jrtd��|dk r td|�d���|j}|dkr(|}n||kr7td|�d|� d���t�|�}tt j | j |||�}t |� |S )Nz%Can only recv_into contiguous buffersz Cannot recv_into readonly bufferr znbytes=z must be non-negativez too big for memoryview of �B) r� � contiguous� BufferError�readonlyr7 r� r � from_bufferr rF Zzmq_recvrD r )rI r8 r� r� �viewZ view_bytesZc_bufrW r r r � recv_into� s zSocket.recv_intorZ c C sD |dk rt j}|du rtj}t|t�r|�d�}t�| j ||� dS )a s.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. r NrY ) r> Z EVENT_ALLr rG r\ r] r^ rF Zzmq_socket_monitorrD )rI �addr�eventsr r r �monitor� s zSocket.monitor)NNr NrS )r FF)r TF)rZ ) �__name__� __module__� __qualname__r@ rJ rD rH Z_refrE rA rB r? rK �propertyrM rR rT rX rf rj rl rm rV rN r� r� r� r� r r� r� r r r r r< b s: G r< r` )r )(�__doc__rO ra rz r> Z zmq.constantsr r Z zmq.errorr r r Z_cffir r rF �messager �utilsr r Znew_sizet_pointerr r r r" r' r) r* r+ r Z_fd_sizer1 Zget_ipc_path_max_lenr` r6 r9 r; r< �__all__r r r r �<module> s: S
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings