diff options
| author | Amit Kapila <akapila@postgresql.org> | 2024-10-07 14:45:39 +0530 |
|---|---|---|
| committer | Amit Kapila <akapila@postgresql.org> | 2024-10-07 14:45:39 +0530 |
| commit | efe706e273cec0ec83b4d72190fed6b000bd11fd (patch) | |
| tree | 5d17ffb6aefaa5f5a977507c633ac2a81cc0653b /src | |
| parent | 3922c9e9f3de7fee04249c9d65be172432b878cf (diff) | |
| download | postgresql-efe706e273cec0ec83b4d72190fed6b000bd11fd.tar.gz postgresql-efe706e273cec0ec83b4d72190fed6b000bd11fd.zip | |
Fix fetching default toast value during decoding of in-progress transactions.
During logical decoding of in-progress transactions, we perform the toast
table scan while fetching the default toast value for an attribute. We
forgot to initialize the flag during this scan to indicate that the system
table scan is in progress. We need this flag to ensure that during logical
decoding we never directly access the tableam or heap APIs because we check
for concurrent aborts only in systable_* APIs.
Reported-by: Alexander Lakhin
Author: Takeshi Ideriha, Hou Zhijie
Reviewed-by: Amit Kapila, Hou Zhijie
Backpatch-through: 14
Discussion: https://postgr.es/m/18641-6687273b7f15269d@postgresql.org
Diffstat (limited to 'src')
| -rw-r--r-- | src/backend/access/index/genam.c | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/src/backend/access/index/genam.c b/src/backend/access/index/genam.c index d2f5bf94a07..ac531f071e2 100644 --- a/src/backend/access/index/genam.c +++ b/src/backend/access/index/genam.c @@ -700,6 +700,14 @@ systable_beginscan_ordered(Relation heapRelation, index_rescan(sysscan->iscan, key, nkeys, NULL, 0); sysscan->scan = NULL; + /* + * If CheckXidAlive is set then set a flag to indicate that system table + * scan is in-progress. See detailed comments in xact.c where these + * variables are declared. + */ + if (TransactionIdIsValid(CheckXidAlive)) + bsysscan = true; + return sysscan; } @@ -744,6 +752,14 @@ systable_endscan_ordered(SysScanDesc sysscan) index_endscan(sysscan->iscan); if (sysscan->snapshot) UnregisterSnapshot(sysscan->snapshot); + + /* + * Reset the bsysscan flag at the end of the systable scan. See detailed + * comments in xact.c where these variables are declared. + */ + if (TransactionIdIsValid(CheckXidAlive)) + bsysscan = false; + pfree(sysscan); } |