XLOG_FROM_STREAM->XLOG_FROM_ARCHIVE直接切換,只有讀取過程中出錯,就會切換到另外一個日志源。但實際執(zhí)行過程中,XLOG_FROM_AR..."/>
您好,登錄后才能下訂單哦!
日志源會在XLOG_FROM_ARCHIVE->XLOG_FROM_STREAM->XLOG_FROM_ARCHIVE直接切換,只有讀取過程中出錯,就會切換到另外一個日志源。但實際執(zhí)行過程中,XLOG_FROM_ARCHIVE出錯后會到XLOG_FROM_PG_WAL讀取,但是日志源的變量并不會改變。這個需要注意。
static int XLogFileReadAnyTLI(XLogSegNo segno, int emode, int source) { if (expectedTLEs) tles = expectedTLEs; else tles = readTimeLineHistory(recoveryTargetTLI); /* 1、WaitForWALToBecomeAvailable調(diào)用時,source是XLOG_FROM_ARCHIVE時,會使用XLOG_FROM_ANY 2、使用XLOG_FROM_ANY,會首先從歸檔中讀取xlog,如果open失敗,則會使用XLOG_FROM_PG_WAL 3、外部日志源變量并沒有切換 */ foreach(cell, tles){ TimeLineID tli = ((TimeLineHistoryEntry *) lfirst(cell))->tli; if (tli < curFileTLI) break; /* don't bother looking at too-old TLIs */ if (source == XLOG_FROM_ANY || source == XLOG_FROM_ARCHIVE){ fd = XLogFileRead(segno, emode, tli,XLOG_FROM_ARCHIVE, true); if (fd != -1){ if (!expectedTLEs) expectedTLEs = tles; return fd; } } if (source == XLOG_FROM_ANY || source == XLOG_FROM_PG_WAL){ fd = XLogFileRead(segno, emode, tli, XLOG_FROM_PG_WAL, true); if (fd != -1){ if (!expectedTLEs) expectedTLEs = tles; return fd; } } } return -1; }
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。