database/postgres
database/postgres
1
0
Fork 0
mirror of https://github.com/postgres/postgres.git synced 2025-04-21 12:05:57 +03:00
Code

Replace ReadBuffer to ReadBufferWithStrategy in all vacuum-involved places

Browse Source 
to implement limited-size "ring" of buffers for VACUUM for GIN & GIST
This commit is contained in:
Teodor Sigaev 2007-05-31 14:03:09 +00:00
parent 71fb7b9014
commit 54af876593
2 changed files with 21 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/backend/access/gin/ginvacuum.c
View File

@ -8,7 +8,7 @@
* Portions Copyright (c) 1994, Regents of the University of California * Portions Copyright (c) 1994, Regents of the University of California
* *
* IDENTIFICATION * IDENTIFICATION
* $PostgreSQL: pgsql/src/backend/access/gin/ginvacuum.c,v 1.12 2007/02/01 04:16:08 neilc Exp $ * $PostgreSQL: pgsql/src/backend/access/gin/ginvacuum.c,v 1.13 2007/05/31 14:03:09 teodor Exp $
*------------------------------------------------------------------------- *-------------------------------------------------------------------------
*/ */
@ -28,6 +28,7 @@ typedef struct
IndexBulkDeleteCallback callback; IndexBulkDeleteCallback callback;
void *callback_state; void *callback_state;
GinState ginstate; GinState ginstate;
BufferAccessStrategy strategy;
} GinVacuumState; } GinVacuumState;
@ -152,7 +153,7 @@ xlogVacuumPage(Relation index, Buffer buffer)
static bool static bool
ginVacuumPostingTreeLeaves(GinVacuumState *gvs, BlockNumber blkno, bool isRoot, Buffer *rootBuffer) ginVacuumPostingTreeLeaves(GinVacuumState *gvs, BlockNumber blkno, bool isRoot, Buffer *rootBuffer)
{ {
Buffer buffer = ReadBuffer(gvs->index, blkno); Buffer buffer = ReadBufferWithStrategy(gvs->index, blkno, gvs->strategy);
Page page = BufferGetPage(buffer); Page page = BufferGetPage(buffer);
bool hasVoidPage = FALSE; bool hasVoidPage = FALSE;
@ -238,9 +239,10 @@ static void
ginDeletePage(GinVacuumState *gvs, BlockNumber deleteBlkno, BlockNumber leftBlkno, ginDeletePage(GinVacuumState *gvs, BlockNumber deleteBlkno, BlockNumber leftBlkno,
BlockNumber parentBlkno, OffsetNumber myoff, bool isParentRoot) BlockNumber parentBlkno, OffsetNumber myoff, bool isParentRoot)
{ {
Buffer dBuffer = ReadBuffer(gvs->index, deleteBlkno); Buffer dBuffer = ReadBufferWithStrategy(gvs->index, deleteBlkno, gvs->strategy);
Buffer lBuffer = (leftBlkno == InvalidBlockNumber) ? InvalidBuffer : ReadBuffer(gvs->index, leftBlkno); Buffer lBuffer = (leftBlkno == InvalidBlockNumber) ?
Buffer pBuffer = ReadBuffer(gvs->index, parentBlkno); InvalidBuffer : ReadBufferWithStrategy(gvs->index, leftBlkno, gvs->strategy);
Buffer pBuffer = ReadBufferWithStrategy(gvs->index, parentBlkno, gvs->strategy);
Page page, Page page,
parentPage; parentPage;
@ -390,7 +392,7 @@ ginScanToDelete(GinVacuumState *gvs, BlockNumber blkno, bool isRoot, DataPageDel
me = parent->child; me = parent->child;
} }
buffer = ReadBuffer(gvs->index, blkno); buffer = ReadBufferWithStrategy(gvs->index, blkno, gvs->strategy);
page = BufferGetPage(buffer); page = BufferGetPage(buffer);
Assert(GinPageIsData(page)); Assert(GinPageIsData(page));
@ -574,9 +576,10 @@ ginbulkdelete(PG_FUNCTION_ARGS)
gvs.result = stats; gvs.result = stats;
gvs.callback = callback; gvs.callback = callback;
gvs.callback_state = callback_state; gvs.callback_state = callback_state;
gvs.strategy = info->strategy;
initGinState(&gvs.ginstate, index); initGinState(&gvs.ginstate, index);
buffer = ReadBuffer(index, blkno); buffer = ReadBufferWithStrategy(index, blkno, info->strategy);
/* find leaf page */ /* find leaf page */
for (;;) for (;;)
@ -607,8 +610,8 @@ ginbulkdelete(PG_FUNCTION_ARGS)
blkno = GinItemPointerGetBlockNumber(&(itup)->t_tid); blkno = GinItemPointerGetBlockNumber(&(itup)->t_tid);
Assert(blkno != InvalidBlockNumber); Assert(blkno != InvalidBlockNumber);
LockBuffer(buffer, GIN_UNLOCK); UnlockReleaseBuffer(buffer);
buffer = ReleaseAndReadBuffer(buffer, index, blkno); buffer = ReadBufferWithStrategy(index, blkno, info->strategy);
} }
/* right now we found leftmost page in entry's BTree */ /* right now we found leftmost page in entry's BTree */
@ -650,7 +653,7 @@ ginbulkdelete(PG_FUNCTION_ARGS)
if (blkno == InvalidBlockNumber) /* rightmost page */ if (blkno == InvalidBlockNumber) /* rightmost page */
break; break;
buffer = ReadBuffer(index, blkno); buffer = ReadBufferWithStrategy(index, blkno, info->strategy);
LockBuffer(buffer, GIN_EXCLUSIVE); LockBuffer(buffer, GIN_EXCLUSIVE);
} }
@ -713,7 +716,7 @@ ginvacuumcleanup(PG_FUNCTION_ARGS)
vacuum_delay_point(); vacuum_delay_point();
buffer = ReadBuffer(index, blkno); buffer = ReadBufferWithStrategy(index, blkno, info->strategy);
LockBuffer(buffer, GIN_SHARE); LockBuffer(buffer, GIN_SHARE);
page = (Page) BufferGetPage(buffer); page = (Page) BufferGetPage(buffer);

12
src/backend/access/gist/gistvacuum.c
View File

@ -8,7 +8,7 @@
* Portions Copyright (c) 1994, Regents of the University of California * Portions Copyright (c) 1994, Regents of the University of California
* *
* IDENTIFICATION * IDENTIFICATION
* $PostgreSQL: pgsql/src/backend/access/gist/gistvacuum.c,v 1.29 2007/01/05 22:19:22 momjian Exp $ * $PostgreSQL: pgsql/src/backend/access/gist/gistvacuum.c,v 1.30 2007/05/31 14:03:09 teodor Exp $
* *
*------------------------------------------------------------------------- *-------------------------------------------------------------------------
*/ */
@ -35,6 +35,7 @@ typedef struct
Relation index; Relation index;
MemoryContext opCtx; MemoryContext opCtx;
GistBulkDeleteResult *result; GistBulkDeleteResult *result;
BufferAccessStrategy strategy;
} GistVacuum; } GistVacuum;
typedef struct typedef struct
@ -83,7 +84,7 @@ gistDeleteSubtree(GistVacuum *gv, BlockNumber blkno)
Buffer buffer; Buffer buffer;
Page page; Page page;
buffer = ReadBuffer(gv->index, blkno); buffer = ReadBufferWithStrategy(gv->index, blkno, gv->strategy);
LockBuffer(buffer, GIST_EXCLUSIVE); LockBuffer(buffer, GIST_EXCLUSIVE);
page = (Page) BufferGetPage(buffer); page = (Page) BufferGetPage(buffer);
@ -303,7 +304,7 @@ gistVacuumUpdate(GistVacuum *gv, BlockNumber blkno, bool needunion)
vacuum_delay_point(); vacuum_delay_point();
buffer = ReadBuffer(gv->index, blkno); buffer = ReadBufferWithStrategy(gv->index, blkno, gv->strategy);
LockBuffer(buffer, GIST_EXCLUSIVE); LockBuffer(buffer, GIST_EXCLUSIVE);
gistcheckpage(gv->index, buffer); gistcheckpage(gv->index, buffer);
page = (Page) BufferGetPage(buffer); page = (Page) BufferGetPage(buffer);
@ -550,6 +551,7 @@ gistvacuumcleanup(PG_FUNCTION_ARGS)
initGISTstate(&(gv.giststate), rel); initGISTstate(&(gv.giststate), rel);
gv.opCtx = createTempGistContext(); gv.opCtx = createTempGistContext();
gv.result = stats; gv.result = stats;
gv.strategy = info->strategy;
/* walk through the entire index for update tuples */ /* walk through the entire index for update tuples */
res = gistVacuumUpdate(&gv, GIST_ROOT_BLKNO, false); res = gistVacuumUpdate(&gv, GIST_ROOT_BLKNO, false);
@ -600,7 +602,7 @@ gistvacuumcleanup(PG_FUNCTION_ARGS)
vacuum_delay_point(); vacuum_delay_point();
buffer = ReadBuffer(rel, blkno); buffer = ReadBufferWithStrategy(rel, blkno, info->strategy);
LockBuffer(buffer, GIST_SHARE); LockBuffer(buffer, GIST_SHARE);
page = (Page) BufferGetPage(buffer); page = (Page) BufferGetPage(buffer);
@ -704,7 +706,7 @@ gistbulkdelete(PG_FUNCTION_ARGS)
while (stack) while (stack)
{ {
Buffer buffer = ReadBuffer(rel, stack->blkno); Buffer buffer = ReadBufferWithStrategy(rel, stack->blkno, info->strategy);
Page page; Page page;
OffsetNumber i, OffsetNumber i,
maxoff; maxoff;