diff options
| author |   Dan Klein <danklei@cisco.com> | 2015-08-26 18:16:09 +0300 |
|---|---|---|
| committer | Dan Klein <danklei@cisco.com> | 2015-08-26 18:16:09 +0300 |
| commit | f8ac9d14a989c8cf1535e16165551dfa370b0b74 (patch) | |
| tree | 43e396eb5d096ad74ec02afeccf8995a4d241a0f /external_libs/python/zmq/utils/monitor.py | |
| parent | cdcc62972d42f009f55e6aeb2ca5c60c3acd75eb (diff) | |
| parent | 53f0e28d7f30c7175cbb15884c309613593859d8 (diff) | |
Merge branch 'master' into dan_stateless
Diffstat (limited to 'external_libs/python/zmq/utils/monitor.py')
| -rw-r--r-- | external_libs/python/zmq/utils/monitor.py | 68 |
1 files changed, 0 insertions, 68 deletions
diff --git a/external_libs/python/zmq/utils/monitor.py b/external_libs/python/zmq/utils/monitor.py deleted file mode 100644 index 734d54b1..00000000 --- a/external_libs/python/zmq/utils/monitor.py +++ /dev/null @@ -1,68 +0,0 @@ -# -*- coding: utf-8 -*- -"""Module holding utility and convenience functions for zmq event monitoring.""" - -# Copyright (C) PyZMQ Developers -# Distributed under the terms of the Modified BSD License. - -import struct -import zmq -from zmq.error import _check_version - -def parse_monitor_message(msg): - """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`. - """ - - if len(msg) != 2 or len(msg[0]) != 6: - raise RuntimeError("Invalid event message format: %s" % msg) - event = {} - event['event'], event['value'] = struct.unpack("=hi", msg[0]) - event['endpoint'] = msg[1] - return event - -def recv_monitor_message(socket, flags=0): - """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`. - """ - _check_version((4,0), 'libzmq event API') - # will always return a list - msg = socket.recv_multipart(flags) - # 4.0-style event API - return parse_monitor_message(msg) - -__all__ = ['parse_monitor_message', 'recv_monitor_message'] |