MDS中MDCache中对resolve的理解

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请求。函数

相关文章
相关标签/搜索