这篇文章将为大家详细讲解有关EMetaBlob类有什么用，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。
创新互联公司长期为1000多家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为迎江企业提供专业的成都网站建设、成都网站设计，迎江网站改版等技术服务。拥有10年丰富建站经验和众多成功案例,为您定制开发。
EMetaBlob用于记录CDir和CDentry的Log
EMetaBlob类说明：
class EMetaBlob: public LogEvent {
};
EMetaBlob类的方法：
EMetaBlob::add_dir_context(dir, mode) 将dir及其父目录添加到EMetaBlob类中
|__检查当前lump_map集合中是否已经包含dir
|__直接返回
|__从dir目录开始依次向根目录遍历
|__得到dir的CInode(diri)和CDentry(parent)
|__若mode==TO_AUTH_SUBTREE_ROOT
|__若dir是subtree_root并且已经是auth的
|__退出遍历
|__若dir是subtree_root但不是auth的
|__将maybe数组(CDentry list)插入到parents数组的首部
|__若diri已经journal过了
|__退出遍历
|__若diri->last_journaled >= last_subtree_map 说明从last subtree map开始，该inode已经写入日志了
|__maybenot=true
|__若已经是根目录了（parent为空）
|__退出遍历
|__maybenot==true
|__将parent插入到maybe数组中
|__maybenot==false
|__将parent插入到parents数组中
|__dir=parent->get_dir() 从当前dir开始向根目录递进
|__将maybe数组插入到parents数组的首部
|__遍历parents数组
|__add_dentry() 将parents数组中成员添加到EMetaBlob类中
EMetaBlob::update_segment(ls) 更新LogSegment的inotablev和sessionmapv
|__若inotablev不为空
|__ls->inotablev=inotablev
|__若sessionmapv不为空
|__ls->sessionmapv=sessionmapv
EMetaBlob::fullbit::update_inode(mds, in)
|__用EMedaBlob类对象中的数据初始化CInode类对象
EMetaBlob::get_inodes(inodes)
|__遍历lump_map集合
|__得到lump_map结合中每个成员的dirfrag的inode号
|__将inode号插入到inodes数组中
|__从lump_map中得到dirlump信息
|__遍历dirlump中的fullbit
|__将dirlump中fullbit对应的inode号插入到inodes数组中
|__遍历dirlump中的remotebit
|__将remotebit的inode号插入到inodes数组中
EMetaBlob::get_dentries(dentries)
|__遍历lump_map集合
|__从lump_map中得到dirlump信息
|__从dirlump结构中分别得到full_dentry/remote_dentry/null_dentry信息
|__遍历full_dentry数组
|__将full_dentry数组中成员的dn(dentry name)插入到dentries数组中
|__遍历remote_dentry数组
|__将remote_dentry数组中成员的dn(dentry name)插入到dentries数组中
|__遍历null_dentry数组
|__将null_dentry数组中成员的dn(dentry name)插入到dentries数组中
EMetaBlob::get_paths(paths) 从dirlump结构中得到所有的绝对目录信息
|__若lump_map为空且roots不为空
|__将”/“插入到paths数组
|__遍历lump_map集合
|__得到full_dentry/remote_dentry/null_dentry数组
|__遍历full_dentry数组
|__将full_dentry数组成员中的dentry name插入到children数组中，即：children[dir_ino].push_back(dentry)
|__更新ino_locations数组，即：ino_locations[(*iter)->inode.ino] = Location(dir_ino, dentry)
|__遍历remote_dentry数组
|__将remote_dentry数组成员中的dentry name插入到children数组中，即：children[dir_ino].push_back(dentry)
|__遍历null_dentry数组
|__将null_dentry数组成员中的dentry name插入到children数组中，即：children[dir_ino].push_back(dentry)
|__遍历lump_map集合
|__得到full_dentry/remote_dentry/null_dentry数组
|__遍历full_dentry数组
|__若在children数组中没有找到对应的节点，则说明此节点是叶子节点
|__将节点的inode和dentry信息插入到leaf_locations数组中，即：leaf_locations.push_back(Location(dir_ino, dentry))
|__遍历remote_dentry数组
|__将节点的inode和dentry信息插入到leaf_locations数组中，即：leaf_locations.push_back(Location(dir_ino, dentry))
|__遍历null_dentry数组
|__将节点的inode和dentry信息插入到leaf_locations数组中，即：leaf_locations.push_back(Location(dir_ino, dentry))
|__遍历leaf_locations数组
|__得到inode号和对应的path
|__在ino_locations数组中遍历查找inode号，若查找成功
|__将ino_locations数组中对应的path值添加到path的前面，即：构成当前path的上一级path目录信息
|__inode号更新为ino_locations对应的inode号
|__将得到的path值插入到paths数组中
EMetaBlob::replay(mds, logseg, slaveup)
|__遍历roots数组
|__从MDCache中得到CInode信息，即：mds->mdcache->get_inode()
|__若MDCache中没有CInode信息
|__创建一个新的CInode类对象
|__EMetaBlob::fullbit::update_inode() 使用fullbit信息更新CInode信息
|__若roots成员是dirty的
|__设置CInode为dirty
|__若renamed_dirino不为空
|__从MDCache中得到CInode信息，即：mds->mdcache->get_inode(renamed_dirino)
|__遍历lump_order数组
|__从lump_map数组中得到dirlump信息
|__dirlump的nnull不为空
|__更新nnull个数，即：nnull += lump.nnull
|__遍历lump_order数组
|__从lump_map数组中得到dirlump信息
|__从MDCache中得到dirfrag对应的CDir信息，即：mds->mdcache->get_force_dirfrag()
|__若CDir为空
|__从MDCache中得到该CDir对应的CInode信息，即：mds->mdcache->get_inode()
|__若CInode为空
|__若CDir对应的CInode号是MDSDIR的范围
|__从MDCache中创建一个CInode，即：mds->mdcache->create_system_inode()
|__清除新建的CInode的AUTH标识，即：diri->state_clear(STATE_AUTH)
|__若CDir对应的CInode号不是MDSDIR的范围
|__assert(0)
|__根据CInode得到CDir信息，即：diri->get_or_open_dirfrag()
|__若CInode对应的号是ROOT或MDSDIR
|__调整subtree的auth，即：mds->mdcache->adjust_subtree_auth()
|__设置CDir的version/fnode信息
|__若dirlump是is_importing()
|__设置CDir STATE_AUTH标志，清除STATE_COMPLETE标志
|__若dirlump是is_dirty()
|__CDir::_mark_dirty()
|__若dir->fnode.rstat != dir->fnode.accounted_rstat 说明有dirty nestinfo
|__mds->locker->mark_updated_scatterlock()
|__logseg->dirty_dirfrag_nest.push_back(dir->inode->item_dirty_dirfrag_nest)
|__若dir->fnode.fragstat != dir->fnode.accounted_fragstat 说明有dirty fragstat
|__mds->locker->mark_updated_scatterlock()
|__logseg->dirty_dirfrag_dir.push_back(dir->inode->item_dirty_dirfrag_nest)
|__若lump是is_dirty_dft()
|__设置dir的状态为DIRTYDFT，即：dir->state_set(STATE_DIRTYDFT)
|__mds->locker->mark_updated_scatterlock()
|__logseg->dirty_dirfrag_dirfragtree.push_back(dir->inode->item_dirty_dirfrag_nest)
|__若lump是is_new()
|__设置dir是new的，即：dir->mark_new()
|__若lump是is_complete()
|__设置dir是complete的，即：dir->mark_complete()
|__从lump中解析出dfull/dremote/dnull信息，即：lump._decode_bits()
|__遍历full_dentry数组
|__得到dnlast对应的CDentry对象，即：dir->lookup_exact_snap(dn, dnlast)
|__若CDentry对象为空
|__向dir添加一个空的dentry，即：dir->add_null_dentry()
|__根据full_dentry的dentry version信息，设置dentry的版本信息
|__若CDentry对象不为空
|__根据full_dentry的dentry version信息，设置dentry的版本信息
|__设置dentry的first为full_entry的dnfirst
|__若lump是is_importing()
|__设置dentry的状态为AUTH，即：dn->state_set(STATE_AUTH)
|__从MDCache中得到dnlast的CInode信息，即：mds->mdcache->get_inode(ino, dnlast)
|__若CInode信息为空
|__创建一个新的CInode类对象
|__使用full_dentry信息初始化新的CInode类对象，即：p->update_inode(mds, in)
|__将新的CInode添加到MDCache中，即：mds->mdcache->add_inode(in)
|__若dentry的linkage不为空
|__若dentry的linkage是primary
|__将dir放入到unlinked数组中 应该被删除掉的
|__解除dir和dentry之间的对应关系，即：dir->unlink_inode(dn)
|__若CInode位于unlinked数组中
|__将CInode插入到linked数组中
|__设置dir的primary link inode，即：dir->link_primary_inode(dn, in)
|__若CInode信息不为空
|__设置CInode的first值，即：in->first = p->dnfirst
|__使用full_dentry信息初始化新的CInode类对象，即：p->update_inode(mds, in)
|__若dentry的linkage不是CInode并且CInode有parent dentry
|__将CInode的parent dir放入unlinked数组
|__解除CInode与其parent dir的对应关系，即：in->get_parent_dir()->unlink_inode(in->get_parent_dn())
|__若dentry的linkage不是CInode
|__若dentry的linkage不为空
|__若dentry的linkage是primary
|__将dir放入到unlinked数组中 应该被删除掉的
|__解除dir和dentry之间的对应关系，即：dir->unlink_inode(dn)
|__若CInode位于unlinked数组中
|__将CInode插入到linked数组中
|__设置dir的primary link inode，即：dir->link_primary_inode(dn, in)
|__若full_dentry是is_dirty()
|__设置CInode为dirty， 即：in->_mark_dirty(logseg)
|__若full_dentry是is_dirty_parent()
|__设置CInode为dirty parent，即：in->_mark_dirty_parent()
|__若dentry是is_auth()
|__设置CInode的状态为AUTH，即：in->state_set(STATE_AUTH)
|__遍历remote dentry数组
|__得到dnlast对应的CDentry对象，即：dir->lookup_exact_snap(dn, dnlast)
|__若CDentry对象为空
|__向dir添加一个新的remote dentry，即：dir->add_remote_dentry()
|__根据remote_dentry的dentry version信息，设置dentry的版本信息
|__若CDentry对象不为空
|__若dentry的linkage不为空
|__若dentry的linkage是primary
|__将dir插入到unlinked数组中
|__解除dir与dentry之间的关联，即：dir->unlink_inode(dn)
|__向dir添加remote inode，即：dir->link_remote_inode()
|__根据remote_dentry的dentry version信息，设置dentry的版本信息
|__设置dentry的first为remote_dentry的first
|__若lump是is_importing()
|__设置dentry的状态为AUTH，即：dn->state_set(STATE_AUTH)
|__遍历null_dentry数组
|__得到dnlast对应的CDentry对象，即：dir->lookup_exact_snap(dn, dnlast)
|__若CDentry对象为空
|__向dir添加一个新的remote dentry，即：dir->add_remote_dentry()
|__根据remote_dentry的dentry version信息，设置dentry的版本信息
|__若CDentry对象不为空
|__设置dentry的first为null_dentry的first
|__若dentry的linkage不为空
|__将dir插入到unlinked数组中
|__解除dir与dentry之间的关联，即：dir->unlink_inode(dn)
|__根据null_dentry的版本信息，设置dentry的版本信息
|__若lump是is_importing()
|__设置dentry的状态为AUTH，即：dn->state_set(STATE_AUTH)
|__若renamed_dirino不为空
|__若renamed_diri不为空
|__设置olddir为unlinked[renamed_diri]
|__若renamed_diri为空
|__从MDCache中得到renamed_diri，即：mds->mdcache->get_inode(renamed_dirino)
|__若olddir不为空
|__从renamed_diri的dirfragtree上得到所有的叶子节点，即：renamed_diri->dirfragtree.get_leaves()
|__遍历叶子节点
|__根据叶子节点找到对应的CDir信息
|__若CDir没有被认证
|__将CDir对应的CInode插入到slaveup的olddirs中，即：slaveup->olddirs.insert(dir->inode)
|__若CDir被认证
|__设置dir的状态为AUTH，即：dir->state_set(STATE_AUTH)
|__更新MDCache中的subtree信息，即：mds->mdcache->adjust_subtree_after_rename()
|__从MDCache中得到olddir的subtree_root的CDir信息
|__若subtree_root未认证
|__若slaveup不为空
|__将olddir对应的CInode插入到slaveup的olddirs中，即：slaveup->olddirs.insert(dir->inode)
|__若slaveup为空
|__更新MDCache的subtree信息，即：mds->mdcache->try_trim_non_auth_subtree()
|__若renamed_diri被认证
|__遍历renamed_dir_frags数组
|__从renamed_diri这个CInode得到其dirfrag的CDir信息，即：reanmed_diri->get_dirfrag()
|__若CDir信息存在
|__遍历下一个
|__创建一个新的CDir对象，即：renamed_diri->get_or_open_dirfrag()
|__清除新建的CDir的AUTH，即：dir->state_clear(STATE_AUTH)
|__调整MDCache中的subtree信息，即：mds->mdcache->adjust_subtree_auth()
|__从unlinked数组中删除renamed_diri
|__遍历unlined数组
|__调整MDCache中的subtree信息，即：mds->mdcache->adjust_subtree_after_rename()
|__若unlinked数组不为空
|__遍历linked数组
|__从unlinked数组中删除linked数组中的成员
|__遍历unlinked数组
|__若slaveup不为空
|__将unlinked信息插入到slaveup的unlinked数组中，即：slaveup->unlinked.insert()
|__若slaveup为空
|__更新MDCache，即：mds->mdcache->remove_inode_recursive()
|__遍历table_tids数组（遍历table client）
|__得到MDSTableClient类对象，即：mds->get_table_client()
|__执行client的got_journaled_agree()函数，即：client->got_journaled_agree()
|__若opened_ino不为空
|__从MDCache中得到opened_ino对应的CInode，即：mds->mdcache->get_inode()
|__将CInode的item_open_file插入到logseg的open_files数组中，即：logseg->open_files.push_back()
|__若inotablev不为空
|__若mds的inotable版本号小于inotablev
|__若allocated_ino不为空
|__重新分配inode号，即：mds->inotable->replay_alloc_id()
|__若preallocated_inos不为空
|__重新分配inode号，即：mds->inotable->replay_alloc_id()
|__若sessionmapv不为空
|__若mds的sessionmap版本号+2>=sessionmapv
|__根据client_name得到session信息，即：mds->sessionmap.get_session()
|__若session不为空
|__重新执行dirty的session，即：mds->sessionmap.replay_dirty_session()
|__若session为空
|__执行advance version，即：mds->sessionmap.replay_advance_version()
|__遍历truncate_start数组
|__从MDCache中得到对应的CInode信息，即：mds->mdcache->get_inode()
|__在MDCache中执行add recovered truncate，即：mds->mdcache->add_recovered_truncate()
|__遍历truncate_finish数组
|__从MDLog中得到对应的LogSegment，即：mds->mdlog->get_segment()
|__从MDCache中得到对应的CInode信息，即：mds->mdcache->get_inode()
|__在MDCache中执行remove recovered truncate，即：mds->mdcache->remove_recovered_truncate()
|__遍历destroyed_inodes数组
|__从MDCache中得到对应的CInode信息，即：mds->mdcache->get_inode()
|__在MDCache中删除对应的CInode，即：mds->mdcache->remove_inode()
|__遍历client_reqs数组
|__从sessionmap中得到对应的Session类对象，即：mds->sessionmap.get_session()
|__在Session对象中添加completed request，即：session->add_completed_request()
|__若client_reqs数组中包含trim的session
|__在Session对象中执行trim completed request，即：session->trim_completed_request()
|__遍历client_flushes数组
|__从sessionmap中得到对应的Session类对象，即：mds->sessionmap.get_session()
|__在Session对象中添加completed request，即：session->add_completed_request()
|__若client_reqs数组中包含trim的session
|__在Session对象中执行trim completed request，即：session->trim_completed_request()
|__更新LogSegment信息，即：update_segment(logseg)
关于“EMetaBlob类有什么用”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。
重庆分公司
重庆分公司
