ó L]c@sSdZddlZddlZddlmZd„Zdd„ZddgZdS( sJModule holding utility and convenience functions for zmq event monitoring.i’’’’N(t_check_versioncCs†t|ƒdks(t|dƒdkr;td|ƒ‚nitjd|dƒdd6tjd|dƒdd6|dd 6}|S( sŲ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`. iiis Invalid event message format: %ss=hiteventitvaluetendpoint(tlent RuntimeErrortstructtunpack(tmsgR((s0lib/python2.7/site-packages/zmq/utils/monitor.pytparse_monitor_message s (icCs&tddƒ|j|ƒ}t|ƒS(sā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 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`. iislibzmq event API(ii(Rtrecv_multipartR (tsockettflagsR((s0lib/python2.7/site-packages/zmq/utils/monitor.pytrecv_monitor_message(s R R (t__doc__Rtzmqt zmq.errorRR R t__all__(((s0lib/python2.7/site-packages/zmq/utils/monitor.pyts