def _flush_control(self, sock):
        if self._ignored_control_replies <= 0:
            return
        idents,msg = self.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)
Flush replies from the control channel waiting
dataset/ETHPy150Open ipython/ipython-py3k/IPython/parallel/client/client.py/Client._flush_control