13518219792
这篇文章主要介绍了Migrator类怎么用，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。
成都创新互联从2013年创立，先为台州等服务建站，台州等地企业，进行企业商务咨询服务。为台州企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。
Migrator类说明：
class Migrator {
MDSRank *mds; 记录mds信息
MDCache *cache; 记录MDCache信息
struct export_state_t {
int state; 记录export的当前状态
mds_rank_t peer; 记录export到对端mds rank信息
uint64_t tid; 记录export到对端的session id信息
set warning_ack_waiting; 等待warning ack的mds集合
set notify_ack_waiting; 等待notify ack的mds集合
map> peer_imported; 记录export对端信息
list waiting_for_finish; 记录等待finish的集合
MutationRef mut; MutationImpl对象引用
utime_t last_cum_auth_pins_change;
int last_cum_auth_pins;
int num_remote_waiters; 远程auth pin waiters
};
map export_state; export的状态集合
list> export_queue; export队列
struct import_state_t {
int state;
mds_rank_t peer;
uint64_t tid;
set bystanders;
list bound_ls;
list updated_scatterlocks;
map client_map;
map> peer_exports;
MutationRef mut;
};
map import_state;
}; Migrator类方法：
Migrator::dispatch(m) 核心分发处理函数
|__根据m的类型决定后续的处理过程
|__类型是MSG_MDS_EXPORTDIRDISCOVER
|__调用handle_export_discover(MExportDirDiscover* m)
|__类型是MSG_MDS_EXPORTDIRPREP
|__调用handle_export_prep(MExportDirPrep* m)
|__类型是MSG_MDS_EXPORTDIR
|__调用handle_export_dir(MExportDir* m)
|__类型是MSG_MDS_EXPORTDIRFINISH
|__调用handle_export_finsih(MExportDirFinish* m)
|__类型是MSG_MDS_EXPORTDIRCANCEL
|__调用handle_export_cancel(MExportDirCancel* m)
|__类型是MSG_MDS_EXPORTDIRDISCOVERACK
|__调用handle_export_discover_ack(MExportDirDiscoverAck* m)
|__类型是MSG_MDS_EXPORTDIRPREACK
|__调用handle_export_prep_ack(MExportDirPrepAck* m)
|__类型是MSG_MDS_EXPORTDIRACK
|__调用handle_export_ack(MExportDirAck* m)
|__类型是MSG_MDS_EXPORTDIRNOTIFYACK
|__调用handle_export_notify_ack(MExportDirNotifyAck* m)
|__类型是MSG_MDS_EXPORTDIRNOTIFY
|__调用handle_export_dir_notify(MExportDirNotify* m)
|__类型是MSG_MDS_EXPORTCAPS
|__调用handle_export_caps(MExportCaps* m)
|__类型是MSG_MDS_GATHERCAPS
|__调用handle_gather_caps(MGatherCaps* m)
Migrator::export_empty_import(dir)
|__dir对应的inode节点是auth的
|__直接返回
|__dir是auth的
|__直接返回
|__dir是freezing或frozen
|__直接返回
|__dir不是空目录
|__直接返回
|__dir是root节点
|__直接返回
|__得到export目的dir所在的mds节点，即：dir->inode->authority().first
|__调用export_dir(dir, dest) 执行实际的export操作
Migrator::export_dir(dir, dest)
|__检查MDCache是否是readonly(目前尚不支持read-only模式的export)
|__直接返回
|__检查mdsmap是否是degraded(cluster处于degraded状态则不能export)
|__直接返回
|__检查dir的inode是否是system(不能export system dir)
|__直接返回
|__检查dir的inode是否是stray
|__直接返回
|__检查dir是否处于freezing或frozen
|__直接返回
|__检查dir是否处于EXPORTING状态
|__直接返回
|__执行dir的auth_pin()
|__设置dir的当前状态为EXPORTING，即：dir->state_set(STATE_EXPORTING)
|__从MDCache中得到MDRequestRef类对象，即：mds->mdcache->request_start_internal(EXPORTDIR)
|__设置MDRequest类对象中的_more的export_dir为dir，即：保存待export的dir数据
|__从export_state数组中得到dir为索引对应的export_state_t对象stat
|__设置stat的state为EXPORT_LOCKING
|__设置stat的peer为dest
|__设置stat的tid为mdr->reqid.tid
|__设置stat的mut为mdr
|__调用dispatch_export_dir(mdr)来发送export dir请求
Migrator::dispatch_export_dir(mdr)
|__从mdr的_more中得到待export的dir数据，即：mdr->more()->export_dir
|__从export_state数组中找到dir对应的export state项
|__设置export_state_t的当前状态是EXPORT_DISCOVERING
|__创建MExportDirDiscover类消息
|__将消息发送给目的MDS进程，即：mds->send_message_mds(discover, it->second.peer)
|__设置export_state_t中的last_cum_auth_pins_change为系统当前时间
|__freeze当前dir的tree，即：dir->freeze_tree()
|__添加dir等待WAIT_FROZEN的回调函数C_MDC_ExportFreeze()，即：调用export_frozen()函数
Migrator::handle_export_discover(MExportDirDiscover *m) (对端)
|__从消息中得到对端的mds_rank_t以及dirfrag_t结构，即：from=m->get_source_mds()/df = m->get_dirfrag()
|__遍历import_state数组
|__若数组中没有找到对应的项且m->started==false
|__设置m->started=true
|__更新import_state数组中对应的项，即：state=IMPORT_DISCOVERING/peer=from/tid=m->get_tid()
|__从MDCache中得到export的dir的CInode信息，即：in=cache->get_inode(m->get_dirfrag().ino)
|__更新import_state数组中对应的项，即：state==IMPORT_DISCOVERED
|__创建MExportDirDiscoverAck类消息
|__将类消息发送回给mds进程，即：mds->send_message_mds()
Migrator::handle_export_discover_ack(MExportDirDiscoverAck* m)
|__从消息中得到dirfrag，之后从MDCache中得到dirfrag对应的CDir类对象，即：cache->get_dirfrag(m->get_dirfrag())
|__在export_state数组中查找dir对应的项
|__在export_state数组对应的dir项中设置其状态为EXPORT_FREEZING
Migrator::export_frozen(dir, tid)
|__从export_state数组中查找dir对应的项
|__得到该dir对应的CInode，即：dir->get_inode()
|__创建一个新的MutationImpl类对象且将其放入export_state_t的mut中
|__根据dirfrag和tid创建一个MExportDirPrep类消息
|__遍历dir的replicas数组
|__将数组中的成员添加到MExportDirPrep类消息的bystander中
|__将basedir添加到MExportDirPrep类消息的basedir中
|__遍历bounds数组
|__将bounds成员添加到MExportDirPrep类消息的bound中
|__循环处理如下内容
|__将bounds成员的inode添加到inodes_added数组中
|__遍历bounds成员的parent目录
|__将dirfrag以及start信息序列化到bufferlist中
|__将bufferlist写入到MExportDirPrep类消息的trace中
|__设置export_state_t中的状态为EXPORT_PREPPING
|__将MExportDirPrep类消息发送给目的MDS，即：mds->send_message_mds()
Migrator::handle_export_prep(MExportDirPrep *m) (对端)
|__从import_state数组中找到消息中对应的dirfrag项
|__从MDCache中得到dir和dir对应的CInode
|__遍历消息中的bounds数组
|__将数组中的内容添加到import_bound_fragset数组中
|__若消息中的did_assim()==false
|__设置当前import_state数组中对应项的state为IMPORT_PREPPING
|__从消息中解析traces数组
|__将traces数组中的内容添加到MDCache中
|__遍历import_bound_fragset数组
|__从数组成员的inodeno_t的到对应的CInode结构
|__调用CInode对应的get_stickydirs()函数
|__遍历import_bound_fragset数组
|__从数组成员的inodeno_t的到对应的CInode结构
|__遍历数组成员中fragset_t下所有叶子节点
|__根据叶子节点得到在MDCache中对应的CDir数据
|__若CDir数据不在MDCache中
|__执行MDCache中的open_remote_dirfrag()函数来创建这个CDir
|__将叶子节点对应的CDir数据插入到import_bounds数组中
|__设置import_state数组指定成员的状态为IMPORT_PREPPED
|__创建MExportDirPreAck类消息
|__调用mds的send_message()方法将类消息发送给指定的MDS进程
Migrator::handle_export_prep_ack(MExportDirPrepAck *m)
|__根据消息的dirfrag得到对应的CDir类对象
|__在export_state数组中查找CDir类对象对应的项
|__遍历replicas数组
|__将mds_rank_t信息插入到export_state_t结构中的warning_ack_waiting/notify_ack_waiting数组中
|__创建MExportDirNotify类消息
|__将MEXportDirNotify类消息发送给对端mds进程
|__设置export_state_t结构中的state为EXPORT_WARNING
Migrator::handle_export_notify(MExportDirNotify *m) (对端)
|__从MDCache中得到消息中dirfrag对应的CDir类对象
|__创建MExportDirNotifyAck类消息
|__调用mds的send_message_mds()将类消息发送回给mds进程
Migrator::handle_export_notify_ack(MExportDirNotifyAck *m)
|__根据消息的dirfrag得到对应的CDir类对象
|__从消息中得到对端mds_rank_t信息
|__若在export_state数组中能够找到dir对应的项
|__若export_state_t的state==EXPORT_WARNING
|__调用export_go(dir) 执行实际的export操作
|__若export_state_t的state==EXPORT_NOTIFYING
|__调用export_finish(dir)
Migrator::export_go(dir)
|__调用哦mds中mdlog的wait_for_safe()函数来设置回调函数C_M_ExportGo()，最后执行export_go_synced(dir, tid)
|__flush mds的mdlog，即：|mds->mdlog->flush()
Migrator::export_go_synced(dir, tid)
|__在export_state数组中查找dir对应的项
|__设置其状态为EXPORT_EXPORTING
|__创建MExportDir类消息
|__调用encode_export_dir()得到export的map信息以及得到exported_inodes数量
|__将得到的export的map信息序列化到类消息的client_map中
|__遍历bounds数组
|__将数组中的成员添加到类消息的export数组中
|__发送类消息到对端mds进程，即：mds->send_message_mds()
Migrator::handle_export_dir(MExportDir *m) (对端)
|__从MDCache中得到消息中dirfrag对应的CDir类对象
|__从import_state数组中查到消息中dirfrag对象的项
|__创建C_MDS_ImportDirLoggedStart回调函数类
|__创建EImportStart日志入口
|__调用MDS的mlog的start_entry()来启动日志
|__将消息中的client_map信息解析道EImportStart中的imported_client_map中
|__从消息中得到export_data
|__调用decode_import_dir()函数，将export_data写入到mdlog对应的current segment里
|__遍历消息中的bounds数组
|__将数组中dirfrag_t对应的CDir添加到LogSegment中
|__将数组中dirfrag_t对应的CDir添加到import_bounds数组中
|__调用mds的balancer的add_import()函数来平衡查找树
|__设置import_state_t中的状态为IMPORT_LOGGINGSTART
|__启动mdlog，即：mds->mdlog->submit_entry()/mds->mdlog->flush()
Migrator::import_logged_start() (对端)
|__在import_state数组中查找dirfrag对应的项
|__设置对应项的state为IMPORT_ACKING
|__创建MExportDirAck类对象
|__发送MExportDirAck类对象到mds进程
Migrator::handle_export_ack(MExportDirAck *m)
|__在export_state数组中查找dirfrag对应的项
|__将消息中的imported_caps解析到export_state_t中的peer_imported中
|__设置对应项的state为EXPORT_LOGGINGFINISH
|__创建EExport类对象
|__将bounds数组中的内容写入到EExport类对象的metablob中
|__创建C_MDS_ExportFinishLogged回调函数类
|__启动mdlog，即：mds->mdlog->submit_entry()/mds->mdlog->flush()
Migator::export_logged_finish(dir)
|__查找export_state数组中指定dir的export_state_t项
|__遍历export_state_t项中的notify_ack_waiting数组
|__创建MExportDirNotify类消息
|__发送MExportDirNotify类消息到mds进程
|__设置export_state_t中的状态为EXPORT_NOTIFYING
|__创建MExportDirFinish类消息
|__发送MExportDirFinish类消息到mds进程
Migrator::handle_export_finish(MExportDirFinish *m) (对端)
|__在import_state数组中找到对应项
|__调用import_finish()函数
Migrator::import_finish(dir, notify, last) (对端)
|__从import_state数组中得到指定dirfrag
|__若state==IMPORT_ACKING
|__遍历import_state_t中的peer_exports数组
|__更新MDCache中的内容
|__若last==false
|__设置state=IMPORT_FINISHING
|__直接返回
|__处理MDCache中的内容
=======================export client maps and client caps
Migrator::encode_export_inode_caps(in, auth_cap, bl, exported_client_map) 得到client map以及client caps map
|__调用in->export_client_caps()函数，得到in的client capability map信息
|__将client capability map信息序列化到bl中
|__遍历in的client_caps数组
|__从mds的sessionmap中得到client_caps数组成员对应的信息并写入到exported_client_map中
Migrator::export_caps(CInode *in)
|__从in中得到授权的mds_rank_t信息，即：in->authority().first
|__创建MExportCaps类消息
|__设置类消息的ino为in->ino()
|__调用encode_export_inode_caps()
|__调用mds的send_message_mds()函数将MExportCaps消息发送给指定的MDS进程
Migrator::handle_export_caps(MExportCaps *ex)
|__从MDCache中得到类消息中的CInode信息，即：in=cache->get_inode(ex->ino)
|__若in处于frozen状态
|__直接返回
|__创建C_M_LoggedImportCaps回调函数类
|__将类消息中的client_map信息写入到回调函数类的client_map中
|__调用decode_import_inode_caps()函数将类消息中的client caps信息反序列化并保存到peer_exports数组中
|__创建ESession类型的LogEvent类消息(client_map)
|__写mdlog日志，即：mds->mdlog->start_submit_entry()
|__调用mds->mdlog->flush() 刷mdlog日志
Migrator::handle_gather_caps(MGatherCaps *m)
|__从MDCache中得到类消息对应的CInode信息，即：cache->get_inode(m->ino)
|__若in存在caps并且in不存在auth并且in没有EXPORTINGCAPS
|__调用export_caps(in) 将in对应的client maps和client caps map export出去
Migrator导入导出状态机处理过程如下图所示：
感谢你能够认真阅读完这篇文章，希望小编分享的“Migrator类怎么用”这篇文章对大家有帮助，同时也希望大家多多支持创新互联，关注创新互联行业资讯频道，更多相关知识等着你来学习!
