int main(int argc, const char **argv) 
{
	......
	// 创建用于通信的messenger
	Messenger *msgr = Messenger::create(g_ceph_context, g_conf->ms_type,
			entity_name_t::MDS(-1), "mds",
			nonce);

	// 开始接收消息
	msgr->start();

	// 创建mds daemon对象
	mds = new MDSDaemon(g_conf->name.get_id().c_str(), msgr, &mc);

	// 初始化daemon
	r = mds->init();

	// 等待结束
	msgr->wait();
}

class MDSDaemon : public Dispatcher, public md_config_obs_t {
	Beacon  beacon; // beacon专门用来向mon发送和接收beacon消息，可以理解为mds向mon的心跳消息
	Messenger    *messenger; // 网络通信的组件
	MonClient    *monc; // 连接mon的组件
	MDSMap       *mdsmap; // mdsmap信息
	Objecter     *objecter; // 连接osd的组件
	MDSRankDispatcher *mds_rank; // 文件系统真正的核心实现类
}

int MDSDaemon::init()
{
	// 初始化messenger, objecter, monc，以及订阅需要的map
	monc->sub_want("mdsmap", 0, 0);

	// 初始化beacon对象
	beacon.init(mdsmap);
}

void Beacon::init(MDSMap const *mdsmap)
{
	_send(); // 周期性地向mon发送beacon消息
}

class Filesystem
{
	public:
		fs_cluster_id_t fscid; // 文件系统的编号
		MDSMap mds_map; // 对应的mds信息
		......
};

class FSMap {
	......
	std::map<fs_cluster_id_t, std::shared_ptr<Filesystem> > filesystems; // 所有的文件系统
	std::map<mds_gid_t, fs_cluster_id_t> mds_roles; // 记录mds与文件系统的对应关系，如果是多活模式，多个mds会对应同一个文件系统

	std::map<mds_gid_t, MDSMap::mds_info_t> standby_daemons; // standby的mds
};

class MDSMap {
	std::set<int64_t> data_pools; // 数据池对应的pool id，一个文件系统是可以设置多个data pool的
	int64_t metadata_pool; // 元数据池对应的pool id

	mds_rank_t max_mds; // 文件系统包含的active mds个数

	// 与rank相关的信息
	std::set<mds_rank_t> in;
	std::set<mds_rank_t> failed, stopped, damaged;
	std::map<mds_rank_t, mds_gid_t> up;
	
	// mds的具体信息
	std::map<mds_gid_t, mds_info_t> mds_info;
};

class MDSMonitor : public PaxosService {
	public:
		FSMap fsmap; // 当前的map
		FSMap pending_fsmap; // 待决议的map

		struct beacon_info_t {
			utime_t stamp;
			uint64_t seq;
		};
		map<mds_gid_t, beacon_info_t> last_beacon; // 记录daemon的beacon信息
};

void MDSMonitor::tick()
{
	......
	bool do_propose = false;
	for (auto i : pending_fsmap.filesystems) {
		do_propose |= maybe_expand_cluster(i.second); // 如果需要更新，会做paxos决议
	}

	......

	if (do_propose) {
		propose_pending(); // 开始决议
	}
}

bool MDSMonitor::maybe_expand_cluster(std::shared_ptr<Filesystem> fs)
{
	bool do_propose = false;

	while (fs->mds_map.get_num_in_mds() < size_t(fs->mds_map.get_max_mds()) &&
			!fs->mds_map.is_degraded()) { // 当前负责文件系统的mds个数小于最大值
		......
		mds_gid_t newgid = pending_fsmap.find_replacement_for({fs->fscid, mds},
				name, g_conf->mon_force_standby_active);
		......
		pending_fsmap.promote(newgid, fs, mds); // 增加一个mds，并且会根据不同情况设置mds的初始状态，没有文件系统的时候其状态为STATE_CREATING
		do_propose = true;
	}

	return do_propose;
}

void MDSDaemon::handle_mds_map(MMDSMap *m)
{
	......

	if (mds_rank == NULL) { // 新建一个rank，准备为文件系统服务
		mds_rank = new MDSRankDispatcher(whoami, mds_lock, clog,
				timer, beacon, mdsmap, messenger, monc, objecter,
				new C_VoidFn(this, &MDSDaemon::respawn),
				new C_VoidFn(this, &MDSDaemon::suicide));
		mds_rank->init();
	}

	......

	mds_rank->handle_mds_map(m, oldmap); // rank处理mdsmap，会对文件系统进行初始化
}

// MDSRankDispatcher继承自MDSRank，后者就是文件系统的核心，每个组建都单独独立出一个类完成
class MDSRank {
	const mds_rank_t whoami; // rank id

	MDSMap *&mdsmap; // 当前的mdsmap

	Objecter     *objecter; // 和osd通信的组件

	// 各个子系统的实现
	Server       *server;
	MDCache      *mdcache;
	Locker       *locker;
	MDLog        *mdlog;
	MDBalancer   *balancer;
	ScrubStack   *scrubstack;
	DamageTable  damage_table;

	InoTable     *inotable;

	SnapServer   *snapserver;
	SnapClient   *snapclient;

	......
};

void MDSRankDispatcher::handle_mds_map(
		MMDSMap *m,
		MDSMap *oldmap)
{
	......
	// 很多case
	else if (is_creating()) { // 第一次的时候，需要新建文件系统
		boot_create(); // 初始化文件系统
	}
	......
}

void MDSRank::boot_create()
{
	......
	// 创建journal	
	mdlog->create(fin.new_sub());

	// 新建存放jorunal日志的segment 
	mdlog->prepare_new_segment();

	if (whoami == mdsmap->get_root()) {
		mdcache->create_empty_hierarchy(fin.get()); // 创建文件系统的根目录，分配ionde和dentry等
	}

	......
}

void MDCache::create_empty_hierarchy(MDSGather *gather)
{
	// 创建根目录的inode，默认编号为1
	CInode *root = create_root_inode();

	// 创建根目录
	CDir *rootdir = root->get_or_open_dirfrag(this, frag_t());

	......
}