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

!4880 修改 NDP Plugin 中拼写错误

Browse Source 
Merge pull request !4880 from sungwu/fix_spell_ndpplugin
This commit is contained in:
opengauss_bot
2024-03-25 08:58:23 +00:00
committed by Gitee
parent c171aee44f 4a7c3abc36
commit 02cbd84c98
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
contrib/ndpplugin/ndpplugin.cpp
View File

@ -37,7 +37,7 @@ void TransitionFunction(AggState* aggstate,
FunctionCallInfoData* fcinfo);
static void NdpAggSlotAppend(AggState* state, AggStatePerGroup pergroup, TupleTableSlot* slot);
static void knl_u_ndp_init(knl_u_ndp_context* ndp_cxt);
static void NdpReInitConetxt();
static void NdpReInitContext();
THR_LOCAL ndp_pushdown_hook_type backup_ndp_pushdown_hook_type = NULL;
THR_LOCAL TableAmNdpRoutine_hook_type backup_ndp_tableam = NULL;
@ -996,7 +996,7 @@ void NdpDestroyContext(NdpContext* context)
context->channelCache = nullptr;
}
static void NdpReInitConetxt()
static void NdpReInitContext()
{
if (u_sess->ndp_cxt.cxt == nullptr) {
return;
@ -1148,7 +1148,7 @@ NdpContext* GetNdpContext()
u_sess->ndp_cxt.cxt = NdpCreateContext();
MemoryContextSwitchTo(oldContext);
} else {
NdpReInitConetxt();
NdpReInitContext();
}
return (NdpContext*)u_sess->ndp_cxt.cxt;
}
@ -1376,7 +1376,7 @@ static void NdpExecutorEnd(QueryDesc* queryDesc)
else
standard_ExecutorEnd(queryDesc);
if (!StreamThreadAmI()) {
NdpReInitConetxt();
NdpReInitContext();
}
}