liuyu/pgvector
1
0
Fork 0
mirror of https://github.com/pgvector/pgvector.git synced 2026-07-10 14:46:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

Revert "Commit pages with tuple"

Browse Source 
This reverts commit 94eeb83abe.
This commit is contained in:
Andrew Kane
2022-07-31 21:36:46 -07:00
parent 94eeb83abe
commit 92a671eeb1
1 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/ivfinsert.c
View File

@@ -60,7 +60,6 @@ static void
InsertTuple(Relation rel, IndexTuple itup, Relation heapRel, Datum *values) InsertTuple(Relation rel, IndexTuple itup, Relation heapRel, Datum *values)
{ {
Buffer buf; Buffer buf;
Buffer prevbuf = InvalidBuffer;
Page page; Page page;
GenericXLogState *state; GenericXLogState *state;
Size itemsz; Size itemsz;
@@ -106,18 +105,20 @@ InsertTuple(Relation rel, IndexTuple itup, Relation heapRel, Datum *values)
/* Update previous buffer */ /* Update previous buffer */
IvfflatPageGetOpaque(page)->nextblkno = insertPage; IvfflatPageGetOpaque(page)->nextblkno = insertPage;
MarkBufferDirty(buf);
/* Init page */ /* Init page */
PageInit(newpage, BufferGetPageSize(newbuf), sizeof(IvfflatPageOpaqueData)); PageInit(newpage, BufferGetPageSize(newbuf), sizeof(IvfflatPageOpaqueData));
IvfflatPageGetOpaque(newpage)->nextblkno = InvalidBlockNumber; IvfflatPageGetOpaque(newpage)->nextblkno = InvalidBlockNumber;
IvfflatPageGetOpaque(newpage)->page_id = IVFFLAT_PAGE_ID; IvfflatPageGetOpaque(newpage)->page_id = IVFFLAT_PAGE_ID;
prevbuf = buf; /* Commit */
buf = newbuf; MarkBufferDirty(buf);
page = newpage; MarkBufferDirty(newbuf);
GenericXLogFinish(state);
break; /* Unlock */
UnlockReleaseBuffer(buf);
UnlockReleaseBuffer(newbuf);
} }
} }
@@ -127,9 +128,6 @@ InsertTuple(Relation rel, IndexTuple itup, Relation heapRel, Datum *values)
IvfflatCommitBuffer(buf, state); IvfflatCommitBuffer(buf, state);
if (BufferIsValid(prevbuf))
UnlockReleaseBuffer(prevbuf);
/* Update the insert page */ /* Update the insert page */
if (insertPage != originalInsertPage) if (insertPage != originalInsertPage)
IvfflatUpdateList(rel, state, listInfo, insertPage, originalInsertPage, InvalidBlockNumber, MAIN_FORKNUM); IvfflatUpdateList(rel, state, listInfo, insertPage, originalInsertPage, InvalidBlockNumber, MAIN_FORKNUM);