Lines Matching refs:proute

165 										   PartitionTupleRouting *proute);
167 EState *estate, PartitionTupleRouting *proute,
173 PartitionTupleRouting *proute,
178 PartitionTupleRouting *proute,
221 PartitionTupleRouting *proute; in ExecSetupPartitionTupleRouting() local
231 proute = (PartitionTupleRouting *) palloc0(sizeof(PartitionTupleRouting)); in ExecSetupPartitionTupleRouting()
232 proute->partition_root = rel; in ExecSetupPartitionTupleRouting()
233 proute->memcxt = CurrentMemoryContext; in ExecSetupPartitionTupleRouting()
241 ExecInitPartitionDispatchInfo(estate, proute, RelationGetRelid(rel), in ExecSetupPartitionTupleRouting()
253 ExecHashSubPlanResultRelsByOid(mtstate, proute); in ExecSetupPartitionTupleRouting()
255 return proute; in ExecSetupPartitionTupleRouting()
280 PartitionTupleRouting *proute, in ExecFindPartition() argument
283 PartitionDispatch *pd = proute->partition_dispatch_info; in ExecFindPartition()
358 Assert(dispatch->indexes[partidx] < proute->num_partitions); in ExecFindPartition()
359 rri = proute->partitions[dispatch->indexes[partidx]]; in ExecFindPartition()
370 if (proute->subplan_resultrel_htab) in ExecFindPartition()
375 elem = hash_search(proute->subplan_resultrel_htab, in ExecFindPartition()
386 ExecInitRoutingInfo(mtstate, estate, proute, dispatch, in ExecFindPartition()
393 rri = ExecInitPartitionInfo(mtstate, estate, proute, in ExecFindPartition()
410 Assert(dispatch->indexes[partidx] < proute->num_dispatch); in ExecFindPartition()
412 rri = proute->nonleaf_partitions[dispatch->indexes[partidx]]; in ExecFindPartition()
430 proute, in ExecFindPartition()
435 dispatch->indexes[partidx] < proute->num_dispatch); in ExecFindPartition()
437 rri = proute->nonleaf_partitions[dispatch->indexes[partidx]]; in ExecFindPartition()
515 PartitionTupleRouting *proute) in ExecHashSubPlanResultRelsByOid() argument
528 proute->subplan_resultrel_htab = htab; in ExecHashSubPlanResultRelsByOid()
562 PartitionTupleRouting *proute, in ExecInitPartitionInfo() argument
576 oldcxt = MemoryContextSwitchTo(proute->memcxt); in ExecInitPartitionInfo()
735 ExecInitRoutingInfo(mtstate, estate, proute, dispatch, in ExecInitPartitionInfo()
943 PartitionTupleRouting *proute, in ExecInitRoutingInfo() argument
953 oldcxt = MemoryContextSwitchTo(proute->memcxt); in ExecInitRoutingInfo()
1018 rri_index = proute->num_partitions++; in ExecInitRoutingInfo()
1021 if (proute->num_partitions >= proute->max_partitions) in ExecInitRoutingInfo()
1023 if (proute->max_partitions == 0) in ExecInitRoutingInfo()
1025 proute->max_partitions = 8; in ExecInitRoutingInfo()
1026 proute->partitions = (ResultRelInfo **) in ExecInitRoutingInfo()
1027 palloc(sizeof(ResultRelInfo *) * proute->max_partitions); in ExecInitRoutingInfo()
1031 proute->max_partitions *= 2; in ExecInitRoutingInfo()
1032 proute->partitions = (ResultRelInfo **) in ExecInitRoutingInfo()
1033 repalloc(proute->partitions, sizeof(ResultRelInfo *) * in ExecInitRoutingInfo()
1034 proute->max_partitions); in ExecInitRoutingInfo()
1038 proute->partitions[rri_index] = partRelInfo; in ExecInitRoutingInfo()
1055 PartitionTupleRouting *proute, Oid partoid, in ExecInitPartitionDispatchInfo() argument
1069 oldcxt = MemoryContextSwitchTo(proute->memcxt); in ExecInitPartitionDispatchInfo()
1076 if (partoid != RelationGetRelid(proute->partition_root)) in ExecInitPartitionDispatchInfo()
1079 rel = proute->partition_root; in ExecInitPartitionDispatchInfo()
1121 dispatchidx = proute->num_dispatch++; in ExecInitPartitionDispatchInfo()
1124 if (proute->num_dispatch >= proute->max_dispatch) in ExecInitPartitionDispatchInfo()
1126 if (proute->max_dispatch == 0) in ExecInitPartitionDispatchInfo()
1128 proute->max_dispatch = 4; in ExecInitPartitionDispatchInfo()
1129 proute->partition_dispatch_info = (PartitionDispatch *) in ExecInitPartitionDispatchInfo()
1130 palloc(sizeof(PartitionDispatch) * proute->max_dispatch); in ExecInitPartitionDispatchInfo()
1131 proute->nonleaf_partitions = (ResultRelInfo **) in ExecInitPartitionDispatchInfo()
1132 palloc(sizeof(ResultRelInfo *) * proute->max_dispatch); in ExecInitPartitionDispatchInfo()
1136 proute->max_dispatch *= 2; in ExecInitPartitionDispatchInfo()
1137 proute->partition_dispatch_info = (PartitionDispatch *) in ExecInitPartitionDispatchInfo()
1138 repalloc(proute->partition_dispatch_info, in ExecInitPartitionDispatchInfo()
1139 sizeof(PartitionDispatch) * proute->max_dispatch); in ExecInitPartitionDispatchInfo()
1140 proute->nonleaf_partitions = (ResultRelInfo **) in ExecInitPartitionDispatchInfo()
1141 repalloc(proute->nonleaf_partitions, in ExecInitPartitionDispatchInfo()
1142 sizeof(ResultRelInfo *) * proute->max_dispatch); in ExecInitPartitionDispatchInfo()
1145 proute->partition_dispatch_info[dispatchidx] = pd; in ExecInitPartitionDispatchInfo()
1157 proute->nonleaf_partitions[dispatchidx] = rri; in ExecInitPartitionDispatchInfo()
1160 proute->nonleaf_partitions[dispatchidx] = NULL; in ExecInitPartitionDispatchInfo()
1185 PartitionTupleRouting *proute) in ExecCleanupTupleRouting() argument
1187 HTAB *htab = proute->subplan_resultrel_htab; in ExecCleanupTupleRouting()
1197 for (i = 1; i < proute->num_dispatch; i++) in ExecCleanupTupleRouting()
1199 PartitionDispatch pd = proute->partition_dispatch_info[i]; in ExecCleanupTupleRouting()
1207 for (i = 0; i < proute->num_partitions; i++) in ExecCleanupTupleRouting()
1209 ResultRelInfo *resultRelInfo = proute->partitions[i]; in ExecCleanupTupleRouting()