ps-lite源碼分析: 系統(tǒng)參數(shù)

1.節(jié)點(diǎn)角色I(xiàn)D
三種節(jié)點(diǎn),Scheduler節(jié)點(diǎn)只有一個堕扶,多個Worker和多個Server可以組成一個Group,因此有WorkerGroup和ServerGroup;還有Worker節(jié)點(diǎn)和Server節(jié)點(diǎn)塞栅。每個節(jié)點(diǎn)以及每一個Group都有唯一確定的ID。Scheduler腔丧、ServerGroup放椰、WorkerGroup節(jié)點(diǎn)ID確定如下:
static const int kScheduler = 1;
static const int kServerGroup = 2;
static const int kWorkerGroup = 4;
1作烟、2、4的二進(jìn)制表示分別為:001砾医、010拿撩、001。這樣可以做Group之間的合并如蚜,例如要和ServerGroup和WorkerGroup發(fā)信息压恒,只需要destination node id設(shè)為2+4=6。
1-7用來表示節(jié)點(diǎn)的組合错邦,用以廣播消息探赫。單個節(jié)點(diǎn)的ID從8開始,用以發(fā)送點(diǎn)對點(diǎn)信息兴猩。
單個Server和單個Worker節(jié)點(diǎn)從自己的rank(0期吓、1早歇、2……)轉(zhuǎn)換到其ID:
static inline int WorkerRankToID(int rank) {
return rank * 2 + 9;
}
static inline int ServerRankToID(int rank) {
return rank * 2 + 8;
}

從ID到其rank轉(zhuǎn)換:
static inline int IDtoRank(int id) {
return std::max((id - 8) / 2, 0);
}

Postoffice中td::unordered_map<int, std::vector<int>> node_ids_保存了Node/NodeGroup與連接節(jié)點(diǎn)集合的對應(yīng)關(guān)系倾芝。

Start方法:
(1)通過init_stage_控制是否需要初始化,如果已經(jīng)初始化則跳過箭跳;
如果未初始化晨另,則調(diào)用InitEnvironment進(jìn)行環(huán)境初始化,創(chuàng)建van_谱姓,獲取num_workers_與num_servers_借尿,并設(shè)置當(dāng)前節(jié)點(diǎn)角色,設(shè)定verbose屉来;根據(jù)num_workers_和num_serverse_信息路翻,填充節(jié)點(diǎn)組( kWorkerGroup, kServerGroup, kScheduler, kWorkerGroup + kServerGroup, kWorkerGroup+kScheduler, kServerGroup+kScheduler, kWorkerGroup + kServerGroup + kScheduler)包含的節(jié)點(diǎn)信息以初始化node_ids_;
(2)調(diào)用van_->Start(customer_id);
從環(huán)境中獲取獲取scheduler的主機(jī)名茄靠、端口茂契、角色、ID慨绳,并根據(jù)postoffice的is_scheduler()判斷當(dāng)前節(jié)點(diǎn)角色是否是scheduler掉冶;如果是則設(shè)置van的my_node_信息為scheduler信息;否則設(shè)置van的my_node_信息為當(dāng)前節(jié)點(diǎn)的IP脐雪、端口厌小、角色,ID設(shè)置為默認(rèn)空待后面scheduler分配后修改战秋,并設(shè)置van的customer_id璧亚;然后綁定本地端口,并連接至scheduler節(jié)點(diǎn)脂信;啟動接收線程癣蟋;下面對于非scheduler節(jié)點(diǎn)拐袜,給scheduler節(jié)點(diǎn)發(fā)送注冊節(jié)點(diǎn)控制消息;等待ready或超時梢薪,然后根據(jù)環(huán)境配置確定是否創(chuàng)建resender_蹬铺,如果不是scheduler節(jié)點(diǎn)則啟動心跳線程;
(3)記錄啟動時間秉撇,設(shè)置Barrier(customer_id, kWorkerGroup + kServerGroup + kScheduler)甜攀;

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市琐馆,隨后出現(xiàn)的幾起案子规阀,更是在濱河造成了極大的恐慌,老刑警劉巖瘦麸,帶你破解...
    沈念sama閱讀 212,718評論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件谁撼,死亡現(xiàn)場離奇詭異,居然都是意外死亡滋饲,警方通過查閱死者的電腦和手機(jī)厉碟,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,683評論 3 385
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來屠缭,“玉大人箍鼓,你說我怎么就攤上這事『遣埽” “怎么了款咖?”我有些...
    開封第一講書人閱讀 158,207評論 0 348
  • 文/不壞的土叔 我叫張陵,是天一觀的道長奄喂。 經(jīng)常有香客問我铐殃,道長,這世上最難降的妖魔是什么跨新? 我笑而不...
    開封第一講書人閱讀 56,755評論 1 284
  • 正文 為了忘掉前任富腊,我火速辦了婚禮,結(jié)果婚禮上玻蝌,老公的妹妹穿的比我還像新娘蟹肘。我一直安慰自己,他們只是感情好俯树,可當(dāng)我...
    茶點(diǎn)故事閱讀 65,862評論 6 386
  • 文/花漫 我一把揭開白布帘腹。 她就那樣靜靜地躺著,像睡著了一般许饿。 火紅的嫁衣襯著肌膚如雪阳欲。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 50,050評論 1 291
  • 那天,我揣著相機(jī)與錄音球化,去河邊找鬼秽晚。 笑死,一個胖子當(dāng)著我的面吹牛筒愚,可吹牛的內(nèi)容都是我干的赴蝇。 我是一名探鬼主播,決...
    沈念sama閱讀 39,136評論 3 410
  • 文/蒼蘭香墨 我猛地睜開眼巢掺,長吁一口氣:“原來是場噩夢啊……” “哼句伶!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起陆淀,我...
    開封第一講書人閱讀 37,882評論 0 268
  • 序言:老撾萬榮一對情侶失蹤考余,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后轧苫,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體楚堤,經(jīng)...
    沈念sama閱讀 44,330評論 1 303
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,651評論 2 327
  • 正文 我和宋清朗相戀三年含懊,在試婚紗的時候發(fā)現(xiàn)自己被綠了身冬。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 38,789評論 1 341
  • 序言:一個原本活蹦亂跳的男人離奇死亡绢要,死狀恐怖吏恭,靈堂內(nèi)的尸體忽然破棺而出拗小,到底是詐尸還是另有隱情重罪,我是刑警寧澤,帶...
    沈念sama閱讀 34,477評論 4 333
  • 正文 年R本政府宣布哀九,位于F島的核電站剿配,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏阅束。R本人自食惡果不足惜呼胚,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 40,135評論 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望息裸。 院中可真熱鬧蝇更,春花似錦、人聲如沸呼盆。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,864評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽访圃。三九已至厨幻,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背况脆。 一陣腳步聲響...
    開封第一講書人閱讀 32,099評論 1 267
  • 我被黑心中介騙來泰國打工饭宾, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人格了。 一個月前我還...
    沈念sama閱讀 46,598評論 2 362
  • 正文 我出身青樓看铆,卻偏偏與公主長得像,于是被迫代替她去往敵國和親盛末。 傳聞我的和親對象是個殘疾皇子性湿,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 43,697評論 2 351

推薦閱讀更多精彩內(nèi)容