File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/zmq/backend/cffi/__pycache__/message.cpython-310.pyc
Back
o ;j � @ s� d Z ddlZddlmZ ddlZddlZddlmZ ddlm Z ddlm Z da zddl mZ W n ey; eZY nw d d � Zd d � ZG d d� de�ZeZddgZdS )zDummy Frame object� N)�Event)�ETERM� )�ffi)�lib)� bufferablec C s* t | �tu r| S t| t�st| �} | �� S )z Return content of obj as bytes)�type�bytes� isinstance� memoryview�tobytes)�obj� r �L/opt/saltstack/salt/lib/python3.10/site-packages/zmq/backend/cffi/message.py�_content s r c C s` t �� }| dkr.|tjkrtj�|��|tjkr tj�t��|t kr(tj� |��tj� |��dS )N���r ) �CZ zmq_errno�errnoZEINTR�zmq�errorZInterrruptedSystemCall�EAGAINZAgainr ZContextTerminatedZZMQError)�rc�errr r r � _check_rc! s r c @ s� e Zd ZdZdZdZdZdZdZdZ dZ dZ ddd�Z dd� Z dd� Zd d � Zed d � �Zed d� �Zdd� Zdd� Zedd� �Zdd� Zdd� Zdd� ZdS ) �FrameNFc C s� d| _ t�dt�t�d���| _|rtj| _ t |t �r t d��|d u r2t� | j�}t|� d| _ d S || _t|�tu r>|| _t|�| _| jjsKtd��t�| j�}| jj}|d u rd|rb||k rbd}nd}|r�t�| j|�}t|� | jt�t�| j�|�d d �< d| _ d S |r�t � }|| _ t� |�| _ t d u r�ddl m!a t�d t�t�d ���} t �"|| j �| d _#t j$s�t�%� t _$t�d t j$�| d _&t�d t j'j(�| d _)t�*| j||| �}|dkr�t�+| � t�+| j� t|� d| _ d S ) NTz zmq_msg_t[1]Z zmq_msg_tz@Unicode strings are not allowed. Only: bytes, buffer interfaces.Fz/memoryview: underlying buffer is not contiguousr )�gczzhint[1]Zzhintzmutex_t*zvoid*),� _failed_initr �castr Zmalloc�sizeof�zmq_msgr Z_FINISHED_TRACKER�trackerr �str� TypeErrorZ zmq_msg_initr �_datar r �_bytesr �_buffer� contiguous� BufferError� from_buffer�nbytesZzmq_msg_init_size�buffer� zmq_msg_datar � tracker_eventZMessageTracker�zmq_gcZzmq.utils.garbager �store�idZ _push_mutexZmutex_allocate�mutexZ _push_socketZ underlying�sockZzmq_wrap_msg_init_data�free) �self�dataZtrack�copyZcopy_thresholdr Zc_dataZ data_len_cZevt�hintr r r �__init__: sl � � zFrame.__init__c C s | j s | js| �� d S d S d S �N)�closedr �close�r3 r r r �__del__� s �z Frame.__del__c C sV | j s | js | jd u r d S d| _ t�| j�}t�| j� d | _|dkr)t|� d S d S )NTr )r9 r r r Z zmq_msg_closer2 r )r3 r r r r r: � s �z Frame.closec C sF | j du rt�t�| j�t�| j��| _ | jdu r!t| j �| _dS dS )zQone-time extract buffer from zmq_msg for Frames created by recv N) r# r r* r r+ r Z zmq_msg_sizer% r r; r r r �_buffer_from_zmq_msg� s � �zFrame._buffer_from_zmq_msgc C s | j d u r | �� | j S r8 )r% r= r; r r r r* � s z Frame.bufferc C s | j d u r | j�� | _ | j S r8 )r$ r* r r; r r r r � s z Frame.bytesc C s | j jS r8 )r* r) r; r r r �__len__� s z Frame.__len__c C s | j t|�kS r8 )r r )r3 �otherr r r �__eq__� s z Frame.__eq__c C s | j �� S r8 )r �doner; r r r rA � s z Frame.donec C s | j S r8 )r* )r3 �flagsr r r � __buffer__� s zFrame.__buffer__c C s | � � S )a< Create a shallow copy of the message. This does not copy the contents of the Frame, just the pointer. This will increment the 0MQ ref count of the message, but not the ref count of the Python object. That is only done once when the Python is first turned into a 0MQ message. )� fast_copyr; r r r �__copy__� s zFrame.__copy__c C s: t � }t�|j| j� | j|_| j|_| j|_| j|_|S )zPFast shallow copy of the Frame. Does not copy underlying data. )r r Z zmq_msg_copyr r# r% r, r )r3 Znew_msgr r r rD � s zFrame.fast_copy)NFNN)�__name__� __module__� __qualname__r# r r9 Zmorer% r$ r r, r r7 r< r: r= �propertyr* r r> r@ rA rC rE rD r r r r r / s2 T r �Message)�__doc__r � threadingr r Z zmq.errorZ zmq.constantsr Z_cffir r r r- Z__pypy__.bufferabler Zmaybe_bufferable� ImportError�objectr r r rJ �__all__r r r r �<module> s( � 1
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings