1. 程式人生 > >PostgreSQL構建流複製拉取日誌的起始位置在哪裡

PostgreSQL構建流複製拉取日誌的起始位置在哪裡

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://如果是備機,並且執行了promote或者存在TriggerFile檔案則shutdown receive程序
                    if (StandbyMode && CheckForStandbyTrigger()){
                        ShutdownWalRcv();
                        return false;
                    }
                    if (!StandbyMode)
                        return false;
                    /*
                    構建流複製關係的位點:
                    1、如果上次正常關閉,不需要恢復,則從checkpoint點開始
                    2、否則,從恢復的結束位置開始
                    */
                    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、流複製拉取日誌的起始位置是位點所在檔案的檔案開頭
2、也就是說,會以重新拉取整個xlog的檔案並覆蓋pg_xlog目錄的相應檔案
3、所以,當以主shutdown,再次以備啟動時,需要注意,會從新主拉取相應檔案並
4、覆蓋本地檔案,但是本地的pg_control檔案並沒有更新,所以讀取的checkpoint位置會指向一個錯誤的位置
5、這種情況構建流複製需要謹慎注意。
*/
RequestXLogStreaming:
    if (recptr % XLogSegSize != 0)
        recptr -= recptr % XLogSegSize;
    walrcv->receiveStart = recptr;
    walrcv->receiveStartTLI = tli;
    SendPostmasterSignal(PMSIGNAL_START_WALRECEIVER);//發起訊號喚醒receiver程序