MDSDaemon的示例分析

这篇文章主要介绍了MDSDaemon的示例分析,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。

创新互联是一家以网络技术公司,为中小企业提供网站维护、成都网站设计、网站建设、网站备案、服务器租用、域名注册、软件开发、微信小程序定制开发等企业互联网相关业务,是一家有着丰富的互联网运营推广经验的科技公司,有着多年的网站建站经验,致力于帮助中小企业在互联网让打出自已的品牌和口碑,让企业在互联网上打开一个面向全国乃至全球的业务窗口:建站欢迎来电:13518219792

MDSDaemon和MDSRank一起形成了MDS进程核心架构,本文只描述MDSDaemon部分,MDSRank部分后面会讲述。

MDSDaemon::asok_command()

|__对于command == “status"

     |__MDSDaemon::dump_status()          打印mds状态信息

|__对于command != “status”且mds_rank != NULL

     |__MDSRank::handle_asok_command()     由MDSRank类来处理command请求

MDSDaemon::set_up_admin_socket()

|__创建AdminSocket类实例

|__创建MDSSocketHook类实例

|__调用AdminSocket->register_command()来注册MDSDaemon支持的命令

MDSDaemon::init()

|__Objecter::init()

|__设置objecter/beacon/mdsdaemon可以进行消息分发和处理

|__设置monclient的messenger

|__MonClient::init()          初始化monclient

|__设置monclient的log信息

|__MonClient::authenticate()               向monitor进行认证

|__Objecter::start()                              启动Objecter

|__MonClient::sub_want(“mdsmap”)          向monitor索取mdsmap信息

|__set_up_admin_socket()                    设置admin通过socket可以处理的命令

|__SaftTimer::init()                              初始化定时器

|__Beacon::init()                                   初始化Beacon

|__Messenger::set_myname()               设置Messenger名称

|__reset_tick()               

MDSDaemon::reset_tick()

|__创建C_MDS_Tick类对象

|__SafeTimer::add_event_after()               调度timer,当定时器到达时,执行MDSDaemon::tick()函数

MDSDaemon::tick()

|__reset_tick()                                        重置定时器

|__MDSRank::tick()                               执行MDSRank的tick操作

MDSDaemon::handle_command(MCommand *m)          该函数主要用来处理参数提供的命令,之后将命令执行结果反馈给调用者

|__检查参数的有效性以及权限,对于不满足条件的,设置反馈给调用者的信息

|__MDSDaemon::_handle_command()                     执行具体的命令处理

|__创建MCommandReply类对象

|__设置该类对象的tid和data

|__m->get_connection->send_message()               将MCommandReply类对象发送给调用者

MDSDaemon::_handle_command()

|__cmd_getval()                         解析command

|__对于prefix="get_command_descriptions/injectargs/exit/respawn/heap/cpu_profiler”,则由MDSDaemon进行处理,否则由MDSRank::handle_command()进行处理

MDSDaemon::handle_mds_map(MMDSMap *m)

|__得到最新MDSMap的epoch值

|__将最新的MDSMap的epoch值于当前mdsmap的epoch进行比较,若最新epoch小于当前MDSMap的epoch,则直接返回

|__创建MDSMap类对象且用参数进行初始化

|__遍历当前MDSMap

     |__对于当前MDSMap中的MDS进程在最新MDSMap中不存在,则设置该MDS进程down

|__对于在最新的MDSMap中此MDS作为STANDBY_REPLAY形式出现,则得到standby_for_rank值且写道whoami中

|__对于不是standby_replay模式

     |__MDSDaemon::_handle_mds_map()

|__对于是standby_replay模式

     |__对于变换了standby_for_rank的,则调用respawn()函数重新启动MDS进程

     |__若mds_rank为空,则创建MDSRankDispatcher类对象且初始化

     |__mds_rank->handle_mds_map()                    由MDSRank处理mdsmap

MDSDaemon::_handle_mds_map()

|__对于最新MDSMap下此mds进程的状态是STATE_STANDBY

     |__Beacon::set_want_state(STATE_STANDBY)                    更新Beacon中want state状态为STATE_STANDBY

|__对于Beacon中want state=STATE_STANDBY          

     |__Beacon::set_want_state(STATE_BOOT)                          更新Beacon中want state状态为STATE_BOOT

MDSDaemon::suicide()

|__删除定时器timer

|__clean_up_admin_socket()               清除admin socket

|__Beacon::set_want_state(STATE_DNE)          设置Beacon状态为STATE_DNE

|__Beacon::shutdown()

|__若mds_rank不为空

     |__mds_rank->shutdown()

|__若mds_rank为空

     |__objecter->shutdown()

     |__timer->shudown()

     |__monc->shutdown()

     |__messenger->shutdown()

MDSDaemon::respawn()

|__调用execv()系统调用函数重新启动mds进程

MDSDaemon::ms_dispatch()

|__若beacon.get_want_state()==STATE_DNE,说明mds进程已经处于shutdown状态,因此不能处理消息

|__MDSDaemon::handle_core_message()          优先处理MDSDaemon消息

|__若mds_rank不为空

     |__mds_rank->ms_dispatch()                         由mds_rank处理消息

MDSDaemon::ms_get_authorizer()

|__monc->auth->build_authorizer()                         由monitor的auth模块生成auth

MDSDaemon::handle_core_message()

|__ CEPH_MSG_MON_MAP

     |__不处理

|__CEPH_MSG_MDS_MAP

     |__handle_mds_map()                                        调用handle_mds_map()处理新的mds map消息

|__CEPH_MON_COMMAND

     |__handle_command()

|__CEPH_COMMAND

     |__handle_command()

|__CEPH_MSG_OSD_MAP

     |__mds_rank->handle_osd_map()                         由mds_rank来处理osd map

MDSDaemon::ms_handle_reset()

|__判断消息发送端是否是client,若不是则直接退出

|__判断beacon.get_want_state()是否是STATE_DNE,若是则直接退出

|__根据参数Connection类对象得到Session类对象

|__Session对象为空

     |__Connection::mark_down()

|__Session对象不为空

     |__若Session::is_closed()为真

          |__Connection::mark_down()

     |__Session::is_closed()不为真

          |__Session::put()

MDSDaemon::ms_handle_remote_reset()

|__判断消息发送端是否是client,若不是则直接退出

|__判断beacon.get_want_state()是否是STATE_DNE,若是则直接退出

|__根据参数Connection类对象得到Session类对象

|__Session对象不为空

     |__若Session::is_closed()为真

          |__Connection::mark_down()

     |__Session::is_closed()不为真

          |__Session::put()

MDSDaemon::ms_verify_authorizer()

|__判断当前是否处于stopping,若是则直接退出

|__判断beacon.get_want_state()是否是STATE_DNE,若是则直接退出

|__根据peer_type的内容得到对应的authorize_handler(这里主要有两种handler,即:authorize_handler_cluster_registry/authorize_handler_service_registry。若peer_type==CEPH_ENTITY_TYPE_MDS则选择前者)

|__authorize_handler->verify_authorizer()

|__若认证成功

     |__若mds_rank不为空

          |__mds_rank->sessionmap.get_session()     通过mds_rank得到session

     |__若session为空

          |__创建Session类实例

          |__初始化Session类实例

     |__得到认证成功后的caps

          |__Session::auth_caps.parse()          解析认证成功后的caps且保存到Session中

MDSDaemon::ms_handle_accept()

|__得到连接对应的Session类实例

|__设置连接到session类实例,即:s->connection = con

MDSDaemon::is_clean_shutdown()

|__若mds_rank不为空

     |__返回mds_rank是否停止,即:mds_rank->is_stopped()

|__若mds_rank为空

     |__返回true

感谢你能够认真阅读完这篇文章,希望小编分享的“MDSDaemon的示例分析”这篇文章对大家有帮助,同时也希望大家多多支持创新互联,关注创新互联行业资讯频道,更多相关知识等着你来学习!


当前题目:MDSDaemon的示例分析
标题链接:http://myzitong.com/article/gjchsg.html