database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!4565 资源池化：reform场景关闭.cbm文件句柄

Browse Source 
Merge pull request !4565 from 刘展峰/core_fix
This commit is contained in:
opengauss_bot
2023-12-05 07:31:49 +00:00
committed by Gitee
parent 9e5a0006fb a3d3ceca7d
commit 8c963b45ff
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/gausskernel/process/postmaster/postmaster.cpp
View File

@ -6767,6 +6767,10 @@ dms_demote:
signal_child(g_instance.pid_cxt.SnapshotPID, SIGTERM);
}
if (g_instance.pid_cxt.CBMWriterPID != 0) {
signal_child(g_instance.pid_cxt.CBMWriterPID, SIGTERM);
}
ereport(LOG, (errmsg("[SS switchover] primary demoting: "
"killed threads, waiting for backends die")));
pmState = PM_WAIT_BACKENDS;
@ -10361,6 +10365,10 @@ static void sigusr1_handler(SIGNAL_ARGS)
signal_child(g_instance.pid_cxt.FaultMonitorPID, SIGTERM);
}
if (g_instance.pid_cxt.CBMWriterPID != 0) {
signal_child(g_instance.pid_cxt.CBMWriterPID, SIGTERM);
}
pmState = PM_WAIT_BACKENDS;
if (ENABLE_THREAD_POOL) {
g_threadPoolControler->EnableAdjustPool();
@ -10433,6 +10441,10 @@ static void sigusr1_handler(SIGNAL_ARGS)
signal_child(g_instance.pid_cxt.SnapshotPID, SIGTERM);
}
if (g_instance.pid_cxt.CBMWriterPID != 0) {
signal_child(g_instance.pid_cxt.CBMWriterPID, SIGTERM);
}
ereport(LOG, (errmodule(MOD_DMS), errmsg("[SS reform] terminate backends success")));
g_instance.dms_cxt.SSRecoveryInfo.reform_ready = true;
}
@ -10480,6 +10492,9 @@ static void sigusr1_handler(SIGNAL_ARGS)
if (g_instance.pid_cxt.WalWriterPID != 0)
signal_child(g_instance.pid_cxt.WalWriterPID, SIGTERM);
if (g_instance.pid_cxt.CBMWriterPID != 0)
signal_child(g_instance.pid_cxt.CBMWriterPID, SIGTERM);
if (g_instance.pid_cxt.WalWriterAuxiliaryPID != 0)
signal_child(g_instance.pid_cxt.WalWriterAuxiliaryPID, SIGTERM);
pmState = PM_WAIT_BACKENDS;