MDSTable相關內容分析

對MDSTable的操做主要是對version和state保存到集羣以及從集羣中讀取的操做。具體操做處理函數說明以下：

MDSTable::save()

|__對version和state進行encode操做

|__設置committing_version = version          設置committing_version

|__設置waitfor_save[version].push_back(onfinish)

|__get_object_name()          獲得對象名稱mds_${table_name}

|__獲得object_locator_t類實例，即：將數據存放到metadata pool中

|__mds->object_write_full()     將version和state的encode數據寫入到metadata pool中的mds_${table_name}對象中

 

MDSTable::save_2()

|__committed_version = v          設置committed_version

|__遍歷waitfor_save數組

     |__對於waitfor_save[i]->first <=v的，從waitfor_save數組中刪除     

 

MDSTable::reset()

|__reset_state()     

|__state = STATE_ACTIVE          設置state當前值

 

MDSTable::load()

|__state = STATE_OPENING          設置state當前值

|__get_object_name()          獲得對象名稱mds_${table_name}

|__獲得object_locator_t類實例，即：將數據存放到metadata pool中

|__mds->objecter->read_full()     從集羣中獲取MDSTable信息

 

MDSTable::load_2()

|__state = STATE_ACTIVE

|__若r == -EBLACKLISTED，則調用mds->respawn()

|__若r < 0，則調用mds->damaged()

|__從集羣的獲得version值且設置projected_version=committed_version=version

|__從集羣中獲得state信息

 

MDSTableServer類繼承MDSTable類

class MDSTableServer : public MDSTable {

     int table;

     map<version_t,mds_table_pending_t> pending_for_mds;      記錄對mds操做未完成的信息

};

 

MDSTableServer::handle_request()          總路由調度函數，負責將請求分派給不一樣的handle_*()來處理

|__TABLESERVER_OP_QUERY

     |__handle_query()

|__TABLESERVER_OP_PREPARE

     |__handle_prepare()

|__TABLESERVER_OP_COMMIT

     |__handle_commit()

|__TABLESERVER_OP_ROLLBACK

     |__handle_rollback()

 

MDSTableServer::handle_prepare()

|___prepare()               調用子類的_prepare()函數從request消息中獲得具體的信息

|___note_prepare()      填充pending_for_mds數組

|__建立ETableServer類對象

|__mds->mdlog->submit_entry()               寫log

|__mds->mdlog->flush()     

 

MDSTableServer::_prepare_logged()     該函數是handle_prepare()執行完寫log後的回調函數

|__建立MMDSTableRequest類消息(TABLESERVER_OP_AGREE)

|__mds->send_message_mds()          將類消息發送回給調用handle_prepare()的對端

 

MDSTableServer::handle_commit()

|__檢查pending_for_mds數組中是否包含對應的項

     |___commit()          執行子類的commit操做

     |___note_commit()     刪除pending_for_mds數組中對應的項

     |__mds->mdlog->start_submit_entry()          寫log

 

MDSTableServer::_commit_logged()          該函數是handle_commit()執行完寫log後的回調函數

|__建立MMDSTableRequest類消息(TABLESERVER_OP_ACK)

|__mds->send_message_mds()          將類消息發送回給調用handle_prepare()的對端

 

MDSTableServer::handle_rollback()

|___rollback()          執行子類的rollback操做

|___note_rollback()     刪除pending_for_mds數組中對應的項

|___mds->mdlog->start_submit_entry()          寫log

 

MDSTableServer::do_server_update()

|__建立ETableServer類實例

|__mds->mdlog->start_entry()               

|__mds->mdlog->submit_entry()           寫log

 

MDSTableServer::finish_recovery()

|__遍歷參數中的mds_rank_t集合

     |__handle_mds_recovery()

 

MDSTableServer::handle_mds_recovery()

|__遍歷pending_for_mds數組

     |__建立MMDSTableRequest類消息(TABLESERVER_OP_AGREE)

     |__mds->send_message_mds()               發送mds消息

|__建立MMDSTableRequest類消息(TABLESERVER_OP_SERVER_READY)

|__mds->send_message_mds()                    發送mds消息

 

SnapServer類繼承於MDSTableServer，用來記錄須要進行Snap操做的相關信息

class SnapServer: public MDSTableServer {

     MonClient *mon_client;          與monitor交互的client端

     snapid_t last_snap;               

     map<snapid_t, SnapInfo> snaps;

     map<int, set<snapid_t>> need_to_purge;

     map<version_t, SnapInfo> pending_update;

     map<version_t, pair<snapid_t, snapid_t>> pending_destroy;

     set<version_t> pending_noop;

     version_t last_checked_osdmap;

};

 

SnapServer::reset_state()                    清空snaps和need_to_purge這兩個數組，以後獲取last_snap值

|__設置last_snap=1

|__清除snaps和need_to_purge數組

|__遍歷mds使用的osdmap

     |__遍歷mdsmap使用的全部data pools

          |__從osdmap中獲得data pool對應的pg_pool_t結構

          |__對於pg_pool_t結構中removed_snaps數組不爲空，則取removed_snaps.range_end()最大值

|__設置last_snap = removed_snaps.range_end()的最大值

 

SnapServer::_prepare()

|__TABLE_OP_CREATE

     |__更新version值（version++）

     |__從參數bufferlist中獲得SnapInfo信息（ino/name/stamp）

     |__設置SnapInfo的snapid = ++last_snap/long_name=「create"

     |__更新pending_update[version] = info

|__TABLE_OP_DESTROY

     |__從參數bufferlist中獲得inodeno_t和snapid_t的值

     |__更新version值和last_snap值（version++/++last_snap）

     |__更新pending_destroy[version]數組

|__TABLE_OP_UPDATE

     |__從參數bufferlist中獲得SnapInfo信息(ino/snapid/name/stamp)

     |__更新version值和last_snap值（version++/++last_snap）

     |__更新pending_update[version] = info

 

SnapServer::_is_prepared()

|__判斷pending_update或pending_destroy數組中是否包含參數指定的tid

 

SnapServer::_commit()

|__待commit的tid在pending_update數組中

     |__從pending_update數組中獲得指定tid的SnapInfo值

     |__更新snaps[info.snapid] = info

     |__刪除pending_update[tid]

|__待commit的tid在pending_destroy數組中

     |__從pending_destroy數組中獲得指定tid對應的snapid和last_snapid

     |__從snaps數組中刪除snapid對應的值

     |__遍歷mdsmap全部的data pools

          |__更新need_to_purge數組(need_to_purge[*p].insert(snapid)/need_to_purge[*p].insert(last_snapid)

     |__刪除pending_destroy[tid]

|__更新version (version++)

 

SnapServer::_rollback()

|__在pending_update/pending_destroy數組中刪除掉指定tid的值

 

SnapServer::_server_update()

|__從參數bufferlist中獲得map<int, vector<snapid_t>> purge值

|__遍歷purge

     |__刪除need_to_purge中指定的內容

|__更新version

 

SnapServer::check_osd_map()

|__遍歷mds對應的全部osdmap

     |__遍歷need_to_purge數組

          |__從osdmap中獲得pg_pool_t數據結構的值

          |__若pg_pool_t爲空，則設置all_purged[id] = need_to_purge[id].all

          |__遍歷need_to_purge數組的第二個參數

               |__若pg_pool_t->is_removed_snap(i)，則設置all_purged[id].push_back(i)，不然設置all_purge[id].push_back(i)

|__對於all_purged數組不爲空

     |__將all_purged數組序列化

     |__MDSTableServer::do_server_update()

          |__SnapServer::_server_update()

          |__建立ETableServer類對象

          |__mds->mdlog->start_entry()

          |__mds->mdlog->submit_entry()          寫log

|__對於all_purge數組不爲空

     |__建立MRemoveSnaps類消息

     |__mon_client->send_mon_message()     將消息發送給monitor來刪除對應的snaps

 

MDSTable/MDSTableServer/SnapServer之間的關係以下圖所示：