U lu fì ã@sðdZddlZddlmZmZmZmZddlZddlZddl m Z ddl m Z Gdd„de ƒZ eee dœd d „Zeeee d œd d „Zeddeee dœdd„ƒZedejeee dœdd„ƒZdejeee ee fdœdd„Zd dgZdS)zJModule holding utility and convenience functions for zmq event monitoring.éN)Ú AwaitableÚListÚUnionÚoverload)Ú TypedDict)Ú_check_versionc@s&eZdZUeed<eed<eed<dS)Ú_MonitorMessageÚeventÚvalueÚendpointN)Ú__name__Ú __module__Ú __qualname__ÚintÚ__annotations__Úbytes©rrú5/tmp/pip-unpacked-wheel-h6ekxre8/zmq/utils/monitor.pyrs r)ÚmsgÚreturncCs\t|ƒdkst|dƒdkr(td|ƒ‚t d|d¡\}}t |¡t |¡|ddœ}|S)aÄdecode zmq_monitor event messages. Parameters ---------- msg : list(bytes) zmq multipart message that has arrived on a monitor PAIR socket. First frame is:: 16 bit event id 32 bit event value no padding Second frame is the endpoint as a bytestring Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. éréz Invalid event message format: %sz=hié)r r r )ÚlenÚ RuntimeErrorÚstructÚunpackÚzmqÚEvent)rZevent_idr r rrrÚparse_monitor_messages ýr)Ú awaitable_msgrcÃs|IdH}t|ƒS)zyLike parse_monitor_msg, but awaitable Given awaitable message, return awaitable for the parsed monitor message. N)r)r rrrrÚ_parse_monitor_msg_async5s r!zzmq.asyncio.Socket)ÚsocketÚflagsrcCsdS©Nr©r"r#rrrÚrecv_monitor_messageBsr&cCsdSr$rr%rrrr&JscCs.tddƒ| |¡}t|tƒr&t|ƒSt|ƒS)u„Receive and decode the given raw message from the monitoring socket and return a dict. Requires libzmq ≥ 4.0 The returned dict will have the following entries: event : int, the event id as described in libzmq.zmq_socket_monitor value : int, the event value associated with the event, see libzmq.zmq_socket_monitor endpoint : string, the affected endpoint .. versionchanged:: 23.1 Support for async sockets added. When called with a async socket, returns an awaitable for the monitor message. Parameters ---------- socket : zmq PAIR socket The PAIR socket (created by other.get_monitor_socket()) on which to recv the message flags : bitfield (int) standard zmq recv flags Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. )érzlibzmq event API)rZrecv_multipartÚ isinstancerr!r)r"r#rrrrr&Rs    )r)r)r)Ú__doc__rÚtypingrrrrrZ zmq.asyncioZ zmq._typingrZ zmq.errorrrrrr!rr&ZSocketÚ__all__rrrrÚs@  ! þ þýþý þý ,