Method filte_worker

client/task/basic/datahandler/filter.py:162–192

()

        que = Queue()

        def filte_worker():

            while not que.empty():
                fileissue = que.get()
                path = fileissue.get("path", False)
                if not path:
                    que.task_done()
                    continue
                path_format = path.replace(os.sep, "/")

                # 根据include和exclude判断path是否需要过滤
                if filter_util.should_filter_path(path_format):
                    logger.info("match excluded path, ignore. %s", path_format)
                    que.task_done()
                    continue

                # 过滤不在版本控制下的文件
                # 该方法的主要耗时来源
                if not os.getenv("TCA_UNCOMMITTED_CODE") == "True":
                    try:
                        if scm_mgr.check_versioned_file(path_format) is False:
                            logger.info("not versioned path, ignore. %s", path_format)
                            que.task_done()
                            continue
                    except Exception as e:
                        logger.exception("check_versioned_file exception: %s - %s", str(e), path)
                        # 判断异常，当做不过滤处理

                fileissue["path"] = path_format
                filtered_issues.append(fileissue)
                que.task_done()

        thread_num = cpu_count()
        for fileissue in issues: