Method run_status

mod/project/java/groupMod.py:237–325

(self, last_write_time: float)

    # 获取运行状态信息
    def run_status(self, last_write_time: float) -> dict:
        default_error = {
                "running": False,
                "msg": "操作出错，已退出",
                "running_data": None,
                "last_write_time": 0,
            }
        pid_file = "{}/{}.pid".format(Group.GROUP_TMP_DIR, self.group_id)
        log_file = "{}/{}.log".format(Group.GROUP_TMP_DIR, self.group_id)
        if not os.path.isfile(pid_file):
            return default_error
        try:
            pid = int(public.readFile(pid_file))
        except:
            return default_error

        try:
            data = json.loads(public.readFile(log_file))
        except:  # 如果读取出错，则说明进程出现问题，则杀死进程，并清除数据，返回错误
            if os.path.isfile(log_file):
                os.remove(log_file)
            if os.path.isfile(pid_file):
                os.remove(pid_file)
            if self.is_running(pid):
                psutil.Process(pid).kill()

            return default_error

        # 如果进程不在运行，则返回上一次运行的数据（防止卡顿导致导致最后的数据没有读取到）
        if not self.is_running(pid):
            return {
                "running": False,
                "msg": "操作进程已退出",
                "running_data": data,
                "last_write_time": os.path.getmtime(log_file),
            }

        # 如果还在运行， 则进行长链接， 等待最多5秒， 如果没有数据被写入， 且进程依旧在运行，则返回上一次的数据；
        # 若不在运行则说明，且没有写入则说明等待期间出错了 （启动进程退出前必定会进行一次写入）
        # 如果有数据被写入则返回最新数据

        for i in range(50):
            m_time = os.path.getmtime(log_file)
            if abs(m_time - last_write_time) > 0.001:  # 如果时间差大于0.001秒，则说明数据再次被写入了，则退出循环，返回数据
                now_write_time = m_time
                break
            elif i == 49:  # 最后一次检测后，直接退出循环
                continue
            else:
                time.sleep(0.1)
        else:  # 如果 5 秒内没有数据被写入，则返回上一次的数据
            if not self.is_running(pid):  # 不在运行, 说明等待期间出错了
                if os.path.isfile(log_file):
                    os.remove(log_file)
                if os.path.isfile(pid_file):
                    os.remove(pid_file)
                    return default_error