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

!2071 支持idle_in_transaction_session_timeout

Browse Source 
Merge pull request !2071 from 薛蒙恩/idle_in_transaction_session_timeout_v1
This commit is contained in:
opengauss-bot
2022-08-26 11:38:34 +00:00
committed by Gitee
parent e4ed1f3892 2bcb702760
commit 508d07963a
13 changed files with 234 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/gausskernel/process/threadpool/threadpool_worker.cpp
View File

@ -171,6 +171,13 @@ void ThreadPoolWorker::WaitMission()
}
(void)enable_session_sig_alarm(u_sess->attr.attr_common.SessionTimeout * 1000);
#ifndef ENABLE_MULTIPLE_NODES
if (u_sess->attr.attr_common.IdleInTransactionSessionTimeout > 0 &&
(IsAbortedTransactionBlockState() || IsTransactionOrTransactionBlock())) {
(void)enable_idle_in_transaction_session_sig_alarm(
u_sess->attr.attr_common.IdleInTransactionSessionTimeout * 1000);
}
#endif
bool isRawSession = false;
Assert(t_thrd.int_cxt.InterruptHoldoffCount == 0);
@ -226,6 +233,12 @@ void ThreadPoolWorker::WaitMission()
}
MemoryContextSwitchTo(old);
(void)disable_session_sig_alarm();
#ifndef ENABLE_MULTIPLE_NODES
if (u_sess->attr.attr_common.IdleInTransactionSessionTimeout > 0 &&
(IsAbortedTransactionBlockState() || IsTransactionOrTransactionBlock())) {
(void)disable_idle_in_transaction_session_sig_alarm();
}
#endif
/* now we can accept signal. out of this, we rely on signal handle. */
AllowSignal();
ShutDownIfNecessary();