saltstack源码-启动1

......
PYTHON=/usr/bin/python
SALTMASTER=/usr/bin/salt-master
MASTER_ARGS=""
......
stat() {
    ......
    elif $PYTHON $SALTMASTER -d $MASTER_ARGS >& /dev/null; then
            echo -n "OK"
            RETVAL=0
    ......
}
.......

#!/usr/bin/python
‘‘‘
Start the salt-master
‘‘‘
from salt.scripts import salt_master
 
if __name__ == ‘__main__‘:
    salt_master()

#!/usr/bin/python
import os
import sys
 
# Import salt libs
import salt  #包含本身的模块 路径:/usr/lib/python2.6/site-packages/salt/__init__.py
import salt.cli #这个暂时不知道干嘛的,以后再来分析 这个包含的路径是/usr/lib/python2.6/site-packages/salt/cli/__init__.py
 
def salt_master():
    ‘‘‘
    Start the salt-master.
    ‘‘‘
    master = salt.Master()
    master.start()

class Master(parsers.MasterOptionParser):
    ‘‘‘
    #这个类的继承是继承自/usr/lib/python2.6/site-packages/salt/utils/parser.py里面的
    #这个parsers.py模块重写了自带的标准库optoarse.py的几个方法
    Creates a master server
    ‘‘‘
    def prepare(self):
        ‘‘‘
        Run the preparation sequence required to start a salt master server.
 
        If sub-classed, don‘t **ever** forget to run:
 
            super(YourSubClass, self).prepare()
        ‘‘‘
        self.parse_args()
 
        try:
            if self.config[‘verify_env‘]:
                verify_env(
                    [
                        self.config[‘pki_dir‘],
                        os.path.join(self.config[‘pki_dir‘], ‘minions‘),
                        os.path.join(self.config[‘pki_dir‘], ‘minions_pre‘),
                        os.path.join(self.config[‘pki_dir‘],
                                     ‘minions_rejected‘),
                        self.config[‘cachedir‘],
                        os.path.join(self.config[‘cachedir‘], ‘jobs‘),
                        os.path.join(self.config[‘cachedir‘], ‘proc‘),
                        self.config[‘sock_dir‘],
                        self.config[‘token_dir‘],
                    ],
                    self.config[‘user‘],
                    permissive=self.config[‘permissive_pki_access‘],
                    pki_dir=self.config[‘pki_dir‘],
                )
                logfile = self.config[‘log_file‘]
                if logfile is not None and not logfile.startswith((‘tcp://‘,
                                                                   ‘udp://‘,
                                                                   ‘file://‘)):
                    # Logfile is not using Syslog, verify
                    verify_files([logfile], self.config[‘user‘])
        except OSError as err:
            sys.exit(err.errno)
 
        self.setup_logfile_logger()
        logger.info(‘Setting up the Salt Master‘)
 
        if not verify_socket(self.config[‘interface‘],
                             self.config[‘publish_port‘],
                             self.config[‘ret_port‘]):
            self.exit(4, ‘The ports are not available to bind\n‘)
        self.config[‘interface‘] = ip_bracket(self.config[‘interface‘])
        migrations.migrate_paths(self.config)
 
        # Late import so logging works correctly
        import salt.master
        self.master = salt.master.Master(self.config)
        self.daemonize_if_required()
        self.set_pidfile()
 
    def start(self):
        ‘‘‘
        Start the actual master.
 
        If sub-classed, don‘t **ever** forget to run:
 
            super(YourSubClass, self).start()
 
        NOTE: Run any required code before calling `super()`.
        ‘‘‘
        self.prepare() #这里调用自己的prepare的方法
        if check_user(self.config[‘user‘]):
            try:
                self.master.start()
            except MasterExit:
                self.shutdown()
            finally:
                sys.exit()
 
    def shutdown(self):
        ‘‘‘
        If sub-classed, run any shutdown operations on this method.
        ‘‘‘