MDS中MDCache中对resolve的理解

原创
2016/08/09 17:40
阅读数 277

MDCache中handle_resolve()函数处理MMDSResolve类消息。对于MMDSResolve类消息中slave_requests数组不为空则优先处理该数组,将该数组中的保存的数据写入到uncommitted_masters数组、rejoin_slave_exports数组以及rejoin_imported_caps数组。最后创建MMDSResolveAck类消息且设置对应slave request的commit,最后将MMDSResolveAck类消息发送回给对应的MDS进程。对于MDS处于clientreplay/active/stopping状态则通过遍历my_ambiguous_imports数组得到当前处于ambiguous状态的import的目录,之后在MMDSResolve类消息中的subtrees目录下寻找处于ambiguous状态的import的目录,若找到了则执行migrator->import_finish()函数表示import目录完毕。遍历MMDSResolve类消息中的subtrees数组且调用try_subtree_merge()函数来尝试merge该subtree到MDS。最后遍历MMDSResolve类消息的ambiguous_imports数组来更新other_ambiguous_imports数组,之后调用mybe_resolve_finish()函数来确认resolve是否完毕。

 

MDCache中handle_resolve_ack()函数处理MMDSResolveAck类消息。首先遍历MMDSResolveAck类消息中的commit数组,对于数组中的元素位于ambiguous_slave_updates数组中则从ambiguous_slave_updates数组中删除对应的项。若MDS处于Resolve状态则得到MDSlaveUpdate类对象,之后将MDSlaveUpdate类对象写入到mdlog中,最后删除uncommitted_slave_update数组中对应的项。若MDS未处于Resolve状态则得到MDRequest类对象,最后调用request_finish()函数完成request请求。之后遍历MMDSResolveAck类消息中的abort数组,若MDS处于Resolve状态则执行适当的rollback操作,否则调用request_finish()函数完成request请求。

展开阅读全文
打赏
0
0 收藏
分享
加载中
您好 请问这个是处理子树分割的代码吗
2016/12/13 17:34
回复
举报
更多评论
打赏
1 评论
0 收藏
0
分享
返回顶部
顶部