fix_lock_chaining_v2.patch
application/octet-stream
Filename: fix_lock_chaining_v2.patch
Type: application/octet-stream
Part: 0
Message:
Re: Hash Indexes
Patch
Format: unified
Series: patch v2
| File | + | − |
|---|---|---|
| src/backend/access/hash/hashovfl.c | 11 | 27 |
| src/include/access/hash.h | 1 | 1 |
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,