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

!6322 解决adps线程退出异常问题

Browse Source 
Merge pull request !6322 from 吉文克/master
This commit is contained in:
opengauss_bot
2024-09-14 07:07:26 +00:00
committed by Gitee
parent 6cc445ef65 37cd700e94
commit 1d49b32477
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/common/backend/pgxc_single/pool/execRemote.cpp
View File

@ -1308,7 +1308,18 @@ void spq_adps_coordinator_thread_main()
pthread_cond_wait(&t_thrd.spq_ctx.qc_ctx->pq_wait_cv, &t_thrd.spq_ctx.qc_ctx->spq_pq_mutex);
pthread_mutex_unlock(&t_thrd.spq_ctx.qc_ctx->spq_pq_mutex);
} else {
spq_adps_consumer();
PG_TRY();
{
spq_adps_consumer();
}
PG_CATCH();
{
pthread_mutex_unlock(&t_thrd.spq_ctx.qc_ctx->spq_pq_mutex);
spq_finishQcThread();
t_thrd.spq_ctx.qc_ctx->is_exited = true;
PG_RE_THROW();
}
PG_END_TRY();
pthread_mutex_unlock(&t_thrd.spq_ctx.qc_ctx->spq_pq_mutex);
}
}