def recv_thread(self):
        while True:
            with self.lock:
                if not self.is_ready:
                    time.sleep(0.01)
                    continue
            try:
                r = self.recv_cmd()
                self.reply.put(r)
            except __HOLE__ as e:
                self.reply.put(e)
dataset/ETHPy150Open douban/dpark/dpark/moosefs/master.py/MasterConn.recv_thread