U lu f› ã@sNdZddlZddlmZddlmZdd„ZGdd „d eeƒZeZd d gZ dS) z0MQ Frame pure Python methods.éN)ÚFrameé)ÚAttributeSettercCs$tj ||¡tjs td|ƒ‚dS)Nz8libzmq and pyzmq must be built with draft support for %s)ÚzmqÚerrorZ_check_versionZ DRAFT_APIÚ RuntimeError)ÚvZfeature©r ú3/tmp/pip-unpacked-wheel-h6ekxre8/zmq/sugar/frame.pyÚ_draft s ÿr c@sLeZdZdZdd„Zedd„ƒZejdd„ƒZedd„ƒZejd d„ƒZd S) ra½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. cCs | |¡S)N)Úget)ÚselfÚkeyr r r Ú __getitem__CszFrame.__getitem__cCstddƒ| 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 r r r rGs z Frame.groupcCstddƒ| d|¡dS)Nrrr©r Úset)r rr r r rRs cCstddƒ| 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_idrrr r r rWs zFrame.routing_idcCstddƒ| d|¡dS)Nrrrr)r rr r r rbs N) Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚpropertyrÚsetterrr r r r rs.   rÚMessage) rrZ zmq.backendrZ FrameBaseZ attrsettrrr r!Ú__all__r r r r Ús  U