Zd jdZddlZddlmZmZmZmZddlZddlZddl m Z ddl m Z Gdde Z deed e fd Zd eeed e fd Ze dd dded ee fdZe dd ejeded e fdZ dd ejded ee ee ffdZddgZdS)zJModule holding utility and convenience functions for zmq event monitoring.N) AwaitableListUnionoverload) TypedDict)_check_versionc.eZdZUeed<eed<eed<dS)_MonitorMessageeventvalueendpointN)__name__ __module__ __qualname__int__annotations__bytes1lib/python3.11/site-packages/zmq/utils/monitor.pyr r s+ JJJ JJJOOOOOrr msgreturnct|dkst|ddkrtd|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$s* 3xx1}}CF q((=CDDDmE3q622OHe8$$5!!FE Lr awaitable_msgc4K|d{V}t|S)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  % %%rsocketzzmq.asyncio.SocketflagscdSNrr(r)s rrecv_monitor_messager-B CrcdSr+rr,s rr-r-Jr.rctdd||}t|trt |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-RsZ>6-...    & &C#y!!-',,, ! % %%rr$r-)r)__doc__rtypingrrrrr! zmq.asyncio zmq._typingr zmq.errorrr rr$r'rr-Socket__all__rrrr;sPP  333333333333 !!!!!!$$$$$$i tE{@ &T%[) & & & & &      Ju   )&)& J)& )& ?Io6 67)&)&)&)&X #$: ;r