首页 > 代码库 > saltstack源码-启动2-parsers.py选项初始化1
saltstack源码-启动2-parsers.py选项初始化1
class MasterOptionParser(OptionParser, ConfigDirMixIn, MergeConfigMixIn, LogLevelMixIn, RunUserMixin, DaemonMixIn, PidfileMixin):#这些差不多全是salt初始化的类,有的minion也会调用 __metaclass__ = OptionParserMeta #指定他的元类 description = ‘The Salt master, used to control the Salt minions.‘ # ConfigDirMixIn config filename attribute _config_filename_ = ‘master‘#默认配置文件名 # LogLevelMixIn attributes _default_logging_logfile_ = os.path.join(syspaths.LOGS_DIR, ‘master‘) #这里是得到他的日志文件路径/var/log/salt/master def setup_config(self): return config.master_config(self.get_config_file_path())
接下来就是查找他的元类
python类在初始化的时候,经历了两个阶段,第一个阶段是分配空间__new__(),第二个阶段是初始化值__init__()。当类被创建时,python会首先寻找__metaclass__是否存在,
如果存在则调用__metaclass__。如果此类没定义__metaclass__就去看父类,父类没有就去模块里找(全局变量__metaclass__),
模块里再没有就把__metaclass__ = type作为类的metaclass。
mcs代表调用__new__函数的class,name代表对象的__name__值,也就是名称,bases代表对象的父类元组,attrs代表类的属性字典.
class MixInMeta(type): # This attribute here won‘t actually do anything. But, if you need to # specify an order or a dependency within the mix-ins, please define the # attribute on your own MixIn _mixin_prio_ = 0 def __new__(mcs, name, bases, attrs): instance = super(MixInMeta, mcs).__new__(mcs, name, bases, attrs) if not hasattr(instance, ‘_mixin_setup‘): raise RuntimeError( ‘Don\‘t subclass {0} in {1} if you\‘re not going to use it ‘ ‘as a salt parser mix-in.‘.format(mcs.__name__, name) ) return instance class OptionParserMeta(MixInMeta): def __new__(mcs, name, bases, attrs): instance = super(OptionParserMeta, mcs).__new__(mcs, name, bases, attrs) #上面调用父类的MinInMeta.__new__方法 if not hasattr(instance, ‘_mixin_setup_funcs‘): instance._mixin_setup_funcs = [] if not hasattr(instance, ‘_mixin_process_funcs‘): instance._mixin_process_funcs = [] if not hasattr(instance, ‘_mixin_after_parsed_funcs‘): instance._mixin_after_parsed_funcs = [] #这条语句分别创建了3个空列表 for base in _sorted(bases + (instance,)): #这里是把基类和子类进行排序 func = getattr(base, ‘_mixin_setup‘, None)#得到所有类_mixin_setup属性方法,没有就赋值为None if func is not None and func not in instance._mixin_setup_funcs: instance._mixin_setup_funcs.append(func) #for循环过后得到的列表 _mixin_setup_funcs[ConfigDirMixIn._mixin_setup, # LogLevelMixIn._mixin_setup, # RunUserMixin._mixin_setup, # DaemonMixIn_mixin_setup, # PidfileMixin._mixin_setup, # ] #这些类方法是初始化salt的选项命令 func = getattr(base, ‘_mixin_after_parsed‘, None)##得到所有类_mixin_after_parsed属性方法,没有就赋值为None if func is not None and func not in instance._mixin_after_parsed_funcs: instance._mixin_after_parsed_funcs.append(func) #这个列表如果是启动的话在这是空列表,不过会在OptionParser的parse_args方法里面实现添加 # Mark process_<opt> functions with the base priority for sorting for func in dir(base): if not func.startswith(‘process_‘): continue func = getattr(base, func) if getattr(func, ‘_mixin_prio_‘, None) is not None: # Function already has the attribute set, don‘t override it continue func.__func__._mixin_prio_ = getattr( base, ‘_mixin_prio_‘, 1000 ) #这个for循环把所有没_mixin_prio属性的基类 设置属性值1000 return instance #返回实例
接下来就是调用OptionParser的__init__()方法来初始化了
接着调用的OptionParser的parse_args方法
def parse_args(self, args=None, values=None): options, args = optparse.OptionParser.parse_args(self, args, values)#上面这句options的值是{‘daemon‘: False, ‘log_level‘: None, ‘versions_report‘: None, ‘user‘: None, ‘log_file‘: None, ‘config_dir‘: ‘/etc/salt‘, ‘pidfile‘: ‘/var/run/salt.pid‘, ‘log_level_logfile‘: None}#惭愧 到现在都还没找到这些值是怎么来的,找了好久都没找到,后来干脆就不找了,现往下看完再说,别吊死在这 if options.versions_report: self.print_versions_report() self.options, self.args = options, args # Let‘s get some proper sys.stderr logging as soon as possible!!! # This logging handler will be removed once the proper console or # logfile logging is setup. log.setup_temp_logger( getattr(self.options, ‘log_level‘, ‘error‘) ) # Gather and run the process_<option> functions in the proper order process_option_funcs = [] for option_key in options.__dict__.keys(): process_option_func = getattr( self, ‘process_{0}‘.format(option_key), None ) if process_option_func is not None: process_option_funcs.append(process_option_func)#下面分别执行这3个方法process_config_dir process_log_level process_log_file for process_option_func in _sorted(process_option_funcs): try: process_option_func() except Exception as err: logging.getLogger(__name__).exception(err) self.error( ‘Error while processing {0}: {1}‘.format( process_option_func, traceback.format_exc(err) ) )#首先看一下ConfigDirMixIn.process_config_dir 方法 def process_config_dir(self): if not os.path.isdir(self.options.config_dir): # No logging is configured yet sys.stderr.write( ‘WARNING: {0!r} directory does not exist.\n‘.format( self.options.config_dir ) ) # Make sure we have an absolute path self.options.config_dir = os.path.abspath(self.options.config_dir) if hasattr(self, ‘setup_config‘): try: self.config = self.setup_config() #这里调用子类的MasterOptionParser.setup_config 方法,其方法原型如下: #def setup_config(self): # return config.master_config(self.get_config_file_path()) except (IOError, OSError) as exc: self.error( ‘Failed to load configuration: {0}‘.format(exc) )
那个get_config_file_path()返回配置文件的绝对路径然后作为参数传至config.py里面的master_config()方法
草!又调到config.py了,4个编辑器完全不够我用的...妈的继续往下去看
saltstack源码-启动2-parsers.py选项初始化1
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。