Class CpplintRunner

client/tool/cpplint.py:100–142

class CpplintRunner(object):
    def __init__(self):
        self.cmd_output = []

    def __collect_result_callback__(self, line):
        """单行输出回调,收集结果"""
        self.cmd_output.append(line)

    def run_cpplint_on_files(self, toscans, cmd_args, regex_client, source_dir, rules):
        """逐个扫描多个文件"""
        issues = []
        for file_path in toscans:
            file_issues = self.run_cpplint_on_file(file_path, cmd_args, regex_client, source_dir, rules)
            if file_issues:
                issues.extend(file_issues)
        return issues

    def run_cpplint_on_file(self, file_path, cmd_args, regex_client, source_dir, rules):
        """扫描单个文件"""
        # 先置空，以免上一个影响
        self.cmd_output = []
        cmd = cmd_args + ["\"%s\"" % file_path]
        logger.info("scan file: %s" % file_path)
        # cpplint的error信息通过stderr通道输出,结果统计信息通过stdout通道输出,可以只解析stderr结果
        subProC = SubProcController(cmd, stderr_line_callback=self.__collect_result_callback__)
        try:
            subProC.wait(timeout=300)  # 设置cpplint分析单个文件超时为5分钟，避免cpplint卡死的情况
        except Exception as err:
            if "SubProcControllerTimeout" in str(err):
                logger.error(
                    "timeout when run on file(%s): %s. Kill this process(%s)..." % (file_path, str(err), subProC.pid)
                )
                ProcMgr().kill_proc_famliy(subProC.pid)
            else:
                logger.error("error on file(%s): %s" % (file_path, err))
                raise

        # 解析cpplint原始结果
        scan_result = ResultMgr().parse_result(regex_client, self.cmd_output)

        # 转换成codedog最终结果格式
        file_issues = ResultMgr().format_result(source_dir, scan_result, rules)
        return file_issues


class ThreadRunner(object):