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

!3620 【bugfixed】解决并行创建索引出现警告日志的问题

Browse Source 
Merge pull request !3620 from laishenghao/parallel
This commit is contained in:
opengauss_bot
2023-06-29 03:43:00 +00:00
committed by Gitee
parent d1d9e15a4a b971e97474
commit fce417ac01
1 changed files with 39 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/gausskernel/process/postmaster/bgworker.cpp
View File

@ -364,6 +364,7 @@ bool RegisterBackgroundWorker(BgWorkerContext *bwc)
BGW_HDR* bgworker_base = (BGW_HDR *)g_instance.bgw_base;
BackgroundWorker *bgw = NULL;
BackgroundWorkerArgs *bwa = NULL;
Backend* bn = nullptr;
/* Construct bgworker thread args */
bwa = (BackgroundWorkerArgs*)MemoryContextAllocZero(
@ -387,15 +388,49 @@ bool RegisterBackgroundWorker(BgWorkerContext *bwc)
bwa->bgworker = bgw;
bwa->bgworkerId = bgw->bgw_id;
/* Fork a new worker thread */
bgw->bgw_notify_pid = initialize_util_thread(BGWORKER, bwa);
/* failed to fork a new thread */
if (bgw->bgw_notify_pid == 0) {
int slot = AssignPostmasterChildSlot();
if (slot == -1) {
pfree_ext(bwa);
BgworkerPutBackToFreeList(bgw);
return false;
}
bn = AssignFreeBackEnd(slot);
int thisChildSlot = t_thrd.proc_cxt.MyPMChildSlot;
if (bn) {
GenerateCancelKey(false);
bn->cancel_key = t_thrd.proc_cxt.MyCancelKey;
bn->child_slot = t_thrd.proc_cxt.MyPMChildSlot = slot;
bn->role = BGWORKER;
} else {
ReleasePostmasterChildSlot(slot);
pfree_ext(bwa);
BgworkerPutBackToFreeList(bgw);
ereport(LOG, (errcode(ERRCODE_LOG), errmsg("assign backend failed in RegisterBackgroundWorker")));
return false;
}
/* Fork a new worker thread */
bgw->bgw_notify_pid = initialize_util_thread(BGWORKER, bwa);
t_thrd.proc_cxt.MyPMChildSlot = thisChildSlot;
/* failed to fork a new thread */
if (bgw->bgw_notify_pid == 0) {
pfree_ext(bwa);
BgworkerPutBackToFreeList(bgw);
ReleasePostmasterChildSlot(slot);
bn->pid = 0;
bn->role = (knl_thread_role)0;
bn = nullptr;
return false;
}
bn->pid = bgw->bgw_notify_pid;
bn->is_autovacuum = false;
DLInitElem(&bn->elem, bn);
DLAddHead(g_instance.backend_list, &bn->elem);
if (g_threadPoolControler) {
// Try to bind thread to available CPUs in threadpool
g_threadPoolControler->BindThreadToAllAvailCpu(bgw->bgw_notify_pid);