概述：
追踪 VDSM 启动后的代码大概流程，是继 vdsm/vdsm 文件学习后的继续。
Let's go!
从 “def serve_clients(log)” 开始
1 def serve_clients(log): 2 cif = None 3 irs = None 4 scheduler = None 5 running = [True] 6 7 def sigtermHandler(signum, frame): 8 log.debug("Received signal %s" % signum) 9 running[0] = False10 11 def sigusr1Handler(signum, frame):12 if irs:13 log.debug("Received signal %s" % signum)14 irs.spmStop(15 irs.getConnectedStoragePoolsList()['poollist'][0])16 17 sigutils.register()18 signal.signal(signal.SIGTERM, sigtermHandler)19 signal.signal(signal.SIGUSR1, sigusr1Handler)20 zombiereaper.registerSignalHandler()21 22 profile.start()23 24 libvirtconnection.start_event_loop()25 26 try:27 if config.getboolean('irs', 'irs_enable'):28 try:29 irs = Dispatcher(HSM())30 except:31 utils.panic("Error initializing IRS")32 33 from clientIF import clientIF # must import after config is read34 cif = clientIF.getInstance(irs, log)35 36 install_manhole({ 'irs': irs, 'cif': cif})37 38 scheduler = schedule.Scheduler(name="vdsm.Scheduler",39 clock=utils.monotonic_time)40 scheduler.start()41 cif.start()42 periodic.start(cif, scheduler)43 try:44 while running[0]:45 sigutils.wait_for_signal()46 47 profile.stop()48 finally:49 periodic.stop()50 cif.prepareForShutdown()51 scheduler.stop()52 finally:53 libvirtconnection.stop_event_loop(wait=False) 代码：
22 profile.start()
是调用 vdsm/lib/vdsm/profiling/profile.py 的 start() 方法，如下：
1 def start():2 cpu.start()3 memory.start()
再次调用同级目录的 cpu.py 和 memory.py 的 start() 方法，如下：
1 def start(): 2 """ Starts application wide CPU profiling """ 3 if is_enabled(): 4 _start_profiling(_CLOCK, _BUILTINS, _THREADS) 5 6 7 8 def start(): 9 """ Starts application memory profiling """10 if is_enabled():11 _start_profiling()
其本质是两个线程，分别监测 CPU 和内存。
代码：
24 libvirtconnection.start_event_loop()
调用 libvirtconnection.start_event_loop() 注册与 libvirt 的连接事件处理。
其代码在 vdsm/lib/vdsm/libvirtconnection.py
1 def start_event_loop(): 2 __event_loop.start() 3 4 5 __event_loop = _EventLoop() 6 7 8 class _EventLoop: 9 def __init__(self):10 self.run = False11 self.__thread = None12 13 def start(self):14 assert not self.run15 self.__thread = threading.Thread(target=self.__run,16 name="libvirtEventLoop")17 self.__thread.setDaemon(True)18 self.run = True19 self.__thread.start()20 21 @utils.traceback(on=log.name)22 def __run(self):23 try:24 libvirt.virEventRegisterDefaultImpl()25 while self.run:26 libvirt.virEventRunDefaultImpl()27 finally:28 self.run = False
方法 start_event_loop() 通过 _EventLoop 对象的实例调用其 start() 方法，
从而调用到 __run 方法，在 __run() 方法中调用 libvirt 的默认实现方法：
virEventRegisterDefaultImpl()。
其实质也是一个线程，用于处理与 libvirt 的数据交互。
备注：
libvirt 项目代码不包含在 VDSM 项目代码里，如需查看其实现，请下载 libvirt 代码查看。
下载地址：http://libvirt.org/downloads.html。
代码：
29 irs = Dispatcher(HSM())
涉及两个类的初始化。
HSM 类在 vdsm/vdsm/storage/hsm.py 中，查看其 __init__ 方法，代码如下：
1 def __init__(self): 2 """ 3 The HSM Constructor 4 5 :param defExcFunc: The function that will set the default exception 6 for this thread 7 :type defExcFun: function 8 """ 9 self._ready = False10 rm.ResourceManager.getInstance().registerNamespace(11 STORAGE, rm.SimpleResourceFactory())12 self.storage_repository = config.get('irs', 'repository')13 self.taskMng = taskManager.TaskManager()14 15 mountBasePath = os.path.join(self.storage_repository,16 sd.DOMAIN_MNT_POINT)17 fileUtils.createdir(mountBasePath)18 storageServer.MountConnection.setLocalPathBase(mountBasePath)19 storageServer.LocalDirectoryConnection.setLocalPathBase(mountBasePath)20 self._connectionAliasRegistrar = \21 storageServer.ConnectionAliasRegistrar(STORAGE_CONNECTION_DIR)22 self._connectionMonitor = \23 storageServer.ConnectionMonitor(self._connectionAliasRegistrar)24 self._connectionMonitor.startMonitoring()25 26 sp.StoragePool.cleanupMasterMount()27 self.__releaseLocks()28 29 self._preparedVolumes = defaultdict(list)30 31 self.__validateLvmLockingType()32 33 oop.setDefaultImpl(config.get('irs', 'oop_impl'))34 35 # cleanStorageRepoitory uses tasksDir value, this must be assigned36 # before calling it37 self.tasksDir = config.get('irs', 'hsm_tasks')38 39 # This part should be in same thread to prevent race on mounted path,40 # otherwise, storageRefresh can unlink path that is used by another41 # thread that was initiated in the same time and tried to use the42 # same link.43 try:44 # This call won't get stuck if mount is inaccessible thanks to45 # misc.walk, this sync call won't delay hsm initialization.46 self.__cleanStorageRepository()47 except Exception:48 self.log.warn("Failed to clean Storage Repository.", exc_info=True)49 50 @utils.traceback(on=self.log.name)51 def storageRefresh():52 sdCache.refreshStorage()53 lvm.bootstrap(refreshlvs=blockSD.SPECIAL_LVS)54 self._ready = True55 self.log.debug("HSM is ready")56 57 storageRefreshThread = threading.Thread(target=storageRefresh,58 name="storageRefresh")59 storageRefreshThread.daemon = True60 storageRefreshThread.start()61 62 monitorInterval = config.getint('irs', 'sd_health_check_delay')63 self.domainMonitor = monitor.DomainMonitor(monitorInterval) 在初始化函数要看这么多代码，刚开始，我是拒绝的，你不能说代码走到这里，我就
要马上看啊，后来，我试着看了一下，duang ...
代码：
10 rm.ResourceManager.getInstance().registerNamespace(11 STORAGE, rm.SimpleResourceFactory())
这里的 rm 是模块 resourceManager 的别名 (import <模块> as <别名>)，
该模块文件在 vdsm.vdsm.storage.resourceManager （. 替换为 / 即可找到位置，大家都懂的）
调用其模块内的类 ResourceManager.getInstance() 方法，用于获取
ResourceManager 的实例。那代码就转换为调用 ResourceManager 实例的注册名称空间
registerNamespace（） 方法。
补充：
这个方法一般用在某一个类只能有一个实例的场景，使用 getInstance 方法来保证单实例，
C++、Java 也有类似的使用。
代码：
12 self.storage_repository = config.get('irs', 'repository')13 self.taskMng = taskManager.TaskManager() 从配置文件里读取存储路径
创建任务管理器，TaskManager 会创建线程池以及有关线程池操作、维护需要的锁等资源
代码：
15 mountBasePath = os.path.join(self.storage_repository,16 sd.DOMAIN_MNT_POINT)17 fileUtils.createdir(mountBasePath)18 storageServer.MountConnection.setLocalPathBase(mountBasePath)19 storageServer.LocalDirectoryConnection.setLocalPathBase(mountBasePath)20 self._connectionAliasRegistrar = \ 21 storageServer.ConnectionAliasRegistrar(STORAGE_CONNECTION_DIR) 22 self._connectionMonitor = \ 23 storageServer.ConnectionMonitor(self._connectionAliasRegistrar) 24 self._connectionMonitor.startMonitoring()
根据从配置中获取的 [irs] 的 'repository' 的值来复制挂载的根路径
创建该目录
设置挂载目录连接的主目录
设置本地目录连接的主目录
连接的别名注册（打开 connnection 目录下的 '*.con' 文件，并保存文件信息， 使用了 pickle 模块 ）
根据别名对象，生成连接管理对象
创建线程，定时检查连接、并根据连接情况进行处理
代码：
26 sp.StoragePool.cleanupMasterMount()27 self.__releaseLocks()
清除目录 mnt/blockSD/ 目录下的挂载
释放所有的锁（在初始化 VDSM 需要释放所有的锁，例如：之前有 VDSM 在运行）
代码：
29 self._preparedVolumes = defaultdict(list)30 31 self.__validateLvmLockingType()32 33 oop.setDefaultImpl(config.get('irs', 'oop_impl')) 创建一个 defaultdict 类型（参见: ）
检查 lvm 的 LockingType（执行 lvm 命令检查 lvm 的配置项：global/locking_type）
根据配置：irs/oop_impl 设置 oop 的默认实现
代码：
35 # cleanStorageRepoitory uses tasksDir value, this must be assigned36 # before calling it37 self.tasksDir = config.get('irs', 'hsm_tasks') 设置 tasks 目录
代码：
39 # This part should be in same thread to prevent race on mounted path,40 # otherwise, storageRefresh can unlink path that is used by another41 # thread that was initiated in the same time and tried to use the42 # same link.43 try:44 # This call won't get stuck if mount is inaccessible thanks to45 # misc.walk, this sync call won't delay hsm initialization.46 self.__cleanStorageRepository()47 except Exception:48 self.log.warn("Failed to clean Storage Repository.", exc_info=True) 调用清除存储目录
代码：
50 @utils.traceback(on=self.log.name)51 def storageRefresh():52 sdCache.refreshStorage()53 lvm.bootstrap(refreshlvs=blockSD.SPECIAL_LVS)54 self._ready = True55 self.log.debug("HSM is ready") 56 57 storageRefreshThread = threading.Thread(target=storageRefresh, 58 name="storageRefresh") 59 storageRefreshThread.daemon = True 60 storageRefreshThread.start() 创建线程，线程执行的函数为 storageRefresh()，而该函数调用 sdCache 模块的 refreshStorage
来进行实际的刷新存储相关的，
代码：
62 monitorInterval = config.getint('irs', 'sd_health_check_delay')63 self.domainMonitor = monitor.DomainMonitor(monitorInterval) 存储域管理
[欲知后事如何，请听下回分解...]
基于：
1. 文章代码流程分析篇幅较长，太长会冗长、乏味；
2. 没有一个实际的 oVirt 系统运行，像纸上谈兵、凭空捏造；
3. 后续流程涉及部分相关的业务。
VDSM 流程追踪将在后续文章中继续进行分析，而最近的将是 oVirt 系统搭建的简介。