

def run(self):
    while 1:
        (hdrs, payload) = childutils.listener.wait(self.stdin, self.stdout)
        self.handle_event(hdrs, payload)
        childutils.listener.ok(self.stdout)

dataset/ETHPy150Open XiaoMi/minos/supervisor/superlance/process_state_monitor.py ProcessStateMonitor.run/original