Skip to content

Commit 5bb6aa9

Browse files
committed
Fix 'dispath' typo in direct dispatch code.
Corrected the misspelling of 'dispatch' (was 'dispath') in GPDB's direct dispatch code and other places, including variable names and comments where applicable.No functionality is affected. Authored-by: Zhang Mingli [email protected]
1 parent 8226b7d commit 5bb6aa9

File tree

6 files changed

+7
-7
lines changed

6 files changed

+7
-7
lines changed

src/backend/cdb/cdbutil.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ typedef struct HostPrimaryCountEntry
122122
*
123123
* In phase 2 of 2PC, current xact has been marked to TRANS_COMMIT/ABORT,
124124
* COMMIT_PREPARED or ABORT_PREPARED DTM are performed, if they failed,
125-
* dispather disconnect and destroy all gangs and fetch the latest segment
125+
* dispatcher disconnect and destroy all gangs and fetch the latest segment
126126
* configurations to do RETRY_COMMIT_PREPARED or RETRY_ABORT_PREPARED,
127127
* however, postgres disallow catalog lookups outside of xacts.
128128
*

src/backend/commands/cluster.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -210,7 +210,7 @@ cluster(ParseState *pstate, ClusterStmt *stmt, bool isTopLevel)
210210
table_close(rel, NoLock);
211211

212212
/* Do the job. */
213-
/* GPDB_14_MERGE_FIXME: do we need the return value of cluster_rel to dispath ? */
213+
/* GPDB_14_MERGE_FIXME: do we need the return value of cluster_rel to dispatch ? */
214214
cluster_rel(tableOid, indexOid, &params);
215215

216216
if (Gp_role == GP_ROLE_DISPATCH)

src/backend/optimizer/plan/createplan.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2312,12 +2312,12 @@ create_projection_plan(PlannerInfo *root, ProjectionPath *best_path, int flags)
23122312
* https://github.com/greenplum-db/gpdb/issues/9874 for more
23132313
* detailed info.
23142314
*/
2315-
if (root->config->gp_enable_direct_dispatch && best_path->direct_dispath_contentIds)
2315+
if (root->config->gp_enable_direct_dispatch && best_path->direct_dispatch_contentIds)
23162316
{
23172317
DirectDispatchInfo dispatchInfo;
23182318

23192319
dispatchInfo.isDirectDispatch = true;
2320-
dispatchInfo.contentIds = best_path->direct_dispath_contentIds;
2320+
dispatchInfo.contentIds = best_path->direct_dispatch_contentIds;
23212321
dispatchInfo.haveProcessedAnyCalculations = true;
23222322

23232323
MergeDirectDispatchCalculationInfo(&root->curSlice->directDispatch, &dispatchInfo);

src/backend/optimizer/util/pathnode.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2092,7 +2092,7 @@ set_append_path_locus(PlannerInfo *root, Path *pathnode, RelOptInfo *rel,
20922092
* gp_execution_segment() = <segid> here, so we should update
20932093
* direct dispatch info when creating plan.
20942094
*/
2095-
((ProjectionPath *) subpath)->direct_dispath_contentIds = list_make1_int(gp_session_id % numsegments);
2095+
((ProjectionPath *) subpath)->direct_dispatch_contentIds = list_make1_int(gp_session_id % numsegments);
20962096

20972097
CdbPathLocus_MakeStrewn(&(subpath->locus),
20982098
numsegments,

src/include/cdb/cdbtm.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,7 @@ typedef struct TMGXACT
217217
* When first assigning and fetching gxid, using this to keep
218218
* atomic and then assign/fetch gxid with its value.
219219
* Only use this on QD when necessary as QE's gxid and
220-
* DistributedSnapshot is dispathed from QD.
220+
* DistributedSnapshot is dispatched from QD.
221221
*/
222222
pg_atomic_uint64 atomic_gxid;
223223
#endif

src/include/nodes/pathnodes.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2133,7 +2133,7 @@ typedef struct ProjectionPath
21332133
* CDB: projection with qual gp_execution_segment() = <segid>,
21342134
* for such case we should consider update directdispatch info.
21352135
*/
2136-
List *direct_dispath_contentIds;
2136+
List *direct_dispatch_contentIds;
21372137
} ProjectionPath;
21382138

21392139
typedef struct RuntimeFilterPath

0 commit comments

Comments
 (0)