diff --git a/src/backend/access/hash/hash.c b/src/backend/access/hash/hash.c index 34cc08f12d2fcb39b3bb555bce359864e3e1c25f..b835f772d46aaec5c43729b924ae64a88bff132a 100644 --- a/src/backend/access/hash/hash.c +++ b/src/backend/access/hash/hash.c @@ -476,9 +476,17 @@ hashrescan(IndexScanDesc scan, ScanKey scankey, int nscankeys, HashScanOpaque so = (HashScanOpaque) scan->opaque; Relation rel = scan->indexRelation; - /* Before leaving current page, deal with any killed items */ + /* + * Before leaving current page, deal with any killed items. + * Also, ensure that we acquire lock on current page before + * calling _hash_kill_items. + */ if (so->numKilled > 0) + { + LockBuffer(so->hashso_curbuf, BUFFER_LOCK_SHARE); _hash_kill_items(scan); + LockBuffer(so->hashso_curbuf, BUFFER_LOCK_UNLOCK); + } _hash_dropscanbuf(rel, so); @@ -507,9 +515,17 @@ hashendscan(IndexScanDesc scan) HashScanOpaque so = (HashScanOpaque) scan->opaque; Relation rel = scan->indexRelation; - /* Before leaving current page, deal with any killed items */ + /* + * Before leaving current page, deal with any killed items. + * Also, ensure that we acquire lock on current page before + * calling _hash_kill_items. + */ if (so->numKilled > 0) + { + LockBuffer(so->hashso_curbuf, BUFFER_LOCK_SHARE); _hash_kill_items(scan); + LockBuffer(so->hashso_curbuf, BUFFER_LOCK_UNLOCK); + } _hash_dropscanbuf(rel, so);