elog(ERROR, "GroupingFunc found in non-Agg plan node");
scratch.opcode = EEOP_GROUPING_FUNC;
- scratch.d.grouping_func.parent = (AggState *) state->parent;
agg = (Agg *) (state->parent->plan);
else
scratch.opcode = EEOP_AGG_DESERIALIZE;
- scratch.d.agg_deserialize.aggstate = aggstate;
scratch.d.agg_deserialize.fcinfo_data = ds_fcinfo;
scratch.d.agg_deserialize.jumpnull = -1; /* adjust later */
scratch.resvalue = &trans_fcinfo->args[argno + 1].value;
pertrans->initValueIsNull)
{
scratch->opcode = EEOP_AGG_INIT_TRANS;
- scratch->d.agg_init_trans.aggstate = aggstate;
scratch->d.agg_init_trans.pertrans = pertrans;
scratch->d.agg_init_trans.setno = setno;
scratch->d.agg_init_trans.setoff = setoff;
fcinfo->flinfo->fn_strict)
{
scratch->opcode = EEOP_AGG_STRICT_TRANS_CHECK;
- scratch->d.agg_strict_trans_check.aggstate = aggstate;
scratch->d.agg_strict_trans_check.setno = setno;
scratch->d.agg_strict_trans_check.setoff = setoff;
scratch->d.agg_strict_trans_check.transno = transno;
else
scratch->opcode = EEOP_AGG_ORDERED_TRANS_TUPLE;
- scratch->d.agg_trans.aggstate = aggstate;
scratch->d.agg_trans.pertrans = pertrans;
scratch->d.agg_trans.setno = setno;
scratch->d.agg_trans.setoff = setoff;
EEO_CASE(EEOP_AGG_DESERIALIZE)
{
FunctionCallInfo fcinfo = op->d.agg_deserialize.fcinfo_data;
- AggState *aggstate = op->d.agg_deserialize.aggstate;
+ AggState *aggstate = castNode(AggState, state->parent);
MemoryContext oldContext;
/*
*/
EEO_CASE(EEOP_AGG_INIT_TRANS)
{
- AggState *aggstate;
+ AggState *aggstate = castNode(AggState, state->parent);
AggStatePerGroup pergroup;
- aggstate = op->d.agg_init_trans.aggstate;
pergroup = &aggstate->all_pergroups
[op->d.agg_init_trans.setoff]
[op->d.agg_init_trans.transno];
/* check that a strict aggregate's input isn't NULL */
EEO_CASE(EEOP_AGG_STRICT_TRANS_CHECK)
{
- AggState *aggstate;
+ AggState *aggstate = castNode(AggState, state->parent);
AggStatePerGroup pergroup;
- aggstate = op->d.agg_strict_trans_check.aggstate;
pergroup = &aggstate->all_pergroups
[op->d.agg_strict_trans_check.setoff]
[op->d.agg_strict_trans_check.transno];
*/
EEO_CASE(EEOP_AGG_PLAIN_TRANS_BYVAL)
{
- AggState *aggstate;
+ AggState *aggstate = castNode(AggState, state->parent);
AggStatePerTrans pertrans;
AggStatePerGroup pergroup;
FunctionCallInfo fcinfo;
MemoryContext oldContext;
Datum newVal;
- aggstate = op->d.agg_trans.aggstate;
pertrans = op->d.agg_trans.pertrans;
pergroup = &aggstate->all_pergroups
*/
EEO_CASE(EEOP_AGG_PLAIN_TRANS)
{
- AggState *aggstate;
+ AggState *aggstate = castNode(AggState, state->parent);
AggStatePerTrans pertrans;
AggStatePerGroup pergroup;
FunctionCallInfo fcinfo;
MemoryContext oldContext;
Datum newVal;
- aggstate = op->d.agg_trans.aggstate;
pertrans = op->d.agg_trans.pertrans;
pergroup = &aggstate->all_pergroups
void
ExecEvalGroupingFunc(ExprState *state, ExprEvalStep *op)
{
+ AggState *aggstate = castNode(AggState, state->parent);
int result = 0;
- Bitmapset *grouped_cols = op->d.grouping_func.parent->grouped_cols;
+ Bitmapset *grouped_cols = aggstate->grouped_cols;
ListCell *lc;
foreach(lc, op->d.grouping_func.clauses)
/* state itself */
LLVMValueRef v_state;
LLVMValueRef v_econtext;
+ LLVMValueRef v_parent;
/* returnvalue */
LLVMValueRef v_isnullp;
v_tmpisnullp = LLVMBuildStructGEP(b, v_state,
FIELDNO_EXPRSTATE_RESNULL,
"v.state.resnull");
+ v_parent = l_load_struct_gep(b, v_state,
+ FIELDNO_EXPRSTATE_PARENT,
+ "v.state.parent");
/* build global slots */
v_scanslot = l_load_struct_gep(b, v_econtext,
LLVMValueRef v_tmpcontext;
LLVMValueRef v_oldcontext;
- aggstate = op->d.agg_deserialize.aggstate;
+ aggstate = castNode(AggState, state->parent);
fcinfo = op->d.agg_deserialize.fcinfo_data;
v_tmpcontext =
case EEOP_AGG_INIT_TRANS:
{
- AggState *aggstate;
AggStatePerTrans pertrans;
LLVMValueRef v_aggstatep;
LLVMBasicBlockRef b_init;
- aggstate = op->d.agg_init_trans.aggstate;
pertrans = op->d.agg_init_trans.pertrans;
- v_aggstatep = l_ptr_const(aggstate,
- l_ptr(StructAggState));
+ v_aggstatep =
+ LLVMBuildBitCast(b, v_parent, l_ptr(StructAggState), "");
v_pertransp = l_ptr_const(pertrans,
l_ptr(StructAggStatePerTransData));
case EEOP_AGG_STRICT_TRANS_CHECK:
{
- AggState *aggstate;
LLVMValueRef v_setoff,
v_transno;
int jumpnull = op->d.agg_strict_trans_check.jumpnull;
- aggstate = op->d.agg_strict_trans_check.aggstate;
- v_aggstatep = l_ptr_const(aggstate, l_ptr(StructAggState));
+ v_aggstatep =
+ LLVMBuildBitCast(b, v_parent, l_ptr(StructAggState), "");
/*
* pergroup = &aggstate->all_pergroups
LLVMValueRef v_tmpcontext;
LLVMValueRef v_oldcontext;
- aggstate = op->d.agg_trans.aggstate;
+ aggstate = castNode(AggState, state->parent);
pertrans = op->d.agg_trans.pertrans;
fcinfo = pertrans->transfn_fcinfo;
- v_aggstatep = l_ptr_const(aggstate,
- l_ptr(StructAggState));
+ v_aggstatep =
+ LLVMBuildBitCast(b, v_parent, l_ptr(StructAggState), "");
v_pertransp = l_ptr_const(pertrans,
l_ptr(StructAggStatePerTransData));
/* for EEOP_GROUPING_FUNC */
struct
{
- AggState *parent; /* parent Agg */
List *clauses; /* integer list of column numbers */
} grouping_func;
/* for EEOP_AGG_*DESERIALIZE */
struct
{
- AggState *aggstate;
FunctionCallInfo fcinfo_data;
int jumpnull;
} agg_deserialize;
/* for EEOP_AGG_INIT_TRANS */
struct
{
- AggState *aggstate;
AggStatePerTrans pertrans;
ExprContext *aggcontext;
int setno;
/* for EEOP_AGG_STRICT_TRANS_CHECK */
struct
{
- AggState *aggstate;
int setno;
int transno;
int setoff;
/* for EEOP_AGG_{PLAIN,ORDERED}_TRANS* */
struct
{
- AggState *aggstate;
AggStatePerTrans pertrans;
ExprContext *aggcontext;
int setno;
int steps_len; /* number of steps currently */
int steps_alloc; /* allocated length of steps array */
+#define FIELDNO_EXPRSTATE_PARENT 11
struct PlanState *parent; /* parent PlanState node, if any */
ParamListInfo ext_params; /* for compiling PARAM_EXTERN nodes */