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

设置ImmediateInterruptOK确保WLM线程在PQconnect无响应时也能正常被关闭

Browse Source
This commit is contained in:
kenxx
2022-12-20 16:35:19 +08:00
parent 95321a2a6e
commit a411cc302f
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/gausskernel/cbb/workload/statctl.cpp
View File

@ -1880,8 +1880,12 @@ void WLMReadjustUserSpaceByQuery(const char* username, List* database_name_list)
isFirstDb ? "true" : "false");
securec_check_ss(rc, "\0", "\0");
isFirstDb = false;
bool old = t_thrd.int_cxt.ImmediateInterruptOK;
/*Allow cancel/die interrupts because the connection might be stucked forever*/
t_thrd.int_cxt.ImmediateInterruptOK = true;
CHECK_FOR_INTERRUPTS();
pgConn = PQconnectdb(conninfo);
t_thrd.int_cxt.ImmediateInterruptOK = old;
if (PQstatus(pgConn) != CONNECTION_OK) {
ereport(WARNING,
(errcode(ERRCODE_CONNECTION_TIMED_OUT),