Method polling_task

src/task_scheduler.py:339–423

(self)

    # 轮询任务(固定延迟执行)
    def polling_task(self):
        while True:
            # 经测试等于1分钟时原版RCON会出现timeout
            if self.restart_interval < 60:
                INFO.logger.error("[ 轮询任务 ] 服务器重启时间 restart_interval 必须大于1分钟，请重新设置！")
                print("[ 轮询任务 ] 服务器重启时间 restart_interval 必须大于1分钟，请重新设置！")
                time.sleep(2)
                sys.exit(0)

            # 启动程序前检查, 如果存在服务端则不再进行启动操作,改为每次循环结尾关闭进程
            is_running = self.is_palserver_running()
            INFO.logger.info(f"[ 轮询任务 ] 当前 PalServer 进程运行状态：{is_running}")
            if not is_running and (not self.is_restarting):
                INFO.logger.info("[ 前置检查 ] 未检测到 PalServer 服务，正在启动......")
                print("[ 前置检查 ] 未检测到 PalServer 服务，正在启动......")
                self.start_program()

            INFO.logger.info(f'[ 轮询任务 ] 服务器将进入重启倒计时，设置时长为 {self.conf["restart_interval"]} 秒......')
            print(f'\r[ 轮询任务 ] 服务器将进入重启倒计时，设置时长为 {self.conf["restart_interval"]} 秒......')

            # 服务器持续运行时间(重启间隔)
            for i in range(int(self.restart_interval), 0, -1):
                print("\r\033[K", end='')  # 清除当前行
                print(f'\r[ 轮询任务 ] 服务器将在 {i} 秒后重启......', end='')
                time.sleep(1)
                # 检查内存使用情况
                if self.memory_monitor_enabled:
                    if self.polling_interval_seconds > 5:
                        mem_info = psutil.virtual_memory()
                        mem_usage = mem_info.percent  # 获取内存使用百分比

                        # 内存超限关服消息提醒
                        if mem_usage > self.memory_usage_threshold:
                            self.is_restarting = True  # 开始重启
                            max_notice_time = max(map(int, self.shutdown_notice.keys()))  # 获取最大关服通知时间
                            INFO.logger.error(
                                f"[ 内存监控 ] 内存使用超过{self.memory_usage_threshold}%，正在重启程序......")
                            print(f"\r[ 内存监控 ] 内存使用超过{self.memory_usage_threshold}%，正在重启程序......")
                            time.sleep(1)
                            # 倒计时关闭服务端
                            for j in range(max_notice_time, 0, -1):
                                time.sleep(1)
                                self.send_shutdown_notice(j)
                            # 关服之前执行一次SAVE
                            if self.rcon_enabled:
                                success, response = self.send_rcon_command("Save")
                                if success:
                                    INFO.logger.info('[ RCON ] 存档已保存 {0}'.format(response))
                                    print('\r[ RCON ] 存档已保存', response)
                                    time.sleep(3)
                                else:
                                    INFO.logger.error('[ RCON ] 存档保存失败: {0}'.format(response))
                            self.close_process()
                            self.is_first_run = True
                            time.sleep(5)
                            self.start_program()
                            self.is_restarting = False  # 重启完成