diff --git a/src/backend/executor/nodeMotion.c b/src/backend/executor/nodeMotion.c index 0402c837736340d3c9190066403a64defbf3d286..9890301e10840b0e39fa54d31da187a9a6c5ab92 100644 --- a/src/backend/executor/nodeMotion.c +++ b/src/backend/executor/nodeMotion.c @@ -164,23 +164,6 @@ bool isMotionGather(const Motion *m) && m->numOutputSegs == 1); } -/* - * Set the statistic info in gpmon packet. - */ -static void -setMotionStatsForGpmon(MotionState *node) -{ - ChunkTransportState *transportStates = node->ps.state->interconnect_context; - int motionId = ((Motion *) node->ps.plan)->motionID; - - ChunkTransportStateEntry *transportEntry = NULL; - getChunkTransportState(transportStates, motionId, &transportEntry); - uint64 avgAckTime = 0; - if (transportEntry->stat_count_acks > 0) - avgAckTime = transportEntry->stat_total_ack_time / transportEntry->stat_count_acks; -} - - /* ---------------------------------------------------------------- * ExecMotion * ---------------------------------------------------------------- @@ -245,7 +228,6 @@ ExecMotion(MotionState * node) { Gpmon_Incr_Rows_In(GpmonPktFromMotionState(node)); Gpmon_Incr_Rows_Out(GpmonPktFromMotionState(node)); - setMotionStatsForGpmon(node); } #ifdef MEASURE_MOTION_TIME gettimeofday(&stopTime, NULL); @@ -335,7 +317,6 @@ execMotionSender(MotionState * node) /* doSendTuple() may have set node->stopRequested as a side-effect */ Gpmon_Incr_Rows_Out(GpmonPktFromMotionState(node)); - setMotionStatsForGpmon(node); CheckSendPlanStateGpmonPkt(&node->ps); if (node->stopRequested) diff --git a/src/include/nodes/execnodes.h b/src/include/nodes/execnodes.h index f64b15b18cdd0bf8a7b68e6cba2576dc992f47d2..67c3b09391253a12e8864352e08ec4ef877e29b5 100644 --- a/src/include/nodes/execnodes.h +++ b/src/include/nodes/execnodes.h @@ -1416,19 +1416,6 @@ typedef struct PlanState gpmon_packet_t gpmon_pkt; } PlanState; -typedef struct Gpmon_NameUnit_MaxVal -{ - char *name; - char *unit; - int64 maxval; -} Gpmon_NameUnit_MaxVal; - -typedef struct Gpmon_NameVal_Text -{ - char *name; - char *value; -} Gpmon_NameVal_Text; - /* Gpperfmon helper functions defined in execGpmon.c */ extern void CheckSendPlanStateGpmonPkt(PlanState *ps); extern void EndPlanStateGpmonPkt(PlanState *ps);