Inheritance diagram for psClasses.BuildThread:

Public Member Functions
def	__init__ (self, parent, queue, weight=1)

def	build (self)

def	putInServerQueue (self)

def	releaseAllLocks (self)

def	run (self)

Public Attributes
	BuildNode

	IsComplete

	Queue

	QueueList

	Weight

Detailed Description

Classes.

Definition at line 11 of file psClasses.py.

Constructor & Destructor Documentation

◆ init()

def psClasses.BuildThread.__init__	(	self,
		parent,
		queue,
		weight = `1`
	)

Definition at line 13 of file psClasses.py.

   def __init__(self, parent, queue, weight = 1):
     Thread.__init__(self)
     self.BuildNode = parent
     self.QueueList = queue
     self.Weight = weight
     self.IsComplete = Condition()
     self.Queue = None
   

Member Function Documentation

◆ build()

def psClasses.BuildThread.build ( self )

Definition at line 35 of file psClasses.py.

   def build(self):
     self.QueueList[self.Queue].QueueSem.acquire()
     #call(['eval',"scram runtime -sh",";",'EdmPluginRefresh',self.BuildNode.LibName],shell="/bin/bash"))
     rValue=call(['ssh',self.Queue,'cd ~/CMSSW_3_5_7;scram build -j %d' % self.QueueList.Jay,self.BuildNode.LibName])
     self.QueueList.EdmRefreshLock.acquire()
     call(['ssh',self.Queue,'cd ~/CMSSW_3_5_7;eval `scram runtime -sh`;EdmPluginRefresh %s' % self.BuildNode.LibName])   
     self.QueueList.EdmRefreshLock.release()
     if rValue == 0: 
       self.BuildNode.State=STATE_COMPLETED
     else:
       print("Build failed for %s"  % self.BuildNode.LibName)
       self.BuildNode.State=STATE_ERROR
     self.QueueList[self.Queue].QueueSem.release()
   

References psClasses.BuildThread.BuildNode, edm.print(), psClasses.BuildThread.Queue, and psClasses.BuildThread.QueueList.

Referenced by psClasses.BuildThread.run().

◆ putInServerQueue()

def psClasses.BuildThread.putInServerQueue ( self )

Definition at line 21 of file psClasses.py.

   def putInServerQueue(self):
     self.QueueList.QueueLock.acquire()
     sSrv=self.QueueList.smallestQueue()
     tSrv=self.QueueList.thinerQueue()
     self.Queue=sSrv
     if sSrv == tSrv:
       self.QueueList[sSrv].append(self)
     elif self.Weight + self.QueueList[sSrv].queueWeight() <= (self.QueueList.Cores/self.QueueList.Jay)*1.5:
       self.QueueList[sSrv].append(self)
     else:
       self.QueueList[tSrv].append(self)
       self.Queue=tSrv
     self.QueueList.QueueLock.release()
   

References mps_setup.append, psClasses.BuildThread.Queue, psClasses.BuildThread.QueueList, and psClasses.BuildThread.Weight.

Referenced by psClasses.BuildThread.run().

◆ releaseAllLocks()

def psClasses.BuildThread.releaseAllLocks ( self )

Definition at line 49 of file psClasses.py.

   def releaseAllLocks(self):
     #for deps in self.BuildNode.DependsOn:
       #deps.BThread.IsComplete.release()
     self.BuildNode.State=STATE_ERROR
     self.IsComplete.acquire()
     self.IsComplete.notifyAll()
     self.IsComplete.release()
   

References psClasses.BuildThread.BuildNode, psClasses.BuildThread.IsComplete, and fetchall_from_DQM_v2.release.

Referenced by psClasses.BuildThread.run().

◆ run()

def psClasses.BuildThread.run ( self )

Definition at line 57 of file psClasses.py.

   def run(self):
     depsCompleted=False
     while not depsCompleted:
       depsCompleted=True
       for deps in self.BuildNode.DependsOn:
         if deps.State is STATE_ERROR :
           self.releaseAllLocks()
           return -1
         if deps.State is not STATE_COMPLETED :
           depsCompleted=False
           deps.BThread.IsComplete.acquire() 
           deps.BThread.IsComplete.wait()
           #deps.BThread.isAlive() and sys.stdout.write("Wait time exeded %s %s\n" % (deps.LibName,deps.Module))
           deps.BThread.IsComplete.release()
       
     self.putInServerQueue()
     self.build()
     self.IsComplete.acquire()
     self.IsComplete.notifyAll()
     self.IsComplete.release()
     return 0
     