| Server IP : 217.160.0.135 / Your IP : 216.73.217.85 Web Server : Apache System : Linux www 6.18.52-i1-ampere #1203 SMP Mon Sep 14 18:29:59 CEST 2026 aarch64 User : sws1074145052 ( 1074145052) PHP Version : 8.3.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /usr/lib/python3/dist-packages/zmq/sugar/__pycache__/ |
Upload File : |
�
mc�c�
� �Z � d Z ddlZddlmZ ddlmZ d� Z G d� dee� � ZeZdd gZ dS )
z 0MQ Frame pure Python methods.� N)�Frame� )�AttributeSetterc � � t j � | |� � t j st d|z � � �d S )Nz8libzmq and pyzmq must be built with draft support for %s)�zmq�error�_check_version� DRAFT_API� RuntimeError)�v�features �1/usr/lib/python3/dist-packages/zmq/sugar/frame.py�_draftr sH � ��I� � �Q��(�(�(� �=�
�� F�� P�
�
�
�
�
� c � � e Zd ZdZd� Zed� � � Zej d� � � Zed� � � Zej d� � � ZdS )r a� Frame(data=None, track=False, copy=None, copy_threshold=zmq.COPY_THRESHOLD)
A zmq message Frame class for non-copying send/recvs and access to message properties.
A ``zmq.Frame`` wraps an underlying ``zmq_msg_t``.
Message *properties* can be accessed by treating a Frame like a dictionary (``frame["User-Id"]``).
.. versionadded:: 14.4, libzmq 4
Frames created by ``recv(copy=False)`` can be used to access message properties and attributes,
such as the CURVE User-Id.
For example::
frames = socket.recv_multipart(copy=False)
user_id = frames[0]["User-Id"]
This class is used if you want to do non-copying send and recvs.
When you pass a chunk of bytes to this class, e.g. ``Frame(buf)``, the
ref-count of `buf` is increased by two: once because the Frame saves `buf` as
an instance attribute and another because a ZMQ message is created that
points to the buffer of `buf`. This second ref-count increase makes sure
that `buf` lives until all messages that use it have been sent.
Once 0MQ sends all the messages and it doesn't need the buffer of ``buf``,
0MQ will call ``Py_DECREF(s)``.
Parameters
----------
data : object, optional
any object that provides the buffer interface will be used to
construct the 0MQ message data.
track : bool [default: False]
whether a MessageTracker_ should be created to track this object.
Tracking a message has a cost at creation, because it creates a threadsafe
Event object.
copy : bool [default: use copy_threshold]
Whether to create a copy of the data to pass to libzmq
or share the memory with libzmq.
If unspecified, copy_threshold is used.
copy_threshold: int [default: zmq.COPY_THRESHOLD]
If copy is unspecified, messages smaller than this many bytes
will be copied and messages larger than this will be shared with libzmq.
c �, � | � |� � S )N)�get)�self�keys r � __getitem__zFrame.__getitem__C s � ��x�x��}�}� r c �L � t dd� � | � d� � S )z�The RADIO-DISH group of the message.
Requires libzmq >= 4.2 and pyzmq built with draft APIs enabled.
.. versionadded:: 17
�� � �
RADIO-DISH�group�r r �r s r r z Frame.groupG s& � � �v�|�$�$�$��x�x�� � � r c �R � t dd� � | � d|� � d S )Nr r r �r �set)r r s r r z Frame.groupR s, � ��v�|�$�$�$� ����%� � � � � r c �L � t dd� � | � d� � S )z�The CLIENT-SERVER routing id of the message.
Requires libzmq >= 4.2 and pyzmq built with draft APIs enabled.
.. versionadded:: 17
r �
CLIENT-SERVER�
routing_idr r s r r$ zFrame.routing_idW s& � � �v��'�'�'��x�x� �%�%�%r c �R � t dd� � | � d|� � d S )Nr r# r$ r )r r$ s r r$ zFrame.routing_idb s, � ��v��'�'�'� ��� �z�*�*�*�*�*r N) �__name__�
__module__� __qualname__�__doc__r �propertyr �setterr$ � r r r r s� � � � � � �,� ,�\ � � � �!� !� �X�!� �\�!� !� �\�!� �&� &� �X�&� ��+� +� ��+� +� +r r �Message)
r) r � zmq.backendr � FrameBase� attrsettrr r r- �__all__r, r r �<module>r2 s� �� $� $�
�
�
�
� *� *� *� *� *� *� &� &� &� &� &� &�
�
�
�Q+� Q+� Q+� Q+� Q+�I�� Q+� Q+� Q+�j �� �I�
���r