diff --git a/src/gausskernel/ddes/adapter/ss_reform_common.cpp b/src/gausskernel/ddes/adapter/ss_reform_common.cpp index 128b384f03740da7de2da8cee8e30b52a0930b84..04a9a9c2da7151422900f8a4c34a24eea7d7accd 100644 --- a/src/gausskernel/ddes/adapter/ss_reform_common.cpp +++ b/src/gausskernel/ddes/adapter/ss_reform_common.cpp @@ -594,13 +594,17 @@ void SSWaitStartupExit(bool send_signal) ereport(WARNING, (errmodule(MOD_DMS), errmsg("[SS reform] reform failed"))); } - +#ifdef USE_ASSERT_CHECKING + ereport(LOG, (errmodule(MOD_DMS), + errmsg("[SS reform] wait for the startup thread to exit"))); +#else long rto_limit = SS_RTO_LIMIT; ereport(LOG, (errmodule(MOD_DMS), errmsg("[SS reform] wait startup thread exit until RTO limit time:%d sec", rto_limit / (1000 * 1000)))); long wait_time = 0; +#endif while (true) { if (g_instance.pid_cxt.StartupPID == 0) { break; @@ -612,11 +616,13 @@ void SSWaitStartupExit(bool send_signal) "during recovery phase, need exit"))); _exit(0); } +#ifndef USE_ASSERT_CHECKING if (wait_time > rto_limit) { SSProcessForceExit(); } - pg_usleep(REFORM_WAIT_TIME); wait_time += REFORM_WAIT_TIME; +#endif + pg_usleep(REFORM_WAIT_TIME); } }