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

解决adps线程退出异常问题

Browse Source
This commit is contained in:
jiwenke
2024-09-14 09:07:16 +08:00
parent b75bf53737
commit 37cd700e94
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);
}
}