diff --git a/src/backend/access/hash/hashovfl.c b/src/backend/access/hash/hashovfl.c index 5f1513b..e29fe0c 100644 --- a/src/backend/access/hash/hashovfl.c +++ b/src/backend/access/hash/hashovfl.c @@ -382,7 +382,7 @@ _hash_firstfreebit(uint32 map) */ BlockNumber _hash_freeovflpage(Relation rel, Buffer ovflbuf, Buffer wbuf, - bool wbuf_dirty, BufferAccessStrategy bstrategy) + BufferAccessStrategy bstrategy) { HashMetaPage metap; Buffer metabuf; @@ -447,24 +447,10 @@ _hash_freeovflpage(Relation rel, Buffer ovflbuf, Buffer wbuf, Assert(prevopaque->hasho_bucket == bucket); prevopaque->hasho_nextblkno = nextblkno; + MarkBufferDirty(prevbuf); if (prevblkno != writeblkno) - { - MarkBufferDirty(prevbuf); _hash_relbuf(rel, prevbuf); - } - else - { - /* ensure to mark prevbuf as dirty */ - wbuf_dirty = true; - } } - - /* write and unlock the write buffer */ - if (wbuf_dirty) - _hash_chgbufaccess(rel, wbuf, HASH_WRITE, HASH_NOLOCK); - else - _hash_chgbufaccess(rel, wbuf, HASH_READ, HASH_NOLOCK); - if (BlockNumberIsValid(nextblkno)) { Buffer nextbuf = _hash_getbuf_with_strategy(rel, @@ -783,30 +769,28 @@ _hash_squeezebucket(Relation rel, * Tricky point here: if our read and write pages are adjacent in the * bucket chain, our write lock on wbuf will conflict with * _hash_freeovflpage's attempt to update the sibling links of the - * removed page. In that case, we don't need to lock it again and we - * always release the lock on wbuf in _hash_freeovflpage and then - * retake it again here. This will not only simplify the code, but is - * required to atomically log the changes which will be helpful when - * we write WAL for hash indexes. + * removed page. In that case, we don't need to lock it again. */ rblkno = ropaque->hasho_prevblkno; Assert(BlockNumberIsValid(rblkno)); /* free this overflow page (releases rbuf) */ - _hash_freeovflpage(rel, rbuf, wbuf, wbuf_dirty, bstrategy); + _hash_freeovflpage(rel, rbuf, wbuf, bstrategy); + + if (wbuf_dirty) + MarkBufferDirty(wbuf); /* are we freeing the page adjacent to wbuf? */ if (rblkno == wblkno) { /* retain the pin on primary bucket page till end of bucket scan */ - if (wblkno != bucket_blkno) - _hash_dropbuf(rel, wbuf); + if (wblkno == bucket_blkno) + _hash_chgbufaccess(rel, wbuf, HASH_READ, HASH_NOLOCK); + else + _hash_relbuf(rel, wbuf); return; } - /* lock the overflow page being written, then get the previous one */ - _hash_chgbufaccess(rel, wbuf, HASH_NOLOCK, HASH_WRITE); - rbuf = _hash_getbuf_with_strategy(rel, rblkno, HASH_WRITE, diff --git a/src/include/access/hash.h b/src/include/access/hash.h index 9ce44a7..627fa2c 100644 --- a/src/include/access/hash.h +++ b/src/include/access/hash.h @@ -314,7 +314,7 @@ extern OffsetNumber _hash_pgaddtup(Relation rel, Buffer buf, /* hashovfl.c */ extern Buffer _hash_addovflpage(Relation rel, Buffer metabuf, Buffer buf, bool retain_pin); extern BlockNumber _hash_freeovflpage(Relation rel, Buffer ovflbuf, Buffer wbuf, - bool wbuf_dirty, BufferAccessStrategy bstrategy); + BufferAccessStrategy bstrategy); extern void _hash_initbitmap(Relation rel, HashMetaPage metap, BlockNumber blkno, ForkNumber forkNum); extern void _hash_squeezebucket(Relation rel,