@@ -103,7 +103,20 @@ class ChrootUtils(object):

         ChrootUtils.lockForTrackingChroots.release()           

         return True,chrootID

+    def createChroot1(self,chrootID):

+        # need to add timeout for this step

+        # http://stackoverflow.com/questions/1191374/subprocess-with-timeout

+        process = subprocess.Popen("mkdir -p "+chrootID,shell=True,stdout=subprocess.PIPE)

+        retval = process.wait()

+        

+        if retval != 0:

+            self.logger.error("Unable to create chroot:"+ chrootID +".Unknown error.")

+            return False,None

+        

+        return True,chrootID

+    

     def destroyChroot(self,chrootID):

+        '''

         validChroot = True

         ChrootUtils.lockForTrackingChroots.acquire()

         if chrootID not in ChrootUtils.activeChroots:

@@ -114,7 +127,7 @@ class ChrootUtils(object):

         if not validChroot:

             self.logger.error("Given chroot:"+chrootID+" is not a valid chroot. It is not created by ChrootUtils.")

             return False

-

+        '''

         # need to add timeout for this step

         # http://stackoverflow.com/questions/1191374/subprocess-with-timeout

         process = subprocess.Popen("./cleanup-build-root.sh "+chrootID,shell=True,stdout=subprocess.PIPE)

@@ -36,6 +36,21 @@ class PackageBuilder(object):

             raise e

         return chrootID

+    def prepareBuildRoot1(self,chrootID):

+        #chrootID=None

+        try:

+            chrUtils = ChrootUtils(self.logName,self.logPath)

+            returnVal,chrootID = chrUtils.createChroot1(chrootID)

+            if not returnVal:

+                raise Exception("Unable to prepare build root")

+            tUtils=ToolChainUtils(self.logName,self.logPath)

+            tUtils.installToolChain(chrootID)

+        except Exception as e:

+            if chrootID is not None:

+                chrUtils.destroyChroot(chrootID)

+            raise e

+        return chrootID

+    

     def findPackageNameFromRPMFile(self,rpmfile):

         rpmfile=os.path.basename(rpmfile)

         releaseindex=rpmfile.rfind("-")

@@ -70,9 +85,9 @@ class PackageBuilder(object):

     def buildPackage(self,package):

         #should initialize a logger based on package name

         chrUtils = ChrootUtils(self.logName,self.logPath)

-        chrootID=None

+        chrootID="build-"+package

         try:

-            chrootID = self.prepareBuildRoot()

+            chrootID = self.prepareBuildRoot1(chrootID)

             destLogPath=constants.logPath+"/build-"+package

             if not os.path.isdir(destLogPath):

                 cmdUtils = CommandUtils()

@@ -202,7 +202,7 @@ class PackageManager(object):

         Scheduler.setParams(self.sortedPackageList, self.listOfPackagesAlreadyBuilt)

         Scheduler.setEvent(statusEvent)

-        numWorkerThreads=self.calculatePossibleNumWorkerThreads()

+        numWorkerThreads=8#self.calculatePossibleNumWorkerThreads()

         if numWorkerThreads == 0:

             return False

@@ -70,9 +70,11 @@ class Scheduler(object):

     @staticmethod

     def getNextPackageToBuild():

+        Scheduler.logger.info("Waiting to acquire scheduler lock")

         Scheduler.lock.acquire()

         if Scheduler.stopScheduling:

+            Scheduler.logger.info("Released scheduler lock")

             Scheduler.lock.release()

             return None

@@ -85,6 +87,7 @@ class Scheduler(object):

             Scheduler.listOfPackagesNextToBuild=listOfPackagesNextToBuild

         if len(Scheduler.listOfPackagesNextToBuild) == 0:

+            Scheduler.logger.info("Released scheduler lock")

             Scheduler.lock.release()

             return None

@@ -92,6 +95,7 @@ class Scheduler(object):

         if len(Scheduler.listOfPackagesNextToBuild) > 0:

             ThreadPool.activateWorkerThreads(len(Scheduler.listOfPackagesNextToBuild))

+        Scheduler.logger.info("Released scheduler lock")

         Scheduler.lock.release()

         Scheduler.listOfPackagesCurrentlyBuilding.append(package)

         Scheduler.listOfPackagesToBuild.remove(package)