一、問(wèn)題
pg_ctl start啟動(dòng)時(shí)報(bào)錯(cuò)退出：pg_ctl：server did not start in time。超時(shí)時(shí)間是多少？從什么時(shí)候到哪個(gè)階段算超時(shí)？
二、分析：該信息打印位置，從后面代碼段do_start函數(shù)中可以看出
1、pg_ctl start調(diào)用start_postmaster啟動(dòng)PG的主進(jìn)程后，每隔0.1ms檢查一次postmaster.pid文件，是否已寫(xiě)入ready/standby
2、總共會(huì)檢查600次，即從啟動(dòng)主進(jìn)程后，最多等待60s，如果沒(méi)有寫(xiě)入ready/standby則打印上述日志并退出
3、默認(rèn)等待時(shí)間是60s，如果pg_ctl start -t指定等待時(shí)間，則等待時(shí)間為該指定時(shí)間
三、什么時(shí)候postmaster.pid文件寫(xiě)入ready/standby
1、如果是主機(jī)不管有沒(méi)有設(shè)置hot standby
1）當(dāng)startup進(jìn)程恢復(fù)完成退出時(shí)，調(diào)用proc_exit函數(shù)向主進(jìn)程發(fā)送SIGCHLD信號(hào)并退出
2）主進(jìn)程接收到信號(hào)后，signal處理函數(shù)reaper調(diào)用AddToDataDirLockFile向postmaster.pid文件寫(xiě)入ready
2、如果是備機(jī)即data目錄下有recovery.cnf文件，且設(shè)置了hot standby，在實(shí)際恢復(fù)前沒(méi)有到達(dá)一致性位置
1）startup進(jìn)程向主進(jìn)程發(fā)送PMSIGNAL_RECOVERY_STARTED信號(hào)，主進(jìn)程調(diào)用信號(hào)處理函數(shù)sigusr1_handler，將pmState=PM_RECOVERY
2）每次讀取下一個(gè)xlog前都會(huì)調(diào)用CheckRecoveryConsistency函數(shù)進(jìn)行一致性檢查：
2.1 進(jìn)入一致性狀態(tài)，starup進(jìn)程向主進(jìn)程發(fā)送PMSIGNAL_BEGIN_HOT_STANDBY信號(hào)，主進(jìn)程接收到信號(hào)后調(diào)用sigusr1_handler->AddToDataDirLockFile向postmaster.pid文件寫(xiě)入ready
3、如果是備機(jī)即data目錄下有recovery.cnf文件，且設(shè)置了hot standby，在實(shí)際恢復(fù)前沒(méi)有到達(dá)一致性位置
1）startup進(jìn)程向主進(jìn)程發(fā)送PMSIGNAL_RECOVERY_STARTED信號(hào)，主進(jìn)程調(diào)用信號(hào)處理函數(shù)sigusr1_handler，將pmState=PM_RECOVERY
2）每次讀取下一個(gè)xlog前都會(huì)調(diào)用CheckRecoveryConsistency函數(shù)進(jìn)行一致性檢查。如果沒(méi)有進(jìn)入一致性狀態(tài)
3）本地日志恢復(fù)完成，切換日志源時(shí)同樣調(diào)用CheckRecoveryConsistency函數(shù)進(jìn)行一致性檢查
3.1 進(jìn)入一致性狀態(tài)，starup進(jìn)程向主進(jìn)程發(fā)送PMSIGNAL_BEGIN_HOT_STANDBY信號(hào)，主進(jìn)程接收到信號(hào)后調(diào)用sigusr1_handler->AddToDataDirLockFile向postmaster.pid文件寫(xiě)入ready
4、如果是備機(jī)即data目錄下有recovery.cnf文件，且設(shè)置了hot standby，在實(shí)際恢復(fù)前到達(dá)一致性位置
1）startup進(jìn)程向主進(jìn)程發(fā)送PMSIGNAL_RECOVERY_STARTED信號(hào)，主進(jìn)程調(diào)用信號(hào)處理函數(shù)sigusr1_handler，將pmState=PM_RECOVERY
2）CheckRecoveryConsistency函數(shù)進(jìn)行一致性檢查，向主進(jìn)程發(fā)送PMSIGNAL_BEGIN_HOT_STANDBY信號(hào)，主進(jìn)程接收到信號(hào)后調(diào)用sigusr1_handler->AddToDataDirLockFile向postmaster.pid文件寫(xiě)入ready
5、如果是備機(jī)即data目錄下有recovery.cnf文件，沒(méi)有設(shè)置hot standby
1）startup進(jìn)程向主進(jìn)程發(fā)送PMSIGNAL_RECOVERY_STARTED信號(hào)
2）主進(jìn)程接收到信號(hào)后，向postmaster.將pmState=PM_RECOVERY
四、代碼分析
1、pg_ctl start流程
do_start-> pm_pid = start_postmaster(); if (do_wait){ print_msg(_("waiting for server to start...")); switch (wait_for_postmaster(pm_pid, false)){ case POSTMASTER_READY: print_msg(_(" done/n")); print_msg(_("server started/n")); break; case POSTMASTER_STILL_STARTING: print_msg(_(" stopped waiting/n")); write_stderr(_("%s: server did not start in time/n"), progname); exit(1); break; case POSTMASTER_FAILED: print_msg(_(" stopped waiting/n")); write_stderr(_("%s: could not start server/n" "Examine the log output./n"), progname); exit(1); break; } }else print_msg(_("server starting/n"));wait_for_postmaster-> for (i = 0; i < wait_seconds * WAITS_PER_SEC; i++){ if ((optlines = readfile(pid_file, &numlines)) != NULL && numlines >= LOCK_FILE_LINE_PM_STATUS){ pmpid = atol(optlines[LOCK_FILE_LINE_PID - 1]); pmstart = atol(optlines[LOCK_FILE_LINE_START_TIME - 1]); if (pmstart >= start_time - 2 && pmpid == pm_pid){ char *pmstatus = optlines[LOCK_FILE_LINE_PM_STATUS - 1]; if (strcmp(pmstatus, PM_STATUS_READY) == 0 || strcmp(pmstatus, PM_STATUS_STANDBY) == 0){ /* postmaster is done starting up */ free_readfile(optlines); return POSTMASTER_READY; } } } free_readfile(optlines); if (waitpid((pid_t) pm_pid, &exitstatus, WNOHANG) == (pid_t) pm_pid) return POSTMASTER_FAILED; pg_usleep(USEC_PER_SEC / WAITS_PER_SEC); } /* out of patience; report that postmaster is still starting up */ return POSTMASTER_STILL_STARTING;2、server主進(jìn)程及信號(hào)處理函數(shù)
PostmasterMain-> pqsignal_no_restart(SIGUSR1, sigusr1_handler); /* message from child process */ pqsignal_no_restart(SIGCHLD, reaper); /* handle child termination */ ... StartupXLOG(); ... proc_exit(0);//exit函數(shù)向主進(jìn)程發(fā)送SIGCHLD信號(hào)
reaper->//進(jìn)程終止或者停止的信號(hào) AddToDataDirLockFile(LOCK_FILE_LINE_PM_STATUS, PM_STATUS_READY);
postmaster進(jìn)程接收信號(hào)：sigusr1_handler-> if (CheckPostmasterSignal(PMSIGNAL_RECOVERY_STARTED) && pmState == PM_STARTUP && Shutdown == NoShutdown){ CheckpointerPID = StartCheckpointer(); BgWriterPID = StartBackgroundWriter(); if (XLogArchivingAlways()) PgArchPID = pgarch_start(); //hot_standby在postgresql.conf文件中配置TRUE //表示在恢復(fù)的時(shí)候允許連接 if (!EnableHotStandby){ //將standby寫(xiě)入postmaster.pid文件，表示up但不允許連接 AddToDataDirLockFile(LOCK_FILE_LINE_PM_STATUS, PM_STATUS_STANDBY); } pmState = PM_RECOVERY; } if (CheckPostmasterSignal(PMSIGNAL_BEGIN_HOT_STANDBY) && pmState == PM_RECOVERY && Shutdown == NoShutdown){ PgStatPID = pgstat_start(); //將ready寫(xiě)入postmaster.pid文件，允許連接 AddToDataDirLockFile(LOCK_FILE_LINE_PM_STATUS, PM_STATUS_READY); pmState = PM_HOT_STANDBY; } ...3、Startup進(jìn)程
StartupXLOG-> ReadCheckpointRecord if (ArchiveRecoveryRequested && IsUnderPostmaster){//有recovery.conf文件則ArchiveRecoveryRequested為T(mén)RUE //有recovery.conf文件則ArchiveRecoveryRequested為T(mén)RUE PublishStartupProcessInformation(); SetForwardFsyncRequests(); //向master進(jìn)程發(fā)送PMSIGNAL_RECOVERY_STARTED信號(hào) SendPostmasterSignal(PMSIGNAL_RECOVERY_STARTED); bgwriterLaunched = true; } CheckRecoveryConsistency();-->... |-- if (standbyState == STANDBY_SNAPSHOT_READY && !LocalHotStandbyActive && | reachedConsistency && IsUnderPostmaster){ | SpinLockAcquire(&XLogCtl->info_lck); | XLogCtl->SharedHotStandbyActive = true; | SpinLockRelease(&XLogCtl->info_lck); | LocalHotStandbyActive = true; | SendPostmasterSignal(PMSIGNAL_BEGIN_HOT_STANDBY); |-- } ... 回放一個(gè)record后，每次讀取下一個(gè)record前都會(huì)調(diào)用CheckRecoveryConsistency總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)武林網(wǎng)的支持。
新聞熱點(diǎn)
疑難解答
圖片精選
