Don't check rt_runtime_us for CFS scheduler
This commit is contained in:
+6
-6
@@ -674,14 +674,14 @@ class CPULimitedHost( Host ):
|
|||||||
# Tell mnexec to execute command in our cgroup
|
# Tell mnexec to execute command in our cgroup
|
||||||
mncmd = [ 'mnexec', '-g', self.name,
|
mncmd = [ 'mnexec', '-g', self.name,
|
||||||
'-da', str( self.pid ) ]
|
'-da', str( self.pid ) ]
|
||||||
cpuTime = int( self.cgroupGet( 'rt_runtime_us', 'cpu' ) )
|
|
||||||
# if our cgroup is not given any cpu time,
|
# if our cgroup is not given any cpu time,
|
||||||
# we cannot assign the RR Scheduler.
|
# we cannot assign the RR Scheduler.
|
||||||
if self.sched == 'rt' and cpuTime > 0:
|
if self.sched == 'rt':
|
||||||
mncmd += [ '-r', str( self.rtprio ) ]
|
if int( self.cgroupGet( 'rt_runtime_us', 'cpu' ) ) <= 0:
|
||||||
elif self.sched == 'rt' and cpuTime <= 0:
|
mncmd += [ '-r', str( self.rtprio ) ]
|
||||||
debug( '***error: not enough cpu time available for %s.' % self.name,
|
else:
|
||||||
'Using cfs scheduler for subprocess\n' )
|
debug( '*** error: not enough cpu time available for %s.' % self.name,
|
||||||
|
'Using cfs scheduler for subprocess\n' )
|
||||||
return Host.popen( self, *args, mncmd=mncmd, **kwargs )
|
return Host.popen( self, *args, mncmd=mncmd, **kwargs )
|
||||||
|
|
||||||
def cleanup( self ):
|
def cleanup( self ):
|
||||||
|
|||||||
Reference in New Issue
Block a user