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

fix spelling errors in ndpplugin

Browse Source
This commit is contained in:
song.wu
2024-02-22 14:08:27 +08:00
parent fa875e811d
commit 4a7c3abc36
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();
}
}