温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

PostgreSQL构建流复制拉取日志的起始位置在哪里

发布时间:2020-07-20 18:37:54 来源:网络 阅读:926 作者:yzs的专栏 栏目:数据库
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进程
向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI