]> git.proxmox.com Git - mirror_edk2.git/blobdiff - BaseTools/Source/Python/build/build.py
BaseTools: Enable Multiple Process AutoGen
[mirror_edk2.git] / BaseTools / Source / Python / build / build.py
index 3d083f4eaade6239f8b1df766f0fa4b288f05770..af1be8d281361ff32fd32b6a701cb88f92331bb6 100644 (file)
@@ -30,6 +30,7 @@ from optparse import OptionParser
 from AutoGen.PlatformAutoGen import PlatformAutoGen\r
 from AutoGen.ModuleAutoGen import ModuleAutoGen\r
 from AutoGen.WorkspaceAutoGen import WorkspaceAutoGen\r
+from AutoGen.AutoGenWorker import AutoGenWorkerInProcess,AutoGenManager\r
 from AutoGen import GenMake\r
 from Common import Misc as Utils\r
 \r
@@ -50,7 +51,7 @@ from PatchPcdValue.PatchPcdValue import PatchBinaryFile
 \r
 import Common.GlobalData as GlobalData\r
 from GenFds.GenFds import GenFds, GenFdsApi\r
-\r
+import multiprocessing as mp\r
 \r
 # Version and Copyright\r
 VersionNumber = "0.60" + ' ' + gBUILD_VERSION\r
@@ -343,9 +344,9 @@ class ModuleMakeUnit(BuildUnit):
     #   @param  Obj         The ModuleAutoGen object the build is working on\r
     #   @param  Target      The build target name, one of gSupportedTarget\r
     #\r
-    def __init__(self, Obj, Target):\r
-        Dependency = [ModuleMakeUnit(La, Target) for La in Obj.LibraryAutoGenList]\r
-        BuildUnit.__init__(self, Obj, Obj.BuildCommand, Target, Dependency, Obj.MakeFileDir)\r
+    def __init__(self, Obj, BuildCommand,Target):\r
+        Dependency = [ModuleMakeUnit(La, BuildCommand,Target) for La in Obj.LibraryAutoGenList]\r
+        BuildUnit.__init__(self, Obj, BuildCommand, Target, Dependency, Obj.MakeFileDir)\r
         if Target in [None, "", "all"]:\r
             self.Target = "tbuild"\r
 \r
@@ -364,10 +365,10 @@ class PlatformMakeUnit(BuildUnit):
     #   @param  Obj         The PlatformAutoGen object the build is working on\r
     #   @param  Target      The build target name, one of gSupportedTarget\r
     #\r
-    def __init__(self, Obj, Target):\r
-        Dependency = [ModuleMakeUnit(Lib, Target) for Lib in self.BuildObject.LibraryAutoGenList]\r
-        Dependency.extend([ModuleMakeUnit(Mod, Target) for Mod in self.BuildObject.ModuleAutoGenList])\r
-        BuildUnit.__init__(self, Obj, Obj.BuildCommand, Target, Dependency, Obj.MakeFileDir)\r
+    def __init__(self, Obj, BuildCommand, Target):\r
+        Dependency = [ModuleMakeUnit(Lib, BuildCommand, Target) for Lib in self.BuildObject.LibraryAutoGenList]\r
+        Dependency.extend([ModuleMakeUnit(Mod, BuildCommand,Target) for Mod in self.BuildObject.ModuleAutoGenList])\r
+        BuildUnit.__init__(self, Obj, BuildCommand, Target, Dependency, Obj.MakeFileDir)\r
 \r
 ## The class representing the task of a module build or platform build\r
 #\r
@@ -824,8 +825,31 @@ class Build():
         if not (self.LaunchPrebuildFlag and os.path.exists(self.PlatformBuildPath)):\r
             self.InitBuild()\r
 \r
+        self.AutoGenMgr = None\r
         EdkLogger.info("")\r
         os.chdir(self.WorkspaceDir)\r
+    def StartAutoGen(self,mqueue, DataPipe,SkipAutoGen,PcdMaList):\r
+        try:\r
+            if SkipAutoGen:\r
+                return True,0\r
+            feedback_q = mp.Queue()\r
+            file_lock = mp.Lock()\r
+            error_event = mp.Event()\r
+            auto_workers = [AutoGenWorkerInProcess(mqueue,DataPipe.dump_file,feedback_q,file_lock,error_event) for _ in range(self.ThreadNumber)]\r
+            self.AutoGenMgr = AutoGenManager(auto_workers,feedback_q,error_event)\r
+            self.AutoGenMgr.start()\r
+            for w in auto_workers:\r
+                w.start()\r
+            if PcdMaList is not None:\r
+                for PcdMa in PcdMaList:\r
+                    PcdMa.CreateCodeFile(False)\r
+                    PcdMa.CreateMakeFile(False,GenFfsList = DataPipe.Get("FfsCommand").get((PcdMa.MetaFile.File, PcdMa.Arch),[]))\r
+\r
+            self.AutoGenMgr.join()\r
+            rt = self.AutoGenMgr.Status\r
+            return rt, 0\r
+        except Exception as e:\r
+            return False,e.errcode\r
 \r
     ## Load configuration\r
     #\r
@@ -1190,30 +1214,34 @@ class Build():
     #   @param  CreateDepModuleMakeFile     Flag used to indicate creating makefile\r
     #                                       for dependent modules/Libraries\r
     #\r
-    def _BuildPa(self, Target, AutoGenObject, CreateDepsCodeFile=True, CreateDepsMakeFile=True, BuildModule=False, FfsCommand={}):\r
+    def _BuildPa(self, Target, AutoGenObject, CreateDepsCodeFile=True, CreateDepsMakeFile=True, BuildModule=False, FfsCommand=None, PcdMaList=None):\r
         if AutoGenObject is None:\r
             return False\r
-\r
+        if FfsCommand is None:\r
+            FfsCommand = {}\r
         # skip file generation for cleanxxx targets, run and fds target\r
         if Target not in ['clean', 'cleanlib', 'cleanall', 'run', 'fds']:\r
             # for target which must generate AutoGen code and makefile\r
-            if not self.SkipAutoGen or Target == 'genc':\r
-                self.Progress.Start("Generating code")\r
-                AutoGenObject.CreateCodeFile(CreateDepsCodeFile)\r
-                self.Progress.Stop("done!")\r
-            if Target == "genc":\r
-                return True\r
-\r
-            if not self.SkipAutoGen or Target == 'genmake':\r
-                self.Progress.Start("Generating makefile")\r
-                AutoGenObject.CreateMakeFile(CreateDepsMakeFile, FfsCommand)\r
-                self.Progress.Stop("done!")\r
-            if Target == "genmake":\r
-                return True\r
-        else:\r
-            # always recreate top/platform makefile when clean, just in case of inconsistency\r
+            mqueue = mp.Queue()\r
+            for m in AutoGenObject.GetAllModuleInfo:\r
+                mqueue.put(m)\r
+\r
+            AutoGenObject.DataPipe.DataContainer = {"FfsCommand":FfsCommand}\r
+            self.Progress.Start("Generating makefile and code")\r
+            data_pipe_file = os.path.join(AutoGenObject.BuildDir, "GlobalVar_%s_%s.bin" % (str(AutoGenObject.Guid),AutoGenObject.Arch))\r
+            AutoGenObject.DataPipe.dump(data_pipe_file)\r
+            autogen_rt,errorcode = self.StartAutoGen(mqueue, AutoGenObject.DataPipe, self.SkipAutoGen, PcdMaList)\r
+            self.Progress.Stop("done!")\r
+            if not autogen_rt:\r
+                self.AutoGenMgr.TerminateWorkers()\r
+                self.AutoGenMgr.join(0.1)\r
+                raise FatalError(errorcode)\r
             AutoGenObject.CreateCodeFile(False)\r
             AutoGenObject.CreateMakeFile(False)\r
+        else:\r
+            # always recreate top/platform makefile when clean, just in case of inconsistency\r
+            AutoGenObject.CreateCodeFile(True)\r
+            AutoGenObject.CreateMakeFile(True)\r
 \r
         if EdkLogger.GetLevel() == EdkLogger.QUIET:\r
             EdkLogger.quiet("Building ... %s" % repr(AutoGenObject))\r
@@ -1334,8 +1362,8 @@ class Build():
                 return True\r
         else:\r
             # always recreate top/platform makefile when clean, just in case of inconsistency\r
-            AutoGenObject.CreateCodeFile(False)\r
-            AutoGenObject.CreateMakeFile(False)\r
+            AutoGenObject.CreateCodeFile(True)\r
+            AutoGenObject.CreateMakeFile(True)\r
 \r
         if EdkLogger.GetLevel() == EdkLogger.QUIET:\r
             EdkLogger.quiet("Building ... %s" % repr(AutoGenObject))\r
@@ -1713,9 +1741,10 @@ class Build():
                             continue\r
                         if Ma.PcdIsDriver:\r
                             Ma.PlatformInfo = Pa\r
+                            Ma.Workspace = Wa\r
                             PcdMaList.append(Ma)\r
                         self.BuildModules.append(Ma)\r
-                    self._BuildPa(self.Target, Pa, FfsCommand=CmdListDict)\r
+                    self._BuildPa(self.Target, Pa, FfsCommand=CmdListDict,PcdMaList=PcdMaList)\r
 \r
                 # Create MAP file when Load Fix Address is enabled.\r
                 if self.Target in ["", "all", "fds"]:\r
@@ -1850,7 +1879,7 @@ class Build():
                     MakeStart = time.time()\r
                     for Ma in self.BuildModules:\r
                         if not Ma.IsBinaryModule:\r
-                            Bt = BuildTask.New(ModuleMakeUnit(Ma, self.Target))\r
+                            Bt = BuildTask.New(ModuleMakeUnit(Ma, Pa.BuildCommand,self.Target))\r
                         # Break build if any build thread has error\r
                         if BuildTask.HasError():\r
                             # we need a full version of makefile for platform\r
@@ -1980,7 +2009,7 @@ class Build():
                 Wa.CreateMakeFile(False)\r
 \r
                 # Add ffs build to makefile\r
-                CmdListDict = None\r
+                CmdListDict = {}\r
                 if GlobalData.gEnableGenfdsMultiThread and self.Fdf:\r
                     CmdListDict = self._GenFfsCmd(Wa.ArchList)\r
 \r
@@ -1988,6 +2017,7 @@ class Build():
                 ExitFlag = threading.Event()\r
                 ExitFlag.clear()\r
                 self.AutoGenTime += int(round((time.time() - WorkspaceAutoGenTime)))\r
+                self.BuildModules = []\r
                 for Arch in Wa.ArchList:\r
                     PcdMaList    = []\r
                     AutoGenStart = time.time()\r
@@ -2005,6 +2035,8 @@ class Build():
                             if Inf in Pa.Platform.Modules:\r
                                 continue\r
                             ModuleList.append(Inf)\r
+                    Pa.DataPipe.DataContainer = {"FfsCommand":CmdListDict}\r
+                    Pa.DataPipe.DataContainer = {"Workspace_timestamp": Wa._SrcTimeStamp}\r
                     for Module in ModuleList:\r
                         # Get ModuleAutoGen object to generate C code file and makefile\r
                         Ma = ModuleAutoGen(Wa, Module, BuildTarget, ToolChain, Arch, self.PlatformFile,Pa.DataPipe)\r
@@ -2013,6 +2045,7 @@ class Build():
                             continue\r
                         if Ma.PcdIsDriver:\r
                             Ma.PlatformInfo = Pa\r
+                            Ma.Workspace = Wa\r
                             PcdMaList.append(Ma)\r
                         if Ma.CanSkipbyHash():\r
                             self.HashSkipModules.append(Ma)\r
@@ -2024,34 +2057,32 @@ class Build():
                                 EdkLogger.quiet("cache miss: %s[%s]" % (Ma.MetaFile.Path, Ma.Arch))\r
 \r
                         # Not to auto-gen for targets 'clean', 'cleanlib', 'cleanall', 'run', 'fds'\r
-                        if self.Target not in ['clean', 'cleanlib', 'cleanall', 'run', 'fds']:\r
                             # for target which must generate AutoGen code and makefile\r
-                            if not self.SkipAutoGen or self.Target == 'genc':\r
-                                Ma.CreateCodeFile(True)\r
-                            if self.Target == "genc":\r
-                                continue\r
 \r
-                            if not self.SkipAutoGen or self.Target == 'genmake':\r
-                                if CmdListDict and self.Fdf and (Module.File, Arch) in CmdListDict:\r
-                                    Ma.CreateMakeFile(True, CmdListDict[Module.File, Arch])\r
-                                    del CmdListDict[Module.File, Arch]\r
-                                else:\r
-                                    Ma.CreateMakeFile(True)\r
-                            if self.Target == "genmake":\r
-                                continue\r
                         self.BuildModules.append(Ma)\r
                         # Initialize all modules in tracking to 'FAIL'\r
                         if Ma.Arch not in GlobalData.gModuleBuildTracking:\r
                             GlobalData.gModuleBuildTracking[Ma.Arch] = dict()\r
                         if Ma not in GlobalData.gModuleBuildTracking[Ma.Arch]:\r
                             GlobalData.gModuleBuildTracking[Ma.Arch][Ma] = 'FAIL'\r
+                    mqueue = mp.Queue()\r
+                    for m in Pa.GetAllModuleInfo:\r
+                        mqueue.put(m)\r
+                    data_pipe_file = os.path.join(Pa.BuildDir, "GlobalVar_%s_%s.bin" % (str(Pa.Guid),Pa.Arch))\r
+                    Pa.DataPipe.dump(data_pipe_file)\r
+                    autogen_rt, errorcode = self.StartAutoGen(mqueue, Pa.DataPipe, self.SkipAutoGen, PcdMaList)\r
                     self.Progress.Stop("done!")\r
                     self.AutoGenTime += int(round((time.time() - AutoGenStart)))\r
+                    if not autogen_rt:\r
+                        self.AutoGenMgr.TerminateWorkers()\r
+                        self.AutoGenMgr.join(0.1)\r
+                        raise FatalError(errorcode)\r
+                for Arch in Wa.ArchList:\r
                     MakeStart = time.time()\r
                     for Ma in self.BuildModules:\r
                         # Generate build task for the module\r
                         if not Ma.IsBinaryModule:\r
-                            Bt = BuildTask.New(ModuleMakeUnit(Ma, self.Target))\r
+                            Bt = BuildTask.New(ModuleMakeUnit(Ma, Pa.BuildCommand,self.Target))\r
                         # Break build if any build thread has error\r
                         if BuildTask.HasError():\r
                             # we need a full version of makefile for platform\r
@@ -2498,6 +2529,10 @@ def Main():
             EdkLogger.error(X.ToolName, FORMAT_INVALID, File=X.FileName, Line=X.LineNumber, ExtraData=X.Message, RaiseError=False)\r
         ReturnCode = FORMAT_INVALID\r
     except KeyboardInterrupt:\r
+        if MyBuild is not None:\r
+\r
+            # for multi-thread build exits safely\r
+            MyBuild.Relinquish()\r
         ReturnCode = ABORT_ERROR\r
         if Option is not None and Option.debug is not None:\r
             EdkLogger.quiet("(Python %s on %s) " % (platform.python_version(), sys.platform) + traceback.format_exc())\r
@@ -2554,6 +2589,10 @@ def Main():
     return ReturnCode\r
 \r
 if __name__ == '__main__':\r
+    try:\r
+        mp.set_start_method('spawn')\r
+    except:\r
+        pass\r
     r = Main()\r
     ## 0-127 is a safe return range, and 1 is a standard default error\r
     if r < 0 or r > 127: r = 1\r