Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/backend/cffi/__pycache__/socket.cpython-39.pyc
Ðазад
a a�h�# � @ s� d Z ddlZddlmZmZmZmZmZm Z m Z m Z m Z m Z mZ ddlmZ ddlmZ ddlmZ ddlZddlmZmZmZ dd lmZ dd d �Z dd d �Z ddd�Z G dd� de �Z ddgZ!dS )zzmq Socket class� N� ) �C�ffi�new_uint64_pointer�new_int64_pointer�new_int_pointer�new_binary_data�value_uint64_pointer�value_int64_pointer�value_int_pointer�value_binary_data�IPC_PATH_MAX_LEN)�Frame)�RCVMORE)�_retry_sys_call)�ZMQError� _check_rc�_check_version)�unicodec C s8 ddl m}m} | |v r t� S | |v r.t|�S t� S d S �Nr )�int64_sockopts�bytes_sockopts)�zmq.sugar.constantsr r r r r )�option�lengthr r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/backend/cffi/socket.py�new_pointer_from_opt s r c C sP ddl m}m} | |v r$t|d �S | |v r@t�||�d d � S t|d �S d S r )r r r �intr �buffer)r Z opt_pointerr r r r r r �value_from_opt_pointer# s r c C s> ddl m}m} | |v r t|�S | |v r2t||�S t|�S d S r )r r r r r r )r �valuer r r r r r �initialize_opt_pointer. s r" c @ s� e Zd ZdZdZdZdZdZdZdZ d"dd�Z e dd� �Z dd � Z e d d � �Zd#d d �Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd$dd�Zd%d d �Zd&d d!�ZdS )'�SocketNFr c C sf || _ |d ur4t|t�r |j}t�d|�| _d| _nd| _t� |j |�| _| jtj kr\t � �d| _ d S )Nzvoid *TF)�context� isinstancer# � underlyingr �cast� _zmq_socket�_shadowr Z zmq_socketZ_zmq_ctx�NULLr �_closed)�selfr$ � socket_typeZshadowr r r �__init__C s zSocket.__init__c C s t t�d| j��S )z+The address of the underlying libzmq socketZsize_t)r r r' r( �r, r r r r& Q s zSocket.underlyingc C sf | j r dS z| �tj� W nF ty` } z.|jtjkrJd| _ W Y d}~dS � W Y d}~n d}~0 0 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 TNF)r+ �get�zmqZTYPEr �errno�ENOTSOCK)r, �er r r �_check_closed_deepV s zSocket._check_closed_deepc C s | � � S )N)r5 r/ r r r �closedj s z Socket.closedc C sZ d}| j sFt| d�rF| jd ur@|d ur4| �tj|� t�| j�}d| _ |dk rVt|� d S )Nr r( T) r+ �hasattrr( �setr1 ZLINGERr Z zmq_closer )r, Zlinger�rcr r r �closen s z Socket.closec C s� t |t�r|�d�}t�| j|�}|dk r�tr~t�� tj kr~t tu rP|� dd�}|� dd�d }d� |t�}tt�� |d ��nVt�� tjkr�t tu r�|� dd�}|� dd�d }d � |�}tt�� |d ��nt|� d S ) N�utf8r zutf-8�replacez://r ���zLipc path "{0}" is longer than {1} characters (sizeof(sockaddr_un.sun_path)).)�msgz-No such file or directory for ipc path "{0}".)r% r �encoder Zzmq_bindr( r Z zmq_errno� errno_modZ ENAMETOOLONG�str�decode�split�formatr �ENOENTr )r, �addressr9 �pathr> r r r �bindy s* � �z Socket.bindc C s8 t dd� t|t�r |�d�}t�| j|�}t|� d S )N�� � �unbindr; )r r% r r? r Z zmq_unbindr( r �r, rF r9 r r r rL � s z Socket.unbindc C s. t |t�r|�d�}t�| j|�}t|� d S )Nr; )r% r r? r Z zmq_connectr( r rM r r r �connect� s zSocket.connectc C s8 t dd� t|t�r |�d�}t�| j|�}t|� d S )NrI � disconnectr; )r r% r r? r Zzmq_disconnectr( r rM r r r rO � s zSocket.disconnectc C s| d }t |t�rtd��t |t�r@|tjjvr8td| ��t|�}t|||�}|d }|d }t t j | j |t �d|�|� d S )Nz unicode not allowed, use bytesznot a bytes sockopt: %sr r zvoid*)r% r � TypeError�bytesr1 � constantsr �lenr" r r Zzmq_setsockoptr( r r' )r, r r! r �c_data�c_value_pointerZc_sizetr r r r8 � s �z Socket.setc C st t |dd�}|d }|d }ttj| j|||� |d }t|||�}|tjkrp|tjj v rp|� d�rp|d d� }|S )N� )r r r � r= ) r r r Zzmq_getsockoptr( r r1 ZIDENTITYrR r �endswith)r, r rT rU Zc_sizet_pointer�sz�vr r r r0 � s � z Socket.getc C s� t |t�rtd��t |t�r"|j}t�d�}t |t�sBt|��� }t�d|�}t � |t |��}t |� t � t �|�|t |�� tt j|| j|� t �|�}t |� |r�t�� S d S )Nz/Message must be in bytes, not an unicode Object� zmq_msg_t*zchar[])r% r rP r rQ r �new� memoryview�tobytesr Zzmq_msg_init_sizerS r Zmemcpy� zmq_msg_datar Z zmq_msg_sendr( � zmq_msg_closer1 ZMessageTracker) r, �message�flags�copy�track�zmq_msgZ c_messager9 Zrc2r r r �send� s z Socket.sendTc C s� t �d�}t�|� zttj|| j|� W n tyH t�|� � Y n0 t � t� |�t� |��}|d d � }t�|�}t |� t ||d�}| �t�|_|r�|jS |S d S )Nr[ )rd )r r\ r Z zmq_msg_initr Z zmq_msg_recvr( � Exceptionr` r r_ Z zmq_msg_sizer r � getsockoptr �morerQ ) r, rb rc rd re �_bufferr! r9 �framer r r �recv� s z Socket.recvr= c C sN t dd� |dk rtj}|du r&tj}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. rI �monitorr Nr; ) r r1 Z EVENT_ALLr r* r% r r? r Zzmq_socket_monitorr( )r, �addr�eventsr9 r r r rm � s zSocket.monitor)NNN)N)r FF)r TF)r= )�__name__� __module__� __qualname__r$ r- r( r+ Z_refr) Zcopy_thresholdr. �propertyr& r5 r6 r: rH rL rN rO r8 r0 rf rl rm r r r r r# : s. r# r )r )r )r )"�__doc__r2 r@ Z_cffir r r r r r r r r r r ra r rR r �utilsr r1 Z zmq.errorr r r Zzmq.utils.strtypesr r r r" �objectr# �__all__r r r r �<module> s 4 ^
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка