Migrator類怎么用

這篇文章主要介紹了Migrator類怎么用，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

Migrator類說明：

class Migrator {
     MDSRank *mds;          記錄mds信息
     MDCache *cache;          記錄MDCache信息
     struct export_state_t {
          int state;                    記錄export的當前狀態
          mds_rank_t peer;          記錄export到對端mds rank信息
          uint64_t tid;                    記錄export到對端的session id信息
          set<mds_rank_t> warning_ack_waiting;     等待warning ack的mds集合
          set<mds_rank_t> notify_ack_waiting;          等待notify ack的mds集合
          map<inodeno_t, map<client_t, Capability::Import>> peer_imported;     記錄export對端信息
          list<MDSInternalContextBase*> waiting_for_finish;                              記錄等待finish的集合
          MutationRef                     mut;      MutationImpl對象引用
          utime_t last_cum_auth_pins_change;
          int last_cum_auth_pins;
          int num_remote_waiters;              遠程auth pin waiters
     };
     map<CDir*, export_state_t> export_state;          export的狀態集合
     list<pair<dirfrag_t, mds_rank_t>> export_queue;     export隊列
     struct import_state_t {
          int state;
          mds_rank_t peer;
          uint64_t tid;
          set<mds_rank_t> bystanders;
          list<dirfrag_t> bound_ls;
          list<ScatterLock*> updated_scatterlocks;
          map<client_t, entity_inst_t> client_map;
          map<CInode*, map<client_t, Capability::Export>> peer_exports;
          MutationRef mut;
     };
     map<dirfrag_t, import_state_t> import_state;
};

Migrator類方法：

Migrator::dispatch(m)                              核心分發處理函數

|__根據m的類型決定后續的處理過程

     |__類型是MSG_MDS_EXPORTDIRDISCOVER

          |__調用handle_export_discover(MExportDirDiscover* m)

     |__類型是MSG_MDS_EXPORTDIRPREP

          |__調用handle_export_prep(MExportDirPrep* m)

     |__類型是MSG_MDS_EXPORTDIR

          |__調用handle_export_dir(MExportDir* m)

     |__類型是MSG_MDS_EXPORTDIRFINISH

          |__調用handle_export_finsih(MExportDirFinish* m)

     |__類型是MSG_MDS_EXPORTDIRCANCEL

          |__調用handle_export_cancel(MExportDirCancel* m)

     |__類型是MSG_MDS_EXPORTDIRDISCOVERACK

          |__調用handle_export_discover_ack(MExportDirDiscoverAck* m)

     |__類型是MSG_MDS_EXPORTDIRPREACK

          |__調用handle_export_prep_ack(MExportDirPrepAck* m)

     |__類型是MSG_MDS_EXPORTDIRACK

          |__調用handle_export_ack(MExportDirAck* m)

     |__類型是MSG_MDS_EXPORTDIRNOTIFYACK

          |__調用handle_export_notify_ack(MExportDirNotifyAck* m)

     |__類型是MSG_MDS_EXPORTDIRNOTIFY

          |__調用handle_export_dir_notify(MExportDirNotify* m)

     |__類型是MSG_MDS_EXPORTCAPS

          |__調用handle_export_caps(MExportCaps* m)

     |__類型是MSG_MDS_GATHERCAPS     

          |__調用handle_gather_caps(MGatherCaps* m)

Migrator::export_empty_import(dir)

|__dir對應的inode節點是auth的

     |__直接返回

|__dir是auth的

     |__直接返回

|__dir是freezing或frozen

     |__直接返回

|__dir不是空目錄

     |__直接返回

|__dir是root節點

     |__直接返回

|__得到export目的dir所在的mds節點，即：dir->inode->authority().first

|__調用export_dir(dir, dest)               執行實際的export操作

Migrator::export_dir(dir, dest)

|__檢查MDCache是否是readonly(目前尚不支持read-only模式的export)

     |__直接返回

|__檢查mdsmap是否是degraded(cluster處于degraded狀態則不能export)

     |__直接返回

|__檢查dir的inode是否是system(不能export system dir)

     |__直接返回

|__檢查dir的inode是否是stray

     |__直接返回

|__檢查dir是否處于freezing或frozen

     |__直接返回

|__檢查dir是否處于EXPORTING狀態

     |__直接返回

|__執行dir的auth_pin()

|__設置dir的當前狀態為EXPORTING，即：dir->state_set(STATE_EXPORTING)

|__從MDCache中得到MDRequestRef類對象，即：mds->mdcache->request_start_internal(EXPORTDIR)

|__設置MDRequest類對象中的_more的export_dir為dir，即：保存待export的dir數據

|__從export_state數組中得到dir為索引對應的export_state_t對象stat

|__設置stat的state為EXPORT_LOCKING

|__設置stat的peer為dest

|__設置stat的tid為mdr->reqid.tid

|__設置stat的mut為mdr

|__調用dispatch_export_dir(mdr)來發送export dir請求

Migrator::dispatch_export_dir(mdr)

|__從mdr的_more中得到待export的dir數據，即：mdr->more()->export_dir

|__從export_state數組中找到dir對應的export state項

|__設置export_state_t的當前狀態是EXPORT_DISCOVERING

|__創建MExportDirDiscover類消息

|__將消息發送給目的MDS進程，即：mds->send_message_mds(discover, it->second.peer)

|__設置export_state_t中的last_cum_auth_pins_change為系統當前時間

|__freeze當前dir的tree，即：dir->freeze_tree()

|__添加dir等待WAIT_FROZEN的回調函數C_MDC_ExportFreeze()，即：調用export_frozen()函數

Migrator::handle_export_discover(MExportDirDiscover *m) (對端)

|__從消息中得到對端的mds_rank_t以及dirfrag_t結構，即：from=m->get_source_mds()/df = m->get_dirfrag()

|__遍歷import_state數組

     |__若數組中沒有找到對應的項且m->started==false

          |__設置m->started=true

          |__更新import_state數組中對應的項，即：state=IMPORT_DISCOVERING/peer=from/tid=m->get_tid()

|__從MDCache中得到export的dir的CInode信息，即：in=cache->get_inode(m->get_dirfrag().ino)

|__更新import_state數組中對應的項，即：state==IMPORT_DISCOVERED

|__創建MExportDirDiscoverAck類消息

|__將類消息發送回給mds進程，即：mds->send_message_mds()

Migrator::handle_export_discover_ack(MExportDirDiscoverAck* m)

|__從消息中得到dirfrag，之后從MDCache中得到dirfrag對應的CDir類對象，即：cache->get_dirfrag(m->get_dirfrag())

|__在export_state數組中查找dir對應的項

|__在export_state數組對應的dir項中設置其狀態為EXPORT_FREEZING

Migrator::export_frozen(dir, tid)

|__從export_state數組中查找dir對應的項

|__得到該dir對應的CInode，即：dir->get_inode()

|__創建一個新的MutationImpl類對象且將其放入export_state_t的mut中

|__根據dirfrag和tid創建一個MExportDirPrep類消息

|__遍歷dir的replicas數組

     |__將數組中的成員添加到MExportDirPrep類消息的bystander中

|__將basedir添加到MExportDirPrep類消息的basedir中

|__遍歷bounds數組

     |__將bounds成員添加到MExportDirPrep類消息的bound中

     |__循環處理如下內容

          |__將bounds成員的inode添加到inodes_added數組中

          |__遍歷bounds成員的parent目錄

     |__將dirfrag以及start信息序列化到bufferlist中

     |__將bufferlist寫入到MExportDirPrep類消息的trace中

|__設置export_state_t中的狀態為EXPORT_PREPPING

|__將MExportDirPrep類消息發送給目的MDS，即：mds->send_message_mds()

Migrator::handle_export_prep(MExportDirPrep *m)     (對端)

|__從import_state數組中找到消息中對應的dirfrag項

|__從MDCache中得到dir和dir對應的CInode

|__遍歷消息中的bounds數組

     |__將數組中的內容添加到import_bound_fragset數組中

|__若消息中的did_assim()==false

     |__設置當前import_state數組中對應項的state為IMPORT_PREPPING

     |__從消息中解析traces數組

          |__將traces數組中的內容添加到MDCache中

     |__遍歷import_bound_fragset數組

          |__從數組成員的inodeno_t的到對應的CInode結構

          |__調用CInode對應的get_stickydirs()函數

|__遍歷import_bound_fragset數組

     |__從數組成員的inodeno_t的到對應的CInode結構

     |__遍歷數組成員中fragset_t下所有葉子節點

          |__根據葉子節點得到在MDCache中對應的CDir數據

          |__若CDir數據不在MDCache中

               |__執行MDCache中的open_remote_dirfrag()函數來創建這個CDir

          |__將葉子節點對應的CDir數據插入到import_bounds數組中

|__設置import_state數組指定成員的狀態為IMPORT_PREPPED

|__創建MExportDirPreAck類消息

|__調用mds的send_message()方法將類消息發送給指定的MDS進程

Migrator::handle_export_prep_ack(MExportDirPrepAck *m)

|__根據消息的dirfrag得到對應的CDir類對象

|__在export_state數組中查找CDir類對象對應的項

|__遍歷replicas數組

     |__將mds_rank_t信息插入到export_state_t結構中的warning_ack_waiting/notify_ack_waiting數組中

     |__創建MExportDirNotify類消息

     |__將MEXportDirNotify類消息發送給對端mds進程

|__設置export_state_t結構中的state為EXPORT_WARNING

Migrator::handle_export_notify(MExportDirNotify *m)     (對端)

|__從MDCache中得到消息中dirfrag對應的CDir類對象

|__創建MExportDirNotifyAck類消息

|__調用mds的send_message_mds()將類消息發送回給mds進程

Migrator::handle_export_notify_ack(MExportDirNotifyAck *m)

|__根據消息的dirfrag得到對應的CDir類對象

|__從消息中得到對端mds_rank_t信息

|__若在export_state數組中能夠找到dir對應的項

     |__若export_state_t的state==EXPORT_WARNING

          |__調用export_go(dir)     執行實際的export操作

     |__若export_state_t的state==EXPORT_NOTIFYING

          |__調用export_finish(dir)

Migrator::export_go(dir)

|__調用哦mds中mdlog的wait_for_safe()函數來設置回調函數C_M_ExportGo()，最后執行export_go_synced(dir, tid)

|__flush mds的mdlog，即：|mds->mdlog->flush()

Migrator::export_go_synced(dir, tid)

|__在export_state數組中查找dir對應的項

|__設置其狀態為EXPORT_EXPORTING

|__創建MExportDir類消息

|__調用encode_export_dir()得到export的map信息以及得到exported_inodes數量

|__將得到的export的map信息序列化到類消息的client_map中

|__遍歷bounds數組

     |__將數組中的成員添加到類消息的export數組中

|__發送類消息到對端mds進程，即：mds->send_message_mds()

Migrator::handle_export_dir(MExportDir *m)     (對端)

|__從MDCache中得到消息中dirfrag對應的CDir類對象

|__從import_state數組中查到消息中dirfrag對象的項

|__創建C_MDS_ImportDirLoggedStart回調函數類

|__創建EImportStart日志入口

|__調用MDS的mlog的start_entry()來啟動日志

|__將消息中的client_map信息解析道EImportStart中的imported_client_map中

|__從消息中得到export_data

|__調用decode_import_dir()函數，將export_data寫入到mdlog對應的current segment里

|__遍歷消息中的bounds數組

     |__將數組中dirfrag_t對應的CDir添加到LogSegment中

     |__將數組中dirfrag_t對應的CDir添加到import_bounds數組中

|__調用mds的balancer的add_import()函數來平衡查找樹

|__設置import_state_t中的狀態為IMPORT_LOGGINGSTART

|__啟動mdlog，即：mds->mdlog->submit_entry()/mds->mdlog->flush()

Migrator::import_logged_start()     (對端)

|__在import_state數組中查找dirfrag對應的項

|__設置對應項的state為IMPORT_ACKING

|__創建MExportDirAck類對象

|__發送MExportDirAck類對象到mds進程

Migrator::handle_export_ack(MExportDirAck *m)

|__在export_state數組中查找dirfrag對應的項

|__將消息中的imported_caps解析到export_state_t中的peer_imported中

|__設置對應項的state為EXPORT_LOGGINGFINISH

|__創建EExport類對象

|__將bounds數組中的內容寫入到EExport類對象的metablob中

|__創建C_MDS_ExportFinishLogged回調函數類

|__啟動mdlog，即：mds->mdlog->submit_entry()/mds->mdlog->flush()

Migator::export_logged_finish(dir)

|__查找export_state數組中指定dir的export_state_t項

|__遍歷export_state_t項中的notify_ack_waiting數組

     |__創建MExportDirNotify類消息

     |__發送MExportDirNotify類消息到mds進程

|__設置export_state_t中的狀態為EXPORT_NOTIFYING

|__創建MExportDirFinish類消息

|__發送MExportDirFinish類消息到mds進程

Migrator::handle_export_finish(MExportDirFinish *m)     (對端)

|__在import_state數組中找到對應項

|__調用import_finish()函數

Migrator::import_finish(dir, notify, last)     (對端)

|__從import_state數組中得到指定dirfrag

|__若state==IMPORT_ACKING

     |__遍歷import_state_t中的peer_exports數組

          |__更新MDCache中的內容

|__若last==false

     |__設置state=IMPORT_FINISHING

     |__直接返回

|__處理MDCache中的內容

=======================export client maps and client caps

Migrator::encode_export_inode_caps(in, auth_cap, bl, exported_client_map)     得到client map以及client caps map

|__調用in->export_client_caps()函數，得到in的client capability map信息

|__將client capability map信息序列化到bl中

|__遍歷in的client_caps數組

     |__從mds的sessionmap中得到client_caps數組成員對應的信息并寫入到exported_client_map中

Migrator::export_caps(CInode *in)

|__從in中得到授權的mds_rank_t信息，即：in->authority().first

|__創建MExportCaps類消息

|__設置類消息的ino為in->ino()

|__調用encode_export_inode_caps()

|__調用mds的send_message_mds()函數將MExportCaps消息發送給指定的MDS進程

Migrator::handle_export_caps(MExportCaps *ex)

|__從MDCache中得到類消息中的CInode信息，即：in=cache->get_inode(ex->ino)

|__若in處于frozen狀態

     |__直接返回

|__創建C_M_LoggedImportCaps回調函數類

|__將類消息中的client_map信息寫入到回調函數類的client_map中

|__調用decode_import_inode_caps()函數將類消息中的client caps信息反序列化并保存到peer_exports數組中

|__創建ESession類型的LogEvent類消息(client_map)

|__寫mdlog日志，即：mds->mdlog->start_submit_entry()

|__調用mds->mdlog->flush()     刷mdlog日志

Migrator::handle_gather_caps(MGatherCaps *m)

|__從MDCache中得到類消息對應的CInode信息，即：cache->get_inode(m->ino)

|__若in存在caps并且in不存在auth并且in沒有EXPORTINGCAPS

     |__調用export_caps(in)          將in對應的client maps和client caps map export出去

Migrator導入導出狀態機處理過程如下圖所示：

感謝你能夠認真閱讀完這篇文章，希望小編分享的“Migrator類怎么用”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!