Ef @dZddlZddlmZmZmZmZddlZddlZddl m Z ddl m Z Gdde Z deed e fd Zd eeed e fd Ze dd dded ee fdZe dd ej&eded e fdZ dd ej&ded ee ee ffdZddgZy)zJModule holding utility and convenience functions for zmq event monitoring.N) AwaitableListUnionoverload) TypedDict)_check_versionc,eZdZUeed<eed<eed<y)_MonitorMessageeventvalueendpointN)__name__ __module__ __qualname__int__annotations__bytes3/usr/lib/python3/dist-packages/zmq/utils/monitor.pyr r s J JOrr msgreturnct|dk7st|ddk7rtd|ztjd|d\}}t j |t j ||dd}|S)adecode 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`. rz Invalid event message format: %sz=hi)r r r )len RuntimeErrorstructunpackzmqEvent)revent_idr r s rparse_monitor_messager$st* 3x1}CF q(=CDDmmE3q62OHe8$5!FE Lr awaitable_msgc8K|d{}t|S7w)zyLike parse_monitor_msg, but awaitable Given awaitable message, return awaitable for the parsed monitor message. N)r$)r%rs r_parse_monitor_msg_asyncr'5s  C  %% s socketzzmq.asyncio.SocketflagscyNrr(r)s rrecv_monitor_messager-B rcyr+rr,s rr-r-Jr.rctdd|j|}t|tr t |St |S)uReceive 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)rrecv_multipart isinstancerr'r$)r(r)rs rr-r-RsC>6-.    &C#y!',, ! %%rr$r-)r)__doc__rtypingrrrrr! zmq.asyncio zmq._typingr zmq.errorrr rr$r'rr-Socket__all__rrrr;sP 33 !$i tE{@ &T%[) & &      JJu   )& JJ)& )& ?Io6 67)&X #$: ;r