yandextank/stepper/main.py
def read_config(self):
        ''' stepper part of reading options '''
        self.log.info("Configuring StepperWrapper...")
        self.ammo_file = self.get_option(self.OPTION_AMMOFILE)
        self.ammo_type = self.get_option('ammo_type')
        if self.ammo_file:
            self.ammo_file = os.path.expanduser(self.ammo_file)
        self.loop_limit = self.get_option(self.OPTION_LOOP)
        self.ammo_limit = self.get_option("ammo_limit")

        self.load_profile = LoadProfile(**self.get_option('load_profile'))

        self.instances = int(
            self.get_option(self.OPTION_INSTANCES_LIMIT, '1000'))
        self.uris = self.get_option("uris", [])
        while '' in self.uris:
            self.uris.remove('')
        self.headers = self.get_option("headers")
        self.http_ver = self.get_option("header_http")
        self.autocases = self.get_option("autocases")
        self.enum_ammo = self.get_option("enum_ammo")
        self.use_caching = self.get_option("use_caching")

        self.file_cache = self.get_option('file_cache')
        cache_dir = self.get_option("cache_dir") or self.core.artifacts_base_dir
        self.cache_dir = os.path.expanduser(cache_dir)
        self.force_stepping = self.get_option("force_stepping")
        if self.get_option(self.OPTION_LOAD)[self.OPTION_LOAD_TYPE] == 'stpd_file':
            self.stpd = self.get_option(self.OPTION_LOAD)[self.OPTION_SCHEDULE]

        self.chosen_cases = self.get_option("chosen_cases").split()
        if self.chosen_cases:
            self.log.info("chosen_cases LIMITS: %s", self.chosen_cases)
def read_config(self):
        ''' stepper part of reading options '''
        self.log.info("Configuring StepperWrapper...")
        self.ammo_file = self.get_option(self.OPTION_AMMOFILE)
        self.ammo_type = self.get_option('ammo_type')
        if self.ammo_file:
            self.ammo_file = os.path.expanduser(self.ammo_file)
        self.loop_limit = self.get_option(self.OPTION_LOOP)
        self.ammo_limit = self.get_option("ammo_limit")

        self.load_profile = LoadProfile(**self.get_option('load_profile'))

        self.instances = int(
            self.get_option(self.OPTION_INSTANCES_LIMIT, '1000'))
        self.uris = self.get_option("uris", [])
        while '' in self.uris:
            self.uris.remove('')
        self.headers = self.get_option("headers")
        self.http_ver = self.get_option("header_http")
        self.autocases = self.get_option("autocases")
        self.enum_ammo = self.get_option("enum_ammo")
        self.use_caching = self.get_option("use_caching")

        self.file_cache = self.get_option('file_cache')
        cache_dir = self.get_option("cache_dir") or self.core.artifacts_base_dir
        self.cache_dir = os.path.expanduser(cache_dir)
        self.force_stepping = self.get_option("force_stepping")
        if self.get_option(self.OPTION_LOAD)[self.OPTION_LOAD_TYPE] == 'stpd_file':
            self.stpd = self.get_option(self.OPTION_LOAD)[self.OPTION_SCHEDULE]

        self.chosen_cases = self.get_option("chosen_cases").split()
        if self.chosen_cases:
            self.log.info("chosen_cases LIMITS: %s", self.chosen_cases)
def read_config ( self ) : self . log . info ( "Configuring StepperWrapper..." ) self . ammo_file = self . get_option ( self . OPTION_AMMOFILE ) self . ammo_type = self . get_option ( 'ammo_type' ) if self . ammo_file : self . ammo_file = os . path . expanduser ( self . ammo_file ) self . loop_limit = self . get_option ( self . OPTION_LOOP ) self . ammo_limit = self . get_option ( "ammo_limit" ) self . load_profile = LoadProfile ( * * self . get_option ( 'load_profile' ) ) self . instances = int ( self . get_option ( self . OPTION_INSTANCES_LIMIT , '1000' ) ) self . uris = self . get_option ( "uris" , [ ] ) while '' in self . uris : self . uris . remove ( '' ) self . headers = self . get_option ( "headers" ) self . http_ver = self . get_option ( "header_http" ) self . autocases = self . get_option ( "autocases" ) self . enum_ammo = self . get_option ( "enum_ammo" ) self . use_caching = self . get_option ( "use_caching" ) self . file_cache = self . get_option ( 'file_cache' ) cache_dir = self . get_option ( "cache_dir" ) or self . core . artifacts_base_dir self . cache_dir = os . path . expanduser ( cache_dir ) self . force_stepping = self . get_option ( "force_stepping" ) if self . get_option ( self . OPTION_LOAD ) [ self . OPTION_LOAD_TYPE ] == 'stpd_file' : self . stpd = self . get_option ( self . OPTION_LOAD ) [ self . OPTION_SCHEDULE ] self . chosen_cases = self . get_option ( "chosen_cases" ) . split ( ) if self . chosen_cases : self . log . info ( "chosen_cases LIMITS: %s" , self . chosen_cases )
stepper part of reading options
stepper part of reading options