Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit5b215f2

Browse files
Daniil Anisimovdanolivo
Daniil Anisimov
authored andcommitted
Fix. Conventionally use of hooks.
Also, some arrangement for stable14 added by a.lepikhov
1 parente1761d4 commit5b215f2

File tree

5 files changed

+16
-16
lines changed

5 files changed

+16
-16
lines changed

‎aqo_shared.c‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ aqo_init_shmem(void)
2828
HASHCTLinfo;
2929

3030
if (aqo_shmem_startup_next)
31-
aqo_shmem_startup_next();
31+
(*aqo_shmem_startup_next)();
3232

3333
aqo_state=NULL;
3434
stat_htab=NULL;

‎cardinality_hooks.c‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ aqo_set_baserel_rows_estimate(PlannerInfo *root, RelOptInfo *rel)
114114

115115
default_estimator:
116116
rel->predicted_cardinality=-1.;
117-
aqo_set_baserel_rows_estimate_next(root,rel);
117+
(*aqo_set_baserel_rows_estimate_next)(root,rel);
118118
}
119119

120120
staticvoid
@@ -225,7 +225,7 @@ aqo_get_parameterized_baserel_size(PlannerInfo *root,
225225
returnpredicted;
226226

227227
default_estimator:
228-
returnaqo_get_parameterized_baserel_size_next(root,rel,param_clauses);
228+
return(*aqo_get_parameterized_baserel_size_next)(root,rel,param_clauses);
229229
}
230230

231231
/*
@@ -300,7 +300,7 @@ aqo_set_joinrel_size_estimates(PlannerInfo *root, RelOptInfo *rel,
300300

301301
default_estimator:
302302
rel->predicted_cardinality=-1;
303-
aqo_set_joinrel_size_estimates_next(root,rel,outer_rel,inner_rel,
303+
(*aqo_set_joinrel_size_estimates_next)(root,rel,outer_rel,inner_rel,
304304
sjinfo,restrictlist);
305305
}
306306

@@ -373,7 +373,7 @@ aqo_get_parameterized_joinrel_size(PlannerInfo *root,
373373
returnpredicted;
374374

375375
default_estimator:
376-
returnaqo_get_parameterized_joinrel_size_next(root,rel,
376+
return(*aqo_get_parameterized_joinrel_size_next)(root,rel,
377377
outer_path,inner_path,
378378
sjinfo,clauses);
379379
}
@@ -458,8 +458,8 @@ aqo_estimate_num_groups(PlannerInfo *root, List *groupExprs,
458458

459459
default_estimator:
460460
if (aqo_estimate_num_groups_next)
461-
returnaqo_estimate_num_groups_next(root,groupExprs,subpath,
462-
grouped_rel,pgset);
461+
return(*aqo_estimate_num_groups_next)(root,groupExprs,subpath,
462+
grouped_rel,pgset);
463463
else
464464
returnestimate_num_groups(root,groupExprs,subpath->rows,
465465
pgset);

‎path_utils.c‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -542,7 +542,7 @@ aqo_create_plan(PlannerInfo *root, Path *src, Plan **dest)
542542
AQOPlanNode*node;
543543

544544
if (aqo_create_plan_next)
545-
aqo_create_plan_next(root,src,dest);
545+
(*aqo_create_plan_next)(root,src,dest);
546546

547547
if (!query_context.use_aqo&& !query_context.learn_aqo&&
548548
!query_context.collect_stat)

‎postprocessing.c‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -600,7 +600,7 @@ aqo_ExecutorStart(QueryDesc *queryDesc, int eflags)
600600
StoreToQueryEnv(queryDesc);
601601
}
602602

603-
aqo_ExecutorStart_next(queryDesc,eflags);
603+
(*aqo_ExecutorStart_next)(queryDesc,eflags);
604604

605605
if (use_aqo)
606606
StorePlanInternals(queryDesc);
@@ -725,7 +725,7 @@ aqo_ExecutorRun(QueryDesc *queryDesc, ScanDirection direction, uint64 count,
725725

726726
PG_TRY();
727727
{
728-
aqo_ExecutorRun_next(queryDesc,direction,count,execute_once);
728+
(*aqo_ExecutorRun_next)(queryDesc,direction,count,execute_once);
729729
}
730730
PG_FINALLY();
731731
{
@@ -841,7 +841,7 @@ aqo_ExecutorEnd(QueryDesc *queryDesc)
841841
MemoryContextSwitchTo(oldctx);
842842
MemoryContextReset(AQOLearnMemCtx);
843843

844-
aqo_ExecutorEnd_next(queryDesc);
844+
(*aqo_ExecutorEnd_next)(queryDesc);
845845

846846
/*
847847
* standard_ExecutorEnd clears the queryDesc->planstate. After this point no
@@ -982,7 +982,7 @@ print_into_explain(PlannedStmt *plannedstmt, IntoClause *into,
982982
QueryEnvironment*queryEnv)
983983
{
984984
if (aqo_ExplainOnePlan_next)
985-
aqo_ExplainOnePlan_next(plannedstmt,into,es,queryString,
985+
(*aqo_ExplainOnePlan_next)(plannedstmt,into,es,queryString,
986986
params,planduration,queryEnv);
987987

988988
if (IsQueryDisabled()|| !aqo_show_details)
@@ -1038,7 +1038,7 @@ print_node_explain(ExplainState *es, PlanState *ps, Plan *plan)
10381038

10391039
/* Extension, which took a hook early can be executed early too. */
10401040
if (aqo_ExplainOneNode_next)
1041-
aqo_ExplainOneNode_next(es,ps,plan);
1041+
(*aqo_ExplainOneNode_next)(es,ps,plan);
10421042

10431043
if (IsQueryDisabled()|| !plan||es->format!=EXPLAIN_FORMAT_TEXT)
10441044
return;

‎preprocessing.c‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ aqo_planner(Query *parse, const char *query_string, int cursorOptions,
128128
MemoryContextSwitchTo(oldctx);
129129
disable_aqo_for_query();
130130

131-
returnaqo_planner_next(parse,query_string,cursorOptions,boundParams);
131+
return(*aqo_planner_next)(parse,query_string,cursorOptions,boundParams);
132132
}
133133

134134
selectivity_cache_clear();
@@ -149,7 +149,7 @@ aqo_planner(Query *parse, const char *query_string, int cursorOptions,
149149
MemoryContextSwitchTo(oldctx);
150150
disable_aqo_for_query();
151151

152-
returnaqo_planner_next(parse,query_string,cursorOptions,boundParams);
152+
return(*aqo_planner_next)(parse,query_string,cursorOptions,boundParams);
153153
}
154154

155155
elog(DEBUG1,"AQO will be used for query '%s', class "UINT64_FORMAT,
@@ -320,7 +320,7 @@ aqo_planner(Query *parse, const char *query_string, int cursorOptions,
320320
PlannedStmt*stmt;
321321

322322
MemoryContextSwitchTo(oldctx);
323-
stmt=aqo_planner_next(parse,query_string,cursorOptions,boundParams);
323+
stmt=(*aqo_planner_next)(parse,query_string,cursorOptions,boundParams);
324324

325325
/* Release the memory, allocated for AQO predictions */
326326
MemoryContextReset(AQOPredictMemCtx);

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp