ceph scrub处理流程的示例分析

共计 2134 个字符，预计需要花费 6 分钟才能阅读完成。

丸趣 TV 小编给大家分享一下 ceph scrub 处理流程的示例分析，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！

PG::sched_scrub()/PG::_finish_recovery()

|__PG::queue_scrub()

     |__state_set(PG_STATE_SCRUBBING)

     |__PG::requeue_scrub()

          |__OSD::queue_for_scrub()

               |__OSD::op_wq.queue()

PGQueueable::RunVis::operator()(PGScrub)

|__PG::scrub()

     |__PG::chunky_scrub()

          |__scrubber.state = INACTIVE               初始状态

     |__scrubber.epoch_start = info.history.same_interval_since

     |__scrubber.state = NEW_CHUNK

          |__初始化 primary_scrubmap 和 received_maps 数据结构 (分别用来保存 primary 和 replicas 的 scrubmap 信息)

          |__PGBackend::objects_list_partial()           读取指定数量的 objects

          |__遍历 actingbackfill 队列且调用 PG::_request_scrub_map()

               |__创建 MOSDRepScrub 消息对象

               |__OSD::send_message_osd_cluster() 将 MOSDRepScrub 消息对象发送给 actingbackfill 队列中的 OSDs

          |__scrubber.state = WAIT_PUSHES

          |__等待所有 replicas 将 scrub 信息发送回 primary，之后设置 scrubber.state = WAIT_LAST_UPDATE

          |__对于 last_update_applied = scrubber.subset_last_update，则设置 scrubber.state = BUILD_MAP

          |__PG::build_scrub_map_chunk()

               |__PGBackend::objects_list_range()

               |__PGBackend::be_scan_list()

                    |__读取对象的大小信息

                    |__读取对象的属性信息

                    |__对于需要 deep scrub 的则读取对象本身以及对象属性本身，之后计算对应的 digest 值

               |__PG::_scan_rollback_obs()

               |__PG::_scan_snaps()

               |__设置 scrubber.state = WAIT_REPLICAS

               |__等待所有 replicas 都返回 scrub 信息后，设置 scrubber.state = COMPARE_MAPS

               |__PG::scrub_compare_maps()

                    |__PGBackend::be_compare_scrubmaps()

                    |__PG::_scrub()

               |__设置 scrubber.state = WAIT_DIGEST_UPDATE

               |__对于所有待 scrub 的 PG 都完成 scrub 操作后，设置 scrubber.state = FINISH

               |__PG::scrub_finish()

                    |__ReplicatedPG::_scrub_finish()

Replicas 接收到 MOSDRepScrub 消息后的处理流程

ReplicatePG::do_request()

|__PG::replicas_scrub()

     |__PG::build_scrub_map_chunk()

     |__创建 MOSDSubOp 消息对象且设置消息的 op = CEPH_OSD_OP_SCRUB_MAP

     |__OSD::send_message_osd_cluster()

Primary 接收到 MOSDSubOp 消息后的处理流程

ReplicatedPG::do_sub_op()

|__PG::sub_op_scrub_map()

     |__将收到的 replicas 的 scrubmap 写入到 scrubber.received_maps 中

     |__对于所有 replicas 都返回 scrubmap，则调用 PG::requeue_scrub() 函数重新进入 scrub 操作

以上是“ceph scrub 处理流程的示例分析”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注丸趣 TV 行业资讯频道！