新聞中心
這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
PostgreSQL構(gòu)建流復(fù)制拉取日志的起始位置在哪里
WaitForWALToBecomeAvailable:
if (!InArchiveRecovery)
currentSource = XLOG_FROM_PG_WAL;
else if (currentSource == 0)
currentSource = XLOG_FROM_ARCHIVE;
for (;;){
int oldSource = currentSource;
if (lastSourceFailed){
switch (currentSource){
case XLOG_FROM_ARCHIVE:
case XLOG_FROM_PG_WAL://如果是備機(jī),并且執(zhí)行了promote或者存在TriggerFile文件則shutdown receive進(jìn)程
if (StandbyMode && CheckForStandbyTrigger()){
ShutdownWalRcv();
return false;
}
if (!StandbyMode)
return false;
/*
構(gòu)建流復(fù)制關(guān)系的位點(diǎn):
1、如果上次正常關(guān)閉,不需要恢復(fù),則從checkpoint點(diǎn)開(kāi)始
2、否則,從恢復(fù)的結(jié)束位置開(kāi)始
*/
if (PrimaryConnInfo){
if (fetching_ckpt){
ptr = RedoStartLSN;
tli = ControlFile->checkPointCopy.ThisTimeLineID;
}else{
ptr = RecPtr;
tli = tliOfPointInHistory(tliRecPtr, expectedTLEs);
}
curFileTLI = tli;
RequestXLogStreaming(tli, ptr, PrimaryConnInfo, PrimarySlotName);
receivedUpto = 0;
}
currentSource = XLOG_FROM_STREAM;
break;
...
}
}
...
}
/*
1、流復(fù)制拉取日志的起始位置是位點(diǎn)所在文件的文件開(kāi)頭
2、也就是說(shuō),會(huì)以重新拉取整個(gè)xlog的文件并覆蓋pg_xlog目錄的相應(yīng)文件
3、所以,當(dāng)以主shutdown,再次以備啟動(dòng)時(shí),需要注意,會(huì)從新主拉取相應(yīng)文件并
4、覆蓋本地文件,但是本地的pg_control文件并沒(méi)有更新,所以讀取的checkpoint位置會(huì)指向一個(gè)錯(cuò)誤的位置
5、這種情況構(gòu)建流復(fù)制需要謹(jǐn)慎注意。
*/
RequestXLogStreaming:
if (recptr % XLogSegSize != 0)
recptr -= recptr % XLogSegSize;
walrcv->receiveStart = recptr;
walrcv->receiveStartTLI = tli;
SendPostmasterSignal(PMSIGNAL_START_WALRECEIVER);//發(fā)起信號(hào)喚醒receiver進(jìn)程
網(wǎng)頁(yè)題目:PostgreSQL構(gòu)建流復(fù)制拉取日志的起始位置在哪里
瀏覽路徑:http://ef60e0e.cn/article/iesjcs.html