diff options
Diffstat (limited to 'src/backend/access/heap')
| -rw-r--r-- | src/backend/access/heap/heapam.c | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/src/backend/access/heap/heapam.c b/src/backend/access/heap/heapam.c index 388df94a442..e6024a980bb 100644 --- a/src/backend/access/heap/heapam.c +++ b/src/backend/access/heap/heapam.c @@ -561,7 +561,7 @@ heapgettup(HeapScanDesc scan, } } else - block = scan->rs_startblock; /* first page */ + block = scan->rs_startblock; /* first page */ heapgetpage((TableScanDesc) scan, block); lineoff = FirstOffsetNumber; /* first offnum */ scan->rs_inited = true; @@ -569,7 +569,7 @@ heapgettup(HeapScanDesc scan, else { /* continue from previously returned page/tuple */ - block = scan->rs_cblock; /* current page */ + block = scan->rs_cblock; /* current page */ lineoff = /* next offnum */ OffsetNumberNext(ItemPointerGetOffsetNumber(&(tuple->t_self))); } @@ -623,7 +623,7 @@ heapgettup(HeapScanDesc scan, else { /* continue from previously returned page/tuple */ - block = scan->rs_cblock; /* current page */ + block = scan->rs_cblock; /* current page */ } LockBuffer(scan->rs_cbuf, BUFFER_LOCK_SHARE); @@ -769,7 +769,7 @@ heapgettup(HeapScanDesc scan, scan->rs_parallelworkerdata; block = table_block_parallelscan_nextpage(scan->rs_base.rs_rd, - pbscanwork, pbscan); + pbscanwork, pbscan); finished = (block == InvalidBlockNumber); } else @@ -899,7 +899,7 @@ heapgettup_pagemode(HeapScanDesc scan, } } else - block = scan->rs_startblock; /* first page */ + block = scan->rs_startblock; /* first page */ heapgetpage((TableScanDesc) scan, block); lineindex = 0; scan->rs_inited = true; @@ -907,7 +907,7 @@ heapgettup_pagemode(HeapScanDesc scan, else { /* continue from previously returned page/tuple */ - block = scan->rs_cblock; /* current page */ + block = scan->rs_cblock; /* current page */ lineindex = scan->rs_cindex + 1; } @@ -958,7 +958,7 @@ heapgettup_pagemode(HeapScanDesc scan, else { /* continue from previously returned page/tuple */ - block = scan->rs_cblock; /* current page */ + block = scan->rs_cblock; /* current page */ } page = BufferGetPage(scan->rs_cbuf); @@ -1078,7 +1078,7 @@ heapgettup_pagemode(HeapScanDesc scan, scan->rs_parallelworkerdata; block = table_block_parallelscan_nextpage(scan->rs_base.rs_rd, - pbscanwork, pbscan); + pbscanwork, pbscan); finished = (block == InvalidBlockNumber); } else @@ -2722,6 +2722,7 @@ heap_delete(Relation relation, ItemPointer tid, tp.t_self = *tid; l1: + /* * If we didn't pin the visibility map page and the page has become all * visible while we were busy locking the buffer, we'll have to unlock and |