yandextank/core/tankcore.py
def __setup_taskset(self, affinity, pid=None, args=None):
        """ if pid specified: set process w/ pid `pid` CPU affinity to specified `affinity` core(s)
            if args specified: modify list of args for Popen to start w/ taskset w/ affinity `affinity`
        """
        self.taskset_path = self.get_option(self.SECTION, 'taskset_path')

        if args:
            return [self.taskset_path, '-c', affinity] + args

        if pid:
            args = "%s -pc %s %s" % (self.taskset_path, affinity, pid)
            retcode, stdout, stderr = execute(args, shell=True, poll_period=0.1, catch_out=True)
            logger.debug('taskset for pid %s stdout: %s', pid, stdout)
            if retcode == 0:
                logger.info("Enabled taskset for pid %s with affinity %s", str(pid), affinity)
            else:
                logger.debug('Taskset setup failed w/ retcode :%s', retcode)
                raise KeyError(stderr)
def __setup_taskset(self, affinity, pid=None, args=None):
        """ if pid specified: set process w/ pid `pid` CPU affinity to specified `affinity` core(s)
            if args specified: modify list of args for Popen to start w/ taskset w/ affinity `affinity`
        """
        self.taskset_path = self.get_option(self.SECTION, 'taskset_path')

        if args:
            return [self.taskset_path, '-c', affinity] + args

        if pid:
            args = "%s -pc %s %s" % (self.taskset_path, affinity, pid)
            retcode, stdout, stderr = execute(args, shell=True, poll_period=0.1, catch_out=True)
            logger.debug('taskset for pid %s stdout: %s', pid, stdout)
            if retcode == 0:
                logger.info("Enabled taskset for pid %s with affinity %s", str(pid), affinity)
            else:
                logger.debug('Taskset setup failed w/ retcode :%s', retcode)
                raise KeyError(stderr)
def __setup_taskset ( self , affinity , pid = None , args = None ) : self . taskset_path = self . get_option ( self . SECTION , 'taskset_path' ) if args : return [ self . taskset_path , '-c' , affinity ] + args if pid : args = "%s -pc %s %s" % ( self . taskset_path , affinity , pid ) retcode , stdout , stderr = execute ( args , shell = True , poll_period = 0.1 , catch_out = True ) logger . debug ( 'taskset for pid %s stdout: %s' , pid , stdout ) if retcode == 0 : logger . info ( "Enabled taskset for pid %s with affinity %s" , str ( pid ) , affinity ) else : logger . debug ( 'Taskset setup failed w/ retcode :%s' , retcode ) raise KeyError ( stderr )
if pid specified: set process w/ pid `pid` CPU affinity to specified `affinity` core(s)
            if args specified: modify list of args for Popen to start w/ taskset w/ affinity `affinity`
if pid specified : set process w / pid pid CPU affinity to specified affinity core ( s ) if args specified : modify list of args for Popen to start w / taskset w / affinity affinity