

def _flush_control(self, sock):
    'Flush replies from the control channel waiting\n        in the ZMQ queue.\n        \n        Currently: ignore them.'
    if (self._ignored_control_replies <= 0):
        return
    (idents, msg) = msg.session.recv(sock, mode=zmq.NOBLOCK)
    while (msg is not None):
        self._ignored_control_replies -= 1
        if self.debug:
            pprint(msg)
        (idents, msg) = self.session.recv(sock, mode=zmq.NOBLOCK)

dataset/ETHPy150Open ipython/ipython-py3k/IPython/parallel/client/client.py Client._flush_control/VarMisuse@34/81 `self`->`msg`