提交 46b8293f 编写于 作者: H Heikki Linnakangas

Remove some leftover initGpmonPkt* functions.

Commit c1690010 removed most of these, but missed these few in GPDB-
specific executor node. These are no longer needed, just like all the ones
that were removed in commit c1690010.
上级 b70b0086
......@@ -164,8 +164,6 @@ ExecInitAssertOp(AssertOp *node, EState *estate, int eflags)
assertOpState->ps.cdbexplainfun = ExecAssertOpExplainEnd;
}
initGpmonPktForAssertOp((Plan *)node, &assertOpState->ps.gpmon_pkt, estate);
return assertOpState;
}
......@@ -190,13 +188,3 @@ ExecEndAssertOp(AssertOpState *node)
ExecEndNode(outerPlanState(node));
EndPlanStateGpmonPkt(&node->ps);
}
/* Tracing execution for GP Monitor. */
void
initGpmonPktForAssertOp(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate)
{
Assert(planNode != NULL && gpmon_pkt != NULL && IsA(planNode, AssertOp));
InitPlanNodeGpmonPkt(planNode, gpmon_pkt, estate);
}
......@@ -32,14 +32,6 @@ static void LogPartitionSelection(EState *estate, int32 selectorId);
static void
partition_propagation(EState *estate, List *partOids, List *scanIds, int32 selectorId);
void
initGpmonPktForPartitionSelector(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate)
{
Assert(planNode != NULL && gpmon_pkt != NULL && IsA(planNode, PartitionSelector));
InitPlanNodeGpmonPkt(planNode, gpmon_pkt, estate);
}
/* ----------------------------------------------------------------
* ExecInitPartitionSelector
*
......@@ -88,8 +80,6 @@ ExecInitPartitionSelector(PartitionSelector *node, EState *estate, int eflags)
ExecGetResultType(&psstate->ps));
}
initGpmonPktForPartitionSelector((Plan *)node, &psstate->ps.gpmon_pkt, estate);
return psstate;
}
......
......@@ -585,8 +585,6 @@ ExecInitRowTrigger(RowTrigger *node, EState *estate, int eflags)
rowTriggerState->ps.cdbexplainfun = ExecRowTriggerExplainEnd;
}
initGpmonPktForRowTrigger((Plan *)node, &rowTriggerState->ps.gpmon_pkt, estate);
return rowTriggerState;
}
......@@ -598,12 +596,3 @@ ExecEndRowTrigger(RowTriggerState *node)
ExecEndNode(outerPlanState(node));
EndPlanStateGpmonPkt(&node->ps);
}
/* Tracing execution for GP Monitor. */
void
initGpmonPktForRowTrigger(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate)
{
Assert(planNode != NULL && gpmon_pkt != NULL && IsA(planNode, RowTrigger));
InitPlanNodeGpmonPkt(planNode, gpmon_pkt, estate);
}
......@@ -192,8 +192,6 @@ ExecInitSplitUpdate(SplitUpdate *node, EState *estate, int eflags)
splitupdatestate->ps.cdbexplainfun = ExecSplitUpdateExplainEnd;
}
initGpmonPktForSplitUpdate((Plan *)node, &splitupdatestate->ps.gpmon_pkt, estate);
return splitupdatestate;
}
......@@ -209,12 +207,3 @@ ExecEndSplitUpdate(SplitUpdateState *node)
EndPlanStateGpmonPkt(&node->ps);
}
/* Tracing execution for GP Monitor. */
void
initGpmonPktForSplitUpdate(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate)
{
Assert(planNode != NULL && gpmon_pkt != NULL && IsA(planNode, SplitUpdate));
InitPlanNodeGpmonPkt(planNode, gpmon_pkt, estate);
}
......@@ -49,9 +49,6 @@
static void setupFunctionArguments(TableFunctionState *node);
static TupleTableSlot *TableFunctionNext(TableFunctionState *node);
static void initGpmonPktForTableFunction(Plan *planNode,
gpmon_packet_t *gpmon_pkt,
EState *estate);
/* Private structure forward declared in tablefuncapi.h */
typedef struct AnyTableData
......@@ -453,9 +450,6 @@ ExecInitTableFunction(TableFunctionScan *node, EState *estate, int eflags)
/* Initialize result tuple type and projection info */
ExecAssignResultTypeFromTL(&scanstate->ss.ps);
ExecAssignScanProjectionInfo(&scanstate->ss);
initGpmonPktForTableFunction((Plan *)node,
&scanstate->ss.ps.gpmon_pkt, estate);
return scanstate;
}
......@@ -483,19 +477,6 @@ ExecReScanTableFunction(TableFunctionState *node)
}
void
initGpmonPktForTableFunction(Plan *planNode,
gpmon_packet_t *gpmon_pkt,
EState *estate)
{
Assert(planNode != NULL);
Assert(gpmon_pkt != NULL);
Assert(IsA(planNode, TableFunctionScan));
InitPlanNodeGpmonPkt(planNode, gpmon_pkt, estate);
}
/* Callback functions exposed to the user */
TupleDesc
AnyTable_GetTupleDesc(AnyTable t)
......
......@@ -440,7 +440,6 @@ extern void BitmapAOScanReScan(ScanState *scanState);
/*
* prototypes from functions in execBitmapTableScan.c
*/
extern void initGpmonPktForBitmapTableScan(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate);
extern TupleTableSlot *BitmapTableScanNext(BitmapTableScanState *scanState);
extern void BitmapTableScanBegin(BitmapTableScanState *scanState, Plan *plan, EState *estate, int eflags);
extern void BitmapTableScanEnd(BitmapTableScanState *scanState);
......
......@@ -21,7 +21,6 @@ extern TupleTableSlot* ExecAssertOp(AssertOpState *node);
extern AssertOpState* ExecInitAssertOp(AssertOp *node, EState *estate, int eflags);
extern void ExecEndAssertOp(AssertOpState *node);
extern void ExecReScanAssertOp(AssertOpState *node);
extern void initGpmonPktForAssertOp(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate);
#endif /* NODEASSERTOP_H */
......
......@@ -21,7 +21,5 @@ extern TupleTableSlot* ExecDML(DMLState *node);
extern DMLState* ExecInitDML(DML *node, EState *estate, int eflags);
extern void ExecEndDML(DMLState *node);
extern void initGpmonPktForDML(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate);
#endif /* NODEDML_H */
......@@ -21,7 +21,6 @@ extern TupleTableSlot* ExecPartitionSelector(PartitionSelectorState *node);
extern PartitionSelectorState* ExecInitPartitionSelector(PartitionSelector *node, EState *estate, int eflags);
extern void ExecEndPartitionSelector(PartitionSelectorState *node);
extern void ExecReScanPartitionSelector(PartitionSelectorState *node);
extern void initGpmonPktForPartitionSelector(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate);
#endif /* NODEPARTITIONSELECTOR_H */
......@@ -21,8 +21,6 @@ extern TupleTableSlot* ExecRowTrigger(RowTriggerState *node);
extern RowTriggerState* ExecInitRowTrigger(RowTrigger *node, EState *estate, int eflags);
extern void ExecEndRowTrigger(RowTriggerState *node);
extern void initGpmonPktForRowTrigger(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate);
#endif /* NODEROWTRIGGER_H */
......@@ -21,7 +21,5 @@ extern TupleTableSlot* ExecSplitUpdate(SplitUpdateState *node);
extern SplitUpdateState* ExecInitSplitUpdate(SplitUpdate *node, EState *estate, int eflags);
extern void ExecEndSplitUpdate(SplitUpdateState *node);
extern void initGpmonPktForSplitUpdate(Plan *planNode, gpmon_packet_t *gpmon_pkt, EState *estate);
#endif /* NODESplitUpdate_H */
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册