diff options
Diffstat (limited to 'src/backend/access/table')
| -rw-r--r-- | src/backend/access/table/tableam.c | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/backend/access/table/tableam.c b/src/backend/access/table/tableam.c index b3d1a6c3f8f..094b24c7c9c 100644 --- a/src/backend/access/table/tableam.c +++ b/src/backend/access/table/tableam.c @@ -172,19 +172,18 @@ table_parallelscan_initialize(Relation rel, ParallelTableScanDesc pscan, } TableScanDesc -table_beginscan_parallel(Relation relation, ParallelTableScanDesc parallel_scan) +table_beginscan_parallel(Relation relation, ParallelTableScanDesc pscan) { Snapshot snapshot; uint32 flags = SO_TYPE_SEQSCAN | SO_ALLOW_STRAT | SO_ALLOW_SYNC | SO_ALLOW_PAGEMODE; - Assert(RelationGetRelid(relation) == parallel_scan->phs_relid); + Assert(RelationGetRelid(relation) == pscan->phs_relid); - if (!parallel_scan->phs_snapshot_any) + if (!pscan->phs_snapshot_any) { /* Snapshot was serialized -- restore it */ - snapshot = RestoreSnapshot((char *) parallel_scan + - parallel_scan->phs_snapshot_off); + snapshot = RestoreSnapshot((char *) pscan + pscan->phs_snapshot_off); RegisterSnapshot(snapshot); flags |= SO_TEMP_SNAPSHOT; } @@ -195,7 +194,7 @@ table_beginscan_parallel(Relation relation, ParallelTableScanDesc parallel_scan) } return relation->rd_tableam->scan_begin(relation, snapshot, 0, NULL, - parallel_scan, flags); + pscan, flags); } |