小編給大家分享一下ceph scrub處理流程的示例分析，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

目前成都創(chuàng)新互聯(lián)公司已為超過千家的企業(yè)提供了網站建設、域名、虛擬空間、網站托管、服務器租用、企業(yè)網站設計、建始網站維護等服務，公司將堅持客戶導向、應用為本的策略，正道將秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長，共同發(fā)展。

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               初始狀態(tài)

          |__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()

               |__創(chuàng)建MOSDRepScrub消息對象

               |__OSD::send_message_osd_cluster()將MOSDRepScrub消息對象發(fā)送給actingbackfill隊列中的OSDs

          |__scrubber.state = WAIT_PUSHES

          |__等待所有replicas將scrub信息發(fā)送回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()

     |__創(chuàng)建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處理流程的示例分析”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道！