[analyzer] SATest: Use logger in single-threaded mode as well

[vsavchenko]

Summary

It generalizes the way the output looks across any -jN.
Additionally it solves the buffering problems.

[NoQ]

clang/utils/analyzer/SATestBuild.py

650

Now that you have a global Logger, is this still relevant?

[vsavchenko]

clang/utils/analyzer/SATestBuild.py

650

Yes, it prints the name of the project with the actual message, so it's visible what is this line about

[NoQ]

Aha ok nvm then!

clang/utils/analyzer/SATestBuild.py

 from subprocess import CalledProcessError, check_call
 from typing import Dict, IO, List, NamedTuple, Optional, TYPE_CHECKING
 
 
 ###############################################################################
 # Helper functions.
 ###############################################################################
 
+class StreamToLogger:
+    def __init__(self, logger: logging.Logger,
+                 log_level: int = logging.INFO):
+        self.logger = logger
+        self.log_level = log_level
+
+    def write(self, message: str):
+        # Rstrip in order not to write an extra newline.
+        self.logger.log(self.log_level, message.rstrip())
+
+    def flush(self):
+        pass
+
+    def fileno(self) -> int:
+        return 0
+
+
+Logger = logging.getLogger("main")
 LOCAL = threading.local()
-LOCAL.stdout = sys.stdout
-LOCAL.stderr = sys.stderr
+LOCAL.stdout = StreamToLogger(Logger, logging.INFO)
+LOCAL.stderr = StreamToLogger(Logger, logging.ERROR)
 
 
 def stderr(message: str):
     LOCAL.stderr.write(message)
 
 
 def stdout(message: str):
     LOCAL.stdout.write(message)
CHECKERS = ",".join([
     "unix",
     "osx",
     "nullability"
 ])
 
 VERBOSE = 0
 
 
-class StreamToLogger:
-    def __init__(self, logger: logging.Logger,
-                 log_level: int = logging.INFO):
-        self.logger = logger
-        self.log_level = log_level
-
-    def write(self, message: str):
-        # Rstrip in order not to write an extra newline.
-        self.logger.log(self.log_level, message.rstrip())
-
-    def flush(self):
-        pass
-
-    def fileno(self) -> int:
-        return 0
-
-
 ###############################################################################
 # Test harness logic.
 ###############################################################################
 
 
 def run_cleanup_script(directory: str, build_log_file: IO):
     """
     Run pre-processing script if any.
def __init__(self, tasks_queue: TestQueue,
         # Needed to gracefully handle interrupts with Ctrl-C
         self.daemon = True
 
     def run(self):
         while not self.tasks_queue.empty():
             try:
                 test_info = self.tasks_queue.get()
 
                 Logger = logging.getLogger(test_info.project.name)
                 LOCAL.stdout = StreamToLogger(Logger, logging.INFO)
                 LOCAL.stderr = StreamToLogger(Logger, logging.ERROR)
 
                 tester = ProjectTester(test_info)
                 if not tester.test():
                     self.results_differ.set()
 
                 self.tasks_queue.task_done()