File: //lib64/python3.6/site-packages/zmq/backend/cffi/__pycache__/socket.cpython-36.pyc
3
VS�_�# � @ 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} | |kr t� S | |kr.t|�S t� S d S )Nr )�int64_sockopts�bytes_sockopts)�zmq.sugar.constantsr r r r r )�option�lengthr r � r � /usr/lib64/python3.6/socket.py�new_pointer_from_opt s r c C sP ddl m}m} | |kr$t|d �S | |kr@tj||�d d � S t|d �S d S )Nr )r 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} | |kr t|�S | |kr2t||�S t|�S d S )Nr )r 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 k r4t|t�r |j}tjd|�| _d| _nd| _tj |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 tjd| 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 sZ | j r
dS y| jtj� W n: tk
rT } z |jtjkrBd| _ dS � W Y dd}~X nX 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 �errnoZENOTSOCK)r+ �er r r �_check_closed_deepV s zSocket._check_closed_deepc C s | j � S )N)r2 )r+ r r r �closedj s z
Socket.closedc C s\ d}| j rHt| d�rH| jd k rB|d k r6| jtj|� tj| j�}d| _ |dk rXt|� d S )Nr r' T) r* �hasattrr' �setr/ ZLINGERr Z zmq_closer )r+ Zlinger�rcr r r �closen s
z Socket.closec C s� t |t�r|jd�}tj| j|�}|dk r�tr~tj� tj kr~t
tkrP|j dd�}|j dd�d
}dj
|t�}ttj� |d��nVtj� tjkr�t
tkr�|j dd�}|j dd�d }d j
|�}ttj� |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$ r �encoder Zzmq_bindr' r
Z zmq_errno� errno_modZ ENAMETOOLONG�str�decode�split�formatr �ENOENTr )r+ �addressr6 �pathr: r r r �bindy s&
z Socket.bindc C s8 t dd� t|t�r |jd�}tj| j|�}t|� d S )N� � �unbindr8 )rF rG )r r$ r r< r Z
zmq_unbindr' r )r+ rC r6 r r r rH � s
z
Socket.unbindc C s. t |t�r|jd�}tj| j|�}t|� d S )Nr8 )r$ r r< r Z zmq_connectr' r )r+ rC r6 r r r �connect� s
zSocket.connectc C s8 t dd� t|t�r |jd�}tj| j|�}t|� d S )NrF rG �
disconnectr8 )rF rG )r r$ r r< r Zzmq_disconnectr' r )r+ rC r6 r r r rJ � s
zSocket.disconnectc C s| d }t |t�rtd��t |t�r@|tjjkr8td| ��t|�}t|||�}|d }|d }t t
j | j |t
jd|�|� d S )Nz unicode not allowed, use bytesznot a bytes sockopt: %sr r zvoid*)r$ r � TypeError�bytesr/ � constantsr �lenr! r r Zzmq_setsockoptr' r r& )r+ r r r �c_data�c_value_pointerZc_sizetr r r r5 � s
z
Socket.setc C st t |dd�}|d }|d }ttj| j|||� |d }t|||�}|tjkrp|tjj krp|j
d�rp|d d� }|S )N� )r r r � r; ) r r r Zzmq_getsockoptr' r r/ ZIDENTITYrM r �endswith)r+ r rO rP Zc_sizet_pointerZsz�vr r r r. � s z
Socket.getc C s� t |t�rtd��t |t�r"|j}tjd�}t |t�sBt|�j� }tjd|�}t j
|t |��}t |� t j
t j|�|t |�� tt j|| j|� t j|�}t |� |r�tj� S d S )Nz/Message must be in bytes, not an unicode Objectz
zmq_msg_t*zchar[])r$ r rK r rL r �new�
memoryview�tobytesr Zzmq_msg_init_sizerN r Zmemcpy� zmq_msg_datar Z zmq_msg_sendr' �
zmq_msg_closer/ ZMessageTracker) r+ �message�flags�copy�track�zmq_msgZ c_messager6 Zrc2r r r �send� s
z Socket.sendTc C s� t jd�}tj|� yttj|| j|� W n tk
rJ tj|� � Y nX t j tj
|�tj |��}|d d � }tj|�}t |� t
||d�}| jt�|_|r�|jS |S d S )Nz
zmq_msg_t*)r] )r rU r Z zmq_msg_initr Z zmq_msg_recvr' � ExceptionrY r rX Z zmq_msg_sizer r Z
getsockoptr ZmorerL ) r+ r[ r\ r] r^ Z_bufferr r6 �framer r r �recv� s
z Socket.recvr c C sN t dd� |dk rtj}|dkr&tj}t|t�r:|jd�}tj | 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.
rF rG �monitorr Nr8 )rF rG ) r r/ Z EVENT_ALLr r) r$ r r< r Zzmq_socket_monitorr' )r+ ZaddrZeventsr6 r r r rc � s
zSocket.monitor)NNN)N)r FF)r TFr; )r; )�__name__�
__module__� __qualname__r# r, r' r* Z_refr( Zcopy_thresholdr- �propertyr% r2 r3 r7 rE rH rI rJ r5 r. r_ rb rc r r r r r" : s*
r" r
)r )r )r )"�__doc__r0 r= Z_cffir r r r r r r r
r r r
rZ r rM r Zutilsr r/ Z zmq.errorr r r Zzmq.utils.strtypesr r r r! �objectr" �__all__r r r r �<module> s 4
^