o Zh@sNdZddlZddlmZddlmZddZGdd d eeZeZd d gZ dS) z0MQ Frame pure Python methods.N)Frame)AttributeSettercCs&tj||tjstd|dS)Nz6libzmq and pyzmq must be built with draft support for )zmqerrorZ_check_versionZ DRAFT_API RuntimeError)vfeaturer F/var/www/html/lang_env/lib/python3.10/site-packages/zmq/sugar/frame.py_draft s r c@sTeZdZdZddZddZeddZejddZed d Z e jd d Z d S) rau 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 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: :const:`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. cCs ||S)N)get)selfkeyr r r __getitem__Ds zFrame.__getitem__cCst|}d}|dkrBtt|dd}|dkrd}|d}n|dkr*d}|d }n|d kr5d }|d }nd }|}d |d|}n|j}|jj}|dkrOd}d|d|jjd||dS)z#Return the str form of the message.N geAGBiMBg.Ag@@kBBz...z.0fzzmq.sugar.framer<.(z)>)lenbytes memoryview __class__ __module____name__)rnbytesZ msg_suffixZ msg_bytesunitn_moduler r r __repr__Hs*    zFrame.__repr__cCtdd|dS)zThe RADIO-DISH group of the message. Requires libzmq >= 4.2 and pyzmq built with draft APIs enabled. .. versionadded:: 17  RADIO-DISHgroupr r rr r r r+c  z Frame.groupcCtdd|d|dS)Nr'r*r+r set)rr+r r r r+n cCr&)zThe 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-r r r r4sr.zFrame.routing_idcCr/)Nr'r3r4r0)rr4r r r r4~r2N) r r __qualname____doc__rr%propertyr+setterr4r r r r rs/    rMessage) r6rZ zmq.backendrZ FrameBaseZ attrsettrrr r9__all__r r r r s  q