Mh dZddlmZddlZddlmZmZmZddlZddl Zddl m Z GddeZ dd Z ddZe dddZe dd dZ dd!dZddgZdS)"zJModule holding utility and convenience functions for zmq event monitoring.) annotationsN) Awaitable TypedDictoverload)_check_versionc.eZdZUded<ded<ded<dS)_MonitorMessageinteventvaluebytesendpointN)__name__ __module__ __qualname____annotations__Q/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/zmq/utils/monitor.pyr r s+JJJJJJOOOOOrr msg list[bytes]returnct|dkst|ddkrtd|tjd|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`. rzInvalid event message format: z=hi)r r r)len RuntimeErrorstructunpackzmqEvent)revent_idr r s rparse_monitor_messager$s* 3xx1}}CF q((ACAABBBmE3q622OHe8$$5!!FE Lr awaitable_msgAwaitable[list[bytes]]c4K|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(6s-      C  % %%rsocketzmq.asyncio.Socketflagsr Awaitable[_MonitorMessage]cdSNrr)r+s rrecv_monitor_messager0Cs "%rzmq.Socket[bytes]cdSr.rr/s rr0r0Js cr zmq.Socket,_MonitorMessage | Awaitable[_MonitorMessage]ctdd||}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 : str 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.Socket The PAIR socket (created by other.get_monitor_socket()) on which to recv the message flags : 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 rr0r0Qs[D6-...    & &C#y!!-',,, ! % %%rr$r0)rrrr )r%r&rr )r)r)r*r+r rr,)r)r1r+r rr )r)r3r+r rr4)__doc__ __future__rrtypingrrrr! zmq.asyncio zmq.errorrr r$r(r0__all__rrrr?sDPP #""""" 1111111111 $$$$$$i @ & & & & %%%% %   ,&,&,&,&,&^ #$: ;r