訂閱
糾錯(cuò)
加入自媒體

如何運(yùn)用StartupXLOG函數(shù)恢復(fù)讀取WAL?

2021-05-20 11:26
yzsDBA
關(guān)注

1、崩潰恢復(fù)和備機(jī)回放都是StartupXLOG函數(shù)進(jìn)行處理,從pgcontrol文件中讀取checkpoint位置,從這個(gè)位置開(kāi)始讀取WAL記錄進(jìn)行回放。

2、讀取一個(gè)WAL記錄的函數(shù)是ReadRecord,讀取會(huì)后,根據(jù)類型進(jìn)行回放;然后循環(huán)調(diào)用這個(gè)函數(shù)讀取下一個(gè)WAL記錄。

3、ReadRecord調(diào)用函數(shù)XLogReadRecord讀取下一個(gè)WAL記錄,若請(qǐng)求的記錄不在當(dāng)前頁(yè)中,則需要讀取一頁(yè)到內(nèi)存。如果讀取的record為NULL,且是備機(jī)則切換日志源,從下一個(gè)日志源讀取WAL

4、讀取WAL的函數(shù)ReadPageInternal->XLogPageRead,日志源為流復(fù)制則根據(jù)條件判斷讀入的長(zhǎng)度,否則為1頁(yè)大小,但真正進(jìn)行read的時(shí)候是以頁(yè)為單位的。這里應(yīng)該是讀取的真實(shí)日志量。

5、日志讀入內(nèi)存的XLogReaderState->readBuf中,這個(gè)大小為8KB即一頁(yè)大小。XLogReaderState->readLen為讀入的日志量,有可能比8KB小

6、若下個(gè)WAL記錄在下一頁(yè),需要跳過(guò)頁(yè)頭信息,否則為state->EndRecPtr即當(dāng)前已讀取的WAL記錄末尾+1,即下一個(gè)WAL記錄頭

7、請(qǐng)求的大小為Min(targetRecOff + SizeOfXLogRecord, XLOG_BLCKSZ),即targetRecOff為WAL記錄頁(yè)內(nèi)偏移,加上SizeOfXLogRecord即WAL記錄頭,即ReadPageInternal的reqLen長(zhǎng)度最大才為一頁(yè)大小。所以判斷請(qǐng)求的WAL是否還在當(dāng)前readBuf中條件:

if (targetSegNo == state->readSegNo && targetPageOff == state->readOff && reqLen <= state->readLen)

聲明: 本文由入駐維科號(hào)的作者撰寫,觀點(diǎn)僅代表作者本人,不代表OFweek立場(chǎng)。如有侵權(quán)或其他問(wèn)題,請(qǐng)聯(lián)系舉報(bào)。

發(fā)表評(píng)論

0條評(píng)論,0人參與

請(qǐng)輸入評(píng)論內(nèi)容...

請(qǐng)輸入評(píng)論/評(píng)論長(zhǎng)度6~500個(gè)字

您提交的評(píng)論過(guò)于頻繁,請(qǐng)輸入驗(yàn)證碼繼續(xù)

  • 看不清,點(diǎn)擊換一張  刷新

暫無(wú)評(píng)論

暫無(wú)評(píng)論

    掃碼關(guān)注公眾號(hào)
    OFweek人工智能網(wǎng)
    獲取更多精彩內(nèi)容
    文章糾錯(cuò)
    x
    *文字標(biāo)題:
    *糾錯(cuò)內(nèi)容:
    聯(lián)系郵箱:
    *驗(yàn) 證 碼:

    粵公網(wǎng)安備 44030502002758號(hào)